laravel 操作mongodb

配置

修改config/database.php在connection数组中添加mongodb的配置信息,如下

'default' => env('DB_CONNECTION', 'mongodb'),

添加一个新的mongodb连接:

'mongodb' => [
  'driver' => 'mongodb',
  'host' => env('DB_HOST', 'localhost'),
  'port' => env('DB_PORT', 27017),
  'database' => env('DB_DATABASE'),
  'username' => env('DB_USERNAME'),
  'password' => env('DB_PASSWORD'),
  'options' => [
  'database' => 'admin' // sets the authentication database required by mongo 3
  ]
],

你可以用下面的配置连接到多个服务器或副本集:

'mongodb' => [
  'driver' => 'mongodb',
  'host' => ['server1', 'server2'],
  'port' => env('DB_PORT', 27017),
  'database' => env('DB_DATABASE'),
  'username' => env('DB_USERNAME'),
  'password' => env('DB_PASSWORD'),
  'options' => [
 'replicaSet' => 'replicaSetName'
   ]
],

Eloquent

这个包包括启动Mongodb Eloquent的类,你也可以调用响应的类使用

use Jenssegers\Mongodb\Eloquent\Model as Eloquent;
class User extends Eloquent {}

声明默认链接

use Jenssegers\Mongodb\Eloquent\Model as Eloquent;
class MyModel extends Eloquent {
  protected $connection = 'mongodb';
}

Optional: Alias

你也可以通过添加以下在配置 app.php别名阵列登记为MongoDB模型别名:

'Moloquent' => Jenssegers\Mongodb\Eloquent\Model::class,

你就可以使用别名:

class MyModel extends Moloquent {}

Query Builder

数据库驱动程序直接插入原始查询生成器中。当使用MongoDB的连接,你将能够建立良好的查询执行数据库操作。为了您的方便,有许多别名表以及一些额外的MongoDB具体运营/操作。

$users = DB::collection('users')->get();
$user = DB::collection('users')->where('name', 'John')->first();

如果没有更改默认数据库连接,则需要在查询时指定它。

$user = DB::connection('mongodb')->collection('users')->get();

Schema(数据库结构)

你可以依照laravel Schema设置索引:

Schema::create('users', function($collection)
{
  $collection->index('name');
  $collection->unique('email');
});

示例

基本使用

查出所有user

$users = User::all();

按主键检索记录

$user = User::find('517c43667db388101e00000f');

where操作查询

$users = User::where('votes', '>', 100)->take(10)->get();

or操作

$users = User::where('votes', '>', 100)->orWhere('name', 'John')->get();

and操作

$users = User::where('votes', '>', 100)->where('name', '=', 'John')->get();

Using Where In With An Array

$users = User::whereIn('age', [16, 18, 20])->get();

When using whereNotIn objects will be returned if the field is non existent. Combine with whereNotNull('age')
to leave out those documents.
Using Where Between

$users = User::whereBetween('votes', [1, 100])->get();

Where null

$users = User::whereNull('updated_at')->get();

Order By

$users = User::orderBy('name', 'desc')->get();

Offset & Limit

$users = User::skip(10)->take(5)->get();

Distinct
Distinct requires a field for which to return the distinct values.

$users = User::distinct()->get(['name']);// or$users = User::distinct('name')->get();

Distinct can be combined with where:

$users = User::where('active', true)->distinct('name')->get();

Advanced Wheres

$users = User::where('name', '=', 'John')->orWhere(function($query) { $query->where('votes', '>', 100) ->where('title', '<>', 'Admin'); }) ->get();

Group By
Selected columns that are not grouped will be aggregated with the $last function.

$users = Users::groupBy('title')->get(['title', 'name']);

Aggregation
Aggregations are only available for MongoDB versions greater than 2.2.

$total = Order::count();$price = Order::max('price');$price = Order::min('price');$price = Order::avg('price');$total = Order::sum('price');

Aggregations can be combined with where:

$sold = Orders::where('sold', true)->sum('price');

Aggregations can be also used on subdocuments:

$total = Order::max('suborder.price');...

NOTE: this aggreagtion only works with single subdocuments (like embedsOne) not subdocument arrays (like embedsMany)
Like

$user = Comment::where('body', 'like', '%spam%')->get();

Incrementing or decrementing a value of a column
Perform increments or decrements (default 1) on specified attributes:

User::where('name', 'John Doe')->increment('age');User::where('name', 'Jaques')->decrement('weight', 50);

The number of updated objects is returned:

$count = User->increment('age');

You may also specify additional columns to update:

User::where('age', '29')->increment('age', 1, ['group' => 'thirty something']);User::where('bmi', 30)->decrement('bmi', 1, ['category' => 'overweight']);

