node連線mongodb資料庫
阿新 • • 發佈:2018-12-28
第一種方法:
var mongodb = require("mongodb") var server = new mongodb.Server('localhost',27017,{auto_reconnect:true}) var db = new mongodb.Db('zz1805',server,{safe:true}) //var obj = {"name":"xuxu","age":20} db.open((err,database)=>{ database.collection('user',(err,coll)=>{ coll.find({}).toArray((err,data)=>{ console.log(data) database.close() }) // coll.save(obj,(err,data)=>{ // console.log(err); // }) // coll.deleteOne({"name":"xuxu"},()=>{ // console.log("success") // }) // coll.update({"name":"xiaohua"},{$set:{"name":"6666"}},()=>{ // console.log("success") // }) }) })
第二種方法:在這種依賴mongodb模組的時候指定版本@2
var mongodb=require('mongodb').MongoClient; var db_str="mongodb://localhost:27017/資料庫名" mongodb.connect(db_str,(err,database)=>{ database.collection('user',(err,coll)=>{ obj["username"] = req.body.username; coll.find(obj).toArray((err,data)=>{ data1 = data; }) if(data1.length){ res.send("0") }else{ coll.insertOne(req.body,()=>{ res.send('1') database.close(); }) } }) })