写点什么

使用 GO 语言实现 Mysql 数据库 CURD

用户头像
Regan Yue
关注
发布于: 5 小时前
使用GO语言实现Mysql数据库CURD

使用 GO 语言实现 Mysql 数据库 CURD

〇、介绍驱动包和增强版 Mysql 操作库 Sqlx

  1. go-mysql-driver 是 go 语言标准库(SDK)database/sql 的”加工产品“,质量有保障!

  2. go-mysql-driver 运行时间虽然比较长,但是内存使用较少。

  3. go-mysql-driver 实现了 database/sql,即便不是 mysql,是使用其他数据库,也能够使用该包。

  4. go-mysql-driver 接口设计得比较好,上手较快。

  5. 对于 Sqlx,它其实也是 go 语言标准库(SDK)database/sql 的”加工产品“。

  6. Sqlx 也可以用于其他数据库。

  7. 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 int `db:"age"`
复制代码


表示 Age 对应表里面的字段 age。


type Person struct {  // 对应name表字段  Name string `db:"name"`  // 对应age表字段  Age int `db:"age"`  // 对应rmb表字段  Money float64 `db:"rmb"`}
复制代码


var ps []Person
复制代码


因为查询的结果可能为多条,所以使用 Person 切片。然后将查询结果放入 ps 中


提示:要使用 ps 的指针!


e := db.Select(&ps, "select name,age,rmb from person where name like ?;", "%扬")
复制代码


下面我们来看看查询结果:



发布于: 5 小时前阅读数: 5
用户头像

Regan Yue

关注

还未添加个人签名 2020.08.12 加入

对Go、Python、网络安全、区块链感兴趣. · 华为云云享专家

评论

发布
暂无评论
使用GO语言实现Mysql数据库CURD