7x31
/
sniffer-agent
mirror of https://github.com/zr-hebo/sniffer-agent.git
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

fix bug of lost user info and use db stmt

This commit is contained in:
hebo 2019-08-30 12:46:26 +08:00
parent 3a616e9ff0
commit 82f3abbb25
2 changed files with 4 additions and 6 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
session-dealer/mysql/config.go
View File

@ -7,7 +7,7 @@ import (
) )
var ( 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)`) ddlPatern = regexp.MustCompile(`(?i)^\s*(create|alter|drop)`)
) )

6
session-dealer/mysql/session.go
View File

@ -345,12 +345,10 @@ func (ms *MysqlSession) GenerateQueryPiece() (qp model.QueryPiece) {
func filterQueryPieceBySQL(mqp *model.PooledMysqlQueryPiece, querySQL []byte) (model.QueryPiece) { func filterQueryPieceBySQL(mqp *model.PooledMysqlQueryPiece, querySQL []byte) (model.QueryPiece) {
if mqp == nil || querySQL == nil { if mqp == nil || querySQL == nil {
return nil return nil
}
/* } else if (uselessSQLPattern.Match(querySQL)) {
else if (uselessSQLPattern.Match(querySQL)) {
return nil return nil
} }
*/
if ddlPatern.Match(querySQL) { if ddlPatern.Match(querySQL) {
mqp.SetNeedSyncSend(true) mqp.SetNeedSyncSend(true)