NodeJS 5강 : MySql 연동

NodeJS 5강 : MySql 연동

======================================================================

 

MySql 설치

저는 MySql을 Centos 7에 설치를 하겠습니다.

(시스템 구성을 제가 직접하는 편이라 VM을 사용해야해서 docker는 사용하지 않습니다.)

 

MySql은 유료버전과 무료버전이 있는데 무료버전은 커뮤니티라는 이름이 따로 붙어있습니다.

어떤 DB를 사용하시든 DB의 라이선스 정보는 꼭 확인 하시길 바랍니다.

 

설치 참고 문서 : https://www.lesstif.com/pages/viewpage.action?pageId=24445108

권한 참고 문서 : https://ourcstory.tistory.com/45

MySql 모듈 설치

async/await로 구현을 할 예정이라서 모듈은 mysql2로 받도록 하겠습니다.

(mysql 모듈로 하니깐 async/await 오류가 나더군요)

 

https://www.npmjs.com/package/mysql2

npm install --save mysql2

모듈을 설치하고 npm 사이트의 모듈 문서를 읽어봐야합니다.

왠만한 모듈은 문서에 간단한 사용법이 기재되어있습니다.

우선 DB를 연결하려면 설정 정보가 필요하기 때문에 설정 부분을 찾아야합니다.

혹은 모듈 개발자가 github 주소를 기재했다면 오픈 소스를 확인하는것도 하나의 방법입니다.

 

저 같은 경우는 예전에 비동기 방식으로 구현을 했던 코드가 따로 있으니 이 코드를 리뷰 하겠습니다.

 

conf.js

var conf = {
    db_info: {
        connectionLimit: 10,
        waitForConnections: true ,
        host: "192.168.0.178",
        user: "nodeman",
        password: "1234",
        database: "node",
        port: 3306,
        charset: 'utf8'
    }
}
 
module.exports = conf;

import mysql from 'mysql2/promise'
import { db_info } from './conf'
const pool = mysql.createPool(db_info); // db_info에서 설정 정보를 읽고 pool을 생성
 
const DB = async(type, sql, params) => { // async, await
    try {
        // state : 쿼리문 실행 성공시 true 실패 false
        // error : 쿼리문 error 정보 반환
        let result = {}; // 반환 값
        const connection = await pool.getConnection(async conn => conn); // 생성된 풀 정보로 DB 연결
        try {
            const [rows] = await connection.query(sql, params); // sql 쿼리문 실행
            if(type == "GET") result.row = rows;
            result.state = true;
            connection.release(); // 사용된 풀 반환
            return result;
        } catch (err) {
            console.log('Query Error');
            result.state = false;
            result.error = err;
            connection.release();
            return result;
        }
    } catch (err) {
        console.log('DB Error');
        result.state = false;
        result.error = err;
        return result;
    }
}
 
module.exports = DB;

핵심은 async/await 문으로 비동기로 전달 받은 데이터 흐름을 순서대로 제어해야합니다.

그렇지 않으면 비동기 데이터를 다룰때 순서가 달라서 정상적인 처리가 되지 않을 수 있습니다.

 

그래서 가장먼저 connection에 await로 DB 연결을 시키고 쿼리문을 던집니다.

만약에 DB 연결도 안됐는데 쿼리문을 던지면 어떻게 될까요? 당연히 오류가 나겠죠.

 

const connection = await pool.getConnection(async conn => conn);

이 코드는 아주 중요합니다. await를 걸었다고 해서가 다된게 아닙니다.

getConnection 메서드의 동작이 만약에 비동기라면 그 함수 자체에 async를 선언해줘야합니다.

실제로 모듈 내용을 살펴보면 promise로 비동기로 동작됩니다.

 

그리고 쿼리문의 코드가 의아한 코드가 하나 있으실 텐데요.

const [rows] = await connection.query(sql, params);

바로 [rows] 이 녀석이죠

이 배열에 담긴 녀석은 mysql query 메서드 부분에서 반환 부분이 저렇게 되있습니다.

그래서 모듈에서 query를 찾아보시면 아래와 같은 녀석이 있습니다.

query method

이 query 메서드는 코드를 살펴보면 반환값이 done으로 되어있어서 done의 변수를 살펴보면

makeDoneCb라는 메서드가 있습니다. 이 녀석의 반환값을 확인하면

makeDoneCb

resolve로 반환이 [rows, fields]로 묶여있습니다. 그래서 실제로

const [rows, fields] = await connection.query(sql, params);

와 같은 방식으로도 반환을 받을 수 있습니다.

 

핵심적인 코드 리뷰는 끝난거 같습니다.

마음 같아서는 더 리뷰를 하고 싶지만 글이 더 난잡해질거 같고, 실제로 코드를 작성하는게 더 효율적입니다.

 

DB 테스트

제 데이터베이스에는 user라는 테이블이 있습니다.

테이블에는 임의로 데이터를 집어넣었습니다.

지난 강의에서 만든 미들웨어에 위에서 작성한 DB 모듈을 사용하겠습니다.

그리고 사용하기 위해선 DB 모듈을 import 해야합니다.

import DB from './db';

middleware(app) {
    app.use('/node', function(req, res, next) {
        DB('GET', "select 1 as cnt", []).then(function(res) {
            console.log('DB Connect Check')
            console.log(res);
        });
        DB('GET', "select ID, PASSWORD from user", []).then(function(res) {
            console.log('DB Query Test');
            console.log(res);
            console.log(res.row);
        });
        const columns = ['ID', 'PASSWORD', 'user'];
        DB('GET', "select ??, ?? from ??", columns).then(function(res) {
            console.log('DB Query Test2');
            console.log(res);
            console.log(res.row);
        });
        next('isNaN detecting');
    });
}

 

정상적으로 실행이 됐다면 위와같은 결과를 얻을 수 있습니다.

> 5강을 마치며

NodeJS의 강의만 쓰고 싶어서 따로 DB 설정 부분을 정리하지 않았습니다.

 

그리고 이번 강의는 promise문이 나와서 promise문에 대해서 자세히 모르시는분들은

promise문을 찾아보시고 보시는걸 추천드립니다.

 

GitHub URL : https://github.com/BlackPing/node