使用GO语言实现Mysql数据库CURD的简单示例使用GO语言实现Mysql数据库CUR

〇、介绍驱动包和增强版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)

文章图片

成功执行！
来看一看结果吧！
【使用GO语言实现Mysql数据库CURD的简单示例】

文章图片

现在可以看到数据更新成功。将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结构体里面的属性对应数据库里面的字段。比如：