65 lines
No EOL
1.8 KiB
JavaScript
65 lines
No EOL
1.8 KiB
JavaScript
const config = require('config');
|
|
const mysql = require('mysql');
|
|
|
|
const pool = mysql.createPool({
|
|
host: config.get('db.host'),
|
|
user: config.get('db.user'),
|
|
password: config.get('db.password'),
|
|
database: config.get('db.database'),
|
|
});
|
|
|
|
function addMarker(marker) {
|
|
let insertQuery = 'INSERT INTO markers VALUES (?,?,?,POINT(?,?),?)';
|
|
let query = mysql.format(insertQuery, [marker.name, marker.description, marker.filename, marker.long, marker.lat, new Date()]);
|
|
pool.query(query, (err, response) => {
|
|
if (err) {
|
|
console.error(err);
|
|
return;
|
|
}
|
|
// rows added
|
|
console.log(response);
|
|
});
|
|
}
|
|
|
|
function deleteMarkersOlderThanTimeLimit(timeLimit) {
|
|
let deleteQuery = 'DELETE FROM markers WHERE timeStamp < NOW() - INTERVAL (?) HOUR;';
|
|
let query = mysql.format(deleteQuery, timeLimit);
|
|
pool.query(query, (err, response) => {
|
|
if (err) {
|
|
console.error(err);
|
|
return;
|
|
}
|
|
// rows added
|
|
console.log(response);
|
|
});
|
|
}
|
|
|
|
function getAllMarkers(callback) {
|
|
pool.getConnection((err, connection) => {
|
|
if (err) throw err;
|
|
connection.query('SELECT * from markers', (err, rows) => {
|
|
connection.release(); // return the connection to pool
|
|
if (err) throw err;
|
|
callback(rows);
|
|
});
|
|
});
|
|
}
|
|
|
|
function getUpdatedMarkers(fromDate, callback) {
|
|
pool.getConnection((err, connection) => {
|
|
if (err) throw err;
|
|
let selectQuery = 'SELECT * FROM markers mrk WHERE mrk.ts >= ?';
|
|
let query = mysql.format(selectQuery, [new Date(parseInt(fromDate))])
|
|
connection.query(query, (err, rows) => {
|
|
connection.release(); // return the connection to pool
|
|
if (err) throw err;
|
|
callback(rows);
|
|
});
|
|
});
|
|
}
|
|
|
|
module.exports = {
|
|
addMarker,
|
|
getAllMarkers,
|
|
getUpdatedMarkers
|
|
} |