データベースに接続します
var mongo=require("mongodb");
var host="localhost";
var port=mongo.Connection.DEFAULT_PORT;
var server=new mongo.Server(host,port,{auto_reconnect:true});//データベースが配置されているサーバーサーバーを作成します
var db=new mongo.Db("node-mongo-examples",server,{safe:true});//データベースオブジェクトを作成します
db.open(function (err,db) {//データベースに接続します
もし(エラー)
エラーを投げます;
else{
console.log("データベース接続が正常に確立されました");
db.close();
}
});
db.on("close", function (err,db) {//データベースを閉じます
If(err) throw err;
else console.log("データベースは正常に閉じられました。");
});
データを挿入:
データを挿入した後、データドキュメントの内容をコンソールに出力します
var mongo=require("mongodb");
var host="localhost";
var port=mongo.Connection.DEFAULT_PORT;
var server=new mongo.Server(host,port,{auto_reconnect:true});//データベースが配置されているサーバーサーバーを作成します
var db=new mongo.Db("node-mongo-examples",server,{safe:true});//データベースオブジェクトを作成します
db.open(function (err,db) {//データベースに接続します
もし(エラー)
エラーを投げます;
else{
db.collection("users", function (err,collection) {
collection.insert({ユーザー名:"Panpan", 名:"李"}, function (err,docs) {
console.log(docs);
db.close();
});
});
}
});
db.on("close", function (err,db) {//データベースを閉じます
If(err) throw err;
else console.log("データベースは正常に閉じられました。");
});
データベースを閉じるdb.close([forceClose],[callback]);
forceClose が true の場合、データベースは強制的に閉じられます。データベースが閉じられた後は、open を使用してデータベースを開くことはできません。
forceClose が false の場合、データベースは強制的に閉じられません。データベースが閉じられた場合、open を使用して再度開くことができます。
foreClose が true の場合:
コードをコピー コードは次のとおりです:
var mongo=require("mongodb");
var host="localhost";
var port=mongo.Connection.DEFAULT_PORT;
var server=new mongo.Server(host,port,{auto_reconnect:true});//データベースが配置されているサーバーサーバーを作成します
var db=new mongo.Db("node-mongo-examples",server,{safe:true});//データベースオブジェクトを作成します
db.open(function (err,db) {//データベースに接続します
もし(エラー)
エラーを投げます;
else{
db.collection("users", function (err,collection) {
collection.insert({ユーザー名:"Panpan", 名:"李"}, function (err,docs) {
console.log(docs);
db.close(false);
});
});
}
});
db.once("close", function (err,db) {//データベースを閉じます
If(err) throw err;
else {
db.open(function (err,db) {
db.collection("users", function (err,collection) {
collection.insert({username:"三", firstname:"张"}, function (err,docs) {
If(err) throw err;
else{
console.log(docs);
db.close(true);
}
})
});
});
}
});
//データの読み取り
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(関数 (err,db) {
db.collection("ユーザー", function (err,collection) {
If(err) throw err;
else{
collection.find({}).toArray(function(err,docs){
If(err) throw err;
その他{
console.log(docs);
db.close();
}
});
}
});
});
//クエリ条件で検索
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(関数 (err,db) {
db.collection("ユーザー", function (err,collection) {
If(err) throw err;
else{
collection.find({username:{$in:["Yansi","三"]}}).toArray(function(err,docs){
If(err) throw err;
その他{
console.log(docs);
db.close();
}
});
}
});
});
//データのバッチを挿入、type==food を検索し、価格フィールドの値が 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=[
{タイプ:"食品"、価格:11}、
{タイプ:"食品"、価格:10}、
{タイプ:"食品"、価格:9}、
{タイプ:"食品"、価格:8}、
{タイプ:"本"、価格:9}
];
db.open(関数 (err,db) {
db.collection("商品", function (err,collection) {
If(err) throw err;
else{
collection.insert(docs, function (err,docs) {
If(err) throw err;
その他{
collection.find({type:"food",price:{$lt:10}}).toArray(
function(err,docs){
If(err) throw err;
以来
console.log(docs);
}
}
);
}
})
}
});
});
クエリ内の or の式
:
コードをコピー