MySQL与MongoDB都是开源的常用数据库,但是MySQL是传统的关系型数据库,MongoDB则是非关系型数据库,也叫文档型数据库,是一种NoSQL的数据库。它们各有各的优点,关键是看用在什么地方。所以我们所熟知的那些SQL(全称Structured Query Language)语句就不适用于MongoDB了,因为SQL语句是关系型数据库的标准语言。
MongoDB:
创建库——无需单独创建,直接use进去
创建表——无需单独创建,直接插入数据
删除表——db.tname.drop()
删除库——首先进去该库,db.dropDatabase()
插入记录——db.tname.insert({id:2})
删除记录——db.tname.remove({id:2})
修改/更新记录——db.tname.update({id:2},$set:{id:3}},false,true)
查询所有记录——db.tname.find()
查询所有列——db.tname.find({},{id:1})
条件查询——db.tname.find({id:2})
下面是mongoDB封装的基本操作:
//引入mongo客户端
var MongoClient = require("mongodb").MongoClient;
//创建对象
var mongoCtl = function(){};
//连接数据库
mongoCtl.prototype = {
//数据库地址
url:"mongodb://localhost:27017",
//连接数据库
/*!!!! 每次操作数据库前 先连接数据库 操作完成 关闭数据库 !!!!*/
/*
callback 连接成功后执行 能保证获取到数据库db
*/
connect:function(callback){
//连接数据库
MongoClient.connect(this.url, function(err, db){
if(err){
console.log("连接失败!");
return;
}
console.log("连接成功!");
callback(db)
});
},
/*关闭数据库*/
close:function(){
mongoCtl.db.close()
},
//插入数据
insert:function(name,data,callback){
//先连接数据库
var self = this;
self.connect(function(db){
console.log("haha");
//连接到表 site
var collection = db.collection(name);
//插入
collection.insert(data, function(err, result) {
if(err)
{
console.log('Error:'+ err);
return;
}
callback(result);
//关闭数据库
self.close();
});
})
},
//删除
/*
name 表名
data 删除的数据
callback 删除成功后的回调
*/
del:function(name,data,callback){
var self = this;
//先连接数据库
self.connect(function(db){
//链接到表
var collection = db.collection(name);
//要删除的数据
//执行删除
collection.remove(data,function(err,result){
if(err)
{
console.log('Error:'+ err);
return;
}
callback(result);
//关闭数据库
self.close()
})
})
},
//更新数据
updata:function(name,updata,data,callback){
var self = this;
self.connect(function(db){
var collection = db.collection(name);
//要更新的数据
//执行更新
collection.update(updata,data,function(err,result){
if(err)
{
console.log('Error:'+ err);
return;
}
callback(result);
//关闭数据库
self.close()
})
})
},
//查询
sel:function(name,updata,data,callback){
var self = this;
//先连接数据库
self.connect(function(db){
//链接到表
var collection = db.collection(name);
collection.slelect(updata,data,function(err,result){
if(err)
{
console.log('Error:'+ err);
return;
}
callback(result);
//关闭数据库
self.close()
})
})
}
}
//将数据库操作对象导出
module.exports = mongoCtl;