데이터베이스에 연결
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의 표현
:
코드 복사
![[웹 프런트엔드] Node.js 빠른 시작](https://img.php.cn/upload/course/000/000/067/662b5d34ba7c0227.png)
