Node.js와 MongoDB 연동하기 - MongoDB 올인 13일차

Connecting Node.js with MongoDB - All-in Day 13

mkdir my-node-mongo-app
cd my-node-mongo-app
npm init -y 

npm install mongodb

const { MongoClient } = require('mongodb'); // mongodb 드라이버에서 MongoClient 가져오기
 
// 1. Atlas 연결 문자열 준비 (실제 값으로 대체해야 함)
const uri = "mongodb+srv://myAppUser:yourStrongPassword@myfirstatlascluster.xxxxx.mongodb.net/myAppDB?retryWrites=true&w=majority";
 
// 2. MongoClient 인스턴스 생성
const client = new MongoClient(uri);
 
async function run() {
  try {
    // 3. MongoDB 서버에 연결
    await client.connect();
    console.log("MongoDB Atlas에 성공적으로 연결되었습니다!");
 
    // 4. 데이터베이스 및 컬렉션 작업 수행 (이후 CRUD 예제에서 다룰 예정)
    // 예: const database = client.db("myAppDB");
    //     const usersCollection = database.collection("users");
 
  } catch (error) {
    console.error("MongoDB 연결 중 오류 발생:", error);
  } finally {
    // 5. 모든 작업이 끝나면 클라이언트 연결 해제
    // 실제 애플리케이션에서는 서버가 종료될 때 한 번만 호출하는 것이 일반적입니다.
    await client.close();
    console.log("MongoDB 연결이 해제되었습니다.");
  }
}
 
// 스크립트 실행
run().catch(console.dir);

// run 함수 내부 ...
    await client.connect();
    console.log("MongoDB Atlas에 성공적으로 연결되었습니다!");
 
    const database = client.db("myAppDB"); // 기본 DB 외 다른 DB 사용 시 명시
    const usersCollection = database.collection("users"); // 'users' 컬렉션 사용
// ... 이후 CRUD 코드

// run 함수 내부, usersCollection 선언 후
 
    // 새로운 사용자 문서 생성
    const newUser = {
      name: "홍길동",
      age: 30,
      email: "gildong@example.com",
      hobbies: ["독서", "등산"],
      createdAt: new Date()
    };
 
    const insertResult = await usersCollection.insertOne(newUser);
    console.log(`새로운 사용자가 추가되었습니다. ID: ${insertResult.insertedId}`);

// run 함수 내부
 
    // 이름이 "홍길동"인 사용자 찾기
    const foundUser = await usersCollection.findOne({ name: "홍길동" });
    if (foundUser) {
      console.log("사용자 찾음:", foundUser);
    } else {
      console.log("해당 사용자를 찾을 수 없습니다.");
    }

// run 함수 내부
 
    // 나이가 25세 이상인 모든 사용자 찾기
    const cursor = usersCollection.find({ age: { $gte: 25 } });
    const allUsersOver25 = await cursor.toArray();
    console.log("25세 이상 사용자 목록:", allUsersOver25);
 
    // 특정 필드만 선택하여 조회 (프로젝션)
    const projectionCursor = usersCollection.find(
      { age: { $gte: 25 } },
      { projection: { _id: 0, name: 1, email: 1 } } // 이름과 이메일만, _id는 제외
    );
    const projectedUsers = await projectionCursor.toArray();
    console.log("25세 이상 사용자 (이름, 이메일):", projectedUsers);

// run 함수 내부
 
    // 이름이 "홍길동"인 사용자의 나이를 31세로 수정
    const updateResult = await usersCollection.updateOne(
      { name: "홍길동" },               // 필터 조건
      { $set: { age: 31, status: "active" } } // 업데이트할 내용 ($set 연산자 사용)
    );
    console.log(`${updateResult.modifiedCount}개의 문서가 수정되었습니다.`);

// run 함수 내부
 
    // 이메일이 "gildong@example.com"인 사용자 삭제
    const deleteResult = await usersCollection.deleteOne({ email: "gildong@example.com" });
    console.log(`${deleteResult.deletedCount}개의 문서가 삭제되었습니다.`);