Skip to content

Commit

Permalink
fix: drop tableOfIdSource logic
Browse files Browse the repository at this point in the history
  • Loading branch information
Nolife999 committed Dec 1, 2023
1 parent bc3a919 commit 3d1098b
Show file tree
Hide file tree
Showing 2 changed files with 6 additions and 9 deletions.
Original file line number Diff line number Diff line change
Expand Up @@ -81,12 +81,11 @@ public void execute(SendResponse resp) throws ArcException {
if (!reprise) {
this.clientDao.updatePilotage(table.getTableName());
}

this.clientDao.dropTable(table.getTableName());
this.clientDao.dropTable(table);
}

table = this.clientDao.getAClientTableByType(ExportTrackingType.TRACK);
this.clientDao.dropTable(table.getTableName());
this.clientDao.dropTable(table);

resp.send(" ");
resp.endSending();
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -435,20 +435,18 @@ public TableToRetrieve getAClientTableByName(String tableName) throws ArcExcepti
: new TableToRetrieve(content.get("nod").get(0), content.get("table_to_retrieve").get(0));
}

public void dropTable(String clientTable) {
dropTable(ArcDatabase.COORDINATOR.getIndex(), clientTable);
}

public void dropTable(int connectionIndex, String clientTable) {
private void dropTable(int connectionIndex, String clientTable) {
UtilitaireDao.get(connectionIndex).dropTable(connection, clientTable);
}

public void dropTable(TableToRetrieve table) {

dropTable(ArcDatabase.COORDINATOR.getIndex(), table.getTableName());

dropTable(table.getTableName());
int numberOfExecutorNods = ArcDatabase.numberOfExecutorNods();

if (table.getNod().equals(ArcDatabase.EXECUTOR)) {
int numberOfExecutorNods = ArcDatabase.numberOfExecutorNods();
for (int executorConnectionId = ArcDatabase.EXECUTOR.getIndex(); executorConnectionId < ArcDatabase.EXECUTOR
.getIndex() + numberOfExecutorNods; executorConnectionId++) {
dropTable(executorConnectionId, table.getTableName());
Expand Down

0 comments on commit 3d1098b

Please sign in to comment.