go-mysql是一个功能强大的MySQL协议处理工具集,你可以使用client连接操作MySQL,使用server制作自己的MySQL proxy,使用replication同步MySQL的binlog,使用canal进行MySQL到其他服务(Elasticsearch,Redis)的数据实时更新。
示例代码:
import ( "github.com/siddontang/go-mysql/client")// Connect MySQL at 127.0.0.1:3306, with user root, an empty passowrd and database testconn, _ := client.Connect("127.0.0.1:3306", "root", "", "test")conn.Ping()// Insertr, _ := conn.Execute(`insert into table (id, name) values (1, "abc")`)// Get last insert idprintln(r.InsertId)// Selectr, _ := conn.Execute(`select id, name from table where id = 1`)// Handle resultsetv, _ := r.GetInt(0, 0)v, _ = r.GetIntByName(0, "id")
评论