go操作操作mysql(增刪改查)
阿新 • • 發佈:2019-01-09
go中支援MySQL的驅動目前比較多,有如下幾種,有些是支援database/sql標準,而有些是採用了自己的實現介面,
常用的有如下幾種:
https://github.com/Go-SQL-Driver/MySQL 支援database/sql,全部採用go寫。
https://github.com/ziutek/mymysql 支援database/sql,也支援自定義的介面,全部採用go寫。
https://github.com/Philio/GoMySQL 不支援database/sql,自定義介面,全部採用go寫。
推薦第1個,主要理由:
這個驅動比較新,維護的比較好
完全支援database/sql介面
常用的有如下幾種:
https://github.com/Go-SQL-Driver/MySQL 支援database/sql,全部採用go寫。
https://github.com/ziutek/mymysql 支援database/sql,也支援自定義的介面,全部採用go寫。
https://github.com/Philio/GoMySQL 不支援database/sql,自定義介面,全部採用go寫。
推薦第1個,主要理由:
這個驅動比較新,維護的比較好
完全支援database/sql介面
支援keepalive,保持長連線
1、建表
2、下載mysql驅動,我使用的是go get下載,需先安裝git:yum install -y gitCREATE TABLE `user_info` ( `uid` INT(10) NOT NULL AUTO_INCREMENT, `username` VARCHAR(64) NULL DEFAULT NULL, `departname` VARCHAR(64) NULL DEFAULT NULL, `created` DATE NULL DEFAULT NULL, PRIMARY KEY (`uid`) );
go get github.com/go-sql-driver/mysql
我的環境變數設定:
export PATH=$PATH:/usr/local/go/bin
export GOPATH=/data/go
所以下載到/data/go/src目錄
3、編寫程式碼
mysql.go
4、測試package main import ( _ "github.com/go-sql-driver/mysql" "database/sql" "fmt" //"time" ) func main() { db, err := sql.Open("mysql", "root:
[email protected]/test?charset=utf8") checkErr(err) // 插入資料 stmt, err := db.Prepare("INSERT user_info SET username=?,departname=?,created=?") checkErr(err) res, err := stmt.Exec("test", " 研發部門", "2017-12-09") checkErr(err) id, err := res.LastInsertId() checkErr(err) fmt.Println(id) // 更新資料 stmt, err = db.Prepare("update user_info set username=? where uid=?") checkErr(err) res, err = stmt.Exec("test", id) checkErr(err) affect, err := res.RowsAffected() checkErr(err) fmt.Println(affect) // 查詢資料 rows, err := db.Query("SELECT * FROM user_info") checkErr(err) for rows.Next() { var uid int var username string var department string var created string err = rows.Scan(&uid, &username, &department, &created) checkErr(err) fmt.Println(uid) fmt.Println(username) fmt.Println(department) fmt.Println(created) } // 刪除資料 stmt, err = db.Prepare("delete from user_info where uid=?") checkErr(err) //res, err = stmt.Exec(id) checkErr(err) affect, err = res.RowsAffected() checkErr(err) fmt.Println(affect) db.Close() } func checkErr(err error) { if err != nil { panic(err) } }