popov/iot
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

use sql connection pool to help with script stalling;

Browse Source
This commit is contained in:
Dobromir Popov
2020-09-12 22:10:05 +03:00
parent e74f219b79
commit 67271d1c3b
1 changed files with 11 additions and 8 deletions
Download Patch File Download Diff File Expand all files Collapse all files

9
src/db/devicemessages.js
View File

@@ -24,8 +24,10 @@ exports.findByName = function(fieldName, days, cb) {
// console.log("findByName(" +fieldName + ",?" + days +")" ); // console.log("findByName(" +fieldName + ",?" + days +")" );
// days = days|365; // days = days|365;
console.log("findByName(" +fieldName + "," + days +")" ); console.log("findByName(" +fieldName + "," + days +")" );
con.query("SELECT * FROM devicemessages WHERE (field_name=? OR ? IS NULL) AND (timestamp >= ( CURDATE() - INTERVAL ? DAY ))", pool.getConnection(function(err, con) {
[fieldName, fieldName, days], (err, data) => { if (err) throw err; // not connected!
con.query("SELECT * FROM devicemessages WHERE (field_name=? OR ? IS NULL) AND (timestamp >= ( CURDATE() - INTERVAL ? DAY ))", [fieldName, fieldName, days], (err, data) => {
con.release();
if (!err) { if (!err) {
cb(null, data); cb(null, data);
} else { } else {
@@ -33,13 +35,14 @@ exports.findByName = function(fieldName, days, cb) {
} }
}); });
}); });
});
} }
exports.insert = function(device_id, field_name, value, cb){ exports.insert = function(device_id, field_name, value, cb){
var params = [device_id, field_name,value]; var params = [device_id, field_name,value];
let sql = `INSERT INTO devicemessages(device_id,field_name,field_value,timestamp) let sql = `INSERT INTO devicemessages(device_id,field_name,field_value,timestamp)
VALUES (?,?,?,NOW());`; VALUES (?,?,?,NOW());`;
pool.getConnection(function(err, conn) { pool.getConnection(function(err, con) {
if (err) throw err; // not connected! if (err) throw err; // not connected!
con.query(sql,params,(err, r) => { con.query(sql,params,(err, r) => {
con.release(); con.release();