Soft deleting
When soft deleting a model, it is not actually removed from your database. Instead, a deleted_at timestamp is set on the record. To enable soft deletes for a model, apply the SoftDeletingTrait to the model:

use Jenssegers\Mongodb\Eloquent\SoftDeletes;class User extends Eloquent { use SoftDeletes; protected $dates = ['deleted_at'];}

For more information check http://laravel.com/docs/eloquent#soft-deleting
[

](https://github.com/jenssegers/laravel-mongodb#mongodb-specific-operators)MongoDB specific operators
Exists
Matches documents that have the specified field.

User::where('age', 'exists', true)->get();

All
Matches arrays that contain all elements specified in the query.

User::where('roles', 'all', ['moderator', 'author'])->get();

Size
Selects documents if the array field is a specified size.

User::where('tags', 'size', 3)->get();

Regex
Selects documents where values match a specified regular expression.

User::where('name', 'regex', new \MongoDB\BSON\Regex("/.*doe/i"))->get();

NOTE: you can also use the Laravel regexp operations. These are a bit more flexible and will automatically convert your regular expression string to a MongoDB\BSON\Regex object.

User::where('name', 'regexp', '/.*doe/i'))->get();

And the inverse:

User::where('name', 'not regexp', '/.*doe/i'))->get();

Type
Selects documents if a field is of the specified type. For more information check: http://docs.mongodb.org/manual/reference/operator/query/type/#op._S_type

User::where('age', 'type', 2)->get();

Mod
Performs a modulo operation on the value of a field and selects documents with a specified result.

User::where('age', 'mod', [10, 0])->get();

Where
Matches documents that satisfy a JavaScript expression. For more information check http://docs.mongodb.org/manual/reference/operator/query/where/#op._S_where

Inserts, updates and deletes
Inserting, updating and deleting records works just like the original Eloquent.
Saving a new model

$user = new User;$user->name = 'John';$user->save();

You may also use the create method to save a new model in a single line:

User::create(['name' => 'John']);

Updating a model
To update a model, you may retrieve it, change an attribute, and use the save method.

$user = User::first();$user->email = 'john@foo.com';
$user->save();

There is also support for upsert operations, check https://github.com/jenssegers/laravel-mongodb#mongodb-specific-operations
Deleting a model
To delete a model, simply call the delete method on the instance:

$user = User::first();$user->delete();

Or deleting a model by its key:

User::destroy('517c43667db388101e00000f');

For more information about model manipulation, check http://laravel.com/docs/eloquent#insert-update-delete

Dates

Eloquent allows you to work with Carbon/DateTime objects instead of MongoDate objects. Internally, these dates will be converted to MongoDate objects when saved to the database. If you wish to use this functionality on non-default date fields you will need to manually specify them as described here: http://laravel.com/docs/eloquent#date-mutators

Example:

use Jenssegers\Mongodb\Eloquent\Model as Eloquent;class User extends Eloquent { protected $dates = ['birthday'];}

Which allows you to execute queries like:

$users = User::where('birthday', '>', new DateTime('-18 years'))->get();

Relations

Supported relations are:
  • hasOne
  • hasMany
  • belongsTo
  • belongsToMany
  • embedsOne
  • embedsMany

Example:

use Jenssegers\Mongodb\Eloquent\Model as Eloquent;
class User extends Eloquent {

public function items()
{
return $this->hasMany('Item');
}
}

And the inverse relation:

use Jenssegers\Mongodb\Eloquent\Model as Eloquent;
class Item extends Eloquent {
public function user()
{
return $this->belongsTo('User');
}
}

The belongsToMany relation will not use a pivot "table", but will push id's to a related_ids attribute instead. This makes the second parameter for the belongsToMany method useless. If you want to define custom keys for your relation, set it to null:

use Jenssegers\Mongodb\Eloquent\Model as Eloquent;
class User extends Eloquent
{
public function groups()
{
return $this->belongsToMany('Group', null, 'user_ids', 'group_ids');
}
}

Other relations are not yet supported, but may be added in the future. Read more about these relations on http://laravel.com/docs/eloquent#relationships

EmbedsMany Relations

If you want to embed models, rather than referencing them, you can use the embedsMany
relation. This relation is similar to the hasMany
relation, but embeds the models inside the parent object.
REMEMBER: these relations return Eloquent collections, they don't return query builder objects!

use Jenssegers\Mongodb\Eloquent\Model as Eloquent;
class User extends Eloquent
{
public function books()
{
return $this->embedsMany('Book');
}
}

You access the embedded models through the dynamic property:

$books = User::first()->books;

The inverse relation is automagically available, you don't need to define this reverse relation.

$user = $book->user;

Inserting and updating embedded models works similar to the hasMany
relation:

