1

edurouter.js

@@ -5,8 +5,8 @@ var bcrypt = require('bcryptjs');
 var router = express.Router(); // get an instance of the express Router
 const querystring = require('querystring');
 var mysql = require('./mysql');
-const _mysqlLabor = ["123.58.32.151", "art"]; //edu數據庫信息
-// const _mysqlLabor = ["172.16.12.5", "art"]; //edu數據庫信息
+// const _mysqlLabor = ["123.58.32.151", "art"]; //edu數據庫信息
+const _mysqlLabor = ["172.16.12.5", "art"]; //edu數據庫信息
 
 //統壹處理區域
 router.use(async function(req, res, next) {
@@ -35,11 +35,11 @@ function asynnext(req, res, next) {
 //     getmysql(req, res, "b", json['ph'], json['pa']);
 // });
 
-router.route('/b').all((req, res, next) => {
-    var json = queryString(req.url);
-    getmysql(req, res, "a");
+router.route('/insertWork').all((req, res, next) => {
+    postmysql(req, res, "insertWork");
 });
 
+
 queryString = function(url) {
     var a = url.split("?");
     var json = querystring.parse(a[1])

mysql.js

@@ -5,7 +5,7 @@ var us = {
 };
 
 //连接数据库
-us.mysqlconnection = function (host, database) {
+us.mysqlconnection = function(host, database) {
     if (!us.sqle[host] || !us.sqle[host][database]) { //配置数据库连接 
         us.sqle[host] = us.sqle[host] || {};
         us.sqle[host][database] = us.mysql.createPool({
@@ -15,8 +15,8 @@ us.mysqlconnection = function (host, database) {
             user: "root", //用户名
             password: "cocorobo", //密码
             database: database, //数据库名称
-            port: 20007 //端口
-            // port: 3306 //端口    
+            // port: 20007 //端口
+            port: 3306 //端口    
         }); //连接超时和错误从连
     }
     //connectionLimit: 1000, 
@@ -25,16 +25,16 @@ 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);
             } else { //连接成功
                 for (i = 0; i < param.length; i++) {
                     param[i] = decodeURIComponent(param[i]);
-                    
+
                 } //格式化处理参数
                 var i, _sql = "CALL ";
                 var _param = new Array();
@@ -49,7 +49,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();
@@ -60,17 +60,16 @@ exports.usselect = function (param, callback) {
                         //results.affectedRows != null 如果受影响行不等于null（空） 则返回受影响行数
                         //results.length > 1 ? results : results[0] 如果结果集为单行则直接返回Object对象 否则返回数组对象
                         callback(results.affectedRows != null ? results.affectedRows : results.length > 1 ? results : results[0]);
-                    } 
-                    else { //执行错误
+                    } else { //执行错误
                         console.log("sql执行失败", error || "");
                         callback(error);
                     }
                 });
-                
-                connection.release(function (error) { //释放资源
+
+                connection.release(function(error) { //释放资源
                     if (error) console.log("连接释放错误", error);
                 });
-                
+
             }
         });
     }
@@ -85,4 +84,4 @@ exports.usselect = function (param, callback) {
 //             us.mysqlconnection(host, database)
 //         }, 2000);
 //     }
-// }
+// }