Promise Async

앞서 Promise와 Async는 포스팅한 적이 있으니
자세한 설명은 생략하고 4편에서 작성한 코드를 살펴보면
문제점이 하나 있다는 것을 알 수 있다.

해당 라이브러리는 mysql에서 requset(SQL문)를 전달하고
SQL문을 받는 동안까지 기다림의 시간을 Promise로 처리를 했는데
그 처리에 대한 return값을 함수가 제대로 받지 못하는 것이다.
여기서 Promise로 처리했다는 말이 무슨 말이냐면
콜백함수처리했다는 말이다. funcion(err,req,fields){}; 이 부분!
함수를 만들어서 그 안에 pool.query를 통해 SQL문을 요청하고,
바로 콜백함수가 나오게 처리했다는 말이다.

문제는 콜백함수가 반환될 때까지 시간이 걸린다는 것인데
왜 문제냐면 pool.query문 뒤로 console.log(“vlavla”)가 있어도
console.log가 먼저 나오고 쿼리 결과가 출력되기 때문이다.
우리는 원하는 때에 원하는게 동작되기를 원한다.

이를 위한 방법으론 Promise로 처리를 하든지
Async/Await을 써서 해결하는 것이다.

JavaScript의 동작과정은 CALL STACK과
MICROTASK QUEUE, MACROTASK QUEUE가 존재하는데
MICROTASK QUEUE가 먼저 처리되고
MACROTASK QUEUE가 처리되는 방식으로 진행된다.
내가 작성한 mysql 함수는 MICROTASK QUEUE 여기 해당한다.
문제는 console같은 경우는 CALL STACK에 해당돼 바로 처리된다는 것이다.
CALL STACK이 0순위, MICROTASK QUEUE가 1순위,
MACROTASK QUEUE가 2순위인셈이고
결국 우리가 하고자하는 것은 콜스택으로 처리하기 위해
Promise나 Async/Await처리를 하는 것이다.

기존 문법의 수정

Async/Await을 쓰지 않을 때와 사용할 때의 문법 차이는 아래와 같다.

Before

const pool = mysql.createPool({
    host: "",
    user: "admin",
    password: "",
    port: 3306,
    database: "db_name",
  });
function getNotes(){
    pool.query(`select BIN_TO_UUID(uuid,true) as uuid,title,contents,created from notes);`, function (err, results, fields) {
    console.log(results);
    });
};

After

const pool = mysql.createPool({
    host: "",
    user: "admin",
    password: "",
    port: 3306,
    database: "db_name",
  })
  .promise();

export async function getNotes(){
    const [rows] = awit pool.query(`select BIN_TO_UUID(uuid,true) as uuid,title,contents,created from notes);`);
    return rows
};

DB에 대한 풀 쿼리를 정리했다면,
index나 db 풀 쿼리를 사용하고자하는 위치가 있을 것 아닌가
그 곳에 module로 해당 쿼리를 불러오고
사용하면 된다.

import express from "express";
import { getNotesAsync, getNoteAsync, addNotesAsync, updateNoteAsync, deleteNoteAsync } from "./database2.js";

const app = express()
const port = 3000

// body 처리를 위한 미들웨어 설정
app.use(express.json()) // for parsing application/json
app.use(express.urlencoded({ extended: true })) // for parsing application/x-www-form-urlencoded

app.get('/', (req, res) => {
  res.send('Hello World!')
})

app.get('/notes', async (req, res) => {
  const result = await getNotesAsync();
  res.send(result);
});

app.get('/note/:id', async (req, res, next) => {
  try{
    const id = req.params.id;
    if(!id) throw new Error('400@No Path Parameter');
    const result = await getNoteAsync(id);
    if(!result) res.send({});
    if(result.length === 0) res.send({});
    res.send(result[0]);
  }
  catch(err){
    next(err);
  }
});

app.get('/notes', async (req, res, next) => {
  const body = req.body;
  if(!body.title) sendStatus(400);
  if(!body.contents) sendStatus(400);
  const result = await addNotesAsync(body.title, body.contents);
  if(typeof result.affectedRows === "undefined") throw new Error(`400@Not created`);
  if(typeof result.affectedRows !== 1) throw new Error(`400@Not created`);
  res.sendStatus(201);
});

app.use((err, req, res, next) => {
  console.log(err.stack);
  res.status(500).send('Something broke!');
});

app.listen(port, () => {
  console.log(`Example app listening on port ${port}`)
});

body처리

POST를 만들 때, body를 처리하기 위해서는 미들웨어가 필요하다.
Express 공식문서는 이를 위해 두 가지 미들웨어를 추가하라고한다.

app.use(express.json()) // for parsing application/json
app.use(express.urlencoded({ extended: true })) // for parsing application/x-www-form-urlencoded

에러처리

Express 공식문서에 에러 핸들링에 대한 부분도 참고 할 수 있는데
아래처럼 추가해 사용하라 명시한다.

app.use((err, req, res, next) => {
  console.log(err.stack);
  res.status(500).send('Something broke!');
});