$book = new Book(['title' => 'A Game of Thrones']);
$user = User::first();
$book = $user->books()->save($book);
// or$book = $user->books()->create(['title' => 'A Game of Thrones'])

You can update embedded models using their save
method (available since release 2.0.0):

$book = $user->books()->first();$book->title = 'A Game of Thrones';$book->save();

You can remove an embedded model by using the destroy
method on the relation, or the delete
method on the model (available since release 2.0.0):

$book = $user->books()->first();$book->delete();// or$user->books()->destroy($book);

If you want to add or remove an embedded model, without touching the database, you can use the associate
and dissociate
methods. To eventually write the changes to the database, save the parent object:

$user->books()->associate($book);$user->save();

Like other relations, embedsMany assumes the local key of the relationship based on the model name. You can override the default local key by passing a second argument to the embedsMany method:
return $this->embedsMany('Book', 'local_key');

Embedded relations will return a Collection of embedded items instead of a query builder. Check out the available operations here: https://laravel.com/docs/master/collections
EmbedsOne Relations
The embedsOne relation is similar to the EmbedsMany relation, but only embeds a single model.

use Jenssegers\Mongodb\Eloquent\Model as Eloquent;
class Book extends Eloquent
{
public function author()
{
return $this->embedsOne('Author');
}
}

You access the embedded models through the dynamic property:

$author = Book::first()->author;

Inserting and updating embedded models works similar to the hasOne
relation:

$author = new Author(['name' => 'John Doe']);
$book = Books::first();$author = $book->author()->save($author);
// or$author = $book->author()->create(['name' => 'John Doe']);

You can update the embedded model using the save
method (available since release 2.0.0):

$author = $book->author;$author->name = 'Jane Doe';$author->save();

You can replace the embedded model with a new model like this:

$newAuthor = new Author(['name' => 'Jane Doe']);$book->author()->save($newAuthor);

MySQL Relations
If you're using a hybrid MongoDB and SQL setup, you're in luck! The model will automatically return a MongoDB- or SQL-relation based on the type of the related model. Of course, if you want this functionality to work both ways, your SQL-models will need use the Jenssegers\Mongodb\Eloquent\HybridRelations
trait. Note that this functionality only works for hasOne, hasMany and belongsTo relations.
Example SQL-based User model:

use Jenssegers\Mongodb\Eloquent\HybridRelations
;class User extends Eloquent
{
use HybridRelations;
protected $connection = 'mysql';
public function messages()
{
return $this->hasMany('Message');
}
}

And the Mongodb-based Message model:

use Jenssegers\Mongodb\Eloquent\Model as Eloquent;
class Message extends Eloquent
{
protected $connection = 'mongodb';
public function user()
{
return $this->belongsTo('User');
}
}

Raw Expressions
These expressions will be injected directly into the query.

User::whereRaw(['age' => array('$gt' => 30, '$lt' => 40)])->get();

You can also perform raw expressions on the internal MongoCollection object. If this is executed on the model class, it will return a collection of models. If this is executed on the query builder, it will return the original response.

// Returns a collection of User models.
$models = User::raw(function($collection)
{
return $collection->find();
});
// Returns the original MongoCursor.
$cursor = DB::collection('users')->raw(function($collection)
{
return $collection->find();
});

Optional: if you don't pass a closure to the raw method, the internal MongoCollection object will be accessible:

$model = User::raw()->findOne(['age' => array('$lt' => 18]));

The internal MongoClient and MongoDB objects can be accessed like this:

$client = DB::getMongoClient();$db = DB::getMongoDB();

MongoDB specific operations
Cursor timeout
To prevent MongoCursorTimeout exceptions, you can manually set a timeout value that will be applied to the cursor:

DB::collection('users')->timeout(-1)->get();

Upsert
Update or insert a document. Additional options for the update method are passed directly to the native update method.

DB::collection('users')->where('name', 'John') ->update($data, ['upsert' => true]);

Projections
You can apply projections to your queries using the project
method.

DB::collection('items')->project(['tags' => array('$slice' => 1]))->get();

Projections with Pagination

$limit = 25;$projections = ['id', 'name'];DB::collection('items')->paginate($limit, $projections);

Push
Add an items to an array.

DB::collection('users')->where('name', 'John')->push('items', 'boots');DB::collection('users')->where('name', 'John')->push('messages', ['from' => 'Jane Doe', 'message' => 'Hi John']);

If you don't want duplicate items, set the third parameter to true:

DB::collection('users')->where('name', 'John')->push('items', 'boots', true);

Pull
Remove an item from an array.

DB::collection('users')->where('name', 'John')->pull('items', 'boots');DB::collection('users')->where('name', 'John')->pull('messages', ['from' => 'Jane Doe', 'message' => 'Hi John']);

Unset
Remove one or more fields from a document.

