🌲 NESOY

Nodejs MySQL 연결하기

3 min read

Nodejs MySQL

MySQL

  • npm install mysql

Connection(커넥션)

  • mysql.createConnection(DATABASE_CONFIG)
  • host,port : DBMS 주소와 포트(Default 3306)
  • user, password
  • database
  • multipleStatements : 동시에 여러 SQL 실행. 보안에 주의
  • connectTimeout : DBMS 연결 타임 아웃 시간. Default 10,000 ms
  • connect : 연결
  • end : 연결 종료
  • query : SQL문 실행시 커넥션 자동 연결
connection.connect(function(err){
  if(err){
    console.error('error connecting'+err.stack);
    return;
  }
  connection.end();
})

Connection Pool

  • 다수의 Connection 관리 기법
  • Pool에서 Connection 얻어서 사용하고 Pool에 반납
  • mysql.createPool(option)
  • waitForConnections : 풀에 여유 커넥션이 없는 경우 대기 여부
  • connectionLimit : 최대 커넥션 개수, 기본 10개
var mysql = require('mysql');
 
var dbConfig = {
   host: 'localhost',
   user: 'root',
   password: '1234',
   port: 3306,
   database: 'nelp'
   connectionLimit : 50
};
 
var pool = mysql.createPool(dbConfig);
// Get Connection in Pool
pool.getConnection(function(err,connection){
  if(!err){
    //connected!
  }
  // 커넥션을 풀에 반환
  connection.release();
});

SQL 실행

  • connection.query(sql,callback);
  • affectedRow : 영향을 받은 열의 개수
  • insertID : 새로 추가한 경우 Primary Key
  • changedRow : 변경된 열의 수
  • placeholder

SQL Injection 방지

  • mysql.escape()
  • placeholder 사용하기

Transcation

  • conn.beginTransaction(CB);
  • conn.commit(); : Transcation 변경 확정
  • conn.rollback(); : Transcation 복구

Sequelize

  • ORM : 객체와 모델의 Mapping
  • Promise 기반
  • npm install sequelize

사용하기

  • 데이터베이스 연결 설정
  • 모델 설정
  • 모델을 이용해서 데이터 저장
  • 모델에서 데이터 얻어오기
  • 모델을 이용해서 데이터 수정/삭제

연결설정

  • new Sequelize(uri, option)
  • dialect : 데이터베이스 종류
  • host,port
  • pool : 커넥션 풀 설정

Local Connection

var Sequelize = require('sequelize');
var sequelize = new Sequelize('nelp', 'root', 'csedbadmin');

Remote Host Connection Pool

var Sequelize = require('sequelize');
var sequelize = new Sequelize('nelp', 'root', 'csedbadmin',{
  dialect:'mysql',
  host:'RDB_ADDRESS',
  port:3306,
 
  pool:{
    max:10,
    min:0,
    idle:10000
  }
});

Model Define

  • sequelize.define('name',{attributes}, {options})
var User = sequelize.define('user', {
        sso_id: {type: Sequelize.STRING, primaryKey: true},
        account_bank: {type: Sequelize.STRING},
        account_number: {type: Sequelize.STRING},
        name: {type: Sequelize.STRING},
        password: {type: Sequelize.STRING}
    }, {
        freezeTableName: true, // Table이름이 변경된다면 이 옵션을 주면 해결할 수 있다.
        timestamps: false,  //  timestamp Default Value가 true이므로 자동으로 입력되는 경우가 있는데 false를 통해 제거 할 수 있다.
    }
);

Model Create

User.create({
       sso_id: 'testNodejs',
       account_bank: 'testNodejs',
       account_number: 'testNodejs',
       name:'testNodejs',
       password:'testNodejs'
}).then(resolved,rejected);
  • 결과 화면

Model Read

User.findAll({
      attributes: ['sso_id','account_bank'],
      where:{
          sso_id:'testNodejs'
      }
 
}).then(resolved,rejected);

Model Update

User.update({
        sso_id: 'testNodejsUpdate',
    },{
        where:{
            sso_id:'testNodejs'
        }
}).then(resolved,rejected);

Model DELETE

User.destroy({
       where:{
           sso_id:'testNodejsUpdate'
       }
   }).then(resolved,rejected);

Graph View