🎯 주문 API를 설계하고 코드로 구현합니다.

📙 Today I Learned

데이터베이스 설계

Table orders

id integer [primary key]
book_title varchar
total_quantity integer
total_price integer
created_at timestamp
user_id integer
delivery_id integer

Table orderedBooks

id integer [primary key]
order_id integer
book_id integer
quantity integer

Table deliveries

id integer [primary key]
address varchar
receiver varchar
contact varchar

SQL 데이터 PK 가져오기

특정 테이블에서 현재 존재하는 가장 큰 PK 값을 가져옵니다.

SELECT MAX(칼럼명) FROM 테이블이름;

🤔 왜 Last_insert_id()는 사용하지 않을까?

SELECT Last_insert_id();

❌ 한 세션에서만 작동 : 다른 사용자가 INSERT한 데이터는 보이지 않게 됩니다.
( 세션 : DB와 연결된 각각의 사용자(클라이언트)가 가진 독립적인 연결 정보 )

❌ 동시성 문제 발생 가능 : A 사용자가 INSERT INTO orders를 실행하면 LAST_INSERT_ID()는 A가 추가한 행의 ID만 반환됩니다.

❌ 테이블을 지정할 수 없음

코드에서는 result값의 inserId 값을 활용해서 PK를 가져옵니다.

---

주문(결제) API 설계

주문하기

• Method : POST

• URL : /orders

• HTTP Status Code : 200 Ok

• Request Body

{
  "item": [
    {
    	"cartItemId" : 장바구니 도서 id,
      	"bookId" : 도서 id,
      	"quantity" : 수량
    },
    {
    	"cartItemId" : 장바구니 도서 id,
      	"bookId" : 도서 id,
      	"quantity" : 수량
    }  
  ],
  "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 : x

• Response Body :

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

주문 상세 조회

• Method : GET

• URL : /orders/:id

• HTTP Status Code : 200 Ok

• Request Body : x

• Response Body :

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

---

OrderController.js

const conn = require('../mariadb');
const { StatusCodes } = require('http-status-codes');

const order = (req, res) => {
  const { items, delivery, totalQuantity, totalPrice, userId, firstBookTitle } =
    req.body;

  let deliveryId;
  let orderId;
  let sql =
    'INSERT INTO deliveries (address, receiver, contact) VALUES (?, ?, ?)';

  let values = [delivery.address, delivery.receiver, delivery.contact];
  conn.query(sql, values, (err, result) => {
    if (err) {
      console.log(err);
      return res.status(StatusCodes.BAD_REQUEST).end();
    }
    deliveryId = result.insertId;

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

  sql =
    'INSERT INTO orders (book_title, total_quantity, total_price, user_id, delivery_id) VALUES (?, ?, ?, ?, ?)';

  values = [firstBookTitle, totalQuantity, totalPrice, userId, deliveryId];

  conn.query(sql, values, (err, result) => {
    if (err) {
      console.log(err);
      return res.status(StatusCodes.BAD_REQUEST).end();
    }
    orderId = result.insertId;

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

  sql = 'INSERT INTO orderedBooks (order_id, book_id, quantity) VALUES ?';
  values = [];
  items.forEach((item) => {
    values.push([orderId, item.bookId, item.quantity]);
  });
  conn.query(sql, [values], (err, result) => {
    if (err) {
      console.log(err);
      return res.status(StatusCodes.BAD_REQUEST).end();
    }

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

• order : 주문 데이터를 DB에 저장하는 함수

  • deliveries 테이블에 배송 정보를 저장합니다.

    • deliveryId = result.insertId; 로 삽입한 배송 데이터의 PK를 가져옵니다.

  • orders 테이블에 주문 정보를 저장합니다.

    • orderId = result.insertId; 로 삽입한 주문 데이터의 PK를 가져옵니다.

  • orderedBooks 테이블에 주문된 책 목록을 저장합니다.

    • items 배열을 순회하면서 [orderId, bookId, quantity] 형식으로 저장합니다.

---

✏️ 한 줄 회고

한 함수에서 여러 개의 SQL 문을 실행하는 과정에서, VALUES를 2차원 배열로 전달하는 방식을 처음 적용해서 헷갈렸지만, SQL 문을 효율적으로 구성하는 법을 익힐 수 있어 좋았습니다.