|
@@ -19,8 +19,8 @@ var mysql = require("./mysql");
|
|
|
//线上
|
|
//线上
|
|
|
const _mysqlLabor = ["172.16.12.150", "pbl"]; //edu數據庫信息
|
|
const _mysqlLabor = ["172.16.12.150", "pbl"]; //edu數據庫信息
|
|
|
const _mysqluser = ["172.16.12.150", "cocorobouser"]; //用户数据库信息
|
|
const _mysqluser = ["172.16.12.150", "cocorobouser"]; //用户数据库信息
|
|
|
-const _getmysqlLabor = ["172.16.12.150", "pbl"]; //edu數據庫信息
|
|
|
|
|
-const _getmysqluser = ["172.16.12.150", "cocorobouser"]; //用户数据库信息
|
|
|
|
|
|
|
+// const _getmysqlLabor = ["172.16.12.150", "pbl"]; //edu數據庫信息
|
|
|
|
|
+// const _getmysqluser = ["172.16.12.150", "cocorobouser"]; //用户数据库信息
|
|
|
//======================================
|
|
//======================================
|
|
|
|
|
|
|
|
//解析 url 查询参数
|
|
//解析 url 查询参数
|
|
@@ -31,8 +31,8 @@ function queryString(url) {
|
|
|
}
|
|
}
|
|
|
|
|
|
|
|
//直接执行 SQL(pbl 库)
|
|
//直接执行 SQL(pbl 库)
|
|
|
-function runPbl(res, sql, params, isRead) {
|
|
|
|
|
- var cfg = isRead ? _getmysqlLabor : _mysqlLabor;
|
|
|
|
|
|
|
+function runPbl(res, sql, params) {
|
|
|
|
|
+ var cfg = _mysqlLabor;
|
|
|
var p = [cfg[0], cfg[1], sql].concat(params || []);
|
|
var p = [cfg[0], cfg[1], sql].concat(params || []);
|
|
|
mysql.usquery(p, function (ret) {
|
|
mysql.usquery(p, function (ret) {
|
|
|
res.end(JSON.stringify(ret));
|
|
res.end(JSON.stringify(ret));
|
|
@@ -40,8 +40,8 @@ function runPbl(res, sql, params, isRead) {
|
|
|
}
|
|
}
|
|
|
|
|
|
|
|
//直接执行 SQL(cocorobouser 库)
|
|
//直接执行 SQL(cocorobouser 库)
|
|
|
-function runUser(res, sql, params, isRead) {
|
|
|
|
|
- var cfg = isRead ? _getmysqluser : _mysqluser;
|
|
|
|
|
|
|
+function runUser(res, sql, params) {
|
|
|
|
|
+ var cfg = _mysqluser;
|
|
|
var p = [cfg[0], cfg[1], sql].concat(params || []);
|
|
var p = [cfg[0], cfg[1], sql].concat(params || []);
|
|
|
mysql.usquery(p, function (ret) {
|
|
mysql.usquery(p, function (ret) {
|
|
|
res.end(JSON.stringify(ret));
|
|
res.end(JSON.stringify(ret));
|
|
@@ -52,7 +52,7 @@ function runUser(res, sql, params, isRead) {
|
|
|
router.route("/selectUser").all((req, res, next) => {
|
|
router.route("/selectUser").all((req, res, next) => {
|
|
|
var json = queryString(req.url);
|
|
var json = queryString(req.url);
|
|
|
var sql = "SELECT * FROM User WHERE userid = ?";
|
|
var sql = "SELECT * FROM User WHERE userid = ?";
|
|
|
- runPbl(res, sql, [json["uid"]], true);
|
|
|
|
|
|
|
+ runPbl(res, sql, [json["uid"]]);
|
|
|
});
|
|
});
|
|
|
|
|
|
|
|
/* 查询全部用户 */
|
|
/* 查询全部用户 */
|
|
@@ -62,14 +62,14 @@ router.route("/selectUserAll").all((req, res, next) => {
|
|
|
var pageSize = parseInt(json["pageSize"]) || 10;
|
|
var pageSize = parseInt(json["pageSize"]) || 10;
|
|
|
var offset = (page - 1) * pageSize;
|
|
var offset = (page - 1) * pageSize;
|
|
|
var sql = "SELECT * FROM User LIMIT ? OFFSET ?";
|
|
var sql = "SELECT * FROM User LIMIT ? OFFSET ?";
|
|
|
- runPbl(res, sql, [pageSize, offset], true);
|
|
|
|
|
|
|
+ runPbl(res, sql, [pageSize, offset]);
|
|
|
});
|
|
});
|
|
|
|
|
|
|
|
/* 修改用户 */
|
|
/* 修改用户 */
|
|
|
router.route("/updateUser").post((req, res, next) => {
|
|
router.route("/updateUser").post((req, res, next) => {
|
|
|
var json = req.body;
|
|
var json = req.body;
|
|
|
var sql = "UPDATE User SET username = ? WHERE userid = ?";
|
|
var sql = "UPDATE User SET username = ? WHERE userid = ?";
|
|
|
- runPbl(res, sql, [json["username"], json["userid"]], false);
|
|
|
|
|
|
|
+ runPbl(res, sql, [json["username"], json["userid"]]);
|
|
|
});
|
|
});
|
|
|
|
|
|
|
|
module.exports = router;
|
|
module.exports = router;
|