mongoose 连接查询控制副本集等操作引导
引用自:https://cnodejs.org/topic/5206581b44e76d216aae072e
之前已经有朋友总结了mongoose的一些内容，推荐他的文章，包含了主干部分，这是接着后面写的。接下来是翻译自mongoose guide
#Queries
文件可以通过一些静态辅助模型的方法检索。
任何涉及 指定 查询 条件的模型方法，有两种执行的方式：
当一个回调函数：
被传递，将立即执行的操作结果传递给回调。
未被传递，返回一个查询的实例，它为您提供了一个特殊的QueryBuilder接口。
让我们来看看在传递一个回调时会发生什么：
var Person = mongoose.model('Person', yourSchema);
// find each person with a last name matching 'Ghost', selecting the `name` and `occupation` fields
Person.findOne({ 'name.last': 'Ghost' }, 'name occupation', function (err, person) {
if (err) return handleError(err);
console.log('%s %s is a %s.', person.name.first, person.name.last, person.occupation) // Space Ghost is a talk show host.
})在这里，我们可以看到，查询立即执行，并将结果传递给我们的回调。mongoose的所有回调使用模式：callback(error, result) 。如果执行查询时发生错误，错误参数将包含一个错误文件，result将是null。如果查询成功，error参数将是空的，result就会包含查询的结果。
任何地方被传递给一个函数，回调如下格式 callback(error, results)。
现在，让我们看看没有传递回调时，会发生什么：
// find each person with a last name matching 'Ghost'var query = Person.findOne({ 'name.last': 'Ghost' });// selecting the `name` and `occupation` fieldsquery.select('name occupation');// execute the query at a later timequery.exec(function (err, person) {
if (err) return handleError(err);
console.log('%s %s is a %s.', person.name.first, person.name.last, person.occupation) // Space Ghost is a talk show host.})这使我们能够通过返回的query实例建立查询。进一步考虑这个例子：
Person.find({ occupation: /host/ }).where('name.last').equals('Ghost').where('age').gt(17).lt(66).where('likes').in(['vaporizing', 'talking']).limit(10).sort('-occupation').select('name occupation').exec(callback);#References to other documents
MongoDB是非关联型的，但有时我们还是想引用其他集合中的文档。这是population的用武之地。
#Streaming
查询可以从MongoDB的传输到你的应用程序。只需调用查询的数据流的方法，而不是EXEC返回一个实例QueryStream。注：QueryStreams 是 Node.js的0.8风格，不是Node.js的0.10风格。
#Next Up
现在，我们已经覆盖查询，让我们来看看验证。
#Validation
在我们进入具体的Validation语法，请记住以下规则：
Validation是SchemaType中定义的
Validation是middleware的一部分
Validation发生在document试图在默认值应用之后保存的时候
Validation是异步递归的：当你调用 Model#save时，子文档执行Validation。如果发生了错 误，你的 Model#save回调接收错误
Mongoose并不关心复杂的错误消息建设。错误有类型标识符。例如，“min”是数未达到 minimum value时触发错误的标识符。引发错误的路径和值的ValidationError对象可以访问
#Built in validators
Mongoose有几个内置的验证器。
#Custom validators
通过传递一个验证function和一个error tyoe给你的SchemaTypes 验证方法.更多自定义验证器和异步验证器的细节请查阅API。
##Validation错误
Validation失败后返回的Errors包含一个持有实际ValidatorErrors的errors对象。每个ValidatorError有type, path, 和 value属性，为我们提供了多一点的错误处理的灵活性。
var toySchema = new Schema({
color: String,
name: String});var Toy = mongoose.model('Toy', toySchema);Toy.schema.path('color').validate(function (value) {
return /blue|green|white|red|orange|periwinkel/i.test(value);}, 'Invalid color');var toy = new Toy({ color: 'grease'});toy.save(function (err) {
// err.errors.color is a ValidatorError object
console.log(err.errors.color.message) // prints 'Validator "Invalid color" failed for path color with value `grease`'
console.log(String(err.errors.color)) // prints 'Validator "Invalid color" failed for path color with value `grease`'
console.log(err.errors.color.type) // prints "Invalid color"
console.log(err.errors.color.path) // prints "color"
console.log(err.errors.color.value) // prints "grease"
console.log(err.name) // prints "ValidationError"
console.log(err.message) // prints "Validation failed"});;Validation错误后，该文件也将有相同的errprs属性：
toy.errors.color.message === err.errors.color.message
#Next up
现在，我们已经覆盖了Validation，让我们一起来看看，你可能会如何处理先进的Validation与Mongoose中间件。
#Middleware
Middleware是一些函数，在执行init,validate,save和remove的时候传递控制权。有两种类型的中间件，pre和post。让我们开始pre。
##pre
有两种类型的预中间件，串行和并行。
串行
串口中间件执行此起彼伏，每个中间件调用next
var schema = new Schema(..);schema.pre('save', function (next) {
// do stuff
next();});并行
并行中间件提供更细粒度的流量控制。
var schema = new Schema(..);schema.pre('save', true, function (next, done) {
// calling next kicks off the next middleware in parallel
next();
doAsync(done);});像例子一样，方法将不被执行，直到操作完每个中间件。
使用案例
中间件对于细化模型的逻辑，避免嵌套太多的异步代码。这里有一些其他的用途：
复杂的验证
消除依赖文档
（删除用户删除他的所有部落格文章）
异步默认
异步任务触发某个动作
触发自定义事件
通知
错误处理
如果任何中间件调用next，处理错误实例，流程将被打断，错误会传递给回调。
schema.pre('save', function (next) {
var err = new Error('something went wrong');
next(err);});// later...myModel.save(function (err) {
console.log(err.message) // something went wrong});##post
post在勾连方法和它们所有的pre中间件完成之后。pre中间件不直接接收流量控制，例如，没有next或callback被传递给它。post钩为这些方法注册传统的事件监听器。
schema.post('init', function (doc) {
console.log('%s has been initialized from the db', doc._id);})schema.post('validate', function (doc) {
console.log('%s has been validated (but not saved yet)', doc._id);})schema.post('save', function (doc) {
console.log('%s has been saved', doc._id);})schema.post('remove', function (doc) {
console.log('%s has been removed', doc._id);})##Next up
现在，我们已经覆盖了中间件，让我们来看看mongoose方法伪造关联查询的population助手。
#population
MongoDB是非关联数据库。但是有时候我们还是想引用其它的文档。这就是population的用武之地。
Population是从其它文档替换文档中的特定路径。我们可以迁移一个单一的文件，多个文件，普通对象，多个普通的对象，或从查询中返回的所有对象。让我们来看看一些例子。
var mongoose = require('mongoose')
, Schema = mongoose.Schema
var personSchema = Schema({
_id : Number,
name : String,
age : Number,
stories : [{ type: Schema.Types.ObjectId, ref: 'Story' }]});var storySchema = Schema({
_creator : { type: Number, ref: 'Person' },
title : String,
fans : [{ type: Number, ref: 'Person' }]});var Story = mongoose.model('Story', storySchema);var Person = mongoose.model('Person', personSchema);到目前为止，我们已经创造了两个Models。我们的person model有它的stories字段设置到一个ObjectIds数组。ref选项是告诉Mongoose在Story Model的例子中应该在population的时候使用哪个Model。所有_id我们这里存储必须是来自Story Model的document _id s。我们同时还声明了 Story _creator 属性，和在personSchema里的_id一样的类型。匹配这两者非常重要要。
注意: ObjectId, Number, String, 和 Buffer也可以用来作为 refs.
##Saving refs
保存对于其他文件的ref的工作方式和通常保存属性的相同，只是分配_id值：
var aaron = new Person({ _id: 0, name: 'Aaron', age: 100 });aaron.save(function (err) {
if (err) return handleError(err);
var story1 = new Story({
title: "Once upon a timex.",
_creator: aaron._id // assign the _id from the person
});
story1.save(function (err) {
if (err) return handleError(err);
// thats it!
});})##Population
到目前为止，我们还没有做什么太大的不同。我们只是创造了一个Person，一个Story。现在，让我们来看看使用查询生成器扩展我们的story’s_creator：
Story.findOne({ title: 'Once upon a timex.' }).populate('_creator').exec(function (err, story) {
if (err) return handleError(err);
console.log('The creator is %s', story._creator.name);
// prints "The creator is Aaron"})扩展的路径不再设置到原来的_id，在返回结果之前通过分离查询它们的值将会被从数据库返回的mongoose document取代。
refs数组以相同的方式工作。在query上调用populate方法就会返回一个document数组取代原来的_ids。
注意: mongoose >= 3.6 exposes the original _ids used during population through the document#populated() method.
##Field Selection
如果我们只想要一些扩展文档的特定的字段？这可以通过传递populate方法的第二个参数一般的字段名语法来完成：
Story.findOne({ title: /timex/i }).populate('_creator', 'name') // only return the Persons name.exec(function (err, story) {
if (err) return handleError(err);
console.log('The creator is %s', story._creator.name);
// prints "The creator is Aaron"
console.log('The creators age is %s', story._creator.age);
// prints "The creators age is null'})##Populating multiple paths
如果我们想同时扩展多个路径怎么办？
Story.find(...).populate('fans author') // space delimited path names.exec()In mongoose >= 3.6, 我们能用空格分界的字符串异性搞定，但是之前你要调用很多次
Story.find(...).populate('fans').populate('author').exec()##Query conditions and other options
如果我们想要扩展基于年龄的粉丝数组，选择他们的名字，返回最多我个人呢？
Story.find(...).populate({
path: 'fans',
match: { age: { $gte: 21 }},
select: 'name -_id',
options: { limit: 5 }}).exec()##Refs to children
然而，我们使用 aaron 对象，但我们不能够获得stories的清单。这是因为没有story对象‘压栈’到 aaron.stories。
这里有两种观点。首先，aaron知道哪个故事是他的就好了。
aaron.stories.push(story1);aaron.save(callback);
这使我们能够执行查找并扩展组合：
Person.findOne({ name: 'Aaron' }).populate('stories') // only works if we pushed refs to children.exec(function (err, person) {
if (err) return handleError(err);
console.log(person);})我们是否真的要两套指针，因为它们可能走出同步。相反，我们可以跳过扩展，直接find()我们感兴趣的story
Story.find({ _creator: aaron._id }).exec(function (err, stories) {
if (err) return handleError(err);
console.log('The stories are an array: ', stories);})##Updating refs
现在，我们有一个story的_creator不正确。我们可以更新refs就像其它mongoose属性设置一样：
var guille = new Person({ name: 'Guillermo' });guille.save(function (err) {
if (err) return handleError(err);
story._creator = guille;
console.log(story._creator.name);
// prints "Guillermo" in mongoose >= 3.6
// see https://github.com/LearnBoost/mongoose/wiki/3.6-release-notes
story.save(function (err) {
if (err) return handleError(err);
Story
.findOne({ title: /timex/i })
.populate({ path: '_creator', select: 'name' })
.exec(function (err, story) {
if (err) return handleError(err);
console.log('The creator is %s', story._creator.name)
// prints "The creator is Guillermo"
})
})})query population返回的documents 是完全功能化的，可删除的，可保存的文档，除非 lean option 被指定了。不要将它们和子文档搞混了。当你要调用remove方法的时候要注意，因为你将会把它从数据库里删除，不仅仅是数组。
##Populating an existing document
如果我们有一个已有的document，想要扩展路径， mongoose >= 3.6 支持document#populate() 方法。
##Populating multiple existing documents
如果我们想扩展多个document(like mapReduce output)，我们需要通过 Model.populate() 方法，mongoose >= 3.6有效.document#populate() 和 query#populate() 就是用这个方法更新documents.
##Field selection difference from v2 to v3
字段选择在v3 v2的比略有不同。数组的领域不再被接受。请参阅迁移指南和下面的例子中更多的细节。
// this works in v3Story.findOne(..).populate('_creator', 'name age').exec(..);// this doesn'tStory.findOne(..).populate('_creator', ['name', 'age']).exec(..);##Next Up
现在，我们已经覆盖扩展查询，让我们来看看连接。
#Connections
我们可以连接到MongoDB的通过mongoose.connect（）方法。
mongoose.connect('mongodb://localhost/myapp');只是最起码的链接本地运行在默认端口（27017）的myapp数据库。我们也可以指定一些参数在uri中。这取决于你的环境：
mongoose.connect('mongodb://username:password[@host](/user/host):port/database?options...');更多详细信息，请参阅MongoDB的mongodb connection string说明。
##Options
connect方法也接受传递给底层驱动的options对象。所有选项在这里包括的优先于传递到connection 字符串的选项。
mongoose.connect(uri, options);
下列选项键可供选择：
db - passed to the connection db instance
server - passed to the connection server instance(s)
replset - passed to the connection ReplSet instance
user - username for authentication (if not specified in uri)
pass - password for authentication (if not specified in uri)
auth - options for authentication
mongos - Boolean - if true, enables High Availability support for mongos
例如：
var options = {
db: { native_parser: true },
server: { poolSize: 5 },
replset: { rs_name: 'myReplicaSetName' },
user: 'myUserName',
pass: 'myPassword'}mongoose.connect(uri, options);注： 该服务器选项auto_reconnect的是默认为true时，它可以被覆盖。forceServerObjectId db选项设置为false，不能被覆盖。
有关可用选项的更多信息，请参阅驱动的有关信息。
有关的keepalive的注意事项
对于长时间运行的applictions的，它往往是谨慎启用KEEPALIVE。没有它，一段时间后，你可能会开始看没有理由的“connection closed”的错误。如果是这样的话，看这个后，你可能会决定启用KEEPALIVE：
options.server.socketOptions = options.replset.socketOptions = { keepAlive: 1 };mongoose.connect(uri, options);##ReplicaSet Connections
使用同样的方法，而不是通过一个单一的URI连接到一个副本集，但我们通过逗号分隔URIs。
`mongoose.connect('mongodb://username:password[@host](/user/host):port/database,mongodb://username:password[@host](/user/host):port,mongodb://username:password[@host](/user/host):port?options...' [, options]);`注：数据库，只需要在一个指定的的uri。
##Multi-mongos support
在多个Mongos的实例也支持高可用性。通过一个连接字符串Mongos的实例，并设置为true Mongos的选项：
mongoose.connect('mongodb://mongosA:27501,mongosB:27501', { mongos: true }, cb);##Multiple connections
到目前为止，我们已经看到了如何连接到MongoDB。有时我们可能需要mongo打开多个连接，每个有不同的读/写设置，或者只是为了不同的数据库，例如。在这些情况下我们可以利用mongoose.createConnection()接受已经讨论过的所有参数，并返回一个新的连接。
`var conn = mongoose.createConnection('uri,uri,uri...', options);`然后，可以使用此连接对象，用于创建和检索，范围只在这一特定的连接的模型。
##Connection pools
每个连接，无论是mongoose.connect还是mongoose.createConnection都会用一个内置可配置链接池备份，默认大小为5。调节池的大小，使用的连接选项：
// single servervar uri = 'mongodb://localhost/test';mongoose.createConnection(uri, { server: { poolSize: 4 }});// for a replica setmongoose.createConnection(uri, { replset: { poolSize: 4 }});// passing the option in the URI works with single or replica setsvar uri = 'mongodb://localhost/test?poolSize=4';mongoose.createConnection(uri);##Next Up
现在，我们已经覆盖了连接，让我们来看看我们如何能够打破我们的功能件为可重用和共享插件。
#Plugins
Schemas是可插入的，即，它们可以应用预先包装的能力，从而延长其功能。这是一个非常强大的功能。
假设我们有几个collection在我们的资料库中，要添加的最后一次修改给每一个的功能。用插件，这很容易。只需创建一个插件，并把它应用到每个Schema：
// lastMod.jsmodule.exports = exports = function lastModifiedPlugin (schema, options) {
schema.add({ lastMod: Date })
schema.pre('save', function (next) {
this.lastMod = new Date
next()
})
if (options && options.index) {
schema.path('lastMod').index(options.index)
}}// game-schema.jsvar lastMod = require('./lastMod');var Game = new Schema({ ... });Game.plugin(lastMod, { index: true });// player-schema.jsvar lastMod = require('./lastMod');var Player = new Schema({ ... });Player.plugin(lastMod);我们刚添加的last-modified的行为–我们的Game和Player Schemas，并补充添加声明我们的Games的对于lastMOd的index。不坏的几行代码！
##社区！
您不仅可以重新使用模式功能在自己的项目，但你也获益mongoose社区。发表任何插件NPM和带有mongoose标签的，会显示在我们的搜索结果页面。
##Next Up
现在，我们已经覆盖插件以及如何涉足生长在他们周围的伟大的社区，让我们来看看如何可以帮助mongoose本身的持续发展做出贡献。