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()