'myql-queue'

@@ -9,6 +9,7 @@
 const Router = require('koa-router');
 const moment = require('moment');
 const pager = require('../utils/pager');
+const Mysql = require('../../../lib/mysql-promise');
 
 const r = new Router();
 
@@ -155,4 +156,17 @@ r.get('/searchKeywords', async(ctx) => {
         total:1
     }; 
 });
+
+r.get('/syncWord', async(ctx) => {
+    let mysql = new Mysql();
+
+    let r = await mysql.query(`select * from seo_keywords`);
+    console.log(r[0].keyword, ' ===');
+    ctx.body = {
+        code: 200,
+        message: 'success',
+        data: r
+    };
+});
+
 module.exports = r;

@@ -6,12 +6,13 @@ const config = require('../config/config');
 class MysqlPromise {
     constructor() {
         this.connect().then(conn => {
-            this.connect = conn;
+            this.conn = conn;
+            return conn;
         });
     }
 
     connect() {
-        if (this.connect) {
+        if (this.conn) {
             return Promise.resolve(this.connect);
         }
 
@@ -28,6 +29,15 @@ class MysqlPromise {
             return null;
         });
     }
+
+    query(sql) {
+        return this.connect().then(d => {
+            return d.query(sql);
+        }).catch(err => {
+            console.error(`mysql query, err: ${err.message}`);
+            return [];
+        });
+    }
 }
 
 module.exports = MysqlPromise;
\ No newline at end of file