diff --git a/src/main/java/com/alibaba/druid/sql/dialect/mysql/parser/MySqlStatementParser.java b/src/main/java/com/alibaba/druid/sql/dialect/mysql/parser/MySqlStatementParser.java index deada0d47b..69b833522b 100644 --- a/src/main/java/com/alibaba/druid/sql/dialect/mysql/parser/MySqlStatementParser.java +++ b/src/main/java/com/alibaba/druid/sql/dialect/mysql/parser/MySqlStatementParser.java @@ -1900,6 +1900,7 @@ public class MySqlStatementParser extends SQLStatementParser { acceptIdentifier("TRANSACTION"); SQLStartTransactionStatement stmt = new SQLStartTransactionStatement(); + stmt.setDbType(dbType); if (lexer.token() == Token.WITH) { lexer.nextToken(); diff --git a/src/main/java/com/alibaba/druid/sql/dialect/sqlserver/parser/SQLServerStatementParser.java b/src/main/java/com/alibaba/druid/sql/dialect/sqlserver/parser/SQLServerStatementParser.java index e2f9b1d380..b7c3e07b01 100644 --- a/src/main/java/com/alibaba/druid/sql/dialect/sqlserver/parser/SQLServerStatementParser.java +++ b/src/main/java/com/alibaba/druid/sql/dialect/sqlserver/parser/SQLServerStatementParser.java @@ -494,6 +494,7 @@ public class SQLServerStatementParser extends SQLStatementParser { lexer.nextToken(); SQLStartTransactionStatement startTrans = new SQLStartTransactionStatement(); + startTrans.setDbType(dbType); if (lexer.token() == Token.IDENTIFIER) { SQLName name = this.exprParser.name();