(@NotNull Transaction t, Procedure proc)
| 23 | private final boolean isHistory; |
| 24 | |
| 25 | public Changes(@NotNull Transaction t, Procedure proc) { |
| 26 | isHistory = proc.getZeze().getConfig().isHistory(); |
| 27 | // transaction = t; |
| 28 | // 建立脏记录的表的监听者的快照,以后收集日志和通知监听者都使用这个快照,避免由于监听者发生变化造成收集和通知不一致。 |
| 29 | for (var ar : t.getAccessedRecords().values()) { |
| 30 | if (ar.dirty) { |
| 31 | var listeners = ar.atomicTupleRecord.record.getTable().getChangeListenerMap().getListeners(); |
| 32 | if (!listeners.isEmpty()) |
| 33 | this.listeners.putIfAbsent(ar.atomicTupleRecord.record.getTable(), listeners); |
| 34 | } |
| 35 | } |
| 36 | } |
| 37 | |
| 38 | public @NotNull LongHashMap<LogBean> getBeans() { |
| 39 | return beans; |
nothing calls this directly
no test coverage detected