MongoDB

MongoDB

2023. 2. 2. 15:47ㆍ프로그래밍/ETC

Database

공유하여 사용할 목적으로 체계화하여

통합, 관리하는 데이터의 집합

장점

데이터 중복 최소화
데이터 공유
일관성, 무결성, 보안성 유지
최신의 데이터 유지
데이터의 표준화 가능
데이터의 논리적, 물리적 독립성
데이터 접근이 용이함
데이터 저장 공간 절약

단점

데이터베이스 전문가 필요
비용 부담이 많음
데이터 백업, 복구가 어려움
시스템이 복잡함
과부하 발생 가능성

DBMS

Database Management System

데이터베이스를 관리하고 운영하는 소프트웨어

데이터 저장, 검색 기능 등 제공

계층형, 네트워크형, 관계형, 객체형 등이 있음 (관계형(RDBMS)을 주로 사용)

(Oracle, MySQL, PostgreSQL 등)

SQL

관계형 데이터베이스(RDBMS)에서 사용하는 언어

데이터에 접근, 제어할 수 있도록 해줌

NoSQL DBMS

NoSQL: Not only SQL

SQL만을 사용하지 않는 DBMS를 의미함

여러 유형의 데이터베이스를 사용하는 것

NoSQL !== No RDBMS

스키마 없이 동작하기 때문에 데이터 구조를 미리 정의할 필요가 없음
데이터 타입에 따른 암묵적인 스키마는 존재함
SQL 보다 훨씬 자유롭게 스키마를 작성/수정할 수 있음

MongoDB

https://www.mongodb.com/cloud/atlas/register

1. 회원가입

2. 클러스터 생성

3. 데이터베이스 접근 사용자 추가 (User Name, Password 설정)

4. Cluster 목록에서 Connect 클릭

5. Connect your application 선택

6. connection string 복사

Mongoose 설치

npm i mongoose

MongoDB 연결

connect() 의 인수로 connection string 전달

const { default: mongoose } = require('mongoose');

mongoose
  .connect(
    'mongodb+srv://<사용자이름>:<비밀번호>@cluster0.sztrze6.mongodb.net/?retryWrites=true&w=majority'
  )
  .then(() => {
    console.log('데이터베이스 연결 성공');
  })
  .catch((err) => {
    console.log(err);
  });

Mongoose

MongoDB에 다양한 기능을 추가하여 더욱 편리하게 이용할 수 있게 해주는 모듈

ODM 라이브러리 (Object Data Modeling)

RDBS vs MongoDB

RDBS	MongoDB
database	database
table	collection
row (tuple)	field
index	index
primary key	_id
foreign key

Mongoose 사용 방법

스키마 생성
스키마를 이용해 모델 생성
모델을 이용해 데이터를 저장/수정/삭제 등의 작업을 할 수 있음

스키마 생성

model/products.model.js

const { default: mongoose } = require('mongoose');

const productSchema = new mongoose.Schema({
  name: {
    type: String,
    require: true,
  },
  description: {
    type: String,
    require: true,
  },
  price: {
    type: Number,
  },
});

const Product = mongoose.model('Product', productSchema);

module.exports = Product;

Create / Read / Update / Delete

controllers/products.controller.js

const productModel = require('../models/products.model');

// Create
async function createProduct(req, res, next) {
  try {
    const createdProduct = await productModel.create(req.body);
    res.status(201).json(createdProduct);
  } catch (error) {
    next(error);
  }
}

// Read
async function getProducts(req, res, next) {
  try {
    const allProducts = await productModel.find({});
    res.status(200).json(allProducts);
  } catch (error) {
    next(error);
  }
}

// Read
async function getProductById(req, res, next) {
  try {
    const product = await productModel.findById(req.params.productId);
    if (product) {
      res.status(200).json(product);
    } else {
      res.status(404).send();
    }
  } catch (error) {
    next(error);
  }
}

// Update
async function updateProduct(req, res, next) {
  try {
    let updateProduct = await productModel.findByIdAndUpdate(req.params.productId, req.body, {
      new: true,
    });
    if (updateProduct) {
      res.status(200).json(updateProduct);
    } else {
      res.status(404).send();
    }
  } catch (error) {
    next(error);
  }
}

// Delete
async function deleteProduct(req, res, next) {
  try {
    let deletedProduct = await productModel.findByIdAndDelete(req.params.productId);
    if (deletedProduct) {
      res.status(200).json(deletedProduct);
    } else {
      res.status(404).send();
    }
  } catch (error) {
    next(error);
  }
}

module.exports = { createProduct, getProducts, getProductById, updateProduct, deleteProduct };

Router

routes/products.router.js

const express = require('express');
const productsController = require('../controllers/products.controller');
const productsRouter = express.Router();

productsRouter.post('/', productsController.createProduct);
productsRouter.get('/', productsController.getProducts);
productsRouter.get('/:productId', productsController.getProductById);
productsRouter.put('/:productId', productsController.updateProduct);
productsRouter.delete('/:productId', productsController.deleteProduct);

module.exports = productsRouter;

server.js

const productsRouter = require('./routes/products.router');

app.use('/products', productsRouter);

Express 에러 처리

const app = require('express')();

// 미들웨어에서 에러 발생 시 express가 해당 에러를 에러 처리기로 보내줌
app.get('*', function(req, res, next) {
  throw new Error('woops');
});

// 위에서 에러가 발생했기 때문에 에러 처리기로 바로 가야 함
// 이 미들웨어는 에러 핸들러가 아니기 때문에 생략됨
app.get('*', function(req, res, next) {
  console.log('this will not print');
});

// 에러 처리기는 4개의 인자를 받음
// 첫 번째 미들웨어에서 발생한 에러 메시지를 여기서 처리함
app.use(function(error, req, res, next) {
  res.json({ message: error.message });
});

app.listen(3000);

const app = require('express')();

// 에러를 발생시키는 미들웨어
app.get('*', function(req, res, next) => {
  setImmediate(() => { throw new Error('woops'); });
  // 서버 Crash
});

// 에러 처리기
app.use(function(error, req, res, next) => {
  res.json({ message: error.message });
});

app.listen(3000);

비동기 요청으로 인한 에러를 위 처럼 처리하면

에러 처리기에서 해당 에러메시지를 받지 못하기 때문에

서버가 Creash 되어버림

해결 방법

const app = require('express')();

// next 메서드로 에러를 감싸줌
app.get('*', function(req, res, next) => {
  setImmediate(() => { next(throw new Error('woops')); });
});

// 에러 처리기
app.use(function(error, req, res, next) => {
  res.json({ message: error.message });
});

app.listen(3000);