-- 트랜잭션을 시작합니다.
START TRANSACTION;

-- 성공시 작업 내역을 DB에 반영합니다.
COMMIT;

-- 실패시 START TRANSACTION이 실행되기 전 상태로 작업 내역을 취소합니다.
ROLLBACK;

-- SPARTA 테이블을 생성합니다.
CREATE TABLE IF NOT EXISTS SPARTA
(
    spartaId      INT(11)      NOT NULL PRIMARY KEY AUTO_INCREMENT,
    spartaName    VARCHAR(255) NOT NULL,
    spartaAddress VARCHAR(255) NOT NULL
);

-- 1번째 트랜잭션을 실행합니다.
START TRANSACTION;

-- SPARTA 테이블에 더미 데이터 3개를 삽입합니다.
INSERT INTO SPARTA (spartaName, spartaAddress)
VALUES ('SPARTA1', 'SEOUL'),
       ('SPARTA2', 'BUSAN'),
       ('SPARTA3', 'DAEGU');

-- 1번째 트랜잭션을 DB에 적용합니다.
COMMIT;


-- 2번째 트랜잭션을 실행합니다.
START TRANSACTION;

-- SPARTA 테이블에 더미 데이터 3개를 삽입합니다.
INSERT INTO SPARTA (spartaName, spartaAddress)
VALUES ('SPARTA4', 'SEOUL'),
       ('SPARTA5', 'BUSAN'),
       ('SPARTA6', 'DAEGU');

-- 2번째 트랜잭션을 롤백합니다.
ROLLBACK;

const { sequelize } = require("../models/index.js");

// 콜백으로 함수를 할당하여 비즈니스로직을 처리합니다.
const result = await sequelize.transaction( async(t) => {
  // 에러가 발생하면 ROLLBACK
  const user = await User.create({
    firstName: '용우',
    lastName: '이',
  }, { transaction: t }); // 해당 쿼리에 트랜잭션을 적용합니다.

  return user;
});

const { sequelize } = require("../models/index.js");

// Sequelize의 트랜잭션을 변수에 할당하여 트랜잭션을 시작합니다.
const t = await sequelize.transaction();

try {
  const user = await User.create({
    firstName: '용우',
    lastName: '이',
  }, { transaction: t }); // 해당 쿼리에 트랜잭션을 적용합니다.

  // 분기마다 COMMIT, ROLLBACK이 가능하다.

  // 트랜잭션을 사용한 모든 로직을 Commit, DB에 반영합니다.
  await t.commit();
} catch(transactionError) {
  // 에러가 발생하였다면, 트랜잭션을 사용한 모든 쿼리를 Rollback, DB에 반영하지 않습니다.
  await t.rollback();
}

// 회원가입 API
router.post('/users', async (req, res) => {
  const { email, password, name, age, gender, profileIamge } = req.body;

  // 1. 동일한 이용자가 있는지 확인
  const isExistUser = await Users.findOne({
    where: {
      email,
    },
  });

  // email과 동일 유저가 있는 경우 에러
  if (isExistUser) {
    return res.status(409).json({
      message: '이미 존재하는 이메일입니다.',
    });
  }

  // 1. 트랜잭션 객체를 할당 Models에 있는 index.js에서 가져옴.
  const t = await sequelize.transaction({
    // 격리 수준 설정
    isolationLevel: Transaction.ISOLATION_LEVELS.READ_COMMITTED,
  });

  try {
    // 사용자 테이블에 데이터 삽입
    const user = await Users.create(
      { email, password },
      { transaction: t } // 트랜잭션 할당
    );

    // 사용자 정보 테이블에 데이터 삽입
    // 어떤 사용자의 정보인지 내용이 필요
    await UserInfos.create(
      {
        UserId: user.userId, // 현재 사용자 정보가 24번째 줄에서 생성된 사용자의 userId를 할당
        name,
        age,
        gender,
        profileIamge,
      },
      { transaction: t } // 트랜잭션 할당
    );

    // 모든 로직이 완료된 경우
    await t.commit();
  } catch (transactionError) {
    // 트랜잭션 내 작업 실패한 경우
    await t.rollback();
    return res.status(400).json({ errorMessage: '유저 생성에 실패했습니다.' });
  }

  return res.status(201).json({ message: '회원가입이 완료되었습니다.' });
});

