〇、介绍驱动包和增强版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
|
1
2
3
4
5
6
7
8
|
package main
import (
"fmt"
//并不需要使用其api，只需要执行该包的init方法（加载mysql是驱动程序）
_ "github.com/go-sql-driver/mysql"
"github.com/jmoiron/sqlx"
)
|
此处需要导入导入mysql驱动包和增强版mysql操作库sqlx。
如果不清楚如何导入第三方包，请查看我的技术博客：手把手教你怎么使用go语言第三方库。
二、insert操作
|
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
|
//执行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()操作。
|
1
|
result, e := db.exec("insert into person(name,age,rmb,gender,brithday) values(?,?,?,?,?);", "小扬", 21, 8888, true, 20000101)
|
第一个参数是query语句。
|
1
2
|
rowsaffected, _ := result.rowsaffected()
lastinsertid, _ := result.lastinsertid()
|
rowsaffected()求受影响的行数。rowsaffected返回update, insert, or delete影响的行数。不是每一个数据库和数据库驱动可能支持这个。
lastinsertid()求插入的最后一行的id。
lastinsertid返回数据库生成的最后一个id。通常，这来自插入新行时的“自动递增”列。不是所有数据库都支持此功能。
三、delete操作
|
1
|
result, e := db.exec("delete from person where name not like ?;", "%扬")
|
还是执行db.exec()，第一个参数是delete语句。
查看该操作是否执行成功。
成功！！！试一试吧！
四、update操作
|
1
|
result, e := db.exec("update person set name = ? where id = ?;", "大扬", 1)
|
成功执行！
来看一看结果吧！
现在可以看到数据更新成功。将id为1的数据的name项更新为”大扬“。
这里两个？，后面就要有两个参数。
五、select操作
|
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
|
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结构体里面的属性对应数据库里面的字段。比如：
|
1
|
age int `db:"age"`
|
表示age对应表里面的字段age。
|
1
2
3
4
5
6
7
8
|
type person struct {
// 对应name表字段
name string `db:"name"`
// 对应age表字段
age int `db:"age"`
// 对应rmb表字段
money float64 `db:"rmb"`
}
|
|
1
|
var ps []person
|
因为查询的结果可能为多条，所以使用person切片。然后将查询结果放入ps中
提示：要使用ps的指针！
|
1
|
e := db.select(&ps, "select name,age,rmb from person where name like ?;", "%扬")
|
下面我们来看看查询结果：
到此这篇关于使用go语言实现mysql数据库curd的简单示例的文章就介绍到这了,更多相关go语言mysql数据库curd内容请搜索服务器之家以前的文章或继续浏览下面的相关文章希望大家以后多多支持服务器之家！
原文链接：https://juejin.cn/post/6992370794294673416