test: re-enable slow query warnings

overextended · Dec 10, 2021 · cd2e739 · cd2e739
1 parent 3928415
commit cd2e739
Show file tree

Hide file tree

Showing 2 changed files with 24 additions and 24 deletions.
diff --git a/src/execute.js b/src/execute.js
@@ -8,15 +8,15 @@ const execute = async (query, parameters, resource) => {
     [query, parameters] = parseParameters(query, parameters);
 
     ScheduleResourceTick(resourceName);
-    // const startTime = process.hrtime();
+    const startTime = process.hrtime();
     const [rows] = await pool.query(query, parameters);
-    // const executionTime = process.hrtime(startTime)[1] / 1000000; // nanosecond to millisecond
+    const executionTime = process.hrtime(startTime)[1] / 1000000; // nanosecond to millisecond
 
-    // if (executionTime >= slowQueryWarning || debug)
-    //   console.log(
-    //     `^3[${debug ? 'DEBUG' : 'WARNING'}] ${resource} took ${executionTime}ms to execute a query!
-    //     ${query} ${JSON.stringify(parameters)}^0`
-    //   );
+    if (executionTime >= slowQueryWarning || debug)
+      console.log(
+        `^3[${debug ? 'DEBUG' : 'WARNING'}] ${resource} took ${executionTime}ms to execute a query!
+        ${query} ${JSON.stringify(parameters)}^0`
+      );
 
     return rows;
   } catch (error) {
@@ -58,21 +58,21 @@ const preparedStatement = async (query, parameters, resource) => {
 
     const results = [];
     let queryCount = parameters.length;
-    // const startTime = process.hrtime();
+    const startTime = process.hrtime();
 
     for (let i = 0; i < queryCount; i++) {
       const [rows] = await connection.execute(query, parameters[i]);
       results[i] = rows && (type === 3 ? rows.affectedRows : type === 2 ? rows.insertId : rows);
     }
 
-    // const executionTime = process.hrtime(startTime)[1] / 1000000; // nanosecond to millisecond
-    // if (executionTime >= slowQueryWarning || debug)
-    //   console.log(
-    //     `^3[${debug ? 'DEBUG' : 'WARNING'}] ${resource} took ${executionTime}ms to execute ${
-    //       queryCount > 1 ? queryCount + ' queries' : 'a query'
-    //     }!
-    //     ${query} ${JSON.stringify(parameters)}^0`
-    //   );
+    const executionTime = process.hrtime(startTime)[1] / 1000000; // nanosecond to millisecond
+    if (executionTime >= slowQueryWarning || debug)
+      console.log(
+        `^3[${debug ? 'DEBUG' : 'WARNING'}] ${resource} took ${executionTime}ms to execute ${
+          queryCount > 1 ? queryCount + ' queries' : 'a query'
+        }!
+        ${query} ${JSON.stringify(parameters)}^0`
+      );
 
     if (results.length === 1) {
       if (type === 1) {

diff --git a/src/transaction.js b/src/transaction.js
@@ -13,10 +13,10 @@ const transaction = async (queries, parameters, resource) => {
   ScheduleResourceTick(resourceName);
   const connection = await pool.getConnection();
   try {
-    // const startTime = process.hrtime();
 
     const fullQuery = parseTransaction(queries, parameters);
     const transactionAmount = fullQuery.length;
+    const startTime = process.hrtime();
 
     await connection.beginTransaction();
 
@@ -26,14 +26,14 @@ const transaction = async (queries, parameters, resource) => {
 
     await connection.commit();
 
-    // const executionTime = process.hrtime(startTime)[1] / 1000000;
+    const executionTime = process.hrtime(startTime)[1] / 1000000;
 
-    // if (executionTime >= slowQueryWarning * transactionAmount || debug)
-    //   console.log(
-    //     `^3[${
-    //       debug ? 'DEBUG' : 'WARNING'
-    //     }] ${resource} took ${executionTime}ms to execute a transaction!\n${transactionError(queries, parameters)}^0`
-    //   );
+    if (executionTime >= slowQueryWarning * transactionAmount || debug)
+      console.log(
+        `^3[${
+          debug ? 'DEBUG' : 'WARNING'
+        }] ${resource} took ${executionTime}ms to execute a transaction!\n${transactionError(queries, parameters)}^0`
+      );
 
     return true;
   } catch (error) {