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

save

Browse source
This commit is contained in:
ilyin 2024-09-23 15:58:06 +03:00
parent 5026c23897
commit 36ace281ec
2 changed files with 47 additions and 16 deletions
Download patch file Download diff file Expand all files Collapse all files

56
сonfig-data-executor/config-examples/removeFromCallList.xml
View file

@ -1,18 +1,48 @@
<Requests> <Requests>
<SqlRequest> <SqlRequest>
<RequestURL> <RequestURL>DELETE FROM summoned_list where recruit_id in ${endpointArguments} ${extraConditions}</RequestURL>
<![CDATA[ <SqlConnectionParams>
DO <JdbcHost>10.10.31.118</JdbcHost>
$$ <JdbcPort>5432</JdbcPort>
BEGIN <JdbcUsername>ervu</JdbcUsername>
DELETE FROM summoned_list where recruit_id in ${endpointArguments} ${extraConditions}; <JdbcPassword>ervu</JdbcPassword>
DELETE FROM recruit_active_list where recruit_id in ${endpointArguments} ${extraConditions}; <JdbcDriverClassName>org.postgresql.Driver</JdbcDriverClassName>
DELETE FROM documents where recruit_id in ${endpointArguments} ${extraConditions}; <JdbcXaDataSourceClassName>org.postgresql.xa.PGXADataSource</JdbcXaDataSourceClassName>
DELETE FROM subpoena where recruit_id in ${endpointArguments} ${extraConditions}; <JdbcXaDataSourcePoolSize>15</JdbcXaDataSourcePoolSize>
END <JdbcDatabase>summon-list-registry</JdbcDatabase>
$$; </SqlConnectionParams>
]]> </SqlRequest>
</RequestURL>
<SqlRequest>
<RequestURL>DELETE FROM documents where recruit_id in ${endpointArguments} ${extraConditions}</RequestURL>
<SqlConnectionParams>
<JdbcHost>10.10.31.118</JdbcHost>
<JdbcPort>5432</JdbcPort>
<JdbcUsername>ervu</JdbcUsername>
<JdbcPassword>ervu</JdbcPassword>
<JdbcDriverClassName>org.postgresql.Driver</JdbcDriverClassName>
<JdbcXaDataSourceClassName>org.postgresql.xa.PGXADataSource</JdbcXaDataSourceClassName>
<JdbcXaDataSourcePoolSize>15</JdbcXaDataSourcePoolSize>
<JdbcDatabase>summon-list-registry</JdbcDatabase>
</SqlConnectionParams>
</SqlRequest>
<SqlRequest>
<RequestURL>DELETE FROM subpoena where recruit_id in ${endpointArguments} ${extraConditions}</RequestURL>
<SqlConnectionParams>
<JdbcHost>10.10.31.118</JdbcHost>
<JdbcPort>5432</JdbcPort>
<JdbcUsername>ervu</JdbcUsername>
<JdbcPassword>ervu</JdbcPassword>
<JdbcDriverClassName>org.postgresql.Driver</JdbcDriverClassName>
<JdbcXaDataSourceClassName>org.postgresql.xa.PGXADataSource</JdbcXaDataSourceClassName>
<JdbcXaDataSourcePoolSize>15</JdbcXaDataSourcePoolSize>
<JdbcDatabase>summon-list-registry</JdbcDatabase>
</SqlConnectionParams>
</SqlRequest>
<SqlRequest>
<RequestURL>DELETE FROM recruit_active_list where recruit_id in ${endpointArguments} ${extraConditions}</RequestURL>
<SqlConnectionParams> <SqlConnectionParams>
<JdbcHost>10.10.31.118</JdbcHost> <JdbcHost>10.10.31.118</JdbcHost>
<JdbcPort>5432</JdbcPort> <JdbcPort>5432</JdbcPort>

7
сonfig-data-executor/src/main/java/org/micord/service/RequestService.java
View file

@ -134,7 +134,8 @@ public class RequestService {
try (Connection connection = DatabaseConnection.getConnection( try (Connection connection = DatabaseConnection.getConnection(
request.getSqlConnectionParams())) { request.getSqlConnectionParams())) {
query = buildSqlQuery(request, String.join(",", ids)); 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) { catch (SQLException e) {
logger.error("SQL execution failed for query: {}", query, e); logger.error("SQL execution failed for query: {}", query, e);
@ -181,9 +182,9 @@ public class RequestService {
.replace("${endpointArguments}", endpointArguments); .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)) { try (PreparedStatement stmt = connection.prepareStatement(query)) {
stmt.execute(); return stmt.executeUpdate();
} }
} }