DataSyncServer/app.js

/**
 * Created by taohm on 2016/11/2.
 */
var restify = require('restify');
global.config = require('./config');
var db = require('./db'),
    tableProvider = db.tableProvider;

var server = restify.createServer({
    name: 'DataSyncServer',
    version: '1.0.0'
});
server.use(restify.acceptParser(server.acceptable));
server.use(restify.queryParser());
server.use(restify.bodyParser());

server.post('/api/sqls', function (req, res) {
    var promises = [];

    if (Array.isArray(req.body))
        // 执行批量sql文
        promises.push(tableProvider.excute(req.body.join('')));
    /* 执行一条条sql文
    req.body.forEach(function (element) {
        promises.push(tableProvider.excute(element));
    }, this);*/

    Promise.all(promises).then(function () {
        //res.send('{success:true}');
    }).catch(function (err) {
        //res.send('{success:false}');
        console.log('error:' + err);
    });

    res.send('ok');
});

server.listen(8080, function () {
    console.log('%s listening at %s', server.name, server.url);
});