perf(database): normalize logged SQL without extracting tables

Call the existing normalization helper directly for base query-log records. Statement type and table extraction remain in the optional analysis path, where their results are used. Verify the normalized SQL actually persisted by the logger.

Complete in-memory SQLite read-and-log workload on a shared M3 Pro laptop, Bun 1.3.14: 23.581 to 22.3115 us per operation (5.38% less time), three alternating pairs, all 3000 records verified each round. No disk HTTP throughput claim. Passed 1377 router/database tests, 366 unit tests, lint, typecheck, and both review axes.

Author: chrisbbreuer

storage/framework/core/database/src/query-logger.ts

@@ -4,7 +4,7 @@ import { memoryUsage } from 'node:process'
 import { AsyncLocalStorage } from 'node:async_hooks'
 import { config } from '@stacksjs/config'
 import { log } from '@stacksjs/logging'
-import { parseQuery } from './query-parser'
+import { normalizeQuery, parseQuery } from './query-parser'
 import { db } from './utils'
 
 /**
@@ -225,7 +225,7 @@ async function createQueryLogRecord(
   const connection = config.database.default || 'unknown'
 
   // Get normalized query (replace specific values with placeholders)
-  const normalizedQuery = parseQuery(query).normalized || query
+  const normalizedQuery = normalizeQuery(query) || query
 
   // Extract stack trace and caller information
   const { trace, caller } = extractTraceInfo()

storage/framework/core/database/src/query-parser.ts

@@ -129,7 +129,7 @@ function extractTables(sql: string, type: string): string[] {
 /**
  * Normalize a SQL query by replacing literal values with placeholders
  */
-function normalizeQuery(sql: string): string {
+export function normalizeQuery(sql: string): string {
   try {
     let normalizedSql = sql
 

storage/framework/core/database/tests/fixtures/query-logger-dispatch.ts

@@ -104,6 +104,13 @@ try {
     await Bun.sleep(0)
     await createLogTable()
     await queryWithDiagnostics('query_logger_after_failed_store')
+
+    const { logQuery } = await import('../../src/query-logger')
+    const literalQuery = "SELECT 42 AS total, 'Ada' AS name, TRUE AS active, NULL AS missing FROM query_logger_fixture"
+    await logQuery({ query: { sql: literalQuery }, queryDurationMillis: 1 })
+    const normalized = await db.unsafe('SELECT normalized_query FROM query_logs WHERE query = ?', [literalQuery]).execute()
+    if (normalized.length !== 1 || normalized[0]?.normalized_query !== 'SELECT ? AS total, ? AS name, ? AS active, ? AS missing FROM query_logger_fixture')
+      throw new Error('Persisted query normalization changed')
   }
   console.log('query-logger-dispatch-ok')
 }