sequelize transaction - boostcamp-2020/IssueTracker-14 GitHub Wiki

sequelize transaction

Issue 생성시 assignee, label, milestone과 같은 다른 table에도 동시에 생성 쿼리를 날려줘야 해서 transaction을 사용했다.

const createIssue = async (req, res) => {
  const t = await db.sequelize.transaction();
  try {
    const {
      title,
      description,
      milestoneid,
      assigneeIdList,
      labelIdList,
    } = req.body;
    const { id: authorid } = req.user;

    const { id: issueid } = await IssueModel.create(
      {
        title,
        description,
        authorid,
        milestoneid,
        status: "open",
      },
      { transaction: t }
    );

    await AssigneeModel.bulkCreate(
      JSON.parse(assigneeIdList).map((userid) => {
        return { issueid, userid };
      }),
      { transaction: t }
    );

    await LabelHasIssueModel.bulkCreate(
      JSON.parse(labelIdList).map((labelid) => {
        return { issueid, labelid };
      }),
      { transaction: t }
    );
    await t.commit();
    return res.status(200).json({ message: "success" });
  } catch (error) {
    await t.rollback();
    return res.status(400).json({ message: "fail", error: error.message });
  }
};

JSON.parse

req.bdoy로 배열을 받을 시 string으로 들어오기 때문에 JSON.parse()를 통해 파싱해줘야 한다.

bulkCreate

객체들의 배열을 통해 bulkCreate 메소드를 사용할 수 있다.

transaction option

transaction에 포함되는 쿼리들을 {transaction: t}와 같이 옵션을 줘야 한다.

rollback이 되지 않는 에러

labelId로 없는 값을 넣었을 때 rollback()이 되어야 하는데 되지 않는 경우가 발생했다. 모든 쿼리에 await 설정을 해줘야 하는데 그렇지 않아서 생긴 오류였다. 비동기 로직에 await, async를 쓸 경우 유의해야 한다.