update

mysql.js

@@ -5,18 +5,19 @@ var us = {
 };
 
 //连接数据库
-us.mysqlconnection = function(host, database) {
+us.mysqlconnection = function (host, database) {
     if (!us.sqle[host] || !us.sqle[host][database]) { //配置数据库连接 
         let port = host == '172.16.12.7' ? 3306 : 3306;
-        if(host == '123.58.32.152'){
+        if (host == '123.58.32.152') {
             port = 20330;
-        }else if(host == '123.58.32.151'){
+        } else if (host == '123.58.32.151') {
             port = 20007;
         }
         // let port = host == '123.58.32.152' ? 20330 : 20007;
         us.sqle[host] = us.sqle[host] || {};
         us.sqle[host][database] = us.mysql.createPool({
-            connectionLimit: 1000000,
+            connectionLimit: 0,
+            queueLimit: 0,
             host: host, //数据库地址
             // host: '123.58.32.151', //数据库地址
             user: "root", //用户名
@@ -33,10 +34,10 @@ us.mysqlconnection = function(host, database) {
 
 
 //连接数据库调用
-exports.usselect = function(param, callback) {
+exports.usselect = function (param, callback) {
     if (param.length > 1) {
         var _mysqlconnection = us.mysqlconnection(param[0], param[1]); //创建连接池
-        _mysqlconnection.getConnection(function(error, connection) { //获取连接
+        _mysqlconnection.getConnection(function (error, connection) { //获取连接
             if (error) { //连接错误
                 console.log("连接失败：", error);
                 callback(error);
@@ -58,7 +59,7 @@ exports.usselect = function(param, callback) {
                     _sql += param[2] + "();";
                 }
                 // console.log("拼凑的MySQl语句为：", _sql);
-                connection.query(_sql, _param, function(error, results, fields) { //执行sql语句 
+                connection.query(_sql, _param, function (error, results, fields) { //执行sql语句 
                     if (results) {
                         // if (results.pop) {
                         //     results.pop();
@@ -75,7 +76,7 @@ exports.usselect = function(param, callback) {
                     }
                 });
 
-                connection.release(function(error) { //释放资源
+                connection.release(function (error) { //释放资源
                     if (error) {
                         console.log("连接释放错误", error)
                         callback(error);