Nodejs连接MySQL数据库 使用数据库连接池

代码实例：

var mysql=require('mysql');

var mysql_config={
    host: '127.0.0.1',
    port: 3306,
    user: 'root',
    password: '123124',
    database: 'dorder'
};

var pool = mysql.createPool(mysql_config);

pool.getConnection(function(err,connection){

    connection.query("use dorder");
    var querySql = "select * from `e_customer`";
    connection.query(querySql,function(err,rows){
        if(err){
            throw err;
        }
        var jsonData = JSON.stringify(rows);
        console.log(jsonData);
        for(var i=0;i<rows.length;i++){
            console.log("uuid --> " + rows[i].uuid);
            console.log("customerId --> " + rows[i].customerId);
            console.log("customerName --> " + rows[i].customerName);
            console.log("customerSource --> " + rows[i].customerSource);
            console.log("sourceSign --> " + rows[i].sourceSign);
            console.log("sourceAddress --> " + rows[i].sourceAddress);
            console.log("createTime --> " + rows[i].createTime);
            console.log("\n");
        }
       
    });
    connection.release();

});

代码实例：

// mysql_operate.js

var mysql=require('mysql');

var mysql_config={
    host: '127.0.0.1',
    port: 3306,
    user: 'root',
    password: '123124',
    database: 'dorder'
};

var pool = mysql.createPool(mysql_config);

var query=function(sql,callback){
    pool.getConnection(function(err,connection){
        if(err){
            callback(err,null,null);
        }else{
            connection.query(sql,function(qerr,vals,fields){
                //释放连接
                connection.release();
                //事件驱动回调
                callback(qerr,vals,fields);
            });
        }
    });
};

module.exports=query;

var query=require('./mysql_operate.js');

var querySql = "select * from `e_customer`";

query(querySql,function(err,rows,fields){
    if(err){
        throw err;
    }
    console.log(rows);
    console.log(fields);
    var jsonData = JSON.stringify(rows);
    console.log(jsonData);
    for(var i=0;i<rows.length;i++){
        console.log("uuid --> " + rows[i].uuid);
        console.log("customerId --> " + rows[i].customerId);
        console.log("customerName --> " + rows[i].customerName);
        console.log("customerSource --> " + rows[i].customerSource);
        console.log("sourceSign --> " + rows[i].sourceSign);
        console.log("sourceAddress --> " + rows[i].sourceAddress);
        console.log("createTime --> " + rows[i].createTime);
        console.log("\n");
    }
   
});