Mongo DB CRUD

Mongo DB를 이용하여 CRUD를 해보자

 

1. 클라이언트 생성 및 접속 테스트

const MongoClient = require("mongodb").MongoClient; //로드
const url = "mongodb://127.0.0.1:27017"; //접속 url
const dbname = "mydb";

// 클라이언트 생성
const client = new MongoClient(url, { useNewUrlParser: true });

// 접속 테스트
function testConnect() {
  client.connect((err, client) => {

    client
      .connect()
      .then((client) => {
        console.log(client);
        client.close();
      })
      .catch((reson) => {
        Console.error(reson);
      });
  });
}

 

2. Insert

// 한개 문서 insert
// INSERT INTO mydb.friends value(...);
// db.friends.insert({문서})

function testInsertOne(name) {
  client
    .connect()
    .then((clinet) => {
      //DB선택
      const db = client.db("mydb");
      //컬렉션 선택 후 쿼리 수행
      // console.log(db.collection("mydb"))
      db.collection("mydb")
        .insertOne({ name: name })
        .then((result) => {
          console.log(result);
          console.log("새로 삽입된 문서의 ID :", result.insertedId);
          console.log(result.insertedCOunt, "row inserted");
          client.close();
        });
    })
    .catch((reason) => {
      console.log(reason);
    });
}
// testInsertOne("강백호")

// 다수 문서 삽입
// insert into freiends value(...),(...),(...)
// db.friends.insertMany([{doc},{doc},...])

function testInsertMany(names) {
  console.log(names, "는 배열인가?", Array.isArray(names));
  if (Array.isArray(names)) {
    // name가 배열이면 실행
    client.connect().then((client) => {
      const db = client.db("mydb");

      // 문서의 배열 생성
      let data = names.map((item) => {
        return { name: item };
      });
      console.log(data);
      db.collection("friends")
        .insertMany(data)
        .then((result) => {
          console.log(result.insertedCOunt, "개 삽입완료");
          client.close();
        });
    });
  } else {
    testInsertOne(names);
  }
}
// testInsertMany(["서태웅", "송태섭", "채치수", "정대만"]);
// testInsertMany("장길산")

2-1. docs를 이용한 삽입

function testInsertOneDoc(doc) {
  client.connect().then((client) => {
    const db = client.db("mydb");
    db.collection("friends")
      .insertOne(doc)
      .then((result) => {
        console.log(result.insertedCount, "개 등록 완료");
        client.close();
      })
      .catch((reason) => {
        console.error(reson);
      });
  });
}
// testInsertOneDoc({ name: "채치수", position: "center" });

function testInsertManyDocs(docs) {
  console.log(docs, "is array?", Array.isArray(docs));

  if (Array.isArray(docs)) {
    client.connect().then((client) => {
      const db = client.db("mydb");
      db.collection("friends")
        .insertMany(docs)
        .then((result) => {
          console.log(result.insertedCOunt, "개 등록 완료");
          client.close();
        })
        .catch((reson) => {
          console.error(reson);
          client.close();
        });
    });
  }
}

// testInsertManyDocs([
//   { name: "서태웅", position: "forward", num: 11 },
//   { name: "강백호", position: "Power forward", num: 10 },
//   { name: "송태섭", position: "Point Guard", num: 23 },
//   { name: "정대만", position: "guard", num: 9 },
// ]);

3. Update

function testUpdateByJob(name, job) {
  // name이 일치하는 문서의 job field를 업데이트 하자.
  client.connect().then((clinet) => {
    const db = client.db("mydb");
    db.collection("friends")
      .updateMany(
        { name: name }, // 조건객체
        {
          $set: { job: job },
        }
      )
      .then((result) => {
        console.log(
          result.modifiedCount,
          "개 업데이트",
          result.upsertedCount,
          "개 업서트"
        );

        client.close();
      })

      .catch((reason) => {
        console.error(reason);
      });
  });
}
testUpdateByJob("정대만", "고3");

4. delete

// 삭제 :
// delete form friends [where...]
// db.friend.delete, db.friend.deleteMany({조건객체})
function testDeleteAll() {
  client.connect().then((client) => {
    const db = client.db("mydb");
    db.collection("friends")
      .deleteMany({}) // 조건객체
      .then((result) => {
        console.log(result.deletedCount, "개 레코드 삭제");
        client.close();
      });
  });
}

// testDeleteAll();