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 async = require('async');

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)) {
        var sqls = req.body;

        async.whilst(
            function () {
                return sqls.length > 0;
            },
            function (whilecb) {
                var tmp = sqls.length > 100 ? sqls.splice(0, 100) : sqls.splice(0, sqls.length);
                // 执行批量sql文
                tableProvider.excute(tmp.join('')).then(function () {
                    whilecb();
                });
            },
            function (err) {
                if (err == null)
                    res.send('success');
                else
                    res.send('failure');
            });

        /*while (sqls.length > 0) {
            var tmp= sqls.length > 100 ? sqls.splice(0,100) : sqls.splice(0, sqls.length);
            // 执行批量sql文
            promises.push(tableProvider.excute(tmp.join('')));
        }*/
    }

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

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

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