nodejs mysql 연동하기

7887 단어 nodejs db mysql db

nodejs 에서 mysql 연동하기

express를이용해서 코드를짠뒤 mysql에 연동하는법을 알아보자

var express = require("express");
var router = express.Router();
const mysql = require("mysql");
// const connection = mysql.createConnection({ -> 1
//   host: "127.0.0.1",
//   user: "root",
//   password: "???",
// });
const pool = mysql.createPool({
  connectionLimit: 10, // connection이 10개이하로 이루어질떄 pool에있는 connection을 a api이용할때 connection사용 b api 이용할때 2번째 connection 이용하고 1번째 connection반남
  host: "127.0.0.1",
  user: "root",
  password: "???",
  database: "ex11",
});

/* GET home page. */
router.get("/", function (req, res, next) {
  // mysql db 연결 1
  // connection.connect((err) => { -> 1
  //   if (err) {
  //     console.error("error connecting ", err.stack);
  //     return;
  //   }
  //   console.log("coonected as id " + connection.threadId);
  //   res.status(200).json({ id: connection.threadId });
  //밑에부분은 잘안씀 왜냐하면 Pool에 쿼리를돌려도되지만 새로운 connection을 열확률이 크기떄문
  // pool.query("SELECT 1+1 AS solution", (error, results) => {
  //   if (error) throw errow;
  //   console.log("The solution is: ", results[0].solution);
  // });
  // mysql db 연결 1
  pool.getConnection((err, connection) => {
    if (err) throw err; // 서버는 절대죽으면안되기때문에 handling하는 코드가 있어야함
    //Use the connection
    connection.query("SELECT * FROM products", (error, results) => {
      //When done with the connection, release it.
      connection.release(); //무조건해줘야함

      console.log("getConnections : ", results);
      res.status(200).json({ results });
      // Handle error after the release
      if (error) throw error; //이거는 쿼리에대한 error
    });
  });
});
// });

module.exports = router;

Connection Pool 개념

데이터베이스에 연결된 Connection을 미리 만들어 둔후 Pool에 보관하였다가 필요할 때 Pool에서 Connection을 가져다 사용한 후, 다시 Pool에 반환하는 기법이다. Connection Pool을 이용하면 여러 Connection을 이용할 수 있기 때문에 더 큰 부하를 견딜 수 있다.

또한 기존처럼 필요할때 마다 Connection을 생성하고 닫지 않아도 되기 때문에 어플리케이션의 성능향상 또한 기대할 수 있다.

쉽게생각하면 connection 방법과 pool에대해서 pool은 connection을 재사용할수있게 사용하는 기법이고 생각하면 좋다.

const pool = mysql.createPool({
  connectionLimit: 10, // connection이 10개이하로 이루어질떄 pool에있는 connection을 a api이용할때 connection사용 b api 이용할때 2번째 connection 이용하고 1번째 connection반남
  host: "127.0.0.1",
  user: "root",
  password: "???",
  database: "ex11",
});

mysql.createPool(_config) : 새로운 Pool 생성
pool.getConnection : pool에서 Connection 가져오기

Connection Pool 모듈화

getConnection() 함수를 exports하여 아래와 같이 필요한 곳에서 랩핑하여 쉽게 사용할 수 있다.

사용후 꼭 conn.release()를 통해 Pool에 Connection을 반환한다.
connetion pool

router.get("/", function (req, res, next) {
// mysql db 연결 1
  pool.getConnection((err, connection) => {
    if (err) throw err; // 서버는 절대죽으면안되기때문에 handling하는 코드가 있어야함
    //Use the connection
    connection.query("SELECT * FROM products", (error, results) => {
      //When done with the connection, release it.
      connection.release(); //무조건해줘야함

      console.log("getConnections : ", results);
      res.status(200).json({ results });
      // Handle error after the release
      if (error) throw error; //이거는 쿼리에대한 error
    });
  });
});

그후 getConnection코드를 이용해

pool에있는 connection을 사용을한다.

예를들어 a api이용할때 connection사용 b api 이용할때 2번째 connection 이용하고 1번째 connection반납 이런식으로 작동이된다.

위와 같이 Connection Pool을 생성할 수 있다. 그후 Pool에서 Connection을 얻어서 사용할 수 있다. 사용한 후 반드시 conn.release()를 통해 Pool에 반납해야한다.

    connection.query("SELECT * FROM products", (error, results) => {
      //When done with the connection, release it.
      connection.release(); //무조건해줘야함

      console.log("getConnections : ", results);
      res.status(200).json({ results });

connection.query같은경우는 db에 query명령어를 입력하는것인데 위에코드는 products라는 을 선택하는 코드이다.