| sitelink1 | https://blog.naver.com/n_jihyeon/221806066778 |
|---|---|
| sitelink2 | https://www.npmjs.com/package/mysql2 |
| sitelink3 | |
| extra_vars4 | |
| extra_vars5 | |
| extra_vars6 |
mysql 모듈 예제
/** * History
* author date content
* ===============================================
* OOO 19-03-23 유일키 조회 API 최초 생성
* OOO 19-05-19 유일키 선택 후 사용여부 Y로 변경
* ===============================================
* @params token
* @기능 유일키 조회 및 상태 변경
*/
saleApi.get("/api/buyMemo", tokenHandler.verifyToken, (req, res) => {
// 토큰 유효성 검사
const token = req.query.token;
req.tokenContent = tokenHandler.verifyData(token);
// token error
if (req.tokenContent.errCode != errCode.OK) {
res.status(errCode.OK);
res.json(req.tokenContent);
return;
}
const pool = carrotCommon.getConnectionPool();
pool.getConnection((err, connection) => {
// DB connection error
if (err) {
res.status(errCode.Ok);
res.json(errorHandler.ConnectionErrorHandler(err, connection));
return;
}
connection.beginTransaction(err => { /* transaction 에러 처리 */ if (err) {
res.status(errCode.OK);
res.json(errorHandler.TransactionErrorHandler(err, connection));
return;
}
const query1 = " SELECT UNIQ_KEY as uniqKey " + " , UNIQ_KEY_ID as uniqKeyId " + " FROM DEPOSIT_UNIQUE_KEY " + " WHERE IS_USED = 'N' " + " LIMIT 1 ";
connection.query(query1, (err, rows) => {
// SQL error
if (err) {
res.status(errCode.OK);
res.json(errorHandler.QueryErrorHandler(err, connection));
return;
}
if (rows.length == 0) {
res.status(errCode.OK);
res.json({
errCode: errCode.NOTFOUND,
msg: "사용 가능한 입금키가 없습니다."
});
return;
}
let uniqueKey = rows[0].uniqKey;
let uniqueKeyId = rows[0].uniqKeyId;
const query2 = " UPDATE DEPOSIT_UNIQUE_KEY " + " SET IS_USED = 'Y' " + " WHERE UNIQ_KEY_ID = ? ";
connection.query(query2, uniqueKeyId, (err, result) => {
// SQL error
if (err) {
// 실패시 rollback
connection.rollback(err => {
// Rollback error
if (err) {
res.status(errCode.OK);
res.json(errorHandler.TransactionErrorHandler(err, connection));
return;
}
res.status(errCode.OK);
res.json({
errCode: errCode.OK,
msg: "ROLLBACK 완료"
});
return;
});
res.status(errCode.OK);
res.json(errorHandler.QueryErrorHandler(err, connection));
return;
}
if (result.affectedRows > 0) {
connection.commit(err => {
if (err) {
res.status(errCode.OK);
res.json(errorHandler.TransactionErrorHandler(err, connection));
connection.rollback(err => {
res.status(errCode.OK);
res.json(errorHandler.TransactionErrorHandler(err, connection));
return;
});
}
});
res.status(errCode.OK);
res.json({
errCode: errCode.OK,
uniqueKey: uniqueKey,
uniqueKeyId: uniqueKeyId
});
return;
} else {
res.status(errCode.OK);
res.json({
errCode: errCode.UPDATEERROR,
msg: "입금키 업데이트에 실패하였습니다."
});
return;
}
});
});
});
connection.release();
});
});
mysql2 모듈 예제
// uploadStrategy 는 file 처리를 위한 multer 모듈 사용으로 추가된 코드입니다!
router.post("/api/restaurant", uploadStrategy, asyncHandler(async(req, res, next) => {
let file = req.file;
if (!file) {
res.status(errCode.OK).json({
errCode: errCode.BADREQUEST,
msg: "file이 없습니다."
});
return;
} /* file 처리 로직 생략 */
const params = req.body.params;
/* input 검증 */
if (...) {
// ...
return;
}
const connection = await pool.getConnection();
await connection.beginTransaction();
let resId try {
const queryString01 = " SELECT UUID() as uuid";
let result = await connection.query(queryString01);
if (result[0].length < 1) {
throw new Error('uuid was not created');
}
resId = result[0][0].uuid
// 'result[0][0]' looks like wired, but this library returns a tuple when the result of query is a one records.
// So if we want just the first record of the result, we can access it with result[0][0].
const queryString02 = `INSERT INTO RESTAURANT ( ... ) VALUES ( ... )`;
let qureyParam02 = [...]const result02 = await connection.execute(queryString02, qureyParam02)if (result02[0].affectedRows == 0) {
throw new Error('affectedRows is zero where restaurant table')
}
if (result02[0].affectedRows == 1) {
console.log('successfully inserted into restaurant');
}
const queryString03 = `INSERT INTO MENU ( ... ) VALUES ( ... )`;
const result03 = await connection.execute(queryString03, [resId])if (result03[0].affectedRows == 0) {
throw new Error('affectedRows is zero where menu table')
}
if (result03[0].affectedRows == 1) {
console.log('successfully inserted into menu');
}
await connection.commit();
res.status(errCode.OK).json({
errCode: errCode.OK,
msg: "글 등록 완료"
});
} catch (err) {
await connection.rollback();
res.status(errCode.OK)res.json({
errCode: errCode.SERVERERROR,
msg: "식당 정보 등록에 실패하였습니다."
});
throw err;
}
finally {
connection.release();
}
}));
mysql2 모듈 사용시 주의점
1. query 의 실행 결과의 데이터 타입에서 select문 실행으로 record 길이가 1인 결과를 return 하는 경우 데이터 타입을 tuple 로 return함
> const [rows, fields]로 선언후 row를 받던가, const result 로 선언 후 result[0][0] 로 rows 에 접근하면 됨
2. mysql2 에서는 pool.query() 함수로 select문만 실행 가능하며, 조회가 아닌 쿼리들은 pool.execute()로만 실행 가능 (select 문도 execute로 실행 가능)
