|
@@ -7,28 +7,19 @@ var us = {
|
|
|
//连接数据库
|
|
|
us.mysqlconnection = function(host, database) {
|
|
|
if (!us.sqle[host] || !us.sqle[host][database]) { //配置数据库连接
|
|
|
- // console.log(us.sqle[host],us.sqle[host][database]);
|
|
|
us.sqle[host] = us.sqle[host] || {};
|
|
|
- // console.log(us.sqle[host],us.sqle[host][database]);
|
|
|
-
|
|
|
us.sqle[host][database] = us.mysql.createPool({
|
|
|
connectionLimit: 0,
|
|
|
host: host, //数据库地址
|
|
|
user: "root", //用户名
|
|
|
- // password: "222333888", //密码
|
|
|
- password: "usestudio-1", //密码
|
|
|
+ password: "222333888", //密码
|
|
|
+ // password: "usestudio-1", //密码
|
|
|
// password: "662675", //密码
|
|
|
database: database, //数据库名称
|
|
|
// port: 20007 //端口
|
|
|
}); //连接超时和错误从连
|
|
|
- // console.log(us.sqle[database]);
|
|
|
|
|
|
}
|
|
|
- //connectionLimit: 1000,
|
|
|
- // console.log(us.sqle[host]);
|
|
|
- // console.log(us.sqle[database]);
|
|
|
-
|
|
|
- // console.log(us.sqle[host][database]);
|
|
|
return us.sqle[host][database]; //返回连接对象
|
|
|
}
|
|
|
|
|
@@ -60,10 +51,6 @@ exports.usselect = function(param, callback) {
|
|
|
// console.log("拼凑的MySQl语句为:", _sql);
|
|
|
connection.query(_sql, _param, function(error, results, fields) { //执行sql语句
|
|
|
if (results) {
|
|
|
- // if (results.pop) {
|
|
|
- // results.pop();
|
|
|
- // }
|
|
|
- //console.log(JSON.stringify(results)); 输出结果集
|
|
|
//执行回调函数
|
|
|
//results.affectedRows != null 如果受影响行不等于null(空) 则返回受影响行数
|
|
|
//results.affectedRows != null 如果受影响行不等于null(空) 则返回受影响行数
|