插入(增加)数据
//插入数据
//向user表中插入数据
MongoClient.connect(url, function(err, db) {
if (err) throw err;
var dbo = db.db(dbname);
var myobj = { username: "zs", password: "123" };
dbo.collection("user").insertOne(myobj, function(err, res) {
if (err) throw err;
console.log("文档插入成功");
//插入的数据产生的结果
console.log(res])
db.close();
});
});
插入多条数据
//插入多条数据
MongoClient.connect(url, function(err, db) {
if (err) throw err;
var dbo = db.db(dbname);
var myobj = [
{ username: ‘lisi‘, password: ‘1111‘, type: ‘1‘},
{ username: ‘wangwu‘, password: ‘222‘, type: ‘2‘}
];
dbo.collection("user").insertMany(myobj, function(err, res) {
if (err) throw err;
console.log("插入的文档数量为: " + res.insertedCount);
console.log(res)
db.close();
});
});
查询数据
//查询数据
//可以使用 find() 来查找数据, find() 可以返回匹配条件的所有数据。
//如果未指定条件，find() 返回集合中的所有数据。
MongoClient.connect(url, function(err, db) {
if (err) throw err;
var dbo = db.db(dbname);
dbo.collection("user"). find({}).toArray(function(err, result) { // 返回集合中所有数据
if (err) throw err;
console.log(‘查询成功‘+result.length);//结果为数组
db.close();
});
});
查询指定条件
//查询指定条件的数据
//查询用户名为 lisi的用户
MongoClient.connect(url, function(err, db) {
if (err) throw err;
var dbo = db.db(dbname);
var whereStr = {"username":‘lisi‘}; // 查询条件
dbo.collection("user").find(whereStr).toArray(function(err, result) {
if (err) throw err;
console.log(‘查询lisi成功‘+result);
db.close();
});
});
更新数据
//更新一条数据
MongoClient.connect(url, function(err, db) {
if (err) throw err;
var dbo = db.db(dbname);
var whereStr = {"username":‘lisi‘}; // 查询条件
var updateStr = {$set: { "password" : "test" }};
dbo.collection("user").updateOne(whereStr, updateStr, function(err, res) {
if (err) throw err;
console.log("文档更新成功");
db.close();
});
});
// 更新多条数据
MongoClient.connect(url, function(err, db) {
if (err) throw err;
var dbo = db.db(dbname);
var whereStr = {"username":‘lisi‘}; // 查询条件
var updateStr = {$set: { "password" : "test222" }};
dbo.collection("user").updateMany(whereStr, updateStr, function(err, res) {
if (err) throw err;
console.log("文档更新成功");
console.log(‘插入多条成功 ，‘+res.result.nModified + " 条文档被更新");
db.close();
});
});
排序
//排序 使用 sort() 方法，该方法接受一个参数，规定是升序(1)还是降序(-1)。
//{ _id: 1 } // 按 _id 字段升序
//{ _id: -1 } // 按 _id 字段降序
MongoClient.connect(url, function(err, db) {
if (err) throw err;
var dbo = db.db(dbname);
var mysort = { _id: 1 };
dbo.collection("user").find().sort(mysort).toArray(function(err, result) {
if (err) throw err;
console.log(result);
db.close();
});
});
查询分页
//如果要设置指定的返回条数可以使用 limit() 方法，该方法只接受一个参数，
//指定了返回的条数。
// limit()：读取两条数据
MongoClient.connect(url, function(err, db) {
if (err) throw err;
var dbo = db.db(dbname);
dbo.collection("user").find().limit(2).toArray(function(err, result) {
if (err) throw err;
console.log(result);
db.close();
});
});
//如果要指定跳过的条数，可以使用 skip() 方法。
//skip(): 跳过前面两条数据，读取两条数据
MongoClient.connect(url, function(err, db) {
if (err) throw err;
var dbo = db.db(dbname);
dbo.collection("user").find().skip(2).limit(2).toArray(function(err, result) {
if (err) throw err;
console.log(result);
db.close();
});
});
