Node.js MongoDB 문서 삽입

이 Node.js 강의에서는 insertOne()와 insertMany() 메서드를 각각 사용하여, 예제를 통해 Node.js 애플리케이션에서 MongoDB 컬렉션에 하나 또는 여러 개의 문서를 삽입하는 방법을 배웁니다.

이제 단계별 가이드를 제공하고, Node.js 애플리케이션에서 문서를 MongoDB 컬렉션에 삽입하는 예제를 제공합니다.

MongoDB 서비스를 시작합니다. MongoDB 서비스를 시작하려면 다음 명령어를 실행합니다

sudo service mongod start

MongoDB 서비스의 기본 URL을 얻습니다. MongoDB 서비스의 기본 URL을 알아보려면, 터미널을 열고 Mongo Shell을 실행하는 것이 간단한 방법입니다.

터미널 - Mongo Shell

arjun@nodejs:~$ mongo
MongoDB 셸 버전 v3.4.9
연결 중: mongodb://127.0.0.1:27017
MongoDB 서버 버전:　3.4.9
서버는 시작 경고가 있습니다:　
2017-10-29T18:15:36.110+0530 I STORAGE [initandlisten]

Mongo Shell이 시작될 때, MongoDB의 기본 URL을 반영합니다.

mongodb://127.0.0.1:27017

전체 URL을 준비합니다. 연결할 데이터베이스 이름(예: newdb)을 기본 URL에 추가합니다.

mongodb://127.0.0.1:27017/newdb

MongoClient을 생성합니다.

var　MongoClient　=　require('mongodb').MongoClient;

URL의 도움으로 MongoClient를 MongoDB 서버에 연결합니다.

MongoClient.connect(url, <callback_function>);

MongoClient의 연결 시도가 완료되면, 콜백 함수는 오류와 db 객체를 파라미터로 받습니다.

연결이 성공하면 db 객체는 newdb 데이터베이스를 가리킵니다.

문서를 지정된 MongoDB 컬렉션에 삽입합니다. Node.js에서 MongoDB 컬렉션에 문서를 삽입하는 insertOne()와 insertMany() 메서드의 문법은 다음과 같습니다.

insertOne()

db.collection(<collection_name>).insertOne(<document>,　<callback_function>)

insertMany()

db.collection(<collection_name>).insertMany(<documents_array>,　<callback_function>)

　参数说明：

• <collection_name>　 -　 我们要创建的新MongoDB集合的名称
  

• <document> -　　 必须插入到MongoDB Collection中的单个文档

• <document_array>　 -　 要插入到MongoDB Collection中的文档数组

• <callback_function>　　 - 在Node尝试创建集合并准备好结果之后，将调用此Node.js回调函数。回调函数接收错误和结果对象作为参数。

insertOne()–示例Node.js程序

　//　我们在newdb数据库中创建“用户”集合
var　url　=　"mongodb://localhost:27017/newdb";　
　
//　创建一个客户端到mongodb
var　MongoClient　=　require('mongodb').MongoClient;　
　
//　使客户端连接到mongo服务
MongoClient.connect(url,　function(err,　db)　{　
　　　　if　(err)　throw　err;　
　　　　//　db指向newdb
　　　　console.log("Switched　to　"+db.databaseName+"　database");}}　
　
　　　　//　삽입할 파일
　　　　var　doc　=　{　name:　"Roshan",　age:　"22"　};　
　　　　
　　　　//　使用insertOne将文档插入“用户”集合
　　　　db.collection("users").insertOne(doc,　function(err,　res)　{　
　　　　　　　　if　(err)　throw　err;　
　　　　　　　　console.log("Document　inserted");　
　　　　　　　　//　작업이 완료되면 db와의 연결을 닫습니다.
　　　　　　　　db.close();　
　　　　});　
　});

출력 결과

$　node　node-js-mongodb-insert-document.js
Switched　to　newdb　database
Document　inserted

Mongo Shell

>　use　newdb
switched　to　db　newdb
>　show　collections
users
>　db.users.find({});
{　"_id"　:　ObjectId("5a127729a415612642e3d6ad"),　"name"　:　"Roshan",　"age"　:　"22"　}
>

insertMany() –示例Node.js程序

　//　我们在newdb数据库中创建“用户”集合
var　url　=　"mongodb://localhost:27017/newdb";　
　
//　创建一个客户端到mongodb
var　MongoClient　=　require('mongodb').MongoClient;　
　
//　使客户端连接到mongo服务
MongoClient.connect(url,　function(err,　db)　{　
　　　　if　(err)　throw　err;　
　　　　//　db指向newdb
　　　　console.log("Switched　to　"+db.databaseName+"　database");}}　
　
　　　　//　삽입할 파일
　　　　var　docs　=　[{　name:　"Udat",　age:　"21"　},　
　　　　　　　　　　　　　　　　{　name:　"Karthik",　age:　"24"　},　
　　　　　　　　　　　　　　　　{　name:　"Anil",　age:　"23"　}];　
　　　　
　　　　//　insertOne를 사용하여 "사용자" 집합에 여러 문서를 삽입합니다
　　　　db.collection("users").insertMany(docs,　function(err,　res)　{　
　　　　　　　　if　(err)　throw　err;　
　　　　　　　　console.log(res.insertedCount+"　documents　inserted");　
　　　　　　　　//　작업이 완료되면 db와의 연결을 닫습니다.
　　　　　　　　db.close();　
　　　　});　
　});

출력 결과

$　node　node-js-mongodb-insert-many-documents.js
Switched　to　newdb　database
3　documents　inserted

Mongo Shell

>　db.users.find({});
{　"_id"　:　ObjectId("5a127729a415612642e3d6ad"),　"name"　:　"Roshan",　"age"　:　"22"　}
{　"_id"　:　ObjectId("5a1278efecc5062794f4ed8d"),　"name"　:　"Udat",　"age"　:　"21"　}
{　"_id"　:　ObjectId("5a1278efecc5062794f4ed8e"),　"name"　:　"Karthik",　"age"　:　"24"　}
{　"_id"　:　ObjectId("5a1278efecc5062794f4ed8f"),　"name"　:　"Anil",　"age"　:　"23"　}
>

첫 번째 항목은 첫 번째 예제에서 왔으며, 나머지 세 가지는 이 예제와 함께 삽입되었습니다.