AWS RDS를 생성했다면, 사용해보자

AWS에서 RDS를 생성하고 설정했다면,
Node로 사용해보도록하자.
우선은, mysql2 패키지 모듈을 설치한다.
참, RDS편에서 상세한 설정 내용은 생략했지만,
RDS에서 설정한 데이터베이스 모듈을 설치한다고 생각하자.
mysql(aurora가 아니다.)을 설정했으니 모듈도 mysql로 설치한다.

const mysql = require('mysql2');

npm의 공식 사이트에 들어가면 모듈에 대한 설명을 찾아볼 수 있다.
mysql2를 검색해보면 어떻게 사용할 수 있는지 세세하게 나오는데
오늘 정리할 것은 createPool 메서드를 사용하는 것이다.
pool은 내 프로젝트와 RDS를 연결해주는 역할을 한다.

const pool = mysql.createPool({
    host: "", // RDS DB 엔드포인트
    user: "admin",
    password: "",
    port: 3306,
    database: "db_test",
  });

위 예시를 보면 host에는 RDS DB 엔드포인트가 들어가고
user, pw, port는 전부 RDS 생성할 때 설정한 내용이다.
database는 없다면 처음엔 공란으로 시작하고
RDS생성할 때 추가사항에서 처음 생성시 DB 생성을 설정했다면
해당 이름을 넣어주면 된다.
이렇게 하면 이제 내 프로젝트와 RDS는 연결 된 것이다.

pool을 사용해보자

RDS와 연결이 됐다면 이제 본격적으로 사용해보자
DB에 뭔가를 하기 위해선 음, CRUD 작업 등을 하기 위해선
query 메서드를 사용해야 한다.
pool의 query함수는 이렇게 작성한다.

pool.query(`SQL문`, function(err, res, fields){
    console.log(res);
    };
);

그럼 RDS의 DB에 해당 SQL문을 적용시키고
이때 err은 에러, res는 결과, fields는 필드를 나타낸다.

DB 생성과 테이블 생성

pool의 모습을 정리했으니 이제 코드로만 정리하고자 한다.

// db talbe 생성
pool.query(`create table notes(
  uuid BINARY(16) DEFAULT (UUID_TO_BIN(UUID())),
  title VARCHAR(255) NOT NULL,
  contents TEXT NOT NULL,
  created TIMESTAMP NOT NULL DEFAULT NOW()
);`, function (err, results, fields) {
  console.log(results);
});

// db 내용 추가
pool.query(`insert into notes(title, contents) values('My First Note', 'A note about something'), ('My Second Note', 'A note about something else');`, function (err, results, fields) {
  console.log(results);
});

pool CRUD함수 구현

// select 함수 만들기
function getNotes(){
    pool.query(`select BIN_TO_UUID(uuid,true) as uuid,title,contents,created from notes`, function (err, results, fields) {
    console.log(results);
    });
}

// select 함수2 만들기
function getNote(uuid){
    pool.query(`select BIN_TO_UUID(uuid,true) as uuid,title,contents,created from notes where uuid=UUID_TO_BIN('${uuid}', 1);`, function (err, results, fields) {
    // console.log(results); // 복수로 가져온다. 배열처럼 [{}] 이렇게 가져온다.
    console.log(...results); // 단수로 가져온다. {} 이렇게 가져온다.
    });
};

// insert 함수 만들기
function addNotes(title,contents){
    pool.query(`insert into notes(title, contents) values('${title}','${contents}');`, function (err, results, fields) {
    console.log(results);
    });
};

// update 함수 만들기
function updateNotes(uuid,title,contents){
    pool.query(`update notes set title='${title}', contents='${contents}' where uuid=UUID_TO_BIN('${uuid}', 1);`, function (err, results, fields) {
    console.log(results);
    });
}

// delete 함수 만들기
function deleteNotes(uuid){
    pool.query(`delete from notes where uuid=UUID_TO_BIN('${uuid}', 1);`, function (err, results, fields) {
    console.log(results);
    });
}