一、创建schemas
创建schemas的方式:
var userSchema = new mongoose.Schema({
name: String,
email: String,
createdOn: Date
});
</div>
schemas中的数据类型有以下几种:
- String
- Number
- Date
- Boolean
- Buffer
- ObjectId
- Mixed
- Array
特别需要说明一下ObjectId类型和Mixed类型以及Array类型,在schemas中声明这几种类型的方式如下:
//ObjectId就类似于唯一键值
projectSchema.add({
owner: mongoose.Schema.Types.ObjectId
});
//混合类型,顾名思义,就是说里面可以放置任意类型的数据,有两种方式创建该类型数据
//方式一:直接赋予一个空的字面量对象
vardjSchema= new mongoose.Schema({
mixedUp: {}
});
//方式二:根据Schemas.Types中值来赋予
vardjSchema= new mongoose.Schema({
mixedUp: Schema.Types.Mixed
});
//Array类型数据有两种创建方式,一种是简单数组创建:
var userSchema = new mongoose.Schema({
name: String,
emailAddresses: [String]
});
//第二种方式就是复杂类型数据数组,例如我们可以再数组中添加不同类型的schemas:
var emailSchema = new mongoose.Schema({
email: String,
verified: Boolean
});
var userSchema = new mongoose.Schema({
name: String,
emailAddresses: [emailSchema]
});
//注意:如果定义一个空的数据的话,则会创建为一个混合类型数据的数组:
var emailSchema = new mongoose.Schema({
email: String,
verified: Boolean
});
var userSchema = new mongoose.Schema({
name: String,
emailAddresses: [emailSchema]
});
</div>
我们可以给schema创建静态方法,这个静态方法将来会用在Model中,创建该静态方法需要在创建完成schema之后,在Model编译之前:
projectSchema.statics.findByUserID = function (userid, callback) {
this.find({ createdBy: userid }, '_id projectName', {sort: 'modifiedOn'}, callback);
};
</div>
在其对应的模型创建完成并编译后,我们就可以像下面这样来调用该静态方法了:
Model.findByUserID(userid,callback);</div>
该静态方法会返回一个JSON格式的数据,这在我们使用AJAX技术来加载网页数据的时候会比较方便,就像下面这样:
//路由规则:app.get('/project/byuser/:userid', project.byUser);
exports.byUser = function (req, res) {
console.log("Getting user projects");
if (req.params.userid){
Project.findByUserID(req.params.userid,function (err, projects) {
if(!err){
console.log(projects);
res.json(projects);
}else{
console.log(err);
res.json({"status":"error", "error":"Error finding projects"});
}
});
}else{
console.log("No user id supplied");
res.json({"status":"error", "error":"No user id supplied"});
}
};
</div>
二、创建Model
创建Model很简单:
Mongoose.Model('User', userSchema);
</div>
参数一为Model的名字,参数二为生成Model所需要的schema,Model就像是schema所编译而成的一样。
mongoose连接数据库是有两种方式的:
//方式一:
var dbURI = 'mongodb://localhost/mydatabase';
mongoose.connect(dbURI);
//方式二:
var dbURI = 'mongodb://localhost/myadmindatabase';
var adminConnection = mongoose.createConnection(dbURI);
//如果需要声明端口号:
var dbURI = 'mongodb://localhost:27018/mydatabase';
//如果需要定义用户名和密码:
var dbURI = 'mongodb://username:password@localhost/mydatabase';
//也可以像下面这样传一个对象类型的参数:
var dbURI = 'mongodb://localhost/mydatabase';
var dbOptions = {'user':'db_username','pass':'db_password'};
mongoose.connect(dbURI, dbOptions);
</div>
根据连接数据库的方式,我们可以得到第二种创建Model的方式,就是使用数据库连接的引用名来创建:
adminConnection.model( 'User', userSchema );</div>
默认情况下mongoose会根据我们传入的Model名字来生成collection名字,在上面的代码中就会生成名为users(全为小写字母)的collection(集合);
有两种方法能让我们自定义collection的名字。
//方式一,在创建schema的时候定义collection的名字:
var userSchema = new mongoose.Schema({
name: String,
email: {type: String, unique:true}
},
{
collection: 'myuserlist'
});
//方式二,在创建Model的时候定义collection的名字:
mongoose.model( 'User', userSchema, 'myuserlist' );
</div>
创建Model实例:
var user = new User({ name: 'Simon' });
</div>
user就是模型User的一个实例,它具有mongoose中模型所具有的一些方法,例如保存实例:
user.save(function (err) {
if (err) return handleError(err);
});
</div>
模型也具有一些常用的增删查改的方法:
User.findOne({'name' : 'Sally', function(err,user) {
if(!err){
console.log(user);
}
});
User.find({}, function(err, users) {
if(!err){
console.log(users);
}
});
</div>
可以使用链式方式使用这些方法,例如:
var newUser = new User({
name: 'Simon Holmes',
email: 'simon@theholmesoffice.com',
lastLogin : Date.now()
}).save( function( err ){
if(!err){
console.log('User saved!');
}
});
</div>
上面的代码创建了一个模型实例,然后进行保存。我们有一个更为简介的方式来完成这项工作,就是使用Model.create()方法:
User.create({
name: 'Simon Holmes',
email: 'simon@theholmesoffice.com',
lastLogin : Date.now()
}, function( err, user ){
if(!err){
console.log('User saved!');
console.log('Saved user name: ' + user.name);
console.log('_id of saved user: ' + user._id);
}
});
</div>
三、查找数据和读取数据的方法
1.使用QueryBuilder接口来查找数据
先看看下面的代码:
var myQuery = User.find({'name' : 'Simon Holmes'});
myQuery.where('age').gt(18);
myQuery.sort('-lastLogin');
myQuery.select('_id name email');
myQuery.exec(function (err, users){
if (!err){
console.log(users); // output array of users found
}
});
</div>
代码中,我们查找名字为"Simon Holmes",并且年龄大于18岁,查找结果根据lastLogin降序排列,只获取其中的_id, name, email三个字段的值,上面的代码只有在调用exec方法后才真正执行数据库的查询。
当然我们可以使用链式的方式来改写上面的代码,代码会更加简洁:
User.find({'name' : 'Simon Holmes'})
.where('age').gt(18)
.sort('-lastLogin')
.select('_id name email')
.exec(function (err, users){
if (!err){
console.log(users); // output array of users found
}
});
</div>
上面代码中的第一行创建了一个queryBuilder.通过使用这个queryBuilder,我们就可以执行一些比较复杂的查找工作,在创建完成这个queryBuilder之后,查询操作并没有马上执行,而是待到执行exec方法时才会去执行数据库的查找。
当然也有另外一种方式能够直接查找数据库的,就是直接在查找方法中添加回调函数,使用方式为:
Model.find(conditions, [fie

