| 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 connection3 = await pool.getConnection(async conn => conn)
let connection4 = await pool.getConnection(async conn => conn)
let sql = 'SELECT *FROM users'
let user1 = await connection1.query(sql)
let user2 = await connection2.query(sql)
let user3 = await connection3.query(sql)
let user4 = await connection4.query(sql)
console.log(user1)
console.log(user2)
console.log(user3)
console.log(user4)
})()
* 특징
커넥션을 통해 쿼리를 실행하므로 데이터 처리에 대한 트랜잭션 관리가 가능해짐
connection.beginTransaction()
connection.commit()
connection.rollback()
connection.release()
