mysql 연결 방법 2가지

· 11년 전 · 2612 · 2

2014년 현재 가장 많이 쓰이는 mysql 연결 방법은 2가지 정도 있는 듯 합니다.

 

일단 mysql을 사용하려면 mysql 모듈을 설치하셔야 합니다.  

npm install mysql  또는 package.json 에 추가하여 npm install

 

 

단일 커넥션으로 연결하기

예)

var mysql = require('mysql');   // mysql 모듈 불러오고 

var connection = mysql.createConnection({   // 연결 객체 생성 

host : '호스트 이름',

user: '사용자',

password : '비밀번호' 

});

 

connection.connect();  // mysql 연결 

 

connection.query("sql 쿼리", function(err, results, fields) {

 

})   // query 실행 

 

  

connection.end();  // mysql 연결 종료

 

connection.query()의 용법을 살펴 보면

1. connection.query("sql 쿼리")  -- 경우에 따라 콜백 함수가 생략 될 수 있다. sql 쿼리만 입력하는 경우는 STATEMENT 타입이며, 입력 값이 있을 경우 connection.escape()를 사용하여 반드시 escape 하여야 SQL Injection을 예방할 수 있다.

 

2. connection.query("sql 쿼리", "입력 값") - preparedStatement로 사용될 때 이다. 콜백 함수가 들어 갈 수 도 있으나, 경우에 따라 생략 될 수 도 있다.  

 

  예) connection.query("INSERT INTO member ( username ) VALUES (?)", "bluebird")

 

 

3. 콜백 함수와 함께 사용 - 콜백 함수와 함께 사용하는 경우는 보통 데이터를 추출하는 경우이다. argument는 보통 2, 3개가 사용될 수 있다.  

   예) connection.query("SELECT * FROM member WHERE username=?", username, function(err, results, fields) {

if (err) throw err;

else {

console.log(results) // SQL 쿼리를 통해 추출된 데이터 배열, 배열 안에는 JSON의 형태로 필드는 키, 데이터는 값의 형태로 담겨 있다.  

console.log(fields) 추출된 데이터의 필드명 및 기타 데이터가 담겨 있다. 

}); 

    

 

 

 

 

커넥션 풀사용하는 연결

예)

var mysql = require('mysql');

var pool = mysql.createPool({   // 커넥션 풀 형성

host : "호스트명",

user : "사용자",

password : "비밀번호"

});

 

pool.getConnection(function(err, connection) {  // 연결

if ( err ) throw err;

else {

connection.query("SELECT * FROM member", function(err, results) {

if (err) throw err;

else console.log(results);

})

 

connection.release() // 연결 해제

}

});

 

 

커넥션풀의 경우 연결을 여러개 만들어 놓고 사용하기 때문에 많은 사용자가 접속하는 어플리케이션(웹 또는 기타)일 때 단일 연결일때 보다 속도 향상을 가져온다고 한다.

 

createPool을 사용하여 커넥션 풀을 생성하며

 

필요할 때 마다 연결을 생성하고 그 안에서 쿼리를 하는 형태이다.

 

connection.query는 단일 연결에서 사용한 것과 사용방법이 동일 하므로 설명을 생략 한다.

 

다른 점은 커넥션이 종료 되는 것이 아기 때문에 쿼리가 완료되면 end가 아니라 release(connection.release())를 한다.

 

 

|

댓글 2개

감사합니다.~
저는 nodejs에서 mysql을 쓰기가 조금 꺼려지더라구요.

좋아요+스크랩 해갑니다.~
좋은정보 감사합니다~

댓글 작성

댓글을 작성하시려면 로그인이 필요합니다.

로그인하기
🐛 버그신고