feedc0de/LogBlock
1
0
Fork 0
forked from LogBlock/LogBlock
Code Pull Requests Activity

Skip duplicates for chest/sign conversion too

Browse Source
This commit is contained in:
Brokkonaut
2018-11-24 03:39:05 +01:00
parent 7e47a0c375
commit d847908d3c
1 changed files with 22 additions and 4 deletions
Download Patch File Download Diff File Expand all files Collapse all files

26
src/main/java/de/diddiz/LogBlock/Updater.java
View File

@ -552,10 +552,19 @@ class Updater {
if (!anyRow) {
break;
}
insertChestData.executeBatch();
int failedRows = 0;
try {
insertChestData.executeBatch();
} catch (BatchUpdateException e) {
for (int result : e.getUpdateCounts()) {
if (result == Statement.EXECUTE_FAILED) {
failedRows++;
}
}
}
deleteChest.executeBatch();
conn.commit();
logblock.getLogger().info("Done: " + done + "/" + rowsToConvert + " (" + (rowsToConvert > 0 ? (done * 100 / rowsToConvert) : 100) + "%)");
logblock.getLogger().info("Done: " + done + "/" + rowsToConvert + " " + (failedRows > 0 ? "Duplicates: " + failedRows + " " : "") + "(" + (rowsToConvert > 0 ? (done * 100 / rowsToConvert) : 100) + "%)");
}
insertChestData.close();
deleteChest.close();
@ -693,10 +702,19 @@ class Updater {
if (!anyRow) {
break;
}
insertSignState.executeBatch();
int failedRows = 0;
try {
insertSignState.executeBatch();
} catch (BatchUpdateException e) {
for (int result : e.getUpdateCounts()) {
if (result == Statement.EXECUTE_FAILED) {
failedRows++;
}
}
}
deleteSign.executeBatch();
conn.commit();
logblock.getLogger().info("Done: " + done + "/" + rowsToConvert + " (" + (rowsToConvert > 0 ? (done * 100 / rowsToConvert) : 100) + "%)");
logblock.getLogger().info("Done: " + done + "/" + rowsToConvert + " " + (failedRows > 0 ? "Duplicates: " + failedRows + " " : "") + "(" + (rowsToConvert > 0 ? (done * 100 / rowsToConvert) : 100) + "%)");
}
insertSignState.close();
deleteSign.close();