DB::collection('users')->where('name', 'John')->unset('note');

You can also perform an unset on a model.

$user = User::where('name', 'John')->first();$user->unset('note');

Query Caching
You may easily cache the results of a query using the remember method:

$users = User::remember(10)->get();

From: http://laravel.com/docs/queries#caching-queries
Query Logging
By default, Laravel keeps a log in memory of all queries that have been run for the current request. However, in some cases, such as when inserting a large number of rows, this can cause the application to use excess memory. To disable the log, you may use the disableQueryLog
method:

DB::connection()->disableQueryLog();

From: http://laravel.com/docs/database#query-logging

最后编辑于
©著作权归作者所有,转载或内容合作请联系作者
  • 序言:七十年代末,一起剥皮案震惊了整个滨河市,随后出现的几起案子,更是在滨河造成了极大的恐慌,老刑警刘岩,带你破解...
    沈念sama阅读 206,214评论 6 481
  • 序言:滨河连续发生了三起死亡事件,死亡现场离奇诡异,居然都是意外死亡,警方通过查阅死者的电脑和手机,发现死者居然都...
    沈念sama阅读 88,307评论 2 382
  • 文/潘晓璐 我一进店门,熙熙楼的掌柜王于贵愁眉苦脸地迎上来,“玉大人,你说我怎么就摊上这事。” “怎么了?”我有些...
    开封第一讲书人阅读 152,543评论 0 341
  • 文/不坏的土叔 我叫张陵,是天一观的道长。 经常有香客问我,道长,这世上最难降的妖魔是什么? 我笑而不...
    开封第一讲书人阅读 55,221评论 1 279
  • 正文 为了忘掉前任,我火速办了婚礼,结果婚礼上,老公的妹妹穿的比我还像新娘。我一直安慰自己,他们只是感情好,可当我...
    茶点故事阅读 64,224评论 5 371
  • 文/花漫 我一把揭开白布。 她就那样静静地躺着,像睡着了一般。 火红的嫁衣衬着肌肤如雪。 梳的纹丝不乱的头发上,一...
    开封第一讲书人阅读 49,007评论 1 284
  • 那天,我揣着相机与录音,去河边找鬼。 笑死,一个胖子当着我的面吹牛,可吹牛的内容都是我干的。 我是一名探鬼主播,决...
    沈念sama阅读 38,313评论 3 399
  • 文/苍兰香墨 我猛地睁开眼,长吁一口气:“原来是场噩梦啊……” “哼!你这毒妇竟也来了?” 一声冷哼从身侧响起,我...
    开封第一讲书人阅读 36,956评论 0 259
  • 序言:老挝万荣一对情侣失踪,失踪者是张志新(化名)和其女友刘颖,没想到半个月后,有当地人在树林里发现了一具尸体,经...
    沈念sama阅读 43,441评论 1 300
  • 正文 独居荒郊野岭守林人离奇死亡,尸身上长有42处带血的脓包…… 初始之章·张勋 以下内容为张勋视角 年9月15日...
    茶点故事阅读 35,925评论 2 323
  • 正文 我和宋清朗相恋三年,在试婚纱的时候发现自己被绿了。 大学时的朋友给我发了我未婚夫和他白月光在一起吃饭的照片。...
    茶点故事阅读 38,018评论 1 333
  • 序言:一个原本活蹦乱跳的男人离奇死亡,死状恐怖,灵堂内的尸体忽然破棺而出,到底是诈尸还是另有隐情,我是刑警宁泽,带...
    沈念sama阅读 33,685评论 4 322
  • 正文 年R本政府宣布,位于F岛的核电站,受9级特大地震影响,放射性物质发生泄漏。R本人自食恶果不足惜,却给世界环境...
    茶点故事阅读 39,234评论 3 307
  • 文/蒙蒙 一、第九天 我趴在偏房一处隐蔽的房顶上张望。 院中可真热闹,春花似锦、人声如沸。这庄子的主人今日做“春日...
    开封第一讲书人阅读 30,240评论 0 19
  • 文/苍兰香墨 我抬头看了看天上的太阳。三九已至,却和暖如春,着一层夹袄步出监牢的瞬间,已是汗流浃背。 一阵脚步声响...
    开封第一讲书人阅读 31,464评论 1 261
  • 我被黑心中介骗来泰国打工, 没想到刚下飞机就差点儿被人妖公主榨干…… 1. 我叫王不留,地道东北人。 一个月前我还...
    沈念sama阅读 45,467评论 2 352
  • 正文 我出身青楼,却偏偏与公主长得像,于是被迫代替她去往敌国和亲。 传闻我的和亲对象是个残疾皇子,可洞房花烛夜当晚...
    茶点故事阅读 42,762评论 2 345

推荐阅读更多精彩内容