[Node.js] Sqlite3

이번에는 Node.js와 Sqlite DB를 연결해보겠습니다.

해당 포스팅은 다음의 튜토리얼을 참고하여 작성하였습니다.

http://www.sqlitetutorial.net/sqlite-nodejs/connect/

우선 npm으로 sqlite 관련 모듈을 설치합니다.

--> npm install sqlite3

다음으로 js 파일을 하나 만들고 다음과 같이 타이핑해봅시다.

let db = new sqlite3.Database(':memory:', (err) => {
  if (err) {
    return console.error(err.message);
  }
  console.log('Connected to the in-memory SQlite database.');
});

우선은 메모리에 있는 DB를 사용하는 부분인데 우선은 요걸로 해보고 직접 구성한 로컬 DB 파일을 가져다 쓰는것도 해보겠습니다.

위의 코드를 실행해보면

위와 같이 뜹니다.

그냥 let db = new sqlite3.Database(':memory:');

이렇게 쓸수도 있습니다만, 연결상태를 확인하기위한 콜백 함수를 지정해서 콘솔창에 뜨는 것을 확인할수 있습니다.

DB를 오픈한 후에는 닫아주는것도 중요합니다.

닫을 때는 db.close(); 이렇게 해주어도 되고 위와 마찬가지로 콜백 함수를 추가해서 다음과같이 정의를 하는것도 좋습니다.

db.close((err) => {
  if (err) {
    return console.error(err.message);
  }
  console.log('Close the database connection.');
});

이제는 이 연결된 DB로 로컬 DB연결과 Select 를 한번 해보겠습니다.

우선 로컬 DB를 연결하기위해서는 ':memory:' 부분을 DB가 있는 경로로 바꿔주시면 됩니다. 예를 들면

('./db/tms.db')

위와같이 코딩을 한다면 db폴더 내에 tms.db를 읽겠다는 의미입니다. 

다음과 같이 코딩해볼까요

const sqlite3 = require('sqlite3').verbose();
 
// open the database
let db = new sqlite3.Database('./db/tms.db', sqlite3.OPEN_READWRITE, (err) => {
  if (err) {
    console.error(err.message);
  }
  console.log('Connected to the tms database.');
});
 
db.serialize(() => {
  db.each(`SELECT LineNo, SectionNo                  
           FROM TB_Tree`, (err, row) => {
    if (err) {
      console.error(err.message);
    }
    console.log(row.LineNo + "\t" + row.SectionNo);
  });
});
 
db.close((err) => {
  if (err) {
    console.error(err.message);
  }
  console.log('Close the database connection.');
});

중간에 db.serialize() 부분을 보시면 

쿼리문이 있고 아래쪽에 콘솔로 찍는 부분이 있습니다.

여기서 주의할점은 콘솔처럼 row의 데이터에 접근하려면 반드시 컬럼명과 row내의 변수명을 맞춰줘야한다는 것입니다.

쿼리에서 LineNo, SectionNo를 명시했으므로

row에서도 참조시에 row.LineNo, row.SectionNo로 명시해야한다는 점입니다.

실행해보면 다음과 같이 표시가 됩니다.