如何记录来自 Go / MySQL 的所有传出 SQL 语句?
How can I log all outgoing SQL statements from Go / MySQL?
我正在为 Web 项目使用 sqlx, and MySQL 的非框架 Go 堆栈。
我想记录所有传出的 SQL 语句以进行调试。是否有可能做到这一点?希望得到这样的输出(从 Rails 项目复制):
User Load (94.4ms) SELECT `users`.* FROM `users` WHERE `users`.`login` = 'bondnewyork' LIMIT 1
User Load (16.3ms) SELECT `users`.* FROM `users` WHERE `users`.`login` = 'mkovarik' LIMIT 1
User Load (0.3ms) SELECT `users`.* FROM `users` WHERE `users`.`login` = 'mkovarik' LIMIT 1
User Load (0.3ms) SELECT `users`.* FROM `users` ORDER BY `users`.`id` DESC LIMIT 1
User Load (0.4ms) SELECT `users`.* FROM `users` ORDER BY `users`.`id` DESC LIMIT 1
sqlx 具有以下接口形式的非常有趣的抽象:
它们在整个库中用作表示将字符串用作 SQL 查询的功能的接口。
例如:
db, err := sqlx.Connect("postgres", "user=foo dbname=bar sslmode=disable")
if err != nil {
log.Fatalln(err)
}
// exec the schema or fail; multi-statement Exec behavior varies between
// database drivers; pq will exec them all, sqlite3 won't, ymmv
db.MustExec("CREATE TABLE person (first_name text)")
最后一行实际上等同于:
sqlx.MustExec(db, "CREATE TABLE person (first_name text)")
其中 db
用作 Execer
。
同理,这个:
people := []Person{}
db.Select(&people, "SELECT * FROM person ORDER BY first_name ASC")
相当于:
sqlx.Select(db, &people, "SELECT * FROM person ORDER BY first_name ASC")
其中 db
用作 Queryer
。
因此,如果您不愿意直接使用 DB
类型,而是使用库的底层自由函数,您可以使用以下结构将您的 db
包装到执行的对象中日志记录:
type QueryLogger struct {
queryer sqlx.Queryer
logger *log.Logger
}
func (p *QueryLogger) Query(query string, args ...interface{}) (*sql.Rows, error) {
p.logger.Print(query, args...)
return p.queryer.Query(query, args...)
}
func (p *QueryLogger) Queryx(query string, args ...interface{}) (*Rows, error) {
p.logger.Print(query, args...)
return p.queryer.Queryx(query, args...)
}
func (p *QueryLogger) QueryRowx(query string, args ...interface{}) *Row {
p.logger.Print(query, args...)
return p.queryer.QueryRowx(query, args...)
}
连接到您的数据库时:
db, err := sqlx.Connect("postgres", "user=foo dbname=bar sslmode=disable")
if err != nil {
log.Fatalln(err)
}
ql := &QueryLogger{db, yourLogger}
sqlx.Select(ql, &people, "SELECT * FROM person ORDER BY first_name ASC")
当然这只在使用sqlx库的自由函数时有效,所以如果你的代码有大量使用sqlx.DB类型的调用,这可能不够方便。
我正在为 Web 项目使用 sqlx, and MySQL 的非框架 Go 堆栈。
我想记录所有传出的 SQL 语句以进行调试。是否有可能做到这一点?希望得到这样的输出(从 Rails 项目复制):
User Load (94.4ms) SELECT `users`.* FROM `users` WHERE `users`.`login` = 'bondnewyork' LIMIT 1
User Load (16.3ms) SELECT `users`.* FROM `users` WHERE `users`.`login` = 'mkovarik' LIMIT 1
User Load (0.3ms) SELECT `users`.* FROM `users` WHERE `users`.`login` = 'mkovarik' LIMIT 1
User Load (0.3ms) SELECT `users`.* FROM `users` ORDER BY `users`.`id` DESC LIMIT 1
User Load (0.4ms) SELECT `users`.* FROM `users` ORDER BY `users`.`id` DESC LIMIT 1
sqlx 具有以下接口形式的非常有趣的抽象:
它们在整个库中用作表示将字符串用作 SQL 查询的功能的接口。
例如:
db, err := sqlx.Connect("postgres", "user=foo dbname=bar sslmode=disable")
if err != nil {
log.Fatalln(err)
}
// exec the schema or fail; multi-statement Exec behavior varies between
// database drivers; pq will exec them all, sqlite3 won't, ymmv
db.MustExec("CREATE TABLE person (first_name text)")
最后一行实际上等同于:
sqlx.MustExec(db, "CREATE TABLE person (first_name text)")
其中 db
用作 Execer
。
同理,这个:
people := []Person{}
db.Select(&people, "SELECT * FROM person ORDER BY first_name ASC")
相当于:
sqlx.Select(db, &people, "SELECT * FROM person ORDER BY first_name ASC")
其中 db
用作 Queryer
。
因此,如果您不愿意直接使用 DB
类型,而是使用库的底层自由函数,您可以使用以下结构将您的 db
包装到执行的对象中日志记录:
type QueryLogger struct {
queryer sqlx.Queryer
logger *log.Logger
}
func (p *QueryLogger) Query(query string, args ...interface{}) (*sql.Rows, error) {
p.logger.Print(query, args...)
return p.queryer.Query(query, args...)
}
func (p *QueryLogger) Queryx(query string, args ...interface{}) (*Rows, error) {
p.logger.Print(query, args...)
return p.queryer.Queryx(query, args...)
}
func (p *QueryLogger) QueryRowx(query string, args ...interface{}) *Row {
p.logger.Print(query, args...)
return p.queryer.QueryRowx(query, args...)
}
连接到您的数据库时:
db, err := sqlx.Connect("postgres", "user=foo dbname=bar sslmode=disable")
if err != nil {
log.Fatalln(err)
}
ql := &QueryLogger{db, yourLogger}
sqlx.Select(ql, &people, "SELECT * FROM person ORDER BY first_name ASC")
当然这只在使用sqlx库的自由函数时有效,所以如果你的代码有大量使用sqlx.DB类型的调用,这可能不够方便。