Executing (b839f436-3f3c-4c08-a633-a852b55f82c1): SET TRANSACTION ISOLATION LEVEL READ COMMITTED;
Executing (b839f436-3f3c-4c08-a633-a852b55f82c1): START TRANSACTION;
Executing (b839f436-3f3c-4c08-a633-a852b55f82c1): INSERT INTO `Users` (`userId`,`email`,`password`,`createdAt`,`updatedAt`) VALUES (DEFAULT,?,?,?,?);
Executing (b839f436-3f3c-4c08-a633-a852b55f82c1): INSERT INTO `UserInfos` (`userInfoId`,`UserId`,`name`,`age`,`gender`,`createdAt`,`updatedAt`) VALUES (DEFAULT,?,?,?,?,?,?);
Executing (b839f436-3f3c-4c08-a633-a852b55f82c1): COMMIT;

Executing (649f8232-6820-4cc2-b726-42842f22d79a): SET TRANSACTION ISOLATION LEVEL READ COMMITTED;
Executing (649f8232-6820-4cc2-b726-42842f22d79a): START TRANSACTION;
Executing (649f8232-6820-4cc2-b726-42842f22d79a): INSERT INTO `Users` (`userId`,`email`,`password`,`createdAt`,`updatedAt`) VALUES (DEFAULT,?,?,?,?);
Executing (649f8232-6820-4cc2-b726-42842f22d79a): ROLLBACK;

const { Transaction } = require("sequelize");

const t = await sequelize.transaction({
  isolationLevel: Transaction.ISOLATION_LEVELS.READ_COMMITTED, // 트랜잭션 격리 수준을 설정합니다.
});

await queryInterface.createTable('UserHistories', {
      userHistoryId: {
        allowNull: false, // NOT NULL
        primaryKey: true, // Primary Key (기본키)
        type: Sequelize.UUID, // UUID의 최댓값으로 타입을 지정합니다.
        defaultValue: Sequelize.UUIDV4, // UUID를 기본 값으로 설정합니다.
      },
      UserId: {
        allowNull: false, // NOT NULL
        type: Sequelize.INTEGER,
        references: {
          model: 'Users', // Users 모델을 참조합니다.
          key: 'userId', // Users 모델의 userId를 참조합니다.
        },
        onDelete: 'CASCADE', // 만약 Users 모델의 userId가 삭제되면, UserHistories 모델의 데이터가 삭제됩니다.
      },
      beforeName: {
        allowNull: false, // NOT NULL
        type: Sequelize.STRING,
      },
      afterName: {
        allowNull: false, // NOT NULL
        type: Sequelize.STRING,
      }
    });
  },

// userhistories.js
'use strict';
const { Model } = require('sequelize');
const Sequelize = require('sequelize');
module.exports = (sequelize, DataTypes) => {
  class UserHistories extends Model {
    /**
     * Helper method for defining associations.
     * This method is not a part of Sequelize lifecycle.
     * The `models/index` file will call this method automatically.
     */
    static associate(models) {
      // define association here

      // 1. UserHistories 모델에서
      this.belongsTo(models.Users, { // 2. Users 모델에게 N:1 관계 설정을 합니다.
        targetKey: 'userId', // 3. Users 모델의 userId 컬럼을
        foreignKey: 'UserId', // 4. UserHistories 모델의 UserId 컬럼과 연결합니다.
      });
    }
  }

  UserHistories.init(
    {
      userHistoryId: {
        allowNull: false, // NOT NULL
        primaryKey: true, // Primary Key (기본키)
        type: Sequelize.UUID, // UUID의 최댓값으로 타입을 지정합니다.
        defaultValue: Sequelize.UUIDV4, // UUID를 기본 값으로 설정합니다.
      },
      UserId: {
        allowNull: false, // NOT NULL
        type: DataTypes.INTEGER,
        references: {
          model: 'Users', // Users 모델을 참조합니다.
          key: 'userId', // Users 모델의 userId를 참조합니다.
        },
        onDelete: 'CASCADE', // 만약 Users 모델의 userId가 삭제되면, Comments 모델의 데이터가 삭제됩니다.
      },
      beforeName: {
        allowNull: false, // NOT NULL
        type: DataTypes.STRING,
      },
      afterName: {
        allowNull: false, // NOT NULL
        type: DataTypes.STRING,
      }
    },
    {
      sequelize,
      modelName: 'UserHistories',
      timestamps: false, // createdAt, updatedAt 컬럼을 생성하지 않습니다.
    }
  );
  return UserHistories;
};

CREATE TABLE Users
(
    userId    int(11)             NOT NULL AUTO_INCREMENT PRIMARY KEY,
    email     varchar(255) UNIQUE NOT NULL,
    password  varchar(255)        NOT NULL,
    createdAt datetime            NOT NULL DEFAULT NOW(),
    updatedAt datetime            NOT NULL DEFAULT NOW()
);


CREATE TABLE UserInfos
(
    userInfoId   int(11)        NOT NULL AUTO_INCREMENT PRIMARY KEY,
    UserId       int(11) UNIQUE NOT NULL, -- 1:1 관계 이므로 UNIQUE 조건을 삽입합니다.
    name         varchar(255)   NOT NULL,
    age          int(11)        NOT NULL,
    gender       varchar(255)   NOT NULL,
    profileImage varchar(255)   NULL,
    createdAt    datetime       NOT NULL DEFAULT NOW(),
    updatedAt    datetime       NOT NULL DEFAULT NOW()
);

ALTER TABLE UserInfos
    ADD CONSTRAINT FK_UserInfos_Users
        FOREIGN KEY (UserId) REFERENCES Users (userId) ON DELETE CASCADE;


CREATE TABLE Posts
(
    postId    int(11)      NOT NULL AUTO_INCREMENT PRIMARY KEY,
    UserId    int(11)      NOT NULL,
    title     varchar(255) NOT NULL,
    content   varchar(255) NOT NULL,
    createdAt datetime     NOT NULL DEFAULT NOW(),
    updatedAt datetime     NOT NULL DEFAULT NOW()
);

ALTER TABLE Posts
    ADD CONSTRAINT FK_Posts_Users
        FOREIGN KEY (UserId) REFERENCES Users (userId) ON DELETE CASCADE;


CREATE TABLE Comments
(
    commentId int(11)      NOT NULL AUTO_INCREMENT PRIMARY KEY,
    UserId    int(11)      NOT NULL,
    PostId    int(11)      NOT NULL,
    comment   varchar(255) NOT NULL,
    createdAt datetime     NOT NULL DEFAULT NOW(),
    updatedAt datetime     NOT NULL DEFAULT NOW()
);

ALTER TABLE Comments
    ADD CONSTRAINT FK_Comments_Posts
        FOREIGN KEY (PostId) REFERENCES Posts (postId) ON DELETE CASCADE;

ALTER TABLE Comments
    ADD CONSTRAINT FK_Comments_Users
        FOREIGN KEY (UserId) REFERENCES Users (userId) ON DELETE CASCADE;


CREATE TABLE UserHistories
(
    userHistoryId VARCHAR(36)  NOT NULL DEFAULT (UUID()) PRIMARY KEY,
    UserId        int(11)      NOT NULL,
    beforeName    varchar(255) NOT NULL,
    afterName     varchar(255) NOT NULL
);

ALTER TABLE UserHistories
    ADD CONSTRAINT FK_UserHistories_Users
        FOREIGN KEY (UserId) REFERENCES Users (userId) ON DELETE CASCADE;

npx sequelize db:drop

npx sequelize db:create

npx sequelize db:migrate

// 사용자 이름 변경 API
router.put('/users/name', authMiddleWare, async(req, res) => {
  const {name} = req.body; // 변경할 이름
  const {userId} = res.locals.user;

  const userInfo = await UserInfos.findOne({where: {userId}});
  const beforeUserName = userInfo.name;

  // 트랜잭션
  const t = await sequelize.transaction({
    isolationLevel: Transaction.ISOLATION_LEVELS.READ_COMMITTED,
  });

  try{
    // 사용자 정보 테이블에 있는 이름 변경
    await UserInfos.update(
      { name },
      {
        where: { userId },
        transaction: t, // transaction을 사용합니다.
      }
    );

    // 변경된 이름 내역은 UserHistories 테이블에 삽입
    await UserHistories.create(
      {
        UserId: userId,
        beforeName: beforeUserName,
        afterName: name,
      },
      { transaction: t } // transaction을 사용합니다.
    );
    await t.commit(); // 모든 로직 성공 시 DB에 반영
  }catch(transactionError){
    console.error(transactionError);
    t.rollback();
    return res.status(400).json({errorMessage:"유저 이름 변경에 실패하였습니다."})
  }
  return res.status(200).json({message:"유저 이름 변경에 성공하였습니다."})
})

Executing (c03a9600-80df-4713-b8c3-2815a068755f): SET TRANSACTION ISOLATION LEVEL READ COMMITTED;
Executing (c03a9600-80df-4713-b8c3-2815a068755f): START TRANSACTION;
Executing (c03a9600-80df-4713-b8c3-2815a068755f): UPDATE `UserInfos` SET `name`=?,`updatedAt`=? WHERE `userId` = ?
Executing (c03a9600-80df-4713-b8c3-2815a068755f): INSERT INTO `UserHistories` (`userHistoryId`,`UserId`,`beforeName`,`afterName`) VALUES (?,?,?,?);
Executing (c03a9600-80df-4713-b8c3-2815a068755f): COMMIT;