Skip to content

Commit

Permalink
[Agent] Parsing the statement id of the mysql protocol #3590
Browse files Browse the repository at this point in the history
  • Loading branch information
yuanchaoa committed Aug 30, 2023
1 parent 9aa4027 commit daea269
Show file tree
Hide file tree
Showing 15 changed files with 159 additions and 136 deletions.
24 changes: 12 additions & 12 deletions agent/resources/test/flow_generator/mysql/mysql-database.result
@@ -1,12 +1,12 @@
MysqlInfo { msg_type: Other, is_tls: false, protocol_version: 10, server_version: "", server_thread_id: 0, command: 0, context: "", response_code: 0, error_code: None, affected_rows: 0, error_message: "", status: Ok, rrt: 0, trace_id: None } is_mysql: false
MysqlInfo { msg_type: Other, is_tls: false, protocol_version: 10, server_version: "", server_thread_id: 0, command: 0, context: "", response_code: 0, error_code: None, affected_rows: 0, error_message: "", status: Ok, rrt: 0, trace_id: None } is_mysql: false
MysqlInfo { msg_type: Response, is_tls: false, protocol_version: 10, server_version: "", server_thread_id: 0, command: 0, context: "", response_code: 0, error_code: None, affected_rows: 0, error_message: "", status: Ok, rrt: 0, trace_id: None } is_mysql: false
MysqlInfo { msg_type: Request, is_tls: false, protocol_version: 10, server_version: "", server_thread_id: 0, command: 3, context: "select @@version_comment limit 1", response_code: 0, error_code: None, affected_rows: 0, error_message: "", status: Ok, rrt: 0, trace_id: None } is_mysql: true
MysqlInfo { msg_type: Response, is_tls: false, protocol_version: 10, server_version: "", server_thread_id: 0, command: 0, context: "", response_code: 254, error_code: None, affected_rows: 0, error_message: "", status: Ok, rrt: 0, trace_id: None } is_mysql: false
MysqlInfo { msg_type: Request, is_tls: false, protocol_version: 10, server_version: "", server_thread_id: 0, command: 3, context: "create database yuanchao2", response_code: 0, error_code: None, affected_rows: 0, error_message: "", status: Ok, rrt: 0, trace_id: None } is_mysql: true
MysqlInfo { msg_type: Response, is_tls: false, protocol_version: 10, server_version: "", server_thread_id: 0, command: 0, context: "", response_code: 0, error_code: None, affected_rows: 1, error_message: "", status: Ok, rrt: 0, trace_id: None } is_mysql: false
MysqlInfo { msg_type: Request, is_tls: false, protocol_version: 10, server_version: "", server_thread_id: 0, command: 3, context: "drop database yuanchao2", response_code: 0, error_code: None, affected_rows: 0, error_message: "", status: Ok, rrt: 0, trace_id: None } is_mysql: true
MysqlInfo { msg_type: Response, is_tls: false, protocol_version: 10, server_version: "", server_thread_id: 0, command: 0, context: "", response_code: 0, error_code: None, affected_rows: 0, error_message: "", status: Ok, rrt: 0, trace_id: None } is_mysql: false
MysqlInfo { msg_type: Request, is_tls: false, protocol_version: 10, server_version: "", server_thread_id: 0, command: 3, context: "SELECT DATABASE()", response_code: 0, error_code: None, affected_rows: 0, error_message: "", status: Ok, rrt: 0, trace_id: None } is_mysql: true
MysqlInfo { msg_type: Response, is_tls: false, protocol_version: 10, server_version: "", server_thread_id: 0, command: 0, context: "", response_code: 254, error_code: None, affected_rows: 0, error_message: "", status: Ok, rrt: 0, trace_id: None } is_mysql: false
MysqlInfo { msg_type: Request, is_tls: false, protocol_version: 10, server_version: "", server_thread_id: 0, command: 1, context: "", response_code: 0, error_code: None, affected_rows: 0, error_message: "", status: Ok, rrt: 0, trace_id: None } is_mysql: false
MysqlInfo { msg_type: Other, is_tls: false, protocol_version: 10, server_version: "", server_thread_id: 0, command: 0, context: "", response_code: 0, error_code: None, affected_rows: 0, error_message: "", status: Ok, rrt: 0, statement_id: 0, trace_id: None } is_mysql: false
MysqlInfo { msg_type: Other, is_tls: false, protocol_version: 10, server_version: "", server_thread_id: 0, command: 0, context: "", response_code: 0, error_code: None, affected_rows: 0, error_message: "", status: Ok, rrt: 0, statement_id: 0, trace_id: None } is_mysql: false
MysqlInfo { msg_type: Response, is_tls: false, protocol_version: 10, server_version: "", server_thread_id: 0, command: 0, context: "", response_code: 0, error_code: None, affected_rows: 0, error_message: "", status: Ok, rrt: 0, statement_id: 131072, trace_id: None } is_mysql: false
MysqlInfo { msg_type: Request, is_tls: false, protocol_version: 10, server_version: "", server_thread_id: 0, command: 3, context: "select @@version_comment limit 1", response_code: 0, error_code: None, affected_rows: 0, error_message: "", status: Ok, rrt: 0, statement_id: 0, trace_id: None } is_mysql: true
MysqlInfo { msg_type: Response, is_tls: false, protocol_version: 10, server_version: "", server_thread_id: 0, command: 0, context: "", response_code: 254, error_code: None, affected_rows: 0, error_message: "", status: Ok, rrt: 0, statement_id: 0, trace_id: None } is_mysql: false
MysqlInfo { msg_type: Request, is_tls: false, protocol_version: 10, server_version: "", server_thread_id: 0, command: 3, context: "create database yuanchao2", response_code: 0, error_code: None, affected_rows: 0, error_message: "", status: Ok, rrt: 0, statement_id: 0, trace_id: None } is_mysql: true
MysqlInfo { msg_type: Response, is_tls: false, protocol_version: 10, server_version: "", server_thread_id: 0, command: 0, context: "", response_code: 0, error_code: None, affected_rows: 1, error_message: "", status: Ok, rrt: 0, statement_id: 131073, trace_id: None } is_mysql: false
MysqlInfo { msg_type: Request, is_tls: false, protocol_version: 10, server_version: "", server_thread_id: 0, command: 3, context: "drop database yuanchao2", response_code: 0, error_code: None, affected_rows: 0, error_message: "", status: Ok, rrt: 0, statement_id: 0, trace_id: None } is_mysql: true
MysqlInfo { msg_type: Response, is_tls: false, protocol_version: 10, server_version: "", server_thread_id: 0, command: 0, context: "", response_code: 0, error_code: None, affected_rows: 0, error_message: "", status: Ok, rrt: 0, statement_id: 16908288, trace_id: None } is_mysql: false
MysqlInfo { msg_type: Request, is_tls: false, protocol_version: 10, server_version: "", server_thread_id: 0, command: 3, context: "SELECT DATABASE()", response_code: 0, error_code: None, affected_rows: 0, error_message: "", status: Ok, rrt: 0, statement_id: 0, trace_id: None } is_mysql: true
MysqlInfo { msg_type: Response, is_tls: false, protocol_version: 10, server_version: "", server_thread_id: 0, command: 0, context: "", response_code: 254, error_code: None, affected_rows: 0, error_message: "", status: Ok, rrt: 0, statement_id: 0, trace_id: None } is_mysql: false
MysqlInfo { msg_type: Request, is_tls: false, protocol_version: 10, server_version: "", server_thread_id: 0, command: 1, context: "", response_code: 0, error_code: None, affected_rows: 0, error_message: "", status: Ok, rrt: 0, statement_id: 0, trace_id: None } is_mysql: false
20 changes: 10 additions & 10 deletions agent/resources/test/flow_generator/mysql/mysql-error.result
@@ -1,10 +1,10 @@
MysqlInfo { msg_type: Other, is_tls: false, protocol_version: 10, server_version: "", server_thread_id: 0, command: 0, context: "", response_code: 0, error_code: None, affected_rows: 0, error_message: "", status: Ok, rrt: 0, trace_id: None } is_mysql: false
MysqlInfo { msg_type: Other, is_tls: false, protocol_version: 10, server_version: "", server_thread_id: 0, command: 0, context: "", response_code: 0, error_code: None, affected_rows: 0, error_message: "", status: Ok, rrt: 0, trace_id: None } is_mysql: false
MysqlInfo { msg_type: Response, is_tls: false, protocol_version: 10, server_version: "", server_thread_id: 0, command: 0, context: "", response_code: 0, error_code: None, affected_rows: 0, error_message: "", status: Ok, rrt: 0, trace_id: None } is_mysql: false
MysqlInfo { msg_type: Request, is_tls: false, protocol_version: 10, server_version: "", server_thread_id: 0, command: 3, context: "select @@version_comment limit 1", response_code: 0, error_code: None, affected_rows: 0, error_message: "", status: Ok, rrt: 0, trace_id: None } is_mysql: true
MysqlInfo { msg_type: Response, is_tls: false, protocol_version: 10, server_version: "", server_thread_id: 0, command: 0, context: "", response_code: 254, error_code: None, affected_rows: 0, error_message: "", status: Ok, rrt: 0, trace_id: None } is_mysql: false
MysqlInfo { msg_type: Request, is_tls: false, protocol_version: 10, server_version: "", server_thread_id: 0, command: 3, context: "SELECT DATABASE()", response_code: 0, error_code: None, affected_rows: 0, error_message: "", status: Ok, rrt: 0, trace_id: None } is_mysql: true
MysqlInfo { msg_type: Response, is_tls: false, protocol_version: 10, server_version: "", server_thread_id: 0, command: 0, context: "", response_code: 254, error_code: None, affected_rows: 0, error_message: "", status: Ok, rrt: 0, trace_id: None } is_mysql: false
MysqlInfo { msg_type: Request, is_tls: false, protocol_version: 10, server_version: "", server_thread_id: 0, command: 2, context: "abcd", response_code: 0, error_code: None, affected_rows: 0, error_message: "", status: Ok, rrt: 0, trace_id: None } is_mysql: false
MysqlInfo { msg_type: Response, is_tls: false, protocol_version: 10, server_version: "", server_thread_id: 0, command: 0, context: "", response_code: 255, error_code: Some(1049), affected_rows: 0, error_message: "Unknown database 'abcd'", status: ServerError, rrt: 0, trace_id: None } is_mysql: false
MysqlInfo { msg_type: Request, is_tls: false, protocol_version: 10, server_version: "", server_thread_id: 0, command: 1, context: "", response_code: 0, error_code: None, affected_rows: 0, error_message: "", status: Ok, rrt: 0, trace_id: None } is_mysql: false
MysqlInfo { msg_type: Other, is_tls: false, protocol_version: 10, server_version: "", server_thread_id: 0, command: 0, context: "", response_code: 0, error_code: None, affected_rows: 0, error_message: "", status: Ok, rrt: 0, statement_id: 0, trace_id: None } is_mysql: false
MysqlInfo { msg_type: Other, is_tls: false, protocol_version: 10, server_version: "", server_thread_id: 0, command: 0, context: "", response_code: 0, error_code: None, affected_rows: 0, error_message: "", status: Ok, rrt: 0, statement_id: 0, trace_id: None } is_mysql: false
MysqlInfo { msg_type: Response, is_tls: false, protocol_version: 10, server_version: "", server_thread_id: 0, command: 0, context: "", response_code: 0, error_code: None, affected_rows: 0, error_message: "", status: Ok, rrt: 0, statement_id: 131072, trace_id: None } is_mysql: false
MysqlInfo { msg_type: Request, is_tls: false, protocol_version: 10, server_version: "", server_thread_id: 0, command: 3, context: "select @@version_comment limit 1", response_code: 0, error_code: None, affected_rows: 0, error_message: "", status: Ok, rrt: 0, statement_id: 0, trace_id: None } is_mysql: true
MysqlInfo { msg_type: Response, is_tls: false, protocol_version: 10, server_version: "", server_thread_id: 0, command: 0, context: "", response_code: 254, error_code: None, affected_rows: 0, error_message: "", status: Ok, rrt: 0, statement_id: 0, trace_id: None } is_mysql: false
MysqlInfo { msg_type: Request, is_tls: false, protocol_version: 10, server_version: "", server_thread_id: 0, command: 3, context: "SELECT DATABASE()", response_code: 0, error_code: None, affected_rows: 0, error_message: "", status: Ok, rrt: 0, statement_id: 0, trace_id: None } is_mysql: true
MysqlInfo { msg_type: Response, is_tls: false, protocol_version: 10, server_version: "", server_thread_id: 0, command: 0, context: "", response_code: 254, error_code: None, affected_rows: 0, error_message: "", status: Ok, rrt: 0, statement_id: 0, trace_id: None } is_mysql: false
MysqlInfo { msg_type: Request, is_tls: false, protocol_version: 10, server_version: "", server_thread_id: 0, command: 2, context: "abcd", response_code: 0, error_code: None, affected_rows: 0, error_message: "", status: Ok, rrt: 0, statement_id: 0, trace_id: None } is_mysql: false
MysqlInfo { msg_type: Response, is_tls: false, protocol_version: 10, server_version: "", server_thread_id: 0, command: 0, context: "", response_code: 255, error_code: Some(1049), affected_rows: 0, error_message: "Unknown database 'abcd'", status: ServerError, rrt: 0, statement_id: 0, trace_id: None } is_mysql: false
MysqlInfo { msg_type: Request, is_tls: false, protocol_version: 10, server_version: "", server_thread_id: 0, command: 1, context: "", response_code: 0, error_code: None, affected_rows: 0, error_message: "", status: Ok, rrt: 0, statement_id: 0, trace_id: None } is_mysql: false
@@ -1,2 +1,2 @@
MysqlInfo { msg_type: Request, is_tls: false, protocol_version: 0, server_version: "", server_thread_id: 0, command: 22, context: "SELECT * FROM `controller` WHERE ip <> ?", response_code: 0, error_code: None, affected_rows: 0, error_message: "", status: Ok, rrt: 0, trace_id: None } is_mysql: true
MysqlInfo { msg_type: Response, is_tls: false, protocol_version: 0, server_version: "", server_thread_id: 0, command: 0, context: "", response_code: 0, error_code: None, affected_rows: 0, error_message: "", status: Ok, rrt: 0, trace_id: None } is_mysql: false
MysqlInfo { msg_type: Request, is_tls: false, protocol_version: 0, server_version: "", server_thread_id: 0, command: 22, context: "SELECT * FROM `controller` WHERE ip <> ?", response_code: 0, error_code: None, affected_rows: 0, error_message: "", status: Ok, rrt: 0, statement_id: 0, trace_id: None } is_mysql: true
MysqlInfo { msg_type: Response, is_tls: false, protocol_version: 0, server_version: "", server_thread_id: 0, command: 0, context: "", response_code: 0, error_code: None, affected_rows: 0, error_message: "", status: Ok, rrt: 0, statement_id: 510, trace_id: None } is_mysql: false

0 comments on commit daea269

Please sign in to comment.