micord/ervu-eks
1
0
Fork 0
Code Issues Pull requests Projects Releases Packages Wiki Activity Actions

Change

Browse source
This commit is contained in:
Maksim Tereshin 2025-04-10 13:55:01 -05:00
parent 7217007f4a
commit 167a63ff6f
No known key found for this signature in database
1 changed files with 10 additions and 1 deletions
Download patch file Download diff file Expand all files Collapse all files

11
config-data-executor/src/main/java/org/micord/service/RequestService.java
View file

@ -646,8 +646,13 @@ public class RequestService {
sqlQuery = sqlQuery.replace("${endpointArguments}", "(" + inClause + ")");
}
logger.debug("Executing SQL query: {}", sqlQuery);
logger.info("Executing SQL query: {}", sqlQuery);
List<String> parameterValues = fetchFileListFromDatabaseSQL(connection, sqlQuery);
if (parameterValues != null && !parameterValues.isEmpty()) {
logger.info("Parameter type: {}; values: {}", parameter.getType(), parameterValues.get(0));
} else {
logger.info("No values found for parameter type: {}", parameter.getType());
}
bindVars.put(parameter.getType(), parameterValues);
} catch (SQLException e) {
logger.error("Failed to fetch parameter values for type: {}", parameter.getType(), e);
@ -658,6 +663,10 @@ public class RequestService {
AqlQueryOptions aqlQueryOptions = new AqlQueryOptions().streamTransactionId(transactionId);
bindVars.forEach((key, value) -> {
logger.info("Key: {}; Value: {}", key, value);
});
try (ArangoCursor<Map> cursor = arangoDb.query(url, Map.class, bindVars, aqlQueryOptions)) {
while (cursor.hasNext()) {
Map<String, Object> result = cursor.next();