[typo](comment) code comment fix (#17870)
Co-authored-by: wangqingtao6 <wangqingtao6@jd.com>
This commit is contained in:
@ -596,7 +596,7 @@ public class StmtExecutor implements ProfileWriter {
|
||||
handleTransactionStmt();
|
||||
} else if (parsedStmt instanceof CreateTableAsSelectStmt) {
|
||||
handleCtasStmt();
|
||||
} else if (parsedStmt instanceof InsertStmt) { // Must ahead of DdlStmt because InserStmt is its subclass
|
||||
} else if (parsedStmt instanceof InsertStmt) { // Must ahead of DdlStmt because InsertStmt is its subclass
|
||||
try {
|
||||
handleInsertStmt();
|
||||
if (!((InsertStmt) parsedStmt).getQueryStmt().isExplain()) {
|
||||
@ -1551,7 +1551,7 @@ public class StmtExecutor implements ProfileWriter {
|
||||
executor.beginTransaction(request);
|
||||
}
|
||||
|
||||
// Process a select statement.
|
||||
// Process an insert statement.
|
||||
private void handleInsertStmt() throws Exception {
|
||||
// Every time set no send flag and clean all data in buffer
|
||||
if (context.getMysqlChannel() != null) {
|
||||
|
||||
Reference in New Issue
Block a user