由于标准库里只实现了database/sql只实现了相关接口,所以需要引入第三方包来实现具体的操作

关于go的第三方包可以在这个https://pkg.go.dev/网址上查找相关的包

下载第三方包

github.com/go-sql-driver/mysql这个包是mysql的驱动,其实它在底层实现了database/sql里的接口,所以用法和标准包里的一样,它以连接池的方式实现,可以同时被多个go程同时使用

//下载
go get -u github.com/go-sql-driver/mysql
//也可以下载这个,这个包优化了一些查询的操作,更方便一些 ,但是 不明显
//go get github.com/jmoiron/sqlx

基本方法介绍

Open()方法

func Open(driverName, dataSourceName string) (*DB, error)

//driverName 驱动名

//dataSourceName dsn信息完整的dsn信息如下:username:password@protocol(address)/dbname?param=value

//返回值 db类型的指针

****注意*****

//这个不会建立与数据库的连接,只是验证参数的正确性,可以通过Ping方法,检查合法性

SetMaxOpenConns()方法

func (db *DB) SetMaxOpenConns(n int)

//这个是设置与数据库建立连接的最大数目

//如果n大于0且小于最大闲置连接数，会将最大闲置连接数减小到匹配最大开启连接数的限制。

//如果n <= 0，不会限制最大开启连接数，默认为0（无限制）。

SetMaxIdleConns()方法

func (db *DB) SetMaxIdleConns(n int)

//设置连接池的最大连接数

//如果n大于最大开启连接数，则新的最大闲置连接数会减小到匹配最大开启连接数的限制。

//如果n <= 0，不会保留闲置连接。

基本操作

CREATE TABLE `goods` (

`id` int NOT NULL AUTO_INCREMENT,

`num` int DEFAULT NULL,

`version` int DEFAULT NULL,

PRIMARY KEY (`id`)

) ENGINE=InnoDB AUTO_INCREMENT=5 DEFAULT CHARSET=utf8mb3;

Exec()插入操作,修改操作,删除操作

package main

import (

"database/sql"

"fmt"

_ "github.com/go-sql-driver/mysql"

//"github.com/jmoiron/sqlx"

)

var db *sql.DB

//如果使用sqlx包,应该使用下面之个

//var db *sqlx.DB

//使用init函数初始化数据

func init() {

database, err := sql.Open("mysql", "root:xxx@tcp(127.0.0.1:3306)/test")

//如果使用sqlx包,应该使用下面这个

//database, err := sqlx.Open("mysql", "root:xxx@tcp(127.0.0.1:3306)/test")

if err != nil {//这里只会 验证格式下否正确

fmt.Println("sql open err",err)

return

}

err =database.Ping() //这里可以验证是否连接成功

if err != nil {

fmt.Println("连接失败",err)

}

fmt.Println("链接成功")

db=database

}

func insertData() {

}

func main() {

//插入操作

res,err :=db.Exec("insert into goods(num,version) values (?,?)",20,1)

if err != nil {

fmt.Println("insert err ",err)

return

}

//如果id不是自增的,则直接返回0

num,err :=res.LastInsertId()

if err !=nil{

fmt.Println("获取id失败",err)

return

}

fmt.Println("插入后的值id值",num)

}

Query()查询多条数据

package main

import (

"database/sql"

"fmt"

_ "github.com/go-sql-driver/mysql"

)

var db *sql.DB

type Goods struct{

Id int

Num int

Version int

}

//使用init函数初始化数据

func init() {

database, err := sql.Open("mysql", "root:xxxx@tcp(127.0.0.1:3306)/test")

if err != nil {//这里只会 验证格式下否正确

fmt.Println("sql open err",err)

return

}

err =database.Ping() //这里可以验证是否连接成功

if err != nil {

fmt.Println("连接失败",err)

}

database.SetMaxIdleConns(10)

fmt.Println("链接成功")

db=database

}

func main() {

res,err :=db.Query("select * from goods")

if err != nil {

fmt.Println("select err ",err)

}

defer res.Close()//遍历释放链接,放回到链接池,这里不要忘记

//获取数据

for res.Next(){

var goods Goods

err =res.Scan(&goods.Id,&goods.Num,&goods.Version)

if err != nil {

fmt.Println("获取值失败",err)

return

}

fmt.Println("id值是",goods.Id,"数量是:",goods.Num,"版本是",goods.Version)

}

}

QueryRow()获取单个行

package main

import (

"database/sql"

"fmt"

_ "github.com/go-sql-driver/mysql"

)

var db *sql.DB

type Goods struct{

Id int

Num int

Version int

}

//使用init函数初始化数据

func init() {

database, err := sql.Open("mysql", "root:XXXX@tcp(127.0.0.1:3306)/test")

if err != nil {//这里只会 验证格式下否正确

fmt.Println("sql open err",err)

return

}

err =database.Ping() //这里可以验证是否连接成功

if err != nil {

fmt.Println("连接失败",err)

}

database.SetMaxIdleConns(10)

fmt.Println("链接成功")

db=database

}

func main() {

var goods Goods //结构体

res :=db.QueryRow("select * from goods where id=1")

err :=res.Scan(&goods.Id,&goods.Num,&goods.Version)

if err != nil {

fmt.Println("获取数据err",err)

return

}

fmt.Println("id值是",goods.Id,"数量是:",goods.Num,"版本是",goods.Version)

}

//返回值

//id值是 1 数量是: 0 版本是 11

预处理操作

//也可以使用预处理的方法来实现curd操作,这样效率会更高些!这也是防止sql注入比较有用的操作

func preQueryData() {

prestr :="select * from goods where id >?"

stmt,err :=db.Prepare(prestr)//这个返回值是,可以处理多个查询和多个命令,

if err != nil {

fmt.Println("预处理失败",err)

return

}

res,err :=stmt.Query(2)

if err != nil {

fmt.Println("预处理失败",err)

return

}

defer res.Close() //处理完,放入到连接池

//遍历数据

var goods Goods

for res.Next(){

_ =res.Scan(&goods.Id,&goods.Num,&goods.Version)

fmt.Println("id值是",goods.Id,"数量是:",goods.Num,"版本是",goods.Version)

}

}

func main() {

preQueryData()

}

事务处理

//事务处理

func txData() {

//开启事务

tx,err :=db.Begin()

if err != nil {

fmt.Println("开启事务err",err)

return

}

tmpSql:=`insert into goods(num,version) values(?,?)`

stmt,err :=tx.Prepare(tmpSql)

res,err :=stmt.Exec(9,100)

if err !=nil{

fmt.Println("执行失败",err)

return

}

num,err :=res.LastInsertId()

if err !=nil{

fmt.Println("获取id失败",err)

return

}

fmt.Println("添加后的值是",num)

err =tx.Commit()

if err !=nil{

fmt.Println("提交失败")

//提交失败,回滚

err =tx.Rollback()

if err != nil {

fmt.Println("回滚失败",err)

}

}

fmt.Println("提交成功")

}

func main() {

txData()

}

以上就是go中操作mysql 的基本操作了,还是比较简单的,后面再分享一下关于go操作redis的笔记吧!!!!