데이터베이스 연동하기

데이터베이스 모듈화

mariadb.js

// Get the client
const mysql = require('mysql2');

// Create the connection to database
const connection = mysql.createConnection({
  host: 'localhost',
  user: 'root',
  password: 'root',
  database: 'Youtube',
  port: '3307' ,// mariadb 포트 번호 3307로 변경했음
  dateStrings: true
});

module.exports=connection

 

데이터베이스 모듈 연결하기

users.js

const conn = require('../mariadb')

 

회원 개별 조회: SELECT 문 사용

router
  .route('/users')
  .get((req, res) => {  // 회원 개별 조회
    let { email } = req.body

    conn.query(
      `SELECT * FROM users WHERE email = ?`,email ,
      function (err, results, fields) {
        if(results.length)
          res.status(200).json(results)
        else {
          res.status(404).json({
            message: '회원 정보가 없습니다.'
          })
        }
      }
    );
  })

map 이 아니라 SQL 문을 이용하여 데이터베이스에서 값을 가져오도록 변경하였다. body 에 입력된 email 과 같은 email을 가진 사용자가 있으면 결과를 출력하고 없으면 회원 정보가 없다는 메시지를 출력한다.

 

회원가입:INSERT 문 사용

router.post('/join', (req, res) => {
  if (Object.keys(req.body).length === 0) {
    res.status(400).json({
      message: '입력 값을 다시 확인해주세요!'
    })
  }
  else {
    const { email, name, password, contact } = req.body 
    conn.query(
      `INSERT INTO users (email, name, password, contact) VALUES (?,?,?,?)`, [email, name, password, contact],
      function (err, results, fields) {
          res.status(201).json(results)
      }
    );
  }
})

INSERT 문을 사용하여 body 에 입력된 값이 value로 데이터베이스에 회원 정보가 추가된 것을 확인할 수 있다. 

 

회원 삭제 : DELETE 문 사용

router
  .route('/users')
  .delete((req, res) => { // 회원 개별 삭제
    let { email } = req.body

    conn.query(
      `DELETE FROM users WHERE email = ?`, email,
      function (err, results, fields) {
        res.status(200).json(results)
      }
    );
  })

삭제가 성공된 화면

DELETE 문을 사용하여 body 에 입력된 이메일에 해당하는 사용자를 삭제한다. 

 

로그인: SELECT 문 사용

router.post('/login', (req, res) => {
  // email 이 db 에 저장된 회원인지 확인

  const { email, password } = req.body

  conn.query(
    `SELECT * FROM users WHERE email = ?`, email,
    function (err, results, fields) {
      let loginUser = results[0];

      if (loginUser && loginUser.password === password) {
        res.status(200).json({
          message: `${loginUser.name} 님 로그인 되었습니다.`
        })
      }
      else {
        res.status(404).json({
          message: '이메일 또는 비밀번호가 틀렸습니다.'
        })
      }
    }
  );
})

SELECT 문을 사용하여 입력된 이메일과 같은 이메일을 가진 사용자를 추출한다. 해당 사용자의 비밀번호와 body 에 입력된 비밀번호가 같으면 로그인 되었다는 메시지를 출력하고, 이외의 경우에는 이메일 또는 비밀번호가 틀렸다는 메시지를 출력한다. 

---

users.js 리팩토링 최종 코드

const express = require('express')
const router = express.Router()
const conn = require('../mariadb')

router.use(express.json()) 

router.post('/login', (req, res) => {
  const { email, password } = req.body

  let sql =  `SELECT * FROM users WHERE email = ?`
  conn.query( sql, email,
    function (err, results) {
      let loginUser = results[0]

      if (loginUser && loginUser.password === password) {
        res.status(200).json({
          message: `${loginUser.name} 님 로그인 되었습니다.`
        })
      }
      else {
        res.status(404).json({
          message: '이메일 또는 비밀번호가 틀렸습니다.'
        })
      }
    }
  );
})

router.post('/join', (req, res) => {
  if (Object.keys(req.body).length === 0) {
    res.status(400).json({
      message: '입력 값을 다시 확인해주세요!'
    })
  }
  else {
    const { email, name, password, contact } = req.body

    let sql = `INSERT INTO users (email, name, password, contact) VALUES (?,?,?,?)`
    let values = [email, name, password, contact]
    conn.query(sql, values,
      function (err, results) {
        res.status(201).json(results)
      }
    );
  }
})

router
  .route('/users')
  .get((req, res) => {  
    let { email } = req.body

    let sql = `SELECT * FROM users WHERE email = ?`
    conn.query(sql, email,
      function (err, results, fields) {
        if (results.length)
          res.status(200).json(results)
        else {
          res.status(404).json({
            message: '회원 정보가 없습니다.'
          })
        }
      }
    );
  })
  .delete((req, res) => { 
    let { email } = req.body

    let sql = `DELETE FROM users WHERE email = ?`
    conn.query(sql, email,
      function (err, results) {
        res.status(200).json(results)
      }
    );
  })

module.exports = router

---

🌟 배운 점

오늘은 그동안 했던 프로젝트를 데이터베이스와 연동했다. 이전에는 db 라는 변수를 map 객체로 생성해서 데이터베이스가 있는 것처럼 코드를 구현해서 더 복잡했는데, 연동을 하니까 오히려 코드가 더 깔끔해지고 이해하기도 쉬워진 것 같다. vscode 에서 SQL 문을 이용하여 데이터베이스에서 조회, 삽입, 삭제 등의 연산은 처음 해봐서 조금 헷갈리는 부분도 있긴 하지만 익숙해지기 위해 노력해야겠다.