skysql_field
Rob Hedgpeth 2020-03-25 11:33:35 -05:00
rodzic 1aeb0cca53
commit d25d86886f
1 zmienionych plików z 24 dodań i 8 usunięć

Wyświetl plik

@ -10,6 +10,7 @@ router.get("/", async (req, res, next) => {
let read_count = req.query.r; let read_count = req.query.r;
let write_count = req.query.w; let write_count = req.query.w;
let connection_id = req.query.c; let connection_id = req.query.c;
let conn; let conn;
try { try {
// Establish connection to SkySQL using the db.js module // Establish connection to SkySQL using the db.js module
@ -29,17 +30,32 @@ router.get("/", async (req, res, next) => {
writes += "insert into orders (description) values('order - " + transaction_id + "');"; writes += "insert into orders (description) values('order - " + transaction_id + "');";
} }
var promises = [];
if (read_count > 0) {
promises.push(conn.query(reads));
}
if (write_count > 0) {
promises.push(conn.query(writes));
}
if (promises.length > 0) {
// Start latency timer // Start latency timer
var start = Date.now(); var start = Date.now();
// Asynchronously execute read and write queries // Asynchronously execute read and write queries
await Promise.all([conn.query(reads), conn.query(writes)]); await Promise.all(promises);
// Calculate latency // Calculate latency
var delta = Date.now() - start; var delta = Date.now() - start;
// Return the results // Return the results
res.send({ execution_time: delta }); res.send({ execution_time: delta });
}
else {
res.send({ execution_time: 0.0 });
}
} catch (err) { } catch (err) {
throw err; throw err;
} finally { } finally {