sitelink1 | https://blog.naver.com/pjt3591oo/221505148267 |
---|---|
sitelink2 | |
sitelink3 | |
extra_vars4 | |
extra_vars5 | |
extra_vars6 |
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()
})()