Key-value:

Enumerable  - cache, rychlost čtění hodnoty  (př.: userID_messageID)

BigTable:

Index Table - userID, Composite Key Index - State:City:UserID | State:*

Fulltext engine:

ElasticSearch

(bigtables)

(bigtables)

WHERE state= "CA:*"
WHERE city= "CA:San Francisco*"

Být připraven (v aplikaci) na rychlé změny.

Dbát na architekturu aplikace.

class Entity_Profile extends FM_Model_Entity
{

    protected $_data = array(
        'profileId' => null,
        'display' => '',
        'about_me' => '',
        'state' => '',
        'education' => '',
        ...
    );
    
    ...
}

 class Mapper_Profile extends FM_Model_Mapper { 
   
  protected $map = array(
    'profileId'    => '_id',
  );

  public function insert(Entity_Profile $entity){
    if(!$this->getDbTable()->isExist($entity->getPrimaryName(), $entity ))
      $this->getDbTable()->insert($entity->toArray());
    else return false;
  }
  ...
}

 class DbTable_Profile extends DbTable_Mongo {
    
    CONST NAME = 'profile';
    private $_collection = NULL;
    
    public function __construct(){
        parent::__construct();
        $this->setCollection( self::NAME ); 
    }

    public function insert(array $data = array()){
        return $this->getCollection()->insert($data);
    }

    public function update($filtre=array('_id' => NULL), array $data = array()){
        return $this->getCollection()->update($filtre, array('$set' => $data));
    }
   
    ...
}

 class DbTable_Mongo {
    const NAME = 'dbxyz';
    protected $_db;
          
    public function __construct(){
        try {
            $connection = new Mongo();
            $this->_db = $connection->{self::NAME}; 
        } catch (MongoConnectionException $e) {
            $this->getLog()->log($e, Zend_Log::ERR);
            die(...); // ? // throw new NosqlException(...)
        }
    }

    ...

//find - output Entity_Profile
$mapper = new Mapper_Profile();
$this->view->row = $mapper->find(array("profileId" => $id));

if(!isset($this->view->row)) {
    // flashMsg
    // redirect
}

//insert
$mapper = new Mapper_Profile();
$entity = new Entity_Profile($form->getValues());

if($mapper->insert($entity)) {
    // flashMsg
    // redirect
}

(document-base)

Kdy?

• dynamické dotazy 
• dáváte-li přednost indexům před map/reduce funkcemi 
  
• pokud se mění často data

Proč?

master/slave replikace
velká komunita
dobrá dokumentace
nativní knihovny
má "blíže" k relační db

• dát si pozor na datové typy (Int vs. String, NumberInt vs. NumberLong)
• datumy (Date/ISODate/Unixtime), dělat index

• phpMyAdmin => Rockmongo
  
• PHP extension (PECL, balíčky v repositářích)
  
• Shanty_Mongo - pro Zend Framework
  
• Symfony2?  Doctrine MongoDB ODM

db.users.find(
   { $and: [ 
		{ age: { $gt: 25, $lte: 50 } } , 
		{ user_id: /^bc/ }
     ]   
   } 
).sort( { user_id: -1 } ).limit(5).skip(10)

db.users.update(
   { status: "A" } ,
   { $inc: { age: 3 } },
   { multi: true }
)

(document-base)

Kdy?

• Kde je důležité verzování
  
• Hromadění / shromažďování dat
  - méně se měnící data, na kterých spouštíme předdefinované dotazy
• Využití: CRM, CMS, Multi-site

Proč? 

master-master replikace

map/reduce funkce (javascript)

CouchApps

fulltext skrze ElasticSearch river

CouchDb

vs.

BigCouch

Clustering,  kompatibilní s CouchDb, dojde ke sloučení s CouchDb

vs.

CouchBase

Komerční (podpora), Auto-sharding cluster , Memcached-compatible API ,
 HTTP API ,  CouchApps 

• Použivat co nejjednodužší přístup (i knihovny)
  
• single doc / bulk insert
  

PHP

PHP on Couch, Sag on Couch, DoctrineCouchDBBundle

Ruby

require 'couchrest'

def foo
	db = CouchRest.database!("http://..")
	db.save_doc(doc)
def

require 'json/ext'
require 'couchrest'
@db = "http://..."

def foo
	CouchRest.put(@db, doc)
def

Map/Reduce:

INPUT:

Map/Reduce:

MAPPER => REDUCER:

Map/Reduce:

AFTER REDUCE:

SELECT recipeid FROM recipe JOIN ingredients on ingredients.recipeid = recipe.recipeid WHERE (ingredient = 'carrot' OR ingredient = 'rice') AND totaltime = 20

Map/Reduce:

function(doc, meta)
{
  if (doc.ingredients)
  {
    for (i=0; i < doc.ingredients.length; i++)
    {
      for (j=0; j < doc.ingredients.length; j++)
      {
        emit([doc.ingredients[i].ingredient, doc.ingredients[j].ingredient, recipe.totaltime], null);
      }
    }
  }
}

Query:

 ?startkey=["carrot","rice",0]&key=["carrot","rice",20]