Node-mysql 사용

os x 기준으로 설명

mysql을 사용할 때 가장 많이 사용하는게 이게 아닐까 싶다.

1. node-mysql 설치

$ npm install --save node-mysql

위와 같이 터미널에서 설치해주도록 한다. 

그럼 게이지가 올라가면서 설치가 된다.

<사진 1. 설치 완료>

설치가 완료되면 이렇게 된다. 

2. 홈페이지 방문

node-mysql 홈페이지로 방문

3. 방문하여 튜토리얼 확인

방문을 하게되면 아래로 내려 확인을 해보도록 한다.

Introduction 으로 이동

instroduction에 기본적인 소개가 있는데, 이 소개를 하는 예제를 보도록 하자.

var mysql = require('mysql'); var 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();

3-1. mysql connection

먼저 mysql에 접속하기 위해서는 예전 글을 보면 알겠지만 Security영역에 대해서 로그인을 하여 인증을 해야한다.

서버에 등록되어있는 자신의 호스트명, 유저명, 비밀번호, 데이터베이스 섹션 이름을 받고 로그인을 해야된다.

물론 위와 아래의 예제처럼 실제 서버를 짜면 절대 안된다. 왜냐하면 이 소스들은 밖으로 비밀번호와 유저아이디, db섹션의 데이터가 노출되어 있기 때문이다.

나중에 상용서버로 들어가게되면 이런 데이터등은 암호화 해서 처리하게 된다.

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

위의 소스는 mysql을 js에서 로드하여 가져오는 작업을 보여준다.

mysql 이라는 변수를 만들어 mysql 로드한 데이터를 변수에 넣고, connection이라는 변수를 만들어 그 안에 mysql.createConnection이라는 함수를 사용한다.

이 함수는 db와 외부와의 인증 통로를 만들어준다고 생각하면 되는 함수이다.

그리고 connection.connect(); 로 접속을 하는 아주 간단한 구문이다.

3-2 mysql query

이전 글에서 터미널에서 sql명령어를 사용하여 데이터베이스를 insert, update, delete등의 행위를 했었는데 이러한 행위를 서비스를 할 때 실시간으로 프로그래머가 할 수 없는 노릇이다. 

예를들어 프로그램을 개발해야하는데 그것이 블로그일 경우에는 사용자가 글을 포스트하고 삭제하고 등등의 자기 마음대로 할줄 알아야 하기 때문에 db에 메시지 전송을 수시로 하게 될 것이다. 그러므로 로직상에서 구현을 해놓아야 한다. 

- insert

var queryMessage = 'INSERT INTO users (name, password) VALUES("집", "가고싶다")'; connection.query(queryMessage, function(error, results, fields){ if(error) throw error; console.log('insert!'); });

- update

var queryMessage = 'UPDATE users SET name="캬캬캬" WHERE id=2'; connection.query(queryMessage, function(error, results, fields){ if(error) throw error; console.log('update!!'); });

- delete

var queryMessage = 'DELETE FROM users WHERE id=2'; connection.query(queryMessage, function(error, results, fields){ if(error) throw error; console.log('delete!!'); });

4. 실제로 해보기

먼저 하기 위해서는 간단하게 mysql 환경을 설정하도록 한다.

실제로 해보는 것은 webstorm에서 하도록 하겠다.

<사진 2. 프로젝트 생성>

node js + express app을 선택하여 프로젝트를 만든다.

프로젝트가 만들어지면 왼쪽의 project view에서 mysql폴더를 만들고 그 안에 test.js를 만들어주도록 하자.

<사진 3. 프로젝트탭에서 mysql 폴더와 test.js 파일 만들기>

그러고 나면 test.js에 아래와 같이 코딩을 한다.

var mysql = require('mysql'); var conn = mysql.createConnection({ host : 'localhost', user : 'root', password : '설정한 비밀번호', database : '설정한 데이터베이스' }); conn.connect();

자신이 설정한 데이터베이스를 까먹었다면 webstorm의 터미널을 켜도록 하자.

왼쪽 하단부에 보면 webstorm의 터미널이 있다.

<사진 4. 왼쪽 하단의 터미널 부>

그리고 아래와 같이 작업한 후 확인을 한다.

$ mysql -uroot -p 비밀번호 입력 mysql> SHOW DATABASES;

<사진 5. 데이터베이스 확인>

이렇게 해주면 자신의 데이터베이스들을 확인할 수 있다.

해당된 데이터베이스가 없으면 아래의 구문으로 만들어주도록 한다.

CREATE DATABASE test;  

<사진 6. 데이터베이스 생성>

데이터 베이스를 생성했다면 테이블도 없는거니 테이블도 새로 하나 생성해주도록 하자

 mysql> CREATE TABLE users( -> id INT NOT NULL AUTO_INCREMENT PRIMARY KEY, -> name VARCHAR(25) NOT NULL, -> password VARCHAR(25) NOT NULL ->);

위의 소스를 쳐서 users라는 테이블을 생성하자.

여기까지 했으면 기본 설정이 완료이다.

그러면 소스코드를 적용해보도록 하자.

먼저 mysql을 나온다.

아래의 구문을 치자.

mysql> quit

이렇게 되면 mysql에서 나오며, 우리가 적용할 test.js 스크립트는 mysql안에 있으므로 이동하여 실행해보도록 하자.

mysql> cd mysql mysql> node test.js

실행하게 되면 아무것도 안나오는데 그게 정상적인 거다..

<사진 7. 실행>

여기서 실행 취소는 컨트롤 + c하면 된다.

실행 취소를 해보고 아래들 소스코드들을 test.js에 이어 작성하여 테스트를 해보도록 한다.

- insert

var queryMessage = 'INSERT INTO users (name, password) VALUES("집", "가고싶다")'; connection.query(queryMessage, function(error, results, fields){ if(error) throw error; console.log('insert!'); });

- update

var queryMessage = 'UPDATE users SET name="캬캬캬" WHERE id=2'; connection.query(queryMessage, function(error, results, fields){ if(error) throw error; console.log('update!!'); });

- delete

var queryMessage = 'DELETE FROM users WHERE id=2'; connection.query(queryMessage, function(error, results, fields){ if(error) throw error; console.log('delete!!'); });

실행 해보고 각각의 결과를 확인해보자.

5. 데이터 베이스 종료

서버 전송을 하는 것들이 완료 되었다면 서버를 끄면된다.

아래의 소스코드로 끄도록 하자. 

conn.end();