Sambung ke pangkalan data
var mongo=require("mongodb");
var host="localhost";
var port=mongo.Connection.DEFAULT_PORT;
var server=new mongo.Server(host,port,{auto_reconnect:true});//Buat pelayan pelayan di mana pangkalan data terletak
var db=new mongo.Db("node-mongo-examples",server,{safe:true});//Cipta objek pangkalan data
db.open(function (err,db) {//Sambung ke pangkalan data
Jika(err)
silap buang;
lain{
console.log("Sambungan pangkalan data berjaya diwujudkan");
db.close();
}
});
db.on("close", function (err,db) {//Tutup pangkalan data
If(err) throw err;
else console.log("Pangkalan data berjaya ditutup.");
});
Sisipkan data:
Selepas memasukkan data, keluarkan kandungan dokumen data dalam konsol
var mongo=require("mongodb");
var host="localhost";
var port=mongo.Connection.DEFAULT_PORT;
var server=new mongo.Server(host,port,{auto_reconnect:true});//Buat pelayan pelayan di mana pangkalan data terletak
var db=new mongo.Db("node-mongo-examples",server,{safe:true});//Cipta objek pangkalan data
db.open(function (err,db) {//Sambung ke pangkalan data
Jika(err)
silap buang;
lain{
db.collection("pengguna", fungsi (err,collection) {
collection.insert({username:"Panpan", firstname:"李"}, function (err,docs) {
console.log(docs);
db.close();
});
});
}
});
db.on("close", function (err,db) {//Tutup pangkalan data
If(err) throw err;
else console.log("Pangkalan data berjaya ditutup.");
});
Tutup pangkalan datadb.close([forceClose],[callback]);
Apabila forceClose adalah benar, pangkalan data ditutup secara paksa Selepas pangkalan data ditutup, open tidak boleh digunakan untuk membuka pangkalan data.
Apabila forceClose palsu, pangkalan data tidak dipaksa untuk ditutup Apabila pangkalan data ditutup, ia boleh dibuka semula menggunakan open.
Apabila foreClose adalah benar:
Salin kod Kod adalah seperti berikut:
var mongo=require("mongodb");
var host="localhost";
var port=mongo.Connection.DEFAULT_PORT;
var server=new mongo.Server(host,port,{auto_reconnect:true});//Buat pelayan pelayan di mana pangkalan data terletak
var db=new mongo.Db("node-mongo-examples",server,{safe:true});//Cipta objek pangkalan data
db.open(function (err,db) {//Sambung ke pangkalan data
Jika(err)
silap buang;
lain{
db.collection("pengguna", fungsi (err,collection) {
collection.insert({username:"Panpan", firstname:"李"}, function (err,docs) {
console.log(docs);
db.close(false);
});
});
}
});
db.once("close", function (err,db) {//Tutup pangkalan data
If(err) throw err;
lain {
db.open(fungsi (err,db) {
db.collection("pengguna", fungsi (err,koleksi) {
collection.insert({username:"三", firstname:"张"}, function (err,docs) {
If(err) throw err;
lain{
console.log(docs);
db.close(true);
}
})
});
});
}
});
//Baca data
var mongo=require("mongodb");
var host="localhost";
var port=mongo.Connection.DEFAULT_PORT;
var server=mongo.Server(host,port,{auto_reconnect:true});
var db=new mongo.Db("node-mongo-examples",pelayan,{safe:true});
db.open(fungsi (err,db) {
db.collection("pengguna", fungsi (err,collection) {
If(err) throw err;
lain{
collection.find({}).toArray(function(err,docs){
If(err) throw err;
lain{
console.log(docs);
db.close();
}
});
}
});
});
//Cari dengan syarat pertanyaan
var mongo=require("mongodb");
var host="localhost";
var port=mongo.Connection.DEFAULT_PORT;
var server=mongo.Server(host,port,{auto_reconnect:true});
var db=new mongo.Db("node-mongo-examples",pelayan,{safe:true});
db.open(fungsi (err,db) {
db.collection("pengguna", fungsi (err,collection) {
If(err) throw err;
lain{
collection.find({nama pengguna:{$in:["Yansi","三"]}}).toArray(function(err,docs){
If(err) throw err;
lain{
console.log(docs);
db.close();
}
});
}
});
});
//Masukkan kumpulan data dan cari jenis==makanan dan nilai medan harga kurang daripada 10
var mongo=require("mongodb");
var host="localhost";
var port=mongo.Connection.DEFAULT_PORT;
var server=mongo.Server(host,port,{auto_reconnect:true});
var db=new mongo.Db("node-mongo-examples",pelayan,{safe:true});
var docs=[
{type:"food",price:11},
{type:"food",price:10},
{type:"food",price:9},
{type:"food",price:8},
{type:"book",price:9}
];
db.open(fungsi (err,db) {
db.collection("barang", fungsi (err,collection) {
If(err) throw err;
lain{
collection.insert(docs, function (err,docs) {
If(err) throw err;
lain{
koleksi. find({type:"food",price:{$lt:10}}).toArray(
function(err,docs){
If(err) throw err;
Sejak
console.log(docs);
);
}
})
}
});
});
Ungkapan atau dalam pertanyaan
:
Salin kod