diff --git a/session-dealer/mysql/config.go b/session-dealer/mysql/config.go index 95c67ec..23fae06 100644 --- a/session-dealer/mysql/config.go +++ b/session-dealer/mysql/config.go @@ -7,7 +7,7 @@ import ( ) var ( - uselessSQLPattern = regexp.MustCompile(`(?i)^\s*(select 1|select @@version_comment limit 1|commit|begin)`) + uselessSQLPattern = regexp.MustCompile(`(?i)^\s*(select @@version_comment limit 1)`) ddlPatern = regexp.MustCompile(`(?i)^\s*(create|alter|drop)`) ) diff --git a/session-dealer/mysql/session.go b/session-dealer/mysql/session.go index f07c954..eed1289 100644 --- a/session-dealer/mysql/session.go +++ b/session-dealer/mysql/session.go @@ -345,12 +345,10 @@ func (ms *MysqlSession) GenerateQueryPiece() (qp model.QueryPiece) { func filterQueryPieceBySQL(mqp *model.PooledMysqlQueryPiece, querySQL []byte) (model.QueryPiece) { if mqp == nil || querySQL == nil { return nil + + } else if (uselessSQLPattern.Match(querySQL)) { + return nil } - /* - else if (uselessSQLPattern.Match(querySQL)) { - return nil - } - */ if ddlPatern.Match(querySQL) { mqp.SetNeedSyncSend(true)