/*
* 在MongoDB数据库中插入数据
* */
var mongo = require('mongoDB');
var host = 'localhost';
var port = 27017;
//var port = mongo.Connection.DEFAULT_PORT;
//创建mongoDB数据库所在服务器的Server对象,用于指定需要链接的MongoDB所在的服务器
var server = new mongo.Server(host,port,{auto_reconnect : true});
//创建一个代表MongoDB数据库额的DB对象
var db = new mongo.Db('node-mongo-examples',server,{safe : true});
var person1 = {username:'三',firstname:'张'};
var person2 = {username:'四',firstname:'李'};
var person3 = {username:'五',firstname:'王'};
db.open(function (err, db) {
//访问一个集合
//db.collection(collectionName,[options],[callback]) function(err,collection){}
db.collection('user',function (err, collection) {
//insert方法将数据文档插入集合中
//collection.insert(docs,[options],[callback]) function(err,docs){}
collection.insert({username:'js',age:21},function (err, docs) {
//collection.insert(person3,function (err, docs) {
//collection.insert(person2,function (err, docs) {
//collection.insert(person1,function (err, docs) {
console.log(docs);
//close方法
//close([forceClose],[callback])
//forceClose为是否强制关闭数据库。默认为false。
//false:关闭后还能用open()方法打开 true:关闭后不可用用open()方法打开
db.close();
});
});
});