目錄
- 〇、介紹驅動包和增強版Mysql操作庫Sqlx
- 一、先導入驅動包和增強版Mysql操作庫Sqlx
- 二、insert操作
- 三、delete操作
- 四、update操作
- 五、select操作
〇、介紹驅動包和增強版Mysql操作庫Sqlx
- go-mysql-driver是go語言標準庫(SDK)database/sql的”加工產品“，質量有保障！
- go-mysql-driver運行時間雖然比較長，但是內存使用較少。
- go-mysql-driver實現了database/sql，即便不是mysql，是使用其他數據庫，也能夠使用該包。
- go-mysql-driver接口設計得比較好，上手較快。
- 對于Sqlx，它其實也是go語言標準庫(SDK)database/sql的”加工產品“。
- Sqlx也可以用于其他數據庫。
- Sqlx包其實最大最大的優點是在查詢方面，也就是使用select時優化得比較好。比原來的使用查詢方便了不止一點。
一、先導入驅動包和增強版Mysql操作庫Sqlx
package main
import (
"fmt"
//并不需要使用其API，只需要執行該包的init方法（加載MySQL是驅動程序）
_ "github.com/go-sql-driver/mysql"
"github.com/jmoiron/sqlx"
)
此處需要導入導入mysql驅動包和增強版Mysql操作庫Sqlx。
如果不清楚如何導入第三方包，請查看我的技術博客：手把手教你怎么使用Go語言第三方庫。
二、insert操作
//執行insert操作
func main() {
//連接數據庫
//driverName:mysql,表示驅動器的名稱是mysql也就上面"github.com/go-sql-driver/mysql"導入的驅動器。
//dataSourceName：root:123456@tcp(localhost:3306)/mydb 賬戶名:密碼@tcp(ip:端口)/數據庫名稱
//sqlx.Open返回一個*sqlx.DB和錯誤。
db, _ := sqlx.Open("mysql", "root:123456@tcp(localhost:3306)/mydb")
defer db.Close()
//執行增刪改
//query里面是sql語句。
result, e := db.Exec("insert into person(name,age,rmb,gender,brithday) values(?,?,?,?,?);", "小揚", 21, 8888, true, 20000101)
if e!=nil{
fmt.Println("err=",e)
return
}
// RowsAffected returns the number of rows affected by an
// update, insert, or delete. Not every database or database
// driver may support this.
rowsAffected, _ := result.RowsAffected()
// LastInsertId returns the integer generated by the database
// in response to a command. Typically this will be from an
// "auto increment" column when inserting a new row. Not all
// databases support this feature, and the syntax of such
// statements varies.
lastInsertId, _ := result.LastInsertId()
fmt.Println("受影響的行數=",rowsAffected)
fmt.Println("最后一行的ID=",lastInsertId)
}
使用sqlx包的Open連接數據庫。
driverName:mysql,表示驅動器的名稱是mysql也就上面"github.com/go-sql-driver/mysql"導入的驅動器。
dataSourceName是root:123456@tcp(localhost:3306)/mydb 它的含義是 賬戶名:密碼@tcp(ip:端口)/數據庫名稱。
sqlx.Open返回一個*sqlx.DB和錯誤。
然后執行db.Exec()操作。
result, e := db.Exec("insert into person(name,age,rmb,gender,brithday) values(?,?,?,?,?);", "小揚", 21, 8888, true, 20000101)
第一個參數是query語句。
rowsAffected, _ := result.RowsAffected()
lastInsertId, _ := result.LastInsertId()
RowsAffected()求受影響的行數。RowsAffected返回update, insert, or delete影響的行數。不是每一個數據庫和數據庫驅動可能支持這個。
LastInsertId()求插入的最后一行的ID。
LastInsertId返回數據庫生成的最后一個ID。通常，這來自插入新行時的“自動遞增”列。不是所有數據庫都支持此功能。
三、delete操作
result, e := db.Exec("delete from person where name not like ?;", "%揚")
還是執行db.Exec()，第一個參數是delete語句。
查看該操作是否執行成功。
成功！！！試一試吧！
四、update操作
result, e := db.Exec("update person set name = ? where id = ?;", "大揚", 1)
成功執行！
來看一看結果吧！
現在可以看到數據更新成功。將id為1的數據的name項更新為”大揚“。
這里兩個？，后面就要有兩個參數。
五、select操作
package main
import (
"fmt"
//并不需要使用其API，只需要執行該包的init方法（加載MySQL是驅動程序）
_ "github.com/go-sql-driver/mysql"
"github.com/jmoiron/sqlx"
)
type Person struct {
// 對應name表字段
Name string `db:"name"`
// 對應age表字段
Age int `db:"age"`
// 對應rmb表字段
Money float64 `db:"rmb"`
}
func main() {
db, _ := sqlx.Open("mysql", "root:123456@tcp(localhost:3306)/mydb")
defer db.Close()
//預定義Person切片用于接收查詢結果
var ps []Person
//執行查詢，得到Perosn對象的集合，丟入預定義的ps地址
e := db.Select(ps, "select name,age,rmb from person where name like ?;", "%揚")
if e != nil{
fmt.Println("err=",e)
}
fmt.Println("查詢成功",ps)
}
Person結構體里面的屬性對應數據庫里面的字段。比如：
表示Age對應表里面的字段age。
type Person struct {
// 對應name表字段
Name string `db:"name"`
// 對應age表字段
Age int `db:"age"`
// 對應rmb表字段
Money float64 `db:"rmb"`
}
因為查詢的結果可能為多條，所以使用Person切片。然后將查詢結果放入ps中
提示：要使用ps的指針！
e := db.Select(ps, "select name,age,rmb from person where name like ?;", "%揚")
下面我們來看看查詢結果：
到此這篇關于使用GO語言實現Mysql數據庫CURD的簡單示例的文章就介紹到這了,更多相關GO語言Mysql數據庫CURD內容請搜索腳本之家以前的文章或繼續瀏覽下面的相關文章希望大家以后多多支持腳本之家！
您可能感興趣的文章:- Go語言集成mysql驅動、調用數據庫、查詢數據操作示例
- Go語言中http和mysql的實現代碼
- Go語言使用MySql的方法
- Go語言操作mysql數據庫簡單例子
