之前，已經講過一些Golang的基礎的東西，感興趣的可以看看以前的文章，https://www.cnblogs.com/zhangweizhong/category/1275863.html，

今天簡單介紹下Golang是如何使用mysql數據庫的。由于Go本身不提供具體數據庫驅動，只提供驅動接口和管理。各個數據庫驅動需要第三方實現，并且注冊到Go中的驅動管理中。github上面的mysql驅動有好幾個，我在這里選擇的https://github.com/go-sql-driver/mysql。

?

下面主要從增刪查改以及事物等方面介紹go語言中mysql的使用

一、連接數據庫

使用sql.Open()函數打開數據庫連接，數據庫的連接字符串（dsn）格式如下：

admin:123456@tcp(10.2.1.5)/irisapp

代碼如下：

func (f *mysql_db) mysql_open() {db, err := sql.Open("mysql", dbusername+":"+dbpassword+"@tcp("+dbhostsip+")/"+dbname)if err != nil {fmt.Println("鏈接失敗")}fmt.Println("鏈接成功")f.db = db }

二、插入

func (f *mysql_db) mysql_insert() { //insert 添加數據fmt.Println("開始插入")stmt, err := f.db.Prepare("INSERT INTO depart(departName,memo) VALUES(?,?)")//defer stmt.Close()if err != nil {fmt.Println("插入失敗")return}stmt.Exec("dd", "adadcccda")fmt.Println("插入成功") }

?

三、查詢

func (f *mysql_db) mysql_select(sql_data string) { //select 查詢數據fmt.Println("sql:", sql_data)rows, err := f.db.Query(sql_data)if err != nil {fmt.Println("查詢失敗")}for rows.Next() {var departID intvar departName stringvar memo stringerr = rows.Scan(&departID, &departName, &memo)if err != nil {panic(err)}fmt.Println("departName:", departName)}}

四、更新

func (f *mysql_db) mysql_update() { //update 修改數據stmt, err := f.db.Prepare("update depart set departName=?,memo =? where departId=?")//defer stmt.Close()if err != nil {//錯誤處理 }result,_ := stmt.Exec("aa","asdfadsadsfa",1)if result == nil {fmt.Println("修改失敗")}affect_count,_ := result.RowsAffected() //返回影響的條數,注意有兩個返回值fmt.Println("%v",affect_count) }

五、刪除

func (f *mysql_db) mysql_delete() { //delete 刪除數據stmt, err := f.db.Prepare("delete from depart where departId=?")//defer stmt.Close()if err != nil {//錯誤處理 }stmt.Exec(2) //不返回任何結果fmt.Println("刪除成功") }

六、事物

func (f *mysql_db) mysql_tran(){//事務tx,err := f.db.Begin() //聲明一個事務的開始if err != nil {fmt.Println(err)return}insert_sql := "insert into depart (departName,memo) VALUES(?,?)"insert_stmt,insert_err := tx.Prepare(insert_sql)if insert_err != nil {fmt.Println(insert_err)return}insert_res,insert_err := insert_stmt.Exec("ff","ff")last_insert_id,_ := insert_res.LastInsertId()fmt.Println(last_insert_id)// defer tx.Rollback() //回滾之前上面的last_login_id是有的，但在回滾后該操作沒有被提交，被回滾了，所以上面打印的Last_login_id的這條數據是不存在與數據庫表中的tx.Commit() //這里提交了上面的操作，所以上面的執行的sql 會在數據庫中產生一條數據 }

?

調用

func main() {db := &mysql_db{}db.mysql_open()db.mysql_insert()db.mysql_update()db.mysql_delete()db.mysql_tran()db.mysql_select("select departID,departName,memo from depart")db.mysql_close() //關閉 }

啟動后輸出如下：

D:\Go_Path\go\src\mysqldemo>go run mysqldemo.go 鏈接成功 開始插入 插入成功 0 刪除成功 10 sql: select departID,departName,memo from depart departName: aa departName: dd departName: dd departName: dd departName: dd departName: dd departName: ff departName: dd departName: ff

?

完整代碼?

package mainimport ("database/sql""fmt"_ "github.com/go-sql-driver/mysql")var (dbhostsip = "10.2.1.5:3306"dbusername = "admin"dbpassword = "123456"dbname = "irisapp" )type mysql_db struct {db *sql.DB }func (f *mysql_db) mysql_open() {db, err := sql.Open("mysql", dbusername+":"+dbpassword+"@tcp("+dbhostsip+")/"+dbname)if err != nil {fmt.Println("鏈接失敗")}fmt.Println("鏈接成功")f.db = db }func (f *mysql_db) mysql_close() {defer f.db.Close() }func (f *mysql_db) mysql_select(sql_data string) { //select 查詢數據fmt.Println("sql:", sql_data)rows, err := f.db.Query(sql_data)if err != nil {fmt.Println("查詢失敗")}for rows.Next() {var departID intvar departName stringvar memo stringerr = rows.Scan(&departID, &departName, &memo)if err != nil {panic(err)}fmt.Println("departName:", departName)}}func (f *mysql_db) mysql_insert() { //insert 添加數據fmt.Println("開始插入")stmt, err := f.db.Prepare("INSERT INTO depart(departName,memo) VALUES(?,?)")//defer stmt.Close()if err != nil {fmt.Println("插入失敗")return}stmt.Exec("dd", "adadcccda")fmt.Println("插入成功") }func (f *mysql_db) mysql_update() { //update 修改數據stmt, err := f.db.Prepare("update depart set departName=?,memo =? where departId=?")//defer stmt.Close()if err != nil {//錯誤處理 }result,_ := stmt.Exec("aa","asdfadsadsfa",1)if result == nil {fmt.Println("修改失敗")}affect_count,_ := result.RowsAffected() //返回影響的條數,注意有兩個返回值 fmt.Println(affect_count) }func (f *mysql_db) mysql_delete() { //delete 刪除數據stmt, err := f.db.Prepare("delete from depart where departId=?")//defer stmt.Close()if err != nil {//錯誤處理 }stmt.Exec(2) //不返回任何結果fmt.Println("刪除成功") }func (f *mysql_db) mysql_tran(){//事務tx,err := f.db.Begin() //聲明一個事務的開始if err != nil {fmt.Println(err)return}insert_sql := "insert into depart (departName,memo) VALUES(?,?)"insert_stmt,insert_err := tx.Prepare(insert_sql)if insert_err != nil {fmt.Println(insert_err)return}insert_res,insert_err := insert_stmt.Exec("ff","ff")last_insert_id,_ := insert_res.LastInsertId()fmt.Println(last_insert_id)// defer tx.Rollback() //回滾之前上面的last_login_id是有的，但在回滾后該操作沒有被提交，被回滾了，所以上面打印的Last_login_id的這條數據是不存在與數據庫表中的tx.Commit() //這里提交了上面的操作，所以上面的執行的sql 會在數據庫中產生一條數據 }func main() {db := &mysql_db{}db.mysql_open()db.mysql_insert()db.mysql_update()db.mysql_delete()db.mysql_tran()db.mysql_select("select departID,departName,memo from depart")db.mysql_close() //關閉 } View Code

?

總結

1.?支持預備表達式，可以用來優化SQL查詢提高性能，減少SQL注入的風險,?db.Prepare()和?tx.Prepare 都提供了對于預備表達式的支持。

2.?LastInsertId()　　獲取插入第一條的id

3.?RowsAffected()　　獲取影響/插入的條數

4. 這里只是簡單介紹了go語言開發中mysql在go語言開發中的基本使用，其實真正開發過程中還是主要使用orm相關第三方框架，但是底層原理還是要學的。

?

?

?

轉載于:https://www.cnblogs.com/zhangweizhong/p/10517987.html

總結

以上是生活随笔為你收集整理的Golang 入门系列(十) mysql数据库的使用的全部內容，希望文章能夠幫你解決所遇到的問題。

如果覺得生活随笔網站內容還不錯，歡迎將生活随笔推薦給好友。