}
console.log(data);
res.send('删除数据成功');
db.close();
})
})
})
app.get('/query',function(req,res){
MongoClient.connect(DBurl,function(err,db){
if(err){
console.log('连接数据库失败');
return;
}
//查询数据
var list=[]; /*放数据库里面查询的所有数据*/
var result=db.collection('user').find({});
result.each(function(error,doc){
//console.log(doc);
if(error){
console.log(error);
}else{
if(doc!=null){
list.push(doc);
}else{ /*doc==null表示数据循环完成*/
/*获取数据以后*/
//console.log(list);
ejs.renderFile('views/index.ejs',{list:list},function(err,data){
res.send(data);
})
}
}
})
//console.log(result);
})
})
插入数据
/**
* 插入单条数据
* @param table_name 表名
* @param insertData 插入的数据
* @param callback 回调方法
*/
MongoDbAction.insertData= function (table_name, insertData , callback) {
var node_model = this.getConnection(table_name);
node_model.insertOne(insertData , function (err, res) {
if (err) {
callback(err);
} else {
callback(null, res);
}
});
};查询数据
/**
* 查询单条数据
* @param table_name 表名
* @param conditions 查询条件
* @param callback 回调方法
*/
MongoDbAction.findOne = function (table_name, conditions, callback) {
var node_model = this.getConnection(table_name);
node_model.findOne(conditions, function (err, res) {
if (err) {
callback(err);
} else {
callback(null, res);
}
});
};更新数据
/**
* 更新单条数据
* @param table_name 表名
* @param conditions 查询条件 {"name":'jackson影琪'};
* @param updateStr 更新数据 {$set: { "url" : "https://www.cnblogs.com/jackson-zhangjiang" }};
* @param callback 回调方法
*/
MongoDbAction.updateOne= function (table_name, conditions，updateStr , callback) {
var node_model = this.getConnection(table_name);
node_model.updateOne(conditions，updateStr, function (err, res) {
if (err) {
callback(err);
} else {
callback(null, res);
}
});
};以上就是本次介绍的全部相关知识点，感谢大家的学习。如果有任何补充，可以联系小编。
