From 5b4091a173618307086d1ff663be6399b9787d86 Mon Sep 17 00:00:00 2001
From: 沈斌 <bluelazysb@hotmail.com>
Date: Mon, 08 Jan 2018 19:51:41 +0800
Subject: [PATCH] updated
---
create_data.js | 13 +++++--------
1 files changed, 5 insertions(+), 8 deletions(-)
diff --git a/create_data.js b/create_data.js
index c30bb27..ea70279 100644
--- a/create_data.js
+++ b/create_data.js
@@ -4,9 +4,8 @@
var pool = mysql.createPool(config.mysql);
-
var start_date = moment().add(-1, 'days').format('YYYY-MM-DD');//'2017-11-11';
-var end_date = moment().add(-1, 'days').format('YYYY-MM-DD');//'2018-01-03';
+var end_date = moment().add(-1, 'days').format('YYYY-MM-DD');//'2018-01-07';
console.log(moment().format('YYYY-MM-DD HH:mm:ss') + " => sync minutely data from " + start_date + " to " + end_date);
@@ -61,20 +60,18 @@
}
function insertDeviceData(docs, connection) {
- var sql = "INSERT INTO data (mac, time, json) VALUES ";
-
+ var data = [];
docs.forEach(function(doc) {
var mac = doc.mac;
var time = doc.time;
delete doc.mac;
delete doc.time;
- sql += "('" + mac + "', '" + time + "', '" + JSON.stringify(doc) + "'),";
+ data.push([mac, time, JSON.stringify(doc)]);
});
- sql = sql.substr(0, sql.length -1);
- connection.query(sql, function (error, results, fields) {
+ connection.query("INSERT INTO data (mac, time, json) VALUES ?", [data], function (error, results, fields) {
if (error) throw error;
- connection.release();
+ connection.destroy();
});
}
\ No newline at end of file
--
Gitblit v1.8.0