Setting driver wide collection options for safe, fsync and timeout.

models/datasources/mongodb_source.php

@@ -91,9 +91,29 @@ class MongodbSource extends DboSource {
 		'port'       => '27017',
 		'login'		=> '',
 		'password'	=> '',
-		'replicaset'	=> '',
+		'replicaset'	=> ''
 	);
 
+/**
+ * collection options
+ *
+ * set collection options for various mongo write operations.
+ * options can be found in the php manual
+ * http://www.php.net/manual/en/mongocollection.save.php
+ * http://www.php.net/manual/en/mongocollection.insert.php
+ * http://www.php.net/manual/en/mongocollection.batchinsert.php
+ * http://www.php.net/manual/en/mongocollection.update.php
+ * 
+ * @var array
+ */
+
+	public $collectionOptions = array(
+		'save' => array(),
+		'insert' => array(),
+		'batchInsert' => array(),
+		'update' => array()
+	);
+
 /**
  * column definition
  *
@@ -200,7 +220,7 @@ public function connect() {
 
 				$this->connected = true;
 			}
-
+			
 		} catch(MongoException $e) {
 			$this->error = $e->getMessage();
 			trigger_error($this->error);
@@ -256,16 +276,17 @@ public function insertMulti($table, $fields, $values) {
 			$data[] = array_combine($fields, $row);
 		}
 		$this->_prepareLogQuery($table); // just sets a timer
+		$params = array_merge($this->collectionOptions['batchInsert'], array('safe' => true));
 		try{
 			$return = $this->_db
 				->selectCollection($table)
-				->batchInsert($data, array('safe' => true));
+				->batchInsert($data, $params);
 		} catch (MongoException $e) {
 			$this->error = $e->getMessage();
 			trigger_error($this->error);
 		}
 		if ($this->fullDebug) {
-			$this->logQuery("db.{$table}.insertMulti( :data , array('safe' => true))", compact('data'));
+			$this->logQuery("db.{$table}.insertMulti( :data , :params )", compact('data','params'));
 		}
 	}
 
@@ -466,16 +487,17 @@ public function create(&$Model, $fields = null, $values = null) {
 		}
 
 		$this->_prepareLogQuery($Model); // just sets a timer
+		$params = $this->collectionOptions['insert'];
 		try{
 			$return = $this->_db
 				->selectCollection($Model->table)
-				->insert($data, true);
+				->insert($data, $params);
 		} catch (MongoException $e) {
 			$this->error = $e->getMessage();
 			trigger_error($this->error);
 		}
 		if ($this->fullDebug) {
-			$this->logQuery("db.{$Model->useTable}.insert( :data , true)", compact('data'));
+			$this->logQuery("db.{$Model->useTable}.insert( :data , :params )", compact('data','params'));
 		}
 
 		if (!empty($return) && $return['ok']) {
@@ -710,33 +732,35 @@ public function update(&$Model, $fields = null, $values = null, $conditions = nu
 		}
 
 		$this->_prepareLogQuery($Model); // just sets a timer
+		$return = false;
 		if (!empty($data['_id'])) {
 			$this->_convertId($data['_id']);
 			$cond = array('_id' => $data['_id']);
 			unset($data['_id']);
 
 			$data = $this->setMongoUpdateOperator($Model, $data);
-
+			$params = array_merge($this->collectionOptions['update'], array("multiple" => true));
 			try{
-				$return = $mongoCollectionObj->update($cond, $data, array("multiple" => false));
+				$return = $mongoCollectionObj->update($cond, $data, $params);
 			} catch (MongoException $e) {
 				$this->error = $e->getMessage();
 				trigger_error($this->error);
 			}
 			if ($this->fullDebug) {
 				$this->logQuery("db.{$Model->useTable}.update( :conditions, :data, :params )",
-					array('conditions' => $cond, 'data' => $data, 'params' => array("multiple" => false))
+					array('conditions' => $cond, 'data' => $data, 'params' => $params)
 				);
 			}
 		} else {
+			$params = $this->collectionOptions['save'];
 			try{
-				$return = $mongoCollectionObj->save($data);
+				$return = $mongoCollectionObj->save($data, $params);
 			} catch (MongoException $e) {
 				$this->error = $e->getMessage();
 				trigger_error($this->error);
 			}
 			if ($this->fullDebug) {
-				$this->logQuery("db.{$Model->useTable}.save( :data )", compact('data'));
+				$this->logQuery("db.{$Model->useTable}.save( :data, :params )", compact('data', 'params'));
 			}
 		}
 		return $return;
@@ -804,20 +828,21 @@ public function updateAll(&$Model, $fields = null,  $conditions = null) {
 		$this->_stripAlias($fields, $Model->alias, false, 'value');
 
 		$fields = $this->setMongoUpdateOperator($Model, $fields);
-
+		$params = array_merge($this->collectionOptions['update'], array("multiple" => true));
+
 		$this->_prepareLogQuery($Model); // just sets a timer
 		try{
 			$return = $this->_db
 				->selectCollection($Model->table)
-				->update($conditions, $fields, array("multiple" => true));
+				->update($conditions, $fields, $params);
 		} catch (MongoException $e) {
 			$this->error = $e->getMessage();
 			trigger_error($this->error);
 		}
 
 		if ($this->fullDebug) {
 			$this->logQuery("db.{$Model->useTable}.update( :conditions, :fields, :params )",
-				array('conditions' => $conditions, 'fields' => $fields, 'params' => array("multiple" => true))
+				array('conditions' => $conditions, 'fields' => $fields, 'params' => $params)
 			);
 		}
 		return $return;