How to use the createPool function from mysql

Find comprehensive JavaScript mysql.createPool code examples handpicked from public code repositorys.

mysql.createPool creates a connection pool for MySQL database connections.

504
505
506
507
508
509
510
511
512
513
      pool.end()
      pool = undefined
    }
  }

  var pool = mysql.createPool(connectionOptions)
  queryable = pool

  cb()
})
fork icon213
star icon539
watch icon0

+ 3 other calls in file

4
5
6
7
8
9
10
11
12
13
name: Events.ChannelUpdate,

async execute(oldChannel, channel) {

    // DB Connection
    var con = mysql.createPool({
        host: "localhost",
        user: "kami",
        password: process.env.DBPASS,
        database: "kamidb"
fork icon0
star icon1
watch icon1

+ 2 other calls in file

How does mysql.createPool work?

mysql.createPool is a method provided by the mysql package in Node.js that creates a new pool of database connections that can be used to execute SQL queries and manage database connections in a scalable and efficient way. When mysql.createPool is called, a new Pool object is returned, which can be used to perform queries and manage connections. The pool maintains a set of active connections, and new connections are created automatically as needed, up to a maximum number specified by the max option. When a connection is no longer needed, it is released back to the pool for reuse by other requests. The pool also handles connection errors and automatically reconnects when a connection is lost. The pool can be configured with a variety of options to customize its behavior, including connection limits, timeouts, and logging.

21
22
23
24
25
26
27
28
29
30
app.use(bodyParser.urlencoded({ extended: true }));
app.set('view engine', 'ejs');//se establece express para que maneje plantillas ejs
app.use('/public/', express.static('./public'));//en la carpeta public cargaremos los archivos
//estaticos
const port = 10101;
const pool = mysql.createPool({
    connectionLimit: 100,
    host: 'localhost',
    user: 'root',
    password: 'Sena1234',
fork icon0
star icon1
watch icon1

49
50
51
52
53
54
55
56
57
58
59
60
    return hash.digest('base64');
}




// trying idea from https://stackoverflow.com/questions/18496540/node-js-mysql-connection-pooling
var pool = mysql.createPool({
    host: 'database',
    port: 3306,
    user: MYSQL_USER,
    password: MYSQL_PASS,
fork icon0
star icon0
watch icon1

+ 4 other calls in file

Ai Example

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
const mysql = require("mysql");

const pool = mysql.createPool({
  host: "localhost",
  user: "myuser",
  password: "mypassword",
  database: "mydatabase",
});

pool.getConnection((err, connection) => {
  if (err) throw err;

  connection.query("SELECT * FROM mytable", (error, results, fields) => {
    if (error) throw error;

    console.log(results);
    connection.release();
  });
});

In this example, we create a connection pool using mysql.createPool, specifying the connection details for our database. We then call pool.getConnection to get a connection from the pool. Once we have a connection, we can execute a query using connection.query. Finally, we release the connection back to the pool using connection.release. This allows other parts of our application to reuse the connection later on.

7
8
9
10
11
12
13
14
15
16
17
18
fs = require('fs');


app.use(cors())


var mysql = require('mysql');
var pool  = mysql.createPool({
   host: '8.219.122.105',
   port: 3306,
   user: 'admin',
   password: 'root',
fork icon0
star icon0
watch icon1

43
44
45
46
47
48
49
50
51
52
53
        }
    });
};


exports.init = function (config) {
    pool = mysql.createPool({
        host: config.HOST,
        user: config.USER,
        password: config.PSWD,
        database: config.DB,
fork icon0
star icon0
watch icon1

+ 2 other calls in file

4068
4069
4070
4071
4072
4073
4074
4075
4076
4077
    const newRegExp = new MySQLDatabaseRegExp();
    return newRegExp.create(regexp);
}
createPool() {
    // 创建连接池
    const pool = mysql.createPool(this.$config.connConfig);
    return pool;
}
async runTransaction(callback) {
    // 获取事务
fork icon0
star icon0
watch icon1

-2
fork icon0
star icon0
watch icon1

17
18
19
20
21
22
23
24
25
26
27
28
});


const { v4: uuidv4 } = require('uuid');


const mysql = require('mysql');
const connection = mysql.createPool({
  connectionLimit: 50,
  host: process.env.DBHOST,
  port: process.env.DBPORT,
  user: process.env.DBUSER,
fork icon0
star icon0
watch icon1

31
32
33
34
35
36
37
38
39
40
        console.log(`[SQL][EXEC QUERY] ${execQuery}`)
        return execQuery
    },
}
console.log('New Connection', dbName)
const connection = mysql.createPool(config)

// 연결된 내역 저장
DBConnect.DBCONNECTIONPOOL[dbName] = new this(dbName, connection)
return DBConnect.DBCONNECTIONPOOL[dbName]
fork icon0
star icon0
watch icon1

+ 2 other calls in file

0
1
2
3
4
5
6
7
8
9
10
const mysql = require('mysql');


class MysqlRequests{
    constructor(){
        //Create a connection pool with the user details
        this.db = mysql.createPool({
            connectionLimit: 1,
            host: "localhost",
            user: process.env.MYSQL_USER,
            password: process.env.MYSQL_PASSWORD,
fork icon0
star icon0
watch icon1

6
7
8
9
10
11
12
13
14
15
16
17
const cors = require("cors")


const app = express()
const PORT = process.env.PORT || 3001


var db = mysql.createPool({
    host: process.env.DB_HOST,
    user: process.env.DB_USER,
    password: process.env.DB_PASSWORD,
    database: process.env.DB_NAME
fork icon0
star icon0
watch icon2

12
13
14
15
16
17
18
19
20
21
22
23
const app = express()
const abi_box = require('./abi/Box721.json')


if(!fs.existsSync(config.uploadDir)) fs.mkdirSync(config.uploadDir)


const mysqlPool = mysql.createPool(key.mysql)
const mysqlQuery = async(sql, values) => {
    return new Promise( resolve =>{
        mysqlPool.getConnection((err,connection)=>{
            if(err) {
fork icon0
star icon0
watch icon1

98
99
100
101
102
103
104
105
106
107
108
109
  host            : process.env.DIRECTOR_DATABASE_HOST,
  port            : process.env.DIRECTOR_DATABASE_PORT,
  database        : process.env.DIRECTOR_DATABASE_NAME
}


var pool = mysql.createPool(sql_params);


app.get('/', [checkAuthentication, getUserName], function(req, res){
    var profile = res.locals.profile;
    var first_name = profile.first_name;
fork icon0
star icon0
watch icon1

9
10
11
12
13
14
15
16
17
18
/*
// BlueBird API Doc 에 있는 예제 코드 인데
// getConnectionAsync() 함수가 undefined 로 TypeError 오류 발생 !!!
// getConnection() 함수로 수정해서 하면 disposer() 함수가 undefined 로 TypeError 오류 발생 !!!
// 오류 원인 추후 확인 필요 !!!
var pool = mySQL.createPool(m1Config);

function getSqlConnection() {
    return pool.getConnectionAsync().disposer(function (connection) {
        try {
fork icon0
star icon0
watch icon0