JS에서 MongoDB 함수 간편하게 사용하기

const mongoose = require("mongoose");
require("dotenv").config();

// MongoDB 연결 설정
const { mongoHost, mongoPw, mongoUser, mongoDB } = process.env;
const mongoURI = `mongodb+srv://${mongoUser}:${encodeURIComponent(mongoPw)}@${mongoHost}${mongoDB}?retryWrites=true&w=majority`;

// MongoDB 연결
mongoose.connect(mongoURI, { useNewUrlParser: true, useUnifiedTopology: true })
  .then(() => console.log("MongoDB 연결 성공"))
  .catch(err => console.log("MongoDB 연결 실패:", err));

// MongoDB 명령 실행 함수
async function mongo(command, table, params) {
  if (!command || !table || !params) { return {} }

  try {
    const collection = mongoose.connection.collection(table);

    switch (command.toUpperCase()) {
      case "SELECT":
        return await collection.find(params).toArray();

      case "INSERT":
        return await collection.insertOne(params);

      case "UPDATE":
        const { filter, update } = params;
        if(!filter || !update){ return {} }
        return await collection.updateMany(filter, { $set: update });

      case "DELETE":
        return await collection.deleteMany(params);

      default:
        return {}
    }
  } catch (error) {
    console.error(`MongoDB 명령 실행 중 오류: ${error.message}`);
    return {}
  }
}

module.exports = { mongo };

 

SELECT 요청  // userEmail 찾기

const result = await mongo("SELECT", tableName, {userEmail: userEmail});

 

INSERT 요청

await mongo("INSERT", "tabOrder", {userEmail: "", userPassword: ""});

 

UPDATE 요청

const result = await mongo("UPDATE", tableName, 
{ filter: { userEmail: "" }, update: { userPassword: "" } });

 

DELETE 요청

const result = await mongo("DELETE", tableName, { userEmail: "" });