mirror/dble
1
0
Fork 0
mirror of https://github.com/actiontech/dble.git synced 2026-01-02 02:40:28 -06:00
Code Issues Packages Projects Releases Wiki Activity

fix inner DBLE0REQ-607 (#2269)

Browse Source
This commit is contained in:
ylinzhu
2020-11-16 09:57:06 +08:00
committed by lin
parent 5e88859950
commit 1dc51bcf1d
1 changed files with 14 additions and 2 deletions
Download Patch File Download Diff File Expand all files Collapse all files

16
src/main/java/com/actiontech/dble/server/parser/ServerParse.java
View File

@@ -753,6 +753,7 @@ public class ServerParse {
// BEGIN
protected static int beginCheck(String stmt, int offset) {
String key = "work";
if (stmt.length() > offset + 4) {
char c1 = stmt.charAt(++offset);
char c2 = stmt.charAt(++offset);
@@ -762,15 +763,26 @@ public class ServerParse {
(c2 == 'G' || c2 == 'g') &&
(c3 == 'I' || c3 == 'i') &&
(c4 == 'N' || c4 == 'n') &&
(stmt.length() == ++offset || ParseUtil.isEOF(stmt, offset) || ParseUtil.isMultiEof(stmt, offset))) {
(stmt.length() == ++offset || keyCheck(stmt, key, offset) || ParseUtil.isEOF(stmt, offset) || ParseUtil.isMultiEof(stmt, offset))) {
return BEGIN;
}
}
return OTHER;
}
private static boolean keyCheck(String stmt, String key, int offset) {
String lowerStmt = stmt.toLowerCase().substring(offset).trim();
offset = stmt.toLowerCase().indexOf(key) + key.length() - 1;
if (lowerStmt.startsWith(key) && (stmt.length() == ++offset || ParseUtil.isEOF(stmt, offset) || ParseUtil.isMultiEof(stmt, offset))) {
return true;
}
return false;
}
// COMMIT
private static int commitCheck(String stmt, int offset) {
String key = "work";
if (stmt.length() > offset + 5) {
char c1 = stmt.charAt(++offset);
char c2 = stmt.charAt(++offset);
@@ -782,7 +794,7 @@ public class ServerParse {
(c3 == 'M' || c3 == 'm') &&
(c4 == 'I' || c4 == 'i') &&
(c5 == 'T' || c5 == 't') &&
(stmt.length() == ++offset || ParseUtil.isEOF(stmt, offset) || ParseUtil.isMultiEof(stmt, offset))) {
(stmt.length() == ++offset || keyCheck(stmt, key, offset) || ParseUtil.isEOF(stmt, offset) || ParseUtil.isMultiEof(stmt, offset))) {
return COMMIT;
}
}