lithium\data\source\MongoDb::create()
Implements
lithium\data\Source::create()
Create new document
Parameters
-
string
$query
-
array
$options
Returns
booleanFilter
This method can be filtered.
Source
public function create($query, array $options = []) {
$this->_checkConnection();
$defaults = [
'w' => $this->_config['w'],
'wTimeoutMS' => $this->_config['wTimeoutMS'],
'fsync' => false
];
$options += $defaults;
$params = compact('query', 'options');
return Filters::run($this, __FUNCTION__, $params, function($params) {
$exporter = $this->_classes['exporter'];
$prefix = $this->_config['gridPrefix'];
$query = $params['query'];
$options = $params['options'];
$args = $query->export($this, ['keys' => ['source', 'data']]);
$data = $exporter::get('create', $args['data']);
$source = $args['source'];
if ($source === "{$prefix}.files" && isset($data['create']['file'])) {
$result = ['ok' => true];
$data['create']['_id'] = $this->_saveFile($data['create']);
} else {
$result = $this->connection->{$source}->insert($data['create'], $options);
$result = $this->_ok($result);
}
if ($result === true || isset($result['ok']) && (boolean) $result['ok'] === true) {
if ($query->entity()) {
$query->entity()->sync($data['create']['_id']);
}
return true;
}
return false;
});
}