Collections表示集合,类似关系数据库中的表。
Functions表示函数,类似关系数据库中的存储过程与函数。
Users表示用户。
document表示记录,类似关系数据为中的记录或行。
> use gomall
switched to db gomall
> db.dropDatabase()
{ "dropped" : "gomall", "ok" : 1 }
这里的数据可以是JSON
db.products.insert({name:"iphone",price:1988});
db.products.save({_id:2,name:"HuWei P9",price:2988});
id可以自已插入、一个表中不一定要字段都相同,虽然insert和save方法都可以插入数据,当默认的“_id”值已存在时,调用insert方法插入会报错;而save方法不会,会更新相同的_id所在行数据的信息。mongodb的shell中可以使用javascript脚本,如
for(var i=0;i<5;i++)db.users.save({'_id':i,'name':'zhangguo'+i,'age':i+8});
db.users.find({name:'zhangguo0'});
db.users.find({name:'zhangguo0',age:9}); 对象中的条件要求同时成立
db.集合.findOne(条件);
db.集合.find().limit(4); 取前四条
db.表名.find().skip(4); 跳过前4条,获取第5条以后的数据
$lt:相当于 "<"
$lte:相当于 "<="
$gt:相当于 ">"
$gte:相当于 ">="
$ne:相当于 "!="
db.users.find({age:{'$gt':9}});
查找年龄大于9且小于11岁的
db.表名.find().count();
db.表名.find().sort({"字段名":1}); 1:表示升序,-1:表示降序
db.表名.find({},{"字段名":0}); 参数1:返回 0:不返回
前面save在_id字段已存在是就是修改操作,按指定条件修改语法如下:
db.集合.update({"条件字段名":"字段值"},{$set:{"要修改的字段名":"修改后的字段值"}});
db.users.update({age:{'$eq':9}},{$set:{age:100}});
修改多条:
db.users.updateMany({age:{"$gte":10}},{$set:{age:30}});
db.集合.remove(条件);
db.users.remove({age:{'$gte':10}}); 删除年龄>=10岁的数据
//引入mongodb模块,获得客户端对象 var MongoClient = require('mongodb').MongoClient; //连接字符串 var DB_CONN_STR = 'mongodb://localhost:27017/gomall'; //定义函数表达式,用于操作数据库并返回结果 var insertData = function(db, callback) { //获得指定的集合 var collection = db.collection('users'); //插入数据 var data = [{_id:7,"name":'rose',"age":21},{_id:8,"name":'mark',"age":22}]; collection.insert(data, function(err, result) { //如果存在错误 if(err) { console.log('Error:'+ err); return; } //调用传入的回调方法,将操作结果返回 callback(result); }); } //使用客户端连接数据,并指定完成时的回调方法 MongoClient.connect(DB_CONN_STR, function(err, db) { console.log("连接成功!"); //执行插入数据操作,调用自定义方法 insertData(db, function(result) { //显示结果 console.log(result); //关闭数据库 db.close(); }); });
//引入mongodb模块,获得客户端对象 var MongoClient = require('mongodb').MongoClient; //连接字符串 var DB_CONN_STR = 'mongodb://localhost:27017/gomall'; //定义函数表达式,用于操作数据库并返回结果 var updateData = function(db, callback) { //获得指定的集合 var collection = db.collection('users'); //要修改数据的条件,>=10岁的用户 var where={age:{"$gte":10}}; //要修改的结果 var set={$set:{age:95}}; collection.updateMany(where,set, function(err, result) { //如果存在错误 if(err) { console.log('Error:'+ err); return; } //调用传入的回调方法,将操作结果返回 callback(result); }); } //使用客户端连接数据,并指定完成时的回调方法 MongoClient.connect(DB_CONN_STR, function(err, db) { console.log("连接成功!"); //执行插入数据操作,调用自定义方法 updateData(db, function(result) { //显示结果 console.log(result); //关闭数据库 db.close(); }); });
//引入mongodb模块,获得客户端对象 var MongoClient = require('mongodb').MongoClient; //连接字符串 var DB_CONN_STR = 'mongodb://localhost:27017/gomall'; //定义函数表达式,用于操作数据库并返回结果 var findData = function(db, callback) { //获得指定的集合 var collection = db.collection('users'); //要查询数据的条件,<=10岁的用户 var where={age:{"$lte":10}}; //要显示的字段 var set={name:1,age:1}; collection.find(where,set).toArray(function(err, result) { //如果存在错误 if(err) { console.log('Error:'+ err); return; } //调用传入的回调方法,将操作结果返回 callback(result); }); } //使用客户端连接数据,并指定完成时的回调方法 MongoClient.connect(DB_CONN_STR, function(err, db) { console.log("连接成功!"); //执行插入数据操作,调用自定义方法 findData(db, function(result) { //显示结果 console.log(result); //关闭数据库 db.close(); }); });
//引入mongodb模块,获得客户端对象 var MongoClient = require('mongodb').MongoClient; //连接字符串 var DB_CONN_STR = 'mongodb://localhost:27017/gomall'; //定义函数表达式,用于操作数据库并返回结果 var findData = function(db, callback) { //获得指定的集合 var collection = db.collection('users'); //要删除数据的条件,_id>2的用户删除 var where={_id:{"$gt":2}}; collection.remove(where,function(err, result) { //如果存在错误 if(err) { console.log('Error:'+ err); return; } //调用传入的回调方法,将操作结果返回 callback(result); }); } //使用客户端连接数据,并指定完成时的回调方法 MongoClient.connect(DB_CONN_STR, function(err, db) { console.log("连接成功!"); //执行插入数据操作,调用自定义方法 findData(db, function(result) { //显示结果 console.log(result); //关闭数据库 db.close(); }); });