Come si crea un pool di connessioni MySQL mentre si lavora con NodeJS ed Express?

Question

sono in grado di creare una connessione MySQL come questo:

var mysql  = require('mysql'); 
var connection = mysql.createConnection({ 
    host  : 'localhost', 
    user  : 'me', 
    password : 'secret', 
    database : 'my_db' 
}); 

connection.connect(); 

ma preferirei piacerebbe avviare una piscina e usarlo in tutto il mio progetto.

Answer 1

Proprio per aiutare qualcuno in futuro, questo ha funzionato per me:

ho creato un file di connettore di mysql che contiene la piscina:

// Load module 
var mysql = require('mysql'); 
// Initialize pool 
var pool  = mysql.createPool({ 
    connectionLimit : 10, 
    host  : '127.0.0.1', 
    user  : 'root', 
    password : 'root', 
    database : 'db_name', 
    debug : false 
});  
module.exports = pool; 

In seguito si può semplicemente inserire il connettore in un altro file consente chiamata esso manageDB.js:

var pool = require('./mysqlConnector'); 

e ha fatto un metodo di callable come questo:

exports.executeQuery=function(query,callback){ 
    pool.getConnection(function(err,connection){ 
     if (err) { 
      connection.release(); 
      throw err; 
     } 
     connection.query(query,function(err,rows){ 
      connection.release(); 
      if(!err) { 
       callback(null, {rows: rows}); 
      }   
     }); 
     connection.on('error', function(err) {  
       throw err; 
       return;  
     }); 
    }); 
} 

Answer 2

ci sia qualche bug in Utkarsh Kaushik solution:

• se (ERR), la connessione non può essere rilasciato. connection.release();

• e quando ha un err, prossima dichiarazione .query eseguire sempre anche se diventa un errore e causare l'applicazione si è schiantato.

• quando il risultato è nullo anche se la ricerca ha esito positivo, è necessario verificare se il risultato è nullo in questo caso.

Questa soluzione ha funzionato bene nel mio caso:

exports.getPosts=function(callback){ 
    pool.getConnection(function(err,connection){ 
     if (err) { 
      callback(true); 
      return; 
     } 
     connection.query(query,function(err,results){ 
      connection.release(); 
      if(!err) { 
       callback(false, {rows: results}); 
      } 
      // check null for results here 
     }); 
     connection.on('error', function(err) { 
       callback(true); 
       return; 
     }); 
    }); 
}; 

Answer 3

È possibile creare un file di connessione, Let chiama dbcon.js

var mysql = require('mysql'); 

// connect to the db 
dbConnectionInfo = { 
    host: "localhost", 
    port: "3306", 
    user: "root", 
    password: "root", 
    connectionLimit: 5, //mysql connection pool length 
    database: "db_name" 
}; 

//For mysql single connection 
/* var dbconnection = mysql.createConnection(
     dbConnectionInfo 
); 

dbconnection.connect(function (err) { 
    if (!err) { 
     console.log("Database is connected ... nn"); 
    } else { 
     console.log("Error connecting database ... nn"); 
    } 
}); 

*/ 

//create mysql connection pool 
var dbconnection = mysql.createPool(
    dbConnectionInfo 
); 

// Attempt to catch disconnects 
dbconnection.on('connection', function (connection) { 
    console.log('DB Connection established'); 

    connection.on('error', function (err) { 
    console.error(new Date(), 'MySQL error', err.code); 
    }); 
    connection.on('close', function (err) { 
    console.error(new Date(), 'MySQL close', err); 
    }); 

}); 


module.exports = dbconnection; 

ora includono la connessione a un altro file

var dbconnection = require('../dbcon'); 
dbconnection.query(query, params, function (error, results, fields) { 
    //Do your stuff 
});