wangli/msg-center-plat
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

REQ-3284: 查询数量过大告警

Browse Source
This commit is contained in:
yanglin 2024-11-29 17:44:39 +08:00
parent 0e0d7f8d7b
commit 20c664cc38
1 changed files with 4 additions and 4 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

8
inside-notices/src/main/java/cn/axzo/msg/center/message/service/todo/mybatis/rowcountwarn/ProxyStatement.java
View File

@ -60,12 +60,12 @@ class ProxyStatement extends StatementWrapper {
void rowAdvanced() {
rowCount++;
if (thresholdCrossed() && setWarnedForPhase("Threshold"))
if (rowCountAboveThreshold() && setWarnedForPhase("Threshold"))
warnFor("Threshold");
}
public void resultSetClosed() {
if (thresholdCrossed() && shouldWarnOnResultSetClosed()) {
if (rowCountAboveThreshold() && shouldWarnOnResultSetClosed()) {
String phase = String.format("ResultSetClose-%d-%d", resultSetWarnTimes, resultSetCount);
warnFor(phase);
resultSetWarnTimes++;
@ -93,7 +93,7 @@ class ProxyStatement extends StatementWrapper {
@Override
public void close() throws SQLException {
super.close();
if (thresholdCrossed() && setWarnedForPhase("StatementClose"))
if (rowCountAboveThreshold() && setWarnedForPhase("StatementClose"))
warnFor("StatementClose");
}
@ -116,7 +116,7 @@ class ProxyStatement extends StatementWrapper {
}
}
private boolean thresholdCrossed() {
private boolean rowCountAboveThreshold() {
return rowCount > props.getRowCount().determineWarningThreshold();
}