public/api_builder
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

modified: backend/src/services/ScriptExecutor.ts

Browse Source
This commit is contained in:
GEgorov
2025-10-07 02:05:57 +03:00
parent 195b3c3611
commit 1871d0c397
1 changed files with 12 additions and 0 deletions
Download Patch File Download Diff File Expand all files Collapse all files

12
backend/src/services/ScriptExecutor.ts
View File

@@ -37,6 +37,11 @@ export class ScriptExecutor {
}); });
const dbId = (query as any).database_id || context.databaseId; const dbId = (query as any).database_id || context.databaseId;
if (!dbId) {
throw new Error(`Database ID not found. Query database_id: ${(query as any).database_id}, Context databaseId: ${context.databaseId}. Please specify database_id in the query configuration.`);
}
const result = await sqlExecutor.executeQuery(dbId, processedQuery, paramValues); const result = await sqlExecutor.executeQuery(dbId, processedQuery, paramValues);
return { return {
@@ -161,6 +166,13 @@ print(json.dumps(result))
// Используем database_id из запроса, если указан, иначе из контекста // Используем database_id из запроса, если указан, иначе из контекста
const dbId = (query as any).database_id || context.databaseId; const dbId = (query as any).database_id || context.databaseId;
if (!dbId) {
python.stdin.write(JSON.stringify({
error: `Database ID not found. Query database_id: ${(query as any).database_id}, Context databaseId: ${context.databaseId}. Please specify database_id in the query configuration.`
}) + '\n');
continue;
}
const result = await sqlExecutor.executeQuery( const result = await sqlExecutor.executeQuery(
dbId, dbId,
processedQuery, processedQuery,