mirror/dble
1
0
Fork 0
mirror of https://github.com/actiontech/dble.git synced 2026-05-06 14:30:54 -05:00
Code Issues Packages Projects Releases Wiki Activity

inner-2383: add log

Browse Source
This commit is contained in:
dcy
2024-04-24 10:34:53 +08:00
parent f2fb349085
commit 16750a99d4
3 changed files with 5 additions and 4 deletions
Download Patch File Download Diff File Expand all files Collapse all files
src/main/java/com/actiontech/dble/services/manager/handler/DeleteHandler.java
+1 -1
View File
@@ -119,7 +119,7 @@ public final class DeleteHandler {
Set<LinkedHashMap<String, String>> affectPks = ManagerTableUtil.getAffectPks(service, managerTable, foundRows, null);
rowSize = managerTable.deleteRows(affectPks);
if (rowSize != 0) {
ReloadConfig.execute(service, 0, false, new ConfStatus(ConfStatus.Status.MANAGER_DELETE, managerTable.getTableName()), packetResult, null);
ReloadConfig.execute(service, 0, false, new ConfStatus(ConfStatus.Status.MANAGER_DELETE, managerTable.getTableName()), packetResult);
}
packetResult.setRowSize(rowSize);
} catch (SQLException e) {
src/main/java/com/actiontech/dble/services/manager/handler/InsertHandler.java
+1 -1
View File
@@ -79,7 +79,7 @@ public final class InsertHandler {
managerTable.checkPrimaryKeyDuplicate(rows);
rowSize = managerTable.insertRows(rows);
if (rowSize != 0) {
ReloadConfig.execute(service, 0, false, new ConfStatus(ConfStatus.Status.MANAGER_INSERT, managerTable.getTableName()), packetResult, null);
ReloadConfig.execute(service, 0, false, new ConfStatus(ConfStatus.Status.MANAGER_INSERT, managerTable.getTableName()), packetResult);
}
managerTable.afterExecute();
packetResult.setRowSize(rowSize);
src/main/java/com/actiontech/dble/services/manager/response/ReloadConfig.java
+3 -2
View File
@@ -74,8 +74,9 @@ public final class ReloadConfig {
writeErrorResult(service, e.getMessage() == null ? e.toString() : e.getMessage());
}
}
public static void execute(ManagerService service, final int loadAllMode, boolean returnFlag, ConfStatus confStatus) throws Exception {
execute(service, loadAllMode, returnFlag, confStatus, new ReloadContext());
public static void execute(ManagerService service, final int loadAllMode, boolean returnFlag, ConfStatus confStatus, PacketResult packetResult) throws Exception {
execute(service, loadAllMode, returnFlag, confStatus, packetResult, new ReloadContext());
}
public static void execute(ManagerService service, final int loadAllMode, boolean returnFlag, ConfStatus confStatus, ReloadContext reloadContext) throws Exception {