[connection과 pool-04] connection pool 에서의 Transaction을 이용한 commit 과 rollback

const mysql = require('mysql2/promise');

(async function () {

    let pool = mysql.createPool({

        host: '127.0.0.1',

        user: 'root',

        password: '11111111',

        database: 'test',

        connectionLimit: 4

    });

    let connection1 = await pool.getConnection(async conn => conn)

    let connection2 = await pool.getConnection(async conn => conn)

    let insertSql = 'INSERT INTO users(age, name) VALUES(?, ?)' 

    

    connection1.beginTransaction()

    connection2.beginTransaction()

    

    let user1 = await connection1.query(insertSql, [27, "mung1"])

    let user2 = await connection2.query(insertSql, [27, "mung2"])

    

    connection1.commit()

    connection2.rollback()

    connection1.release()

    connection2.release()

    

    let connection = await pool.getConnection(async conn => conn)

    let selectSql = 'SELECT *FROM Users' 

    let[user] = await connection.query(selectSql)

    

    console.log(user)

    

    connection.release()

})()

 

실행결과