mysql(2😁) query async/await

프로젝트 진행하면서 다른 함수들은 다 async/await으로 비동기처리를 하였는데, 쿼리문은 그렇게 하지 않고 콜백지옥을 구현하고 있었다. 너무 기계적으로 코딩하지 않았나 싶은 생각이 들었다.

version 1

const sql_team_no = 'select max(team_no) as newTeam from travel_with;'
       
        conn.query(sql_team_no, async function(err, data){
            if(err){
                console.log(err)
                return res.send('failed to get new team number')
            }
            else{
              
              ~~~
                
                const sql = 'insert into travel_with set ?;'
                        conn.query(sql, params, function(err, data){
                            if(err){
                                console.log(err)
                                return res.status(statusCode.OK).send(util.fail(statusCode.INTERNAL_SERVER_ERROR, responseMessage.QUERY_ERROR, 
                                    "failed to store new plan (existed user in travel_with table)"))
                            }else{

위와 같은 구조의 문제점이 무엇이라고 생각하나...

sql을 실현하고 만약에 err가 난다면 err에 해당하는 response를 리턴한다.
그렇게 되면 해당 함수에서 빠져나오게 되는데, 그렇게 빠져나오면 어디로 가나.
바로 위에 보면 sql_team_no 쿼리를 실현하는 함수로 간다.
그러면? 리턴을 두번한다
그렇게 되면 Error: Can't render headers after they are sent to the client. 와 같은 서버 개발자들이 많이 겪는 에러를 보게 된다.
나는 처음에 내가 try catch를 잘 못 이해하고 있나...? 에러가 생기면 catch로 가야 하는데 if(err) 여기서 걸려서 response를 두번 해서 오류가 생기는건가??

아니다... 그냥 앞서 말한것이 잘못이었다. 함수를 나와도 또 함수안에 걸리기 때문에...

결국 비동기처리를 내가 못한것이었다.

그럼 어떻게 해야할까

version 2

const connection = await mysql.createConnection(conn.db_info);

      
const locationResult = await getLocation(latlng)
const country_code = locationResult.data.plus_code.global_code // country code ex)87G8M376+PJ - koera
const country = country_code.slice(0,4);

const sql = `select * from travel_with where region_info like '${country}%' and isfinished = '0';` 
const result = await connection.query(sql)
AWS.config.update(userConfig.aws_iam_info);
const docClient = new AWS.DynamoDB.DocumentClient();

위와 같이 쿼리문을 async/await 으로 처리를 해야 response를 해도 또 다시 함수안에 갇히는 그런 불상사가 일어나지 않는다.

어? 나는 nodejs 에서 mysql 모듈을 사용하려고 해도 async/await 처리가 안되던데...? 라고 생각하는 경우가 있을 수 있다. 나 또한 기존에 사용했던 모듈로는 async/await를 처리 하지 못해서 뭐지? 라는 생각을 했었다.

mysql vs mysql2

👀 mysql2 모듈을 사용해야 한다.
즉, mysql은 콜백기반이고, mysql2은 promise객체 사용이 가능하다.

mysql은 콜백기반이기 때문에 promise객체를 사용하기 위해서는 promise-mysql 모듈을 사용해야 한다. 하지만 mysql2은 다른 모듈 필요없이 promise 객체 사용이 가능하다.

그러하다... 그래서 결국은 mysql2를 통해서 promise객체를 사용하여 오류를 해결할 수 있었다. 앞으로 mysql 모듈은 사용하지 않을듯...^^ 무조건 mysql2 👋