var OptPool = require('./函数/OptPool');
var optPool = new OptPool();
var _pool = optPool.getPool();
//从连接池获取连接
_pool.getConnection(function(err, conn) {
//----插入
var userAddSql = 'insert into user (uname,pwd) values(?,?)';
var param = ['eee', 'eee'];
conn.query(userAddSql, param, function(err, rs) {
if (err) {
console.log('insert err:', err.message);
return;
}
console.log('insert success');
// conn.release(); //放回连接池(必须在完成操作之后)
})
//查询
conn.query('SELECT * from user', function(err, rs) {
if (err) {
console.log('[query] - :' + err);
return;
}
for (var i = 0; i < rs.length; i++) {
console.log(rs[i].uname);
}
conn.release(); //放回连接池(必须在完成操作之后)
});
});
var mysql=require('mysql');//调用MYSQL模块
function OptPool(){
this.flag=true;
this.pool=mysql.createPool({
host:'localhost',
user:'root',
password:'root',
database:'world',
port:'6666'
});
this.getPool=function(){
if(this.flag){ //如果第一次连接则需要初始化，以后就不用了
this.pool.on('connection',function(connection){
connection.query('SET SESSION auto_increment_increment=1');
this.flag=false;
});
}
return this.Pool;
}
};
module.exports=OptPool;
运行之后出现这样的错误：
_pool.getConnection(function(err, conn) {
^
TypeError: Cannot read property 'getConnection' of undefined
at Object.<anonymous> (E:\java script学习\node.js\17连接池连mysql.js:8:6)
at Module._compile (module.js:409:26)
at Object.Module._extensions..js (module.js:416:10)
at Module.load (module.js:343:32)
at Function.Module._load (module.js:300:12)
at Function.Module.runMain (module.js:441:10)
at startup (node.js:139:18)
at node.js:968:3

要么你方法名写错了，要么你_pool变量 没有这个方法。你在仔细看看你定义的_pool变量

你怎么还用中文路径