|
|
@@ -0,0 +1,38 @@
|
|
|
+/**
|
|
|
+ * 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 = [];
|
|
|
+
|
|
|
+ // 执行批量sql文
|
|
|
+ promises.push(tableProvider.excute(req.body.join('')));
|
|
|
+ /*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);
|
|
|
+});
|