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

MySQL 04/14 阅读 79 views次 人气 0
摘要:

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

Nodejs连接MySQL数据库 增、删、改、查等操作:

http://www.what21.com/u/10015/5300655980095897993.htm

代码实例:

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");
    }
   
});


评论

表情
  1. 岁月安好 作者 人生最大的挑战没过于战胜自己!

    node operate.js

    2019/04/14 回复
  2. 岁月安好 作者 人生最大的挑战没过于战胜自己!

    // 安装 cnpm // npm install -g cnpm --registry=https://registry.npm.taobao.org // 安装 mysql // cnpm install mysql

    2019/04/14 回复

分享到: