Node.js
몽고 (Mongodb) 통합
수색…
통사론
- db. collection .insertOne ( document , options (w, wtimeout, j, serializeFuntions, forceServerObjectId, bypassDocumentValidation) , 콜백 )
- db. 컬렉션 .insertMany ( [documents] , options (w, wtimeout, j, serializeFuntions, forceServerObjectId, bypassDocumentValidation) , 콜백 )
- db. collection .find ( query )
- db. collection .updateOne ( 필터 , 업데이트 , 옵션 (upsert, w, wtimeout, j, bypassDocumentValidation) , 콜백 )
- db. collection .updateMany ( 필터 , 업데이트 , 옵션 (upsert, w, wtimeout, j) , 콜백 )
- db. collection .deleteOne ( 필터 , 옵션 (upsert, w, wtimeout, j) , 콜백 )
- db. collection .deleteMany ( 필터 , 옵션 (upsert, w, wtimeout, j) , 콜백 )
매개 변수
매개 변수 | 세부 |
---|---|
문서 | 문서를 나타내는 자바 스크립트 객체 |
서류 | 문서 배열 |
질문 | 검색 쿼리를 정의하는 객체 |
필터 | 검색 쿼리를 정의하는 객체 |
콜백 | 조작 완료시에 불려가는 기능 |
옵션들 | (선택 사항) 선택적 설정 (기본값 : null) |
w | (선택 사항) 쓰기 문제 |
wtimeout | (선택 사항) 쓰기 관련 제한 시간. (기본값 : null) |
j | (선택 사항) 저널 쓰기 문제 지정 (기본값 : false) |
업 서트 | (선택 사항) 업데이트 작업 (기본값 : false) |
멀티 | (선택 사항) 하나 또는 모든 문서 업데이트 (기본값 : false) |
serializeFunctions | (선택 사항) 모든 객체에서 함수 직렬화 (기본값 : false) |
forceServerObjectId | (선택 사항) 서버가 드라이버 대신 _id 값을 할당하도록합니다 (기본값 : false) |
bypassDocumentValidation | (선택 사항) 드라이버가 MongoDB 3.2 이상에서 스키마 유효성 검사를 생략하도록 허용합니다 (기본값 : false) |
MongoDB에 연결
MongoDB에 접속하여 'Connected!'를 출력하십시오. 연결을 닫으십시오.
const MongoClient = require('mongodb').MongoClient;
var url = 'mongodb://localhost:27017/test';
MongoClient.connect(url, function(err, db) { // MongoClient method 'connect'
if (err) throw new Error(err);
console.log("Connected!");
db.close(); // Don't forget to close the connection when you are done
});
MongoClient 메소드 Connect()
MongoClient.connect ( url , options , callback )
논의 | 유형 | 기술 |
---|---|---|
url | 끈 | 서버 ip / hostname, port 및 database를 지정하는 문자열 |
options | 목적 | (선택 사항) 선택적 설정 (기본값 : null) |
callback | 기능 | 연결 시도가 끝날 때 호출 할 함수 |
callback
함수는 두 개의 인수를 취합니다.
-
err
: Error - 오류가 발생하면err
인수가 정의됩니다. -
db
: object - MongoDB 인스턴스
문서 삽입
'myFirstDocument'라는 문서를 삽입하고 2 개의 속성, greetings
및 farewell
const MongoClient = require('mongodb').MongoClient;
const url = 'mongodb://localhost:27017/test';
MongoClient.connect(url, function (err, db) {
if (err) throw new Error(err);
db.collection('myCollection').insertOne({ // Insert method 'insertOne'
"myFirstDocument": {
"greetings": "Hellu",
"farewell": "Bye"
}
}, function (err, result) {
if (err) throw new Error(err);
console.log("Inserted a document into the myCollection collection!");
db.close(); // Don't forget to close the connection when you are done
});
});
콜렉션 메소드 insertOne()
db.collection ( 컬렉션 ) .insertOne ( document , options , callback )
논의 | 유형 | 기술 |
---|---|---|
collection | 끈 | 컬렉션을 지정하는 문자열 |
document | 목적 | 컬렉션에 삽입 할 문서 |
options | 목적 | (선택 사항) 선택적 설정 (기본값 : null) |
callback | 기능 | 삽입 작업이 완료 될 때 호출되는 함수 |
callback
함수는 두 개의 인수를 취합니다.
-
err
: Error - 오류가 발생하면err
인수가 정의됩니다. -
result
: object - 삽입 조작에 관한 상세를 포함한 object입니다.
컬렉션 읽기
컬렉션 'myCollection'에있는 모든 문서를 가져 와서 콘솔에 출력하십시오.
const MongoClient = require('mongodb').MongoClient;
const url = 'mongodb://localhost:27017/test';
MongoClient.connect(url, function (err, db) {
if (err) throw new Error(err);
var cursor = db.collection('myCollection').find(); // Read method 'find'
cursor.each(function (err, doc) {
if (err) throw new Error(err);
if (doc != null) {
console.log(doc); // Print all documents
} else {
db.close(); // Don't forget to close the connection when you are done
}
});
});
컬렉션 메서드 find()
db.collection ( collection ) .find ()
논의 | 유형 | 기술 |
---|---|---|
collection | 끈 | 컬렉션을 지정하는 문자열 |
문서 업데이트
{ greetings: 'Hellu' }
속성을 가진 문서를 찾아 { greetings: 'Whut?' }
변경하십시오 { greetings: 'Whut?' }
const MongoClient = require('mongodb').MongoClient;
const url = 'mongodb://localhost:27017/test';
MongoClient.connect(url, function (err, db) {
if (err) throw new Error(err);
db.collection('myCollection').updateOne({ // Update method 'updateOne'
greetings: "Hellu" },
{ $set: { greetings: "Whut?" }},
function (err, result) {
if (err) throw new Error(err);
db.close(); // Don't forget to close the connection when you are done
});
});
컬렉션 메서드 updateOne()
db.collection ( collection ) .updateOne ( 필터 , 업데이트 , 옵션 , 콜백 )
매개 변수 | 유형 | 기술 |
---|---|---|
filter | 목적 | 선택 기준을 지정합니다. |
update | 목적 | 적용 할 수정 사항을 지정합니다. |
options | 목적 | (선택 사항) 선택적 설정 (기본값 : null) |
callback | 기능 | 조작 완료시에 불려가는 기능 |
callback
함수는 두 개의 인수를 취합니다.
-
err
: Error - 오류가 발생하면 err 인수가 정의됩니다. -
db
: object - MongoDB 인스턴스
문서 삭제
{ greetings: 'Whut?' }
속성을 가진 문서를 삭제하십시오 { greetings: 'Whut?' }
const MongoClient = require('mongodb').MongoClient;
const url = 'mongodb://localhost:27017/test';
MongoClient.connect(url, function (err, db) {
if (err) throw new Error(err);
db.collection('myCollection').deleteOne(// Delete method 'deleteOne'
{ greetings: "Whut?" },
function (err, result) {
if (err) throw new Error(err);
db.close(); // Don't forget to close the connection when you are done
});
});
컬렉션 메서드 deleteOne()
db.collection ( collection ) .deleteOne ( 필터 , 옵션 , 콜백 )
매개 변수 | 유형 | 기술 |
---|---|---|
filter | 목적 | 선택 기준을 명시한 문서 |
options | 목적 | (선택 사항) 선택적 설정 (기본값 : null) |
callback | 기능 | 조작 완료시에 불려가는 기능 |
callback
함수는 두 개의 인수를 취합니다.
-
err
: Error - 오류가 발생하면 err 인수가 정의됩니다. -
db
: object - MongoDB 인스턴스
여러 문서 삭제
'farewell'속성이 'okay'로 설정된 모든 문서를 삭제하십시오.
const MongoClient = require('mongodb').MongoClient;
const url = 'mongodb://localhost:27017/test';
MongoClient.connect(url, function (err, db) {
if (err) throw new Error(err);
db.collection('myCollection').deleteMany(// MongoDB delete method 'deleteMany'
{ farewell: "okay" }, // Delete ALL documents with the property 'farewell: okay'
function (err, result) {
if (err) throw new Error(err);
db.close(); // Don't forget to close the connection when you are done
});
});
컬렉션 메서드 deleteMany()
db.collection ( 컬렉션 ) .deleteMany ( 필터 , 옵션 , 콜백 )
매개 변수 | 유형 | 기술 |
---|---|---|
filter | 문서 | 선택 기준을 명시한 문서 |
options | 목적 | (선택 사항) 선택적 설정 (기본값 : null) |
callback | 기능 | 조작 완료시에 불려가는 기능 |
callback
함수는 두 개의 인수를 취합니다.
-
err
: Error - 오류가 발생하면 err 인수가 정의됩니다. -
db
: object - MongoDB 인스턴스
단순 연결
MongoDB.connect('mongodb://localhost:27017/databaseName', function(error, database) { if(error) return console.log(error); const collection = database.collection('collectionName'); collection.insert({key: 'value'}, function(error, result) { console.log(error, result); }); });
단순한 연결, 약속 사용
const MongoDB = require('mongodb');
MongoDB.connect('mongodb://localhost:27017/databaseName')
.then(function(database) {
const collection = database.collection('collectionName');
return collection.insert({key: 'value'});
})
.then(function(result) {
console.log(result);
});
```