Mit Datenbank verbinden
var mongo=require("mongodb");
var host="localhost";
var port=mongo.Connection.DEFAULT_PORT;
var server=new mongo.Server(host,port,{auto_reconnect:true});//Erstellen Sie den Server, auf dem sich die Datenbank befindet
var db=new mongo.Db("node-mongo-examples",server,{safe:true});//Datenbankobjekt erstellen
db.open(function (err,db) {//Mit Datenbank verbinden
Wenn(irr)
throw err;
sonst{
console.log("Datenbankverbindung erfolgreich hergestellt");
db.close();
}
});
db.on("close", function (err,db) {//Schließen Sie die Datenbank
If(err) throw err;
else console.log("Datenbank erfolgreich geschlossen.");
});
Daten einfügen:
Nach dem Einfügen der Daten geben Sie den Inhalt des Datendokuments in der Konsole aus
var mongo=require("mongodb");
var host="localhost";
var port=mongo.Connection.DEFAULT_PORT;
var server=new mongo.Server(host,port,{auto_reconnect:true});//Erstellen Sie den Server, auf dem sich die Datenbank befindet
var db=new mongo.Db("node-mongo-examples",server,{safe:true});//Datenbankobjekt erstellen
db.open(function (err,db) {//Mit Datenbank verbinden
Wenn(irr)
throw err;
sonst{
db.collection("users", function (err,collection) {
collection.insert({username:"Panpan", firstname:"李"}, function (err,docs) {
console.log(docs);
db.close();
});
});
}
});
db.on("close", function (err,db) {//Schließen Sie die Datenbank
If(err) throw err;
else console.log("Datenbank erfolgreich geschlossen.");
});
Schließen Sie die Datenbankdb.close([forceClose],[callback]);
Wenn „forceClose“ wahr ist, wird die Datenbank zwangsweise geschlossen. Nachdem die Datenbank geschlossen wurde, kann „open“ nicht zum Öffnen der Datenbank verwendet werden.
Wenn „forceClose“ den Wert „false“ hat, wird das Schließen der Datenbank nicht erzwungen. Wenn die Datenbank geschlossen wird, kann sie mit „open“ erneut geöffnet werden.
Wenn foreClose wahr ist:
Code kopieren Der Code lautet wie folgt:
var mongo=require("mongodb");
var host="localhost";
var port=mongo.Connection.DEFAULT_PORT;
var server=new mongo.Server(host,port,{auto_reconnect:true});//Erstellen Sie den Server, auf dem sich die Datenbank befindet
var db=new mongo.Db("node-mongo-examples",server,{safe:true});//Datenbankobjekt erstellen
db.open(function (err,db) {//Mit Datenbank verbinden
Wenn(irr)
throw err;
sonst{
db.collection("users", function (err,collection) {
collection.insert({username:"Panpan", firstname:"李"}, function (err,docs) {
console.log(docs);
db.close(false);
});
});
}
});
db.once("close", function (err,db) {//Datenbank schließen
If(err) throw err;
sonst {
db.open(function (err,db) {
db.collection("users", function (err,collection) {
collection.insert({username:"三", firstname:"张"}, function (err,docs) {
If(err) throw err;
sonst{
console.log(docs);
db.close(true);
}
})
});
});
}
});
//Daten lesen
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",server,{safe:true});
db.open(function (err,db) {
db.collection("users", function (err,collection) {
If(err) throw err;
sonst{
collection.find({}).toArray(function(err,docs){
If(err) throw err;
sonst{
console.log(docs);
db.close();
}
});
}
});
});
//Suche mit Abfragebedingungen
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",server,{safe:true});
db.open(function (err,db) {
db.collection("users", function (err,collection) {
If(err) throw err;
sonst{
collection.find({username:{$in:["Yansi","三"]}}).toArray(function(err,docs){
If(err) throw err;
sonst{
console.log(docs);
db.close();
}
});
}
});
});
//Fügen Sie einen Datenstapel ein und suchen Sie nach „type==food“ und der Feldwert „Preis“ ist kleiner als 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",server,{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(function (err,db) {
db.collection("goods", function (err,collection) {
If(err) throw err;
sonst{
collection.insert(docs, function (err,docs) {
If(err) throw err;
sonst{
collection.find({type:"food",price:{$lt:10}}).toArray(
function(err,docs){
If(err) throw err;
Seit
console.log(docs);
}
}
);
}
})
}
});
});
Der Ausdruck von oder in der Abfrage
:
Code kopieren