Update

app.js

@@ -2,7 +2,7 @@
  * @Author: Lienren 
  * @Date: 2018-01-02 14:28:21 
  * @Last Modified by: Lienren
- * @Last Modified time: 2018-01-08 16:55:12
+ * @Last Modified time: 2018-01-08 20:20:25
  */
 'use strict';
 const http = require('http');
@@ -13,6 +13,10 @@ const cors = require('koa2-cors');
 const bodyParser = require('koa-bodyparser');
 const app = new koa();
 
+const mysqlconfig = require('./configs/mysql_config');
+const sqlhelper = require('mysql-helper-simple').init(mysqlconfig);
+app.context.db = sqlhelper
+
 // 静态存放地址
 const staticPath = './static';
 app.use(koastatic(path.join(__dirname, staticPath)));

configs/mysql_config.json

@@ -1,9 +1,6 @@
 {
   "host": "localhost",
-  "port": 3306,
   "user": "root",
   "password": "123456",
-  "database": "mydb",
-  "charset": "UTF8_GENERAL_CI",
-  "dateStrings": true
+  "database": "mydb"
 }

package.json

@@ -9,7 +9,7 @@
     "koa-router": "^7.3.0",
     "koa-static": "^4.0.2",
     "koa2-cors": "^2.0.5",
-    "mysql": "^2.15.0",
+    "mysql-helper-simple": "^1.0.2",
     "squel": "^5.12.0"
   },
   "devDependencies": {},

router.js

@@ -2,12 +2,11 @@
  * @Author: Lienren 
  * @Date: 2018-01-08 16:21:55 
  * @Last Modified by: Lienren
- * @Last Modified time: 2018-01-08 17:07:30
+ * @Last Modified time: 2018-01-08 20:35:35
  */
 'use strict';
 const Router = require('koa-router');
 const squel = require('squel');
-const sqlhelper = require('./utils/mysql-helper');
 const router = new Router();
 
 router
@@ -26,11 +25,36 @@ router
       .from('sm_user')
       .toParam();
 
-    await sqlhelper.query(sql.text, sql.values).then(result => {
-      console.log(result);
-      ctx.body = {
-        ...result
-      };
+    await ctx.db
+      .query({
+        sql: sql.text,
+        values: sql.values
+      })
+      .then(result => {
+        console.log(result);
+        ctx.body = {
+          ...result
+        };
+      });
+  })
+  .get('/getbatch', async (ctx, next) => {
+    let sql = squel
+      .select()
+      .from('sm_user')
+      .toParam();
+
+    await ctx.db.batch([ctx.db.query({ sql: sql.text, values: sql.values })], {
+      completeHanding: results => {
+        console.log('result:', results);
+        ctx.body = {
+          ...results[0]
+        };
+      },
+      exceptionHandling: err => {
+        ctx.body = {
+          ...err
+        };
+      }
     });
   });
 

yarn.lock

@@ -263,6 +263,12 @@ [email protected]:
   version "2.0.0"
   resolved "http://registry.npm.taobao.org/ms/download/ms-2.0.0.tgz#5608aeadfc00be6c2901df5f9861788de0d597c8"
 
+mysql-helper-simple@^1.0.2:
+  version "1.0.4"
+  resolved "http://registry.npm.taobao.org/mysql-helper-simple/download/mysql-helper-simple-1.0.4.tgz#0c9121eb03fe86373b9ea7a0cec39f7050434fbb"
+  dependencies:
+    mysql "^2.15.0"
+
 mysql@^2.15.0:
   version "2.15.0"
   resolved "http://registry.npm.taobao.org/mysql/download/mysql-2.15.0.tgz#ea16841156343e8f2e47fc8985ec41cdd9573b5c"