From 675d455d236f4bd59a31dd18962531ff42f49ca1 Mon Sep 17 00:00:00 2001 From: GEgorov Date: Sat, 29 Nov 2025 16:28:02 +0300 Subject: [PATCH] modified: backend/src/services/SqlExecutor.ts --- backend/src/services/SqlExecutor.ts | 12 ++++-------- 1 file changed, 4 insertions(+), 8 deletions(-) diff --git a/backend/src/services/SqlExecutor.ts b/backend/src/services/SqlExecutor.ts index 8f76685..e3de032 100644 --- a/backend/src/services/SqlExecutor.ts +++ b/backend/src/services/SqlExecutor.ts @@ -56,19 +56,15 @@ export class SqlExecutor { // Execute with retry mechanism const result = await this.retryQuery(async () => { - // Check session info for debugging + // Check if connected to replica const debugResult = await pool.query(` SELECT - current_setting('search_path') as search_path, pg_backend_pid() as pid, - inet_server_addr() as server_ip, - current_user as cur_user, - session_user as sess_user, - current_setting('role') as role, - current_setting('transaction_isolation') as isolation + pg_is_in_recovery() as is_replica, + inet_server_addr() as server_ip `); const d = debugResult.rows[0]; - console.log('[SQL Debug] pid:', d?.pid, 'cur_user:', d?.cur_user, 'sess_user:', d?.sess_user, 'role:', d?.role, 'isolation:', d?.isolation); + console.log('[SQL Debug] pid:', d?.pid, 'is_replica:', d?.is_replica, 'server_ip:', d?.server_ip); // Disable prepared statements by using unique name each time const queryResult = await pool.query({