drop sql

app/controller/dbsync.js

 const Router = require('koa-router')
 const bodyParser = require('koa-bodyparser')
 const _ = require('lodash')
-
+const mysql = require('mysql2/promise');
 const jenkinsService = require('../service/jenkinsService')
 const k8sService = require('../service/k8sService')
 const { DBConfig } = require('../service/mongoService')
@@ -128,10 +128,31 @@ const dbSyncQuery = async function (ctx) {
   ctx.body = ctx.ok({ status: 'queue', log: { body: '' } })
 }
 
+const getDropSQL = async (ctx) => {
+  const { dbName } = ctx.request.query
+  const select = `select \`sql\`,base from core_sqlrecord where to_days(date) = to_days(now()) 
+    and state='Execute Successfully' and \`sql\` like '%drop %'`
+  const connection = await mysql.createConnection({
+    host: '172.30.4.8',
+    user: 'sync_del',
+    password: 'JhHgXdbopEPO6r6K',
+    database: 'yearning',
+  })
+  const [rows] = await connection.execute(select)
+  const res = rows.reduce((a, b) => {
+    if (b.base === dbName) {
+      a += `${b.sql};`
+    }
+    return a
+  }, '')
+  ctx.body = res
+}
+
 const router = new Router()
 router
   .get('/get_dbs', getDBs)
   .get('/get_name_space', getNamespace)
+  .get('/getDropSQL', getDropSQL)
   .post('/db_sync', bodyParser(), dbSync)
   .post('/tke', bodyParser(), dbSyncTke)
   .post('/db_sync_query', bodyParser(), dbSyncQuery)

package.json

@@ -34,6 +34,7 @@
     "lodash": "^4.17.11",
     "moment": "^2.24.0",
     "mongoose": "^5.3.4",
+    "mysql2": "^2.0.2",
     "node-etcd": "^7.0.0",
     "node-schedule": "^1.3.0",
     "nodemailer": "^6.3.1",