🎯 주문 API를 promise를 활용하여 구현합니다.

📙 Today I Learned

MYSQL 데이터 삭제 방법

DELETE

조건이 있으면 해당 조건에 맞는 행만 삭제되며, 조건이 없으면 모든 행이 삭제됩니다.

DELETE FROM 테이블명 (WHERE 조건);

DROP

테이블을 삭제합니다.

DROP TABLE 테이블명;

TRUNCATE

모든 행이 삭제되지만, 테이블 구조는 유지됩니다.

AUTO_INCREMENT 값을 초기화합니다.

TRUNCATE TABLE 테이블명;

⚠️ 발생한 오류

orderedBooks 테이블의 데이터를 삭제하고, orders 테이블의 데이터도 삭제하고자 하였을 때, 외래키 제약 조건이 설정된 테이블에는 삭제 명령어를 쓸 수 없다는 오류였습니다.

Error Code: 1701. Cannot truncate a table referenced in a foreign key constraint (`Bookshop`.`orderedBooks`, CONSTRAINT `fk_orderedBooks_orders_id` FOREIGN KEY (`order_id`) REFERENCES `Bookshop`.`orders` (`id`))	

💡 해결 방안

외래 키 제약 조건을 일시적으로 비활성화를 해줍니다.

SET FOREIGN_KEY_CHECKS = 0;

그리고 다시 orders 테이블의 데이터를 삭제하고 다시 외래 키 제약 조건을 활성화 해줍니다.

TRUNCATE TABLE orders;
SET FOREIGN_KEY_CHECKS = 1;

출처:

---

주문(결제) API 설계

주문하기

• Method : POST

• URL : /orders

• HTTP Status Code : 200 Ok

• Request Body

{
  "items": [ 장바구니 도서 id, 장바구니 도서 id, ...],
  "delivery" : {
    	"address" : "주소",
    	"receiver" : "이름",
    	"contact" : "전화번호"
  },
  "totalQuantity" : 총 수량,
  "totalPrice" : 총 금액,
  "userId" : 유저 아이디
  "firstbookTitle" : "대표 도서 제목"
}

• Response Body : x

• TODO : 현재는 토큰으로 하지 않고, userId를 body값으로 받아서 처리

주문 목록 조회

• Method : GET

• URL : /orders

• HTTP Status Code : 200 Ok

• Request Body :

"userId" : 유저 아이디

• Response Body :

[
  {
    "order_id" : 주문 id,
  	"created_at" : "주문일자",
    "address" : "주소",
    "receiver" : "이름",
    "contact" : "전화번호",
  	"book_title" : "대표 책 제목",
    "total_quantity" : 총 수량,
  	"total_price" : 결제 금액,

  },
  {
    "order_id" : 주문 id,
  	"created_at" : "주문일자",
    "address" : "주소",
    "receiver" : "이름",
    "contact" : "전화번호",
  	"book_title" : "대표 책 제목",
  	"total_quantity" : 총 수량,
    "total_price" : 결제 금액,
  },
  ...
]

• TODO : 현재는 토큰으로 하지 않고, userId를 body값으로 받아서 처리

주문 상세 조회

• Method : GET

• URL : /orders/:id

• HTTP Status Code : 200 Ok

• Request Body : x

• Response Body :

[
  {
    "book_id" : 도서 id,
    "title" : "도서 제목",
    "author" : "작가",
    "price" : 가격,
    "quantity" : 수량
  },
  {
    "book_id" : 도서 id,
    "title" : "도서 제목",
    "author" : "작가",
    "price" : 가격,
    "quantity" : 수량
  },
  ...
]

---

OrderController.js

const mysql = require('mysql2/promise');
const { StatusCodes } = require('http-status-codes');

const order = async (req, res) => {
  const conn = await mysql.createConnection({
    host: 'localhost',
    user: 'root',
    password: 'root',
    database: 'Bookshop',
    dateStrings: true,
  });

  const { items, delivery, totalQuantity, totalPrice, userId, firstBookTitle } =
    req.body;

  let sql =
    'INSERT INTO deliveries (address, receiver, contact) VALUES (?, ?, ?)';
  let values = [delivery.address, delivery.receiver, delivery.contact];
  let [result] = await conn.execute(sql, values);
  const deliveryId = result.insertId;

  sql =
    'INSERT INTO orders (book_title, total_quantity, total_price, user_id, delivery_id) VALUES (?, ?, ?, ?, ?)';
  values = [firstBookTitle, totalQuantity, totalPrice, userId, deliveryId];
  [result] = await conn.execute(sql, values);
  const orderId = result.insertId;

  sql = 'SELECT book_id, quantity FROM cartItems WHERE id IN (?)';
  [orderItems, fields] = await conn.query(sql, [items]);

  sql = 'INSERT INTO orderedBooks (order_id, book_id, quantity) VALUES ?';
  values = [];
  orderItems.forEach((item) => {
    console.log(item);
    values.push([orderId, item.book_id, item.quantity]);
  });

  result = await conn.query(sql, [values]);

  result = await deleteCartItems(conn, items);

  return res.status(StatusCodes.CREATED).json(result[0]);
};

const deleteCartItems = async (conn, items) => {
  let sql = `DELETE FROM cartItems WHERE id IN (?)`;

  let result = await conn.query(sql, [items]);
  return result;
};

const getOrders = async (req, res) => {
  const conn = await mysql.createConnection({
    host: 'localhost',
    user: 'root',
    password: 'root',
    database: 'Bookshop',
    dateStrings: true,
  });

  let sql =
    'SELECT orders.id, created_at, address, receiver, contact, book_title, total_quantity, total_price FROM orders LEFT JOIN deliveries ON orders.delivery_id = deliveries.id';
  let [rows, fields] = await conn.query(sql);
  return res.status(StatusCodes.OK).json(rows);
};

const getOrderDetail = async (req, res) => {
  const id = parseInt(req.params.id);
  const conn = await mysql.createConnection({
    host: 'localhost',
    user: 'root',
    password: 'root',
    database: 'Bookshop',
    dateStrings: true,
  });

  let sql =
    'SELECT book_id, title, author, price, quantity FROM orderedBooks LEFT JOIN books ON orderedBooks.book_id = books.id WHERE order_id = ?';
  let [rows, fields] = await conn.query(sql, id);
  return res.status(StatusCodes.OK).json(rows);
};

• order : 주문 정보를 삽입하고, 장바구니에서 주문 목록을 삭제합니다.

  • 배송 정보 INSERT
  • 주문 정보 INSERT
  • 주문한 책 목록 SELECT
  • 장바구니에서 주문한 항목 DELETE

• getOrders : orders 테이블과 deliveries 테이블을 JOIN 해서 배송 정보를 가져옵니다.

• gerOrderDetail : orderedBooks 테이블과 books 테이블을 JOIN 해서 주문에 포함된 도서 정보를 가져옵니다.

---

✏️ 한 줄 회고

DB 연결 객체(conn)가 계속 재사용되다 보니, 코드 구조를 정리하고 리팩토링의 필요성을 느꼈습니다.