modified: backend/src/services/ScriptExecutor.ts
modified: backend/src/services/SqlExecutor.ts
This commit is contained in:
@@ -85,6 +85,7 @@ export class ScriptExecutor {
|
|||||||
|
|
||||||
const result = await sqlExecutor.executeQuery(dbId, processedQuery, paramValues);
|
const result = await sqlExecutor.executeQuery(dbId, processedQuery, paramValues);
|
||||||
|
|
||||||
|
console.log(`[execQuery ${queryName}] success, rowCount:`, result.rowCount);
|
||||||
return {
|
return {
|
||||||
success: true,
|
success: true,
|
||||||
data: result.rows,
|
data: result.rows,
|
||||||
|
|||||||
@@ -52,7 +52,9 @@ export class SqlExecutor {
|
|||||||
|
|
||||||
// Execute with retry mechanism
|
// Execute with retry mechanism
|
||||||
const result = await this.retryQuery(async () => {
|
const result = await this.retryQuery(async () => {
|
||||||
return await pool.query(sqlQuery, params);
|
const queryResult = await pool.query(sqlQuery, params);
|
||||||
|
console.log('[SQL Result] rowCount:', queryResult.rowCount, 'rows:', JSON.stringify(queryResult.rows).substring(0, 500));
|
||||||
|
return queryResult;
|
||||||
}, 3, 500); // 3 попытки с задержкой 500ms
|
}, 3, 500); // 3 попытки с задержкой 500ms
|
||||||
|
|
||||||
const executionTime = Date.now() - startTime;
|
const executionTime = Date.now() - startTime;
|
||||||
|
|||||||
Reference in New Issue
Block a user