go-sql-proxy

main.go

package main

import (
	"database/sql"
	"log"

	"github.com/go-sql-driver/mysql"
	proxy "github.com/shogo82148/go-sql-proxy"
)

func main() {

	log.SetFlags(log.LstdFlags | log.Lshortfile)

	sql.Register("my-proxy", proxy.NewProxyContext(&mysql.MySQLDriver{}, proxy.NewTraceHooks(proxy.TracerOptions{})))

	db, err := sql.Open("my-proxy", "root:password@/dev")
	if err != nil {
		panic(err)
	}
	defer db.Close()

	rows, err := db.Query("SELECT 1")
	if err != nil {
		panic(err)
	}

	for rows.Next() {
		var (
			result int64
		)
		if err := rows.Scan(&result); err != nil {
			log.Fatal(err)
		}
		log.Printf("%d", result)
	}

}