[Node.js] MySQL 제어하기

 

 

Node.js - MySQL - 생활코딩

 

생활코딩 Node.js - MySQL 강의를 듣고서 작성한 글입니다. 그냥 그렇다고요.

 

---

1. file의 한계

 

소규모의 단순한 기능을 구현하기에는 파일이 좋다.

 

단순하고 쉽고 특별한 설치나 학습이 필요하지 않다.

 

하지만 파일은 한계가 있다.

 

우리가 만든 웹 페이지가 저장한 파일의 수가 커질수록 원하는 파일, 원하는 내용을 찾는 것이 오래 걸린다.

 

뿐만 아니라 파일은 제목과 본문이라는 두 가지 요소만을 표현할 수 있다.

 

부가적으로 작성자의 이름, 작성 시간, 공개 상태 등 관련된 정보를 추가하기 어렵다.

 

그 외에도 보안, 안정성, 성능, 동시성 등 개발자가 직접 관리하기 어려운 문제가 발생하기 쉽다.

 

---

2. Database 활용하기

 

우리는 배울 것도 많고 복잡하지만 DB를 사용할 필요가 있다.

 

데이터베이스를 사용하면 파일보다 더 많은 정보를 저장하고 관리할 수 있다.

 

파일 시스템의 한계를 극복해 데이터를 효과적으로 구성, 저장, 활용할 수 있다.

 

또한 다른 프로그램과 데이터를 공유할 수 있도록 하는 동시성 및 보안 기능을 제공하며, 데이터 검색 및 조작이 쉽고 빠르며 유연하다.

 

생활코딩 node.js 수업에서는 MySQL을 사용한다.

 

우리는 Node.js에서 MySQL을 제어하기 위해서 만든 라이브러리에 대해서 학습할 것이다.

 

---

3. 실습 준비

 

실습준비 - 생활코딩

 

실습을 위해서 MySQL을 설치하고 database를 세팅했다.

 

---

4. node.js에서 mysql 사용하기

 

node.js 자체에서 제공하는 모듈 중에는 mysql을 제어하기 위한 모듈은 없다.

 

npm에서 추가적인 모듈을 설치해줘야 한다.

 

mysql

 

Node.js MySQL

 

npm install mysql
npm install mysql2 #mysql의 버전이 8 이상인 경우 추천

설치를 완료한다.

 

아래는 예시다.

 

const mysql      = require('mysql'); //= require('mysql2');
const connection = mysql.createConnection({
  host     : 'localhost',
  user     : 'me',
  password : 'secret',
  database : 'my_db'
});

connection.connect();

connection.query('SELECT 1 + 1 AS solution', function (error, results, fields) {
  if (error) throw error;
  console.log('The solution is: ', results[0].solution);
});

connection.end();

 

---

가. Create Connection

 

const mysql      = require('mysql');
const connection = mysql.createConnection({
  host     : 'localhost',
  user     : 'me',
  password : 'secret',
  database : 'my_db'
});

connection.connect();

...

connection.end();

• const mysql = require('mysql'); : 설치한 mysql 모듈을 import한다.
• const connection = mysql.createConnection({ … }); : mysql에 연결하고 이를 객체로 만든다.
• host : 'localhost', : 연결하려는 데이터베이스의 호스트 이름입니다. (기본값: localhost)
• user : 'me', : 인증할 MySQL 사용자입니다.
• password : 'secret', : 해당 MySQL 사용자의 비밀번호입니다.
• database : 'my_db' : 이 연결에 사용할 데이터베이스의 이름입니다 (선택 사항).

 

---

나. Query a Database

 

...
connection.connect();

connection.query('SELECT 1 + 1 AS solution', function (error, results, fields) {
  if (error) throw error;
  console.log('The solution is: ', results[0].solution);
});

connection.end();
...

• connection.query('SQL 쿼리', function (error, results, fields) { … });
  : 실행하고자 하는 쿼리문을 문자열로 입력한다. 그리고 결과를 받아서 사용할 콜백함수를 작성한다.
• error : Error if one occurred during the query.
• results : The results of the query. 객체의 배열이다. result[숫자].필드값
• fieds : information about the returned results fields.

 

var queryData = url.parse(_url, true).query;

...

connection.query(`SELECT * FROM topic WHERE id = ${queryData.id}`, function (error, results, fields) { ... });

topic이라는 테이블에서 id가 queryData.id와 같은 튜플의 모든 속성을 가져오는 SELECT문이다.

 

보안을 위해서 아래와 같이 사용할 수 있다.

 

connection.query(`SELECT * FROM topic WHERE id = ?`, [queryData.id], function (error, results, fields) { ... });

입력값을 ?로 남겨놓고 두 번째 인자에 배열로 전달하면 SQL injection와 같이 불순한 의도를 가진 입력값에 대하여 자동으로 처리해 준다.

 

---

다. Streaming query rows

 

만약 많은 양의 rows를 select하고 이를 오는 족족 처리하고 싶다면 다음과 같이 코드를 작성하면 된다.

 

var query = connection.query('SELECT * FROM posts');
query
  .on('error', function(err) {
    // Handle error, an 'end' event will be emitted after this as well
  })
  .on('fields', function(fields) {
    // the field packets for the rows to follow
  })
  .on('result', function(row) {
    // Pausing the connnection is useful if your processing involves I/O
    connection.pause();

    processRow(row, function() {
      connection.resume();
    });
  })
  .on('end', function() {
    // all rows have been received
  });

더 궁금한 점은 아래에서 찾아볼 것.

 

mysql

 

mysql2

---