>  기사  >  웹 프론트엔드  >  node.js 작업 mongoDB 데이터베이스 예제 Sharing_node.js

node.js 작업 mongoDB 데이터베이스 예제 Sharing_node.js

WBOY
WBOY원래의
2016-05-16 16:30:051925검색

데이터베이스에 연결

코드 복사 코드는 다음과 같습니다.

var mongo=require("mongodb");
var 호스트="localhost";
var 포트=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) {//데이터베이스에 연결
만약(err)
           오류를 던졌습니다.
       그 외{
console.log("데이터베이스 연결이 성공적으로 이루어졌습니다.");
          db.close();
}
});
db.on("close", function (err,db) {//데이터베이스 닫기
If(err) throw err;
         else console.log("데이터베이스가 성공적으로 닫혔습니다.");
});

데이터 삽입:

데이터 삽입 후 데이터 문서의 내용을 콘솔에 출력

코드 복사 코드는 다음과 같습니다.

var mongo=require("mongodb");
var 호스트="localhost";
var 포트=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) {//데이터베이스에 연결
만약(err)
           오류를 던졌습니다.
       그 외{
           db.collection("users", function (err,collection) {
               collection.insert({사용자 이름:"Panpan", 이름:"이"}, 함수(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 호스트="localhost";
var 포트=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) {//데이터베이스에 연결
만약(err)
           오류를 던졌습니다.
       그 외{
           db.collection("users", function (err,collection) {
               collection.insert({사용자 이름:"Panpan", 이름:"이"}, 함수(err,docs) {
console.log(docs);
                db.close(false);
             });
          });
}
});
db.once("close", function (err,db) {//데이터베이스 닫기
If(err) throw err;
       그 외 {
        db.open(함수 (err,db) {
            db.collection("users", function (err,collection) {
                   collection.insert({사용자 이름:"三", 이름:"张"}, 함수(err,docs) {
If(err) throw err;
                     그 외{
console.log(docs);
>                     }
                  })
             });
          });
}
});

//

데이터 읽기

코드 복사 코드는 다음과 같습니다.
var mongo=require("mongodb");
var 호스트="localhost";
var 포트=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("사용자", 함수 (err,collection) {
If(err) throw err;
        그 외{
               collection.find({}).toArray(function(err,docs){
If(err) throw err;
                 그 외{
console.log(docs);
                    db.close();
                }
            });
}
});
});

//쿼리조건으로 검색

코드 복사 코드는 다음과 같습니다.

var mongo=require("mongodb");
var 호스트="localhost";
var 포트=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("사용자", 함수 (err,collection) {
If(err) throw err;
        그 외{
              collection.find({사용자 이름:{$in:["Yansi","三"]}}).toArray(function(err,docs){
If(err) throw err;
                 그 외{
console.log(docs);
                    db.close();
                }
            });
}
});
});

//일괄 데이터를 삽입하고 type==food를 검색하고 가격 필드 값이 10보다 작습니다

코드 복사 코드는 다음과 같습니다.

var mongo=require("mongodb");
var 호스트="localhost";
var 포트=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("상품", 함수 (err,collection) {
If(err) throw err;
        그 외{
               collection.insert(docs, function (err,docs) {
If(err) throw err;
                 그 외{
                            collection.find({type:"food",price:{$lt:10}}).toArray(
함수(err,docs){
If(err) throw err;
부터 console.log(docs);
>                                                      | | );
                }
             })
}
});
});




or in query의 표현
:

코드 복사

성명:
본 글의 내용은 네티즌들의 자발적인 기여로 작성되었으며, 저작권은 원저작자에게 있습니다. 본 사이트는 이에 상응하는 법적 책임을 지지 않습니다. 표절이나 침해가 의심되는 콘텐츠를 발견한 경우 admin@php.cn으로 문의하세요.