Comment puis-je créer une connexion MySQL piscine tout en travaillant avec NodeJS et de l'Exprimer?

Je suis en mesure de créer une connexion MySQL comme ceci:

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

connection.connect();

Mais je voudrais plutôt de lancer une piscine et de l'utiliser dans mon projet.

InformationsquelleAutor Utkarsh Kaushik | 2016-05-08
  1. 18

    Juste pour aider quelqu'un dans le futur, cela a fonctionné pour moi:

    J'ai créé une base de données mysql connector fichier contenant la piscine:

    //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;

    Plus tard, vous pouvez simplement inclure le connecteur dans un autre fichier permet à l'appeler manageDB.js:

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

    Et fait un callable méthode comme ceci:

    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;     
        });
    });
}
    • salut.. je suis donc nouveau sur le nœud trop alors j'ai quelques doutes. Si les exportations de la fonction dans le fichier connecteur droit?? et d'appeler cela, je vais devoir passer ma requête en paramètre?
    • Les deux connexion.requête(...) et de connexion.sur(....) besoin de connexion.release();
    InformationsquelleAutor Utkarsh Kaushik
  2. 6

    Il y a quelques bugs dans Utkarsh Kaushik solution:

    • if (err), la connexion ne peut pas être libéré.
      connection.release();

    • et quand il a une erreur, la prochaine déclaration .query toujours exécuter même si elle obtient une erreur et la cause de l'app s'est écrasé.

    • lorsque le résultat est null, bien que la requête de la réussite, nous avons besoin de vérifier si le résultat est nul dans ce cas.

    Cette solution a bien fonctionné dans mon cas:

    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;
        });
    });
};
    InformationsquelleAutor Nam Le
  3. 4

    Vous pouvez créer un fichier de connexion, nous allons appelé 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;

    Maintenant inclure cette connexion à un autre fichier

    var dbconnection = require('../dbcon');
dbconnection.query(query, params, function (error, results, fields) {
    //Do your stuff
});
    • Lorsque vous appelez "se connecter" cmd ou je n'ai pas besoin de cela?
    • Si vous voulez vérifier si votre db connexion est établie ou non, vous pouvez dé-commentez la connecter cmd qui est déjà dit dans le code, sinon n'avez pas besoin d'utiliser.
    InformationsquelleAutor sumitjainjr