Skip to content

Commit ab0c825

Browse files
authored
fix:update语句反引号删除问题 (#12)
1 parent dffa064 commit ab0c825

File tree

2 files changed

+12
-1
lines changed

2 files changed

+12
-1
lines changed

src/main/java/com/cenboomh/commons/ojdbc/SqlHelper.java

+4-1
Original file line numberDiff line numberDiff line change
@@ -42,6 +42,7 @@
4242
import java.util.function.Predicate;
4343
import java.util.logging.Level;
4444
import java.util.logging.Logger;
45+
import java.util.stream.Collectors;
4546

4647
/**
4748
* @author wuwen
@@ -202,7 +203,9 @@ public void visit(Insert insert) {
202203
@Override
203204
public void visit(Update update) {
204205
super.visit(update);
205-
columnsProcess(update.getUpdateSets().get(0).getColumns());
206+
columnsProcess(update.getUpdateSets().stream()
207+
.flatMap(i -> i.getColumns().stream())
208+
.collect(Collectors.toList()));
206209
}
207210

208211
@Override

src/test/java/com/cenboomh/commons/ojdbc/SqlHelperTest.java

+8
Original file line numberDiff line numberDiff line change
@@ -63,6 +63,14 @@ void mysql2oracle() {
6363
assertEquals(test[1].toUpperCase(), SqlHelper.mysql2oracle(test[0]).toUpperCase());
6464
}
6565
}
66+
67+
@Test
68+
void issueUpdateBackquote() {
69+
String sql = "UPDATE xxl_job_log_report SET `running_count` = ?, `suc_count` = ?, `fail_count` = ? WHERE `trigger_day` = ?";
70+
String expeSql = "UPDATE XXL_JOB_LOG_REPORT SET RUNNING_COUNT = ?, SUC_COUNT = ?, FAIL_COUNT = ? WHERE TRIGGER_DAY = ?";
71+
72+
assertEquals(expeSql, SqlHelper.mysql2oracle(sql).toUpperCase());
73+
}
6674

6775

6876

0 commit comments

Comments
 (0)