nodejs连接池连接mysql

Posted 2021-09-12 月疯

/**
 * 1、安装mysql支持
 * npm install mysql
 * 2、安装node.js的mysqlpool模块
 * npm install -g node-mysql //-g表全局
 *
 */

OptPool.js

/**
 * 1、安装mysql支持
 * npm install mysql
 * 2、安装node.js的mysqlpool模块
 * npm install -g node-mysql //-g表全局
 *
 */

var mysql = require('mysql');//调用MYSQL模块

function OptPool(){
    this.flag=true;
    this.pool=mysql.createPool({
        host:'#.#.#.#',  //主机
        user:'#',    //用户名
        password:'#', //密码
        database:'users',  //数据库名字
        port:'70115'   //端口号
    });
    this.getPool=function(){
        if(this.flag){
            //监听connection事件
            this.pool.on('connection',function(connection){
                connection.query('SET SESSION auto_increment_increment=1');
                this.flag=false;
            });
        }
        return this.pool;
    }
};
module.exports = OptPool;

 mysqlPool.js

var OptPool = require('../module/OptPool');

var optPool = new OptPool();
var pool=optPool.getPool();

//执行SQL语句
pool.getConnection(function(err,conn){
    //数据的插入
    var userAddSql='insert into users(uname,pwd) values (?,?)';
//要插入的用户名和密码
    var param = ['htt','123'];
    conn.query(userAddSql,param,function(err,rs){
        if(err){
            console.log('insert err:',err,message);
            return;
        }
        console.log('insert success');
    });
//执行查询rs查询结果,[2]传进sql的参数
    conn.query('SELECT * from users where uid=?',[2],function(err,rs){
        if(err){
            console.log('[query] - :'+err);
            return;
        }
        console.log('The solution is:',rs[0].uname);
    });
});