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