diff --git a/сonfig-data-executor/config-examples/removeFromCallList.xml b/сonfig-data-executor/config-examples/removeFromCallList.xml index 673af80..dcf73f2 100644 --- a/сonfig-data-executor/config-examples/removeFromCallList.xml +++ b/сonfig-data-executor/config-examples/removeFromCallList.xml @@ -1,18 +1,48 @@ - - - + DELETE FROM summoned_list where recruit_id in ${endpointArguments} ${extraConditions} + + 10.10.31.118 + 5432 + ervu + ervu + org.postgresql.Driver + org.postgresql.xa.PGXADataSource + 15 + summon-list-registry + + + + + DELETE FROM documents where recruit_id in ${endpointArguments} ${extraConditions} + + 10.10.31.118 + 5432 + ervu + ervu + org.postgresql.Driver + org.postgresql.xa.PGXADataSource + 15 + summon-list-registry + + + + + DELETE FROM subpoena where recruit_id in ${endpointArguments} ${extraConditions} + + 10.10.31.118 + 5432 + ervu + ervu + org.postgresql.Driver + org.postgresql.xa.PGXADataSource + 15 + summon-list-registry + + + + + DELETE FROM recruit_active_list where recruit_id in ${endpointArguments} ${extraConditions} 10.10.31.118 5432 diff --git a/сonfig-data-executor/src/main/java/org/micord/service/RequestService.java b/сonfig-data-executor/src/main/java/org/micord/service/RequestService.java index e51ed8f..b81e67e 100644 --- a/сonfig-data-executor/src/main/java/org/micord/service/RequestService.java +++ b/сonfig-data-executor/src/main/java/org/micord/service/RequestService.java @@ -134,7 +134,8 @@ public class RequestService { try (Connection connection = DatabaseConnection.getConnection( request.getSqlConnectionParams())) { query = buildSqlQuery(request, String.join(",", ids)); - executeSqlQuery(connection, query); + int rowsAffected = executeSqlQuery(connection, query); + logger.info("Successfully deleted {} rows for IDs: {} in query: {}", rowsAffected, String.join(", ", ids), query); } catch (SQLException e) { logger.error("SQL execution failed for query: {}", query, e); @@ -181,9 +182,9 @@ public class RequestService { .replace("${endpointArguments}", endpointArguments); } - private void executeSqlQuery(Connection connection, String query) throws SQLException { + private int executeSqlQuery(Connection connection, String query) throws SQLException { try (PreparedStatement stmt = connection.prepareStatement(query)) { - stmt.execute(); + return stmt.executeUpdate(); } }