MongoDB从入门到放弃
1.初识
安装配置见 之前配置
show databases
use demo-1(数据库名称 切换/创建数据库)
db.dropDatabase()删除数据库
show tables
db.col.drop() 删除集合col
增删改查
- 增
db.col.insert({title: 'MongoDB 教程', xxx}) 向col集合中插入数据
3.2之后 db.col.insertOne({"a": 3}) 插入一条
db.col.insertMany([{"b": 3}, {'c': 4}]) 插入多条
- 删
db.col.deleteMany({}) 删除全部文档
db.col.deleteMany({ status : "A" }) 删除status等于A的全部文档
db.col.deleteOne( { status: "D" } ) 删除status等于A的一个文档
db.col.remove({})
- 改
3.2版本开始 db.collection.updateOne() 向指定集合更新单个文档
db.test_collection.updateOne({"name":"abc"},{$set:{"age":"28"}})db.collection.updateMany() 向指定集合更新多个文档
- 查
db.col.find().pretty()
AND语句 db.col.find({key1:value1, key2:value2}).pretty()
OR语句 db.col.find({$or:[{"key1":"2333"},{"title": "MongoDB 教程"}]}).pretty()
连用 db.col.find({"likes": {$gt:50}, $or: [{"by": "2333"},{"title": "MongoDB 教程"}]}).pretty()
db.collection.find(query, projection)
db.collection.find(query, {title: 1, by: 1}) // inclusion模式 指定返回的键，不返回其他键 db.collection.find(query, {title: 0, by: 0}) // exclusion模式 指定不返回的键,返回其他键条件操作符实例
$gt -------- greater than >
$gte --------- gt equal >=
$lt -------- less than <
$lte --------- lt equal <=
$ne ----------- not equal !=
$eq -------- equal =
db.col.find({"likes" : {$gt : 100}}) likes大于100 对应于SQL中的 Select * from col where likes > 100;
db.col.find({likes : {$gte : 100}}) likes大于等于100 对应于SQL中的 Select * from col where likes >= 100;
db.col.find({likes : {$lt :200, $gt : 100}}) 对应于SQL中的 Select * from col where likes>100 AND likes<200;
limit 和 skip
db.col.find({},{"title":1,_id:0}).limit(1).skip(2) 第一个 {} 放 where 条件，为空表示返回集合中所有文档。第二个 {} 指定那些列显示和不显示 （0表示不显示 1表示显示)sort 排序
db.col.find().sort({KEY:1}) 1 为升序排列，而-1是用于降序排列索引：高效查询 索引是特殊的数据结构，索引存储在一个易于遍历读取的数据集合中，索引是对数据库表中一列或多列的值进行排序的一种结构
db.COLLECTION_NAME.ensureIndex({KEY:1}) Key 值为你要创建的索引字段，1为指定按升序创建索引，如果你想按降序来创建索引指定为-1即可。聚合 (aggregate)主要用于处理数据(诸如统计平均值,求和等)，并返回计算后的数据结果。有点类似sql语句中的 count(*)。
db.COLLECTION_NAME.aggregate(AGGREGATE_OPERATION)eg:
db.mycol.aggregate([{$group : {_id : "$by_user", num_tutorial : {$sum : 1}}}]) ===>SQL select by_user as _id, count(*) as num_tutorial from mycol group by by_user
2. node链接操作mongoDB
- npm install mongodb
插入数据
var MongoClient = require('mongodb').MongoClient;
var DB_CONN_STR = 'mongodb://localhost:27017/elm'; # 数据库为 elm
var insertData = function(db, callback) {
//连接到表 site
var collection = db.collection('site');
//插入数据
var data = [{"name":"222","url":"www.222.com"},{"name":"333","url":"www.333.com"}];
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();
});
});
查找数据库
var MongoClient = require('mongodb').MongoClient;
var DB_CONN_STR = 'mongodb://localhost:27017/elm';
var selectData = function(db, callback) {
//连接到表
var collection = db.collection('site');
//查询数据
var whereStr = {"name":'wm'};
collection.find(whereStr).toArray(function(err, result) {
if(err)
{
console.log('Error:'+ err);
return;
}
callback(result);
});
}
MongoClient.connect(DB_CONN_STR, function(err, db) {
console.log("连接成功！");
selectData(db, function(result) {
console.log(result);
db.close();
});
});
更新数据
var MongoClient = require('mongodb').MongoClient;
var DB_CONN_STR = 'mongodb://localhost:27017/elm';
var updateData = function(db, callback) {
//连接到表
var collection = db.collection('site');
//更新数据
var whereStr = {"name":'elm'};
var updateStr = {$set: { "url" : "https://www.elm.com" }};
collection.update(whereStr,updateStr, 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();
});
});
删除数据
var MongoClient = require('mongodb').MongoClient;
var DB_CONN_STR = 'mongodb://localhost:27017/runoob';
var delData = function(db, callback) {
//连接到表
var collection = db.collection('site');
//删除数据
var whereStr = {"name":'elm'};
collection.remove(whereStr, function(err, result) {
if(err)
{
console.log('Error:'+ err);
return;
}
callback(result);
});
}
MongoClient.connect(DB_CONN_STR, function(err, db) {
console.log("连接成功！");
delData(db, function(result) {
console.log(result);
db.close();
});
});
3. mongoose
一般我们不直接用MongoDB的函数来操作MongoDB数据库 Mongose就是一套操作MongoDB数据库的接口.
Schema
一种以文件形式存储的数据库模型骨架，无法直接通往数据库端，也就是说它不具备对数据库的操作能力.可以说是数据属性模型(传统意义的表结构)，又或着是“集合”的模型骨架
/* 定义一个 Schema */
var mongoose = require("mongoose");
var TestSchema = new mongoose.Schema({
name : { type:String },//属性name,类型为String
age : { type:Number, default:0 },//属性age,类型为Number,默认为0
time : { type:Date, default:Date.now },
email: { type:String,default:''}
});
上面这个 TestSchema包含4个属性 [name, age, time, email]
Model
由Schema构造生成的模型，除了Schema定义的数据库骨架以外，还具有数据库操作的行为，类似于管理数据库属性、行为的类
var db = mongoose.connect("mongodb://127.0.0.1:27017/test");
// 创建Model
var TestModel = db.model("test1", TestSchema);
test1 数据库中的集合名称, 不存在会创建.
Entity
由Model创建的实体，使用save方法保存数据，Model和Entity都有能影响数据库的操作，但Model比Entity更具操作性
var TestEntity = new TestModel({
name : "Lenka",
age : 36,
email: "lenka@qq.com"
});
console.log(TestEntity.name); // Lenka
console.log(TestEntity.age); // 36
游标
MongoDB 使用游标返回find的执行结果.客户端对游标的实现通常能够对最终结果进行有效的控制。可以限制结果的数量，略过部分结果，根据任意键按任意顺序的组合对结果进行各种排序，或者是执行其他一些强的操作。
ObjectId
存储在mongodb集合中的每个文档（document）都有一个默认的主键_id，这个主键名称是固定的，它可以是mongodb支持的任何数据类型，默认是ObjectId。
ObjectId是一个12字节的 BSON 类型字符串。按照字节顺序，依次代表：
- 4字节：UNIX时间戳
- 3字节：表示运行MongoDB的机器
- 2字节：表示生成此_id的进程
- 3字节：由一个随机数开始的计数器生成的值
Node.js 中
package.json 中加入"mongoose": “*” 字段.npm install 安装依赖.
var mongoose = require("mongoose");
var db = mongoose.connect("mongodb://localhost:27017/test");
然后引用
====API====
var mongoose = require("mongoose");
var db = mongoose.connect("mongodb://localhost:27017/test");
db - 数据库操作
挂接数据库连接事件,参数1: 也可以是error
db.connection.on(‘open’, callback);
Schema - 表结构
构造函数
new mongoose.Schema( { name:{type:String}, age:{type:Number, default:10} } )
2.添加属性
Schema.add( { name: ‘String’, email: ‘String’, age: ‘Number’ } )
3.有时候Schema不仅要为后面的Model和Entity提供公共的属性，还要提供公共的方法
Schema.method( ‘say’, function(){console.log(‘hello’);} )
//这样Model和Entity的实例就能使用这个方法了
4.添加静态方法
Schema.static( ‘say’, function(){console.log(‘hello’);} )
//静态方法，只限于在Model层就能使用
5.追加方法
Schema.methods.say = function(){console.log(‘hello’);};
//静态方法，只限于在Model层就能使用
model - 文档操作
构造函数, 参数1:集合名称, 参数2:Schema实例
构造函数, 参数1:集合名称, 参数2:Schema实例
2.查询, 参数1忽略,或为空对象则返回所有集合文档
model.find({}, callback);
model.find({},field,callback);
过滤查询,参数2: {‘name’:1, ‘age’:0} 查询文档的返回结果包含name , 不包含age.(_id默认是1)
model.find({},null,{limit:20});
过滤查询,参数3: 游标操作 limit限制返回结果数量为20个,如不足20个则返回所有.
model.findOne({}, callback);
查询找到的第一个文档
model.findById(‘obj._id’, callback);
查询找到的第一个文档,同上. 但是只接受 __id 的值查询
创建, 在集合中创建一个文档
Model.create(文档数据, callback))更新,参数1:查询条件, 参数2:更新对象,可以使用MondoDB的更新修改器
Model.update(conditions, update, function(error)删除, 参数1:查询条件
Model.remove(conditions,callback);
Entity - 文档操作
构造函数, 其实就是model的实例
new TestModel( { name:‘xueyou’, age:21 } );创建, 在集合中创建一个文档.
Entity.save(callback);
修改器和更新器
更新修改器:
‘$inc’ 增减修改器,只对数字有效.下面的实例: 找到 age=22的文档,修改文档的age值自增1
Model.update({‘age’:22}, {’$inc’:{‘age’:1} } ); 执行后: age=23‘$set’ 指定一个键的值,这个键不存在就创建它.可以是任何MondoDB支持的类型.
Model.update({‘age’:22}, {’$set’:{‘age’:‘haha’} } ); 执行后: age=‘haha’‘$unset’ 同上取反,删除一个键
Model.update({‘age’:22}, {’$unset’:{‘age’:‘haha’} } ); 执行后: age键不存在
数组修改器:
‘$push’ 给一个键push一个数组成员,键不存在会创建
Model.update({‘age’:22}, {’$push’:{‘array’:10} } ); 执行后: 增加一个 array 键,类型为数组, 有一个成员 10‘$addToSet’ 向数组中添加一个元素,如果存在就不添加
Model.update({‘age’:22}, {’$addToSet’:{‘array’:10} } ); 执行后: array中有10所以不会添加‘$each’ 遍历数组, 和 $push 修改器配合可以插入多个值
Model.update({‘age’:22}, {’$push’:{‘array’:{’$each’: [1,2,3,4,5]}} } ); 执行后: array : [10,1,2,3,4,5]‘$pop’ 向数组中尾部删除一个元素
Model.update({‘age’:22}, {’$pop’:{‘array’:1} } ); 执行后: array : [10,1,2,3,4] tips: 将1改成-1可以删除数组首部元素‘$pull’ 向数组中删除指定元素
Model.update({‘age’:22}, {’$pull’:{‘array’:10} } ); 执行后: array : [1,2,3,4] 匹配到array中的10后将其删除
条件查询:
$gt -------- greater than >
$gte --------- gt equal >=
$lt -------- less than <
$lte --------- lt equal <=
$ne ----------- not equal !=
$eq -------- equal =
Model.find({“age”:{ “$get”:18 , “$lte”:30 } } ); 查询 age 大于等于18并小于等于30的文档
或查询OR:
‘$in’ 一个键对应多个值
‘$nin’ 同上取反, 一个键不对应指定值
“$or” 多个条件匹配, 可以嵌套 $in 使用
“$not” 同上取反, 查询与特定模式不匹配的文档
Model.find({“age”:{ “$in”:[20,21,22,‘a’]} } ); 查询 age等于20或21或21或a的文档
Model.find({"$or" : [ {‘age’:18} , {‘name’:‘xueyou’} ] }); 查询 age等于18 或 name等于’xueyou’ 的文档
类型查询:
null 能匹配自身和不存在的值, 想要匹配键的值 为null, 就要通过 “$exists” 条件判定键值已经存在 "$exists" (表示是否存在的意思)
Model.find(“age” : { “$in” : [null] , “exists” : true } );
查询 age值为null的文档
Model.find({name: {$exists: true}},function(error,docs){
//查询所有存在name属性的文档
});
Model.find({telephone: {$exists: false}},function(error,docs){
//查询所有不存在telephone属性的文档
});
正则表达式:
MongoDb 使用 Prel兼容的正则表达式库来匹配正则表达式
find( {“name” : /joe/i } )
查询name为 joe 的文档, 并忽略大小写
find( {“name” : /joe?/i } )
查询匹配各种大小写组合
查询数组:
‘$all’ 匹配数组中多个元素
Model.find({“array”:[5,10]} ); 查询 匹配array数组中 既有5又有10的文档‘$size’ 匹配数组长度
Model.find({“array”:{"$size" : 3} } ); 查询 匹配array数组长度为3 的文档‘$slice’ 查询子集合返回
Model.find({“array”:{"$slice" : 10} } ); 查询 匹配array数组的前10个元素 Model.find({“array”:{"$slice" : [5,10] } } ); 查询 匹配array数组的第5个到第10个元素 Model.find({“array”:10} ); 查询 array(数组类型)键中有10的文档, array : [1,2,3,4,5,10] 会匹配到 Model.find({“array[5]”:10} ); 查询 array(数组类型)键中下标5对应的值是10, array : [1,2,3,4,5,10] 会匹配到
where
用它可以执行任意javacript语句作为查询的一部分,如果回调函数返回 true 文档就作为结果的一部分返回
find({"$where" : function(){
for( var x in this ){
//这个函数中的 this 就是文档
}
if(this.x !== null && this.y !== null){
return this.x + this.y === 10 ? true : false;
}else{
return true;
}
} } )
简化版本
find( {"$where" : "this.x + this.y === 10" } )
find( {"$where" : " function(){ return this.x + this.y ===10; } " } )