**Golang操作mysql简介**
Golang操作mysql数据库的感觉有点想php中的pdo对mysql操作,假设你原本是phper转型到golang中的接受起来很亲切,总体的感觉非常简单
**Golang操作mysql的注意点**
`golang实现了对mysql操作的标准库然而却没有实现mysql的驱动`
因此我们需要先从github中下载go-sql-driver这个驱动包(建议在src目录下执行),使用命令如下所示:
```go
go get github.com/go-sql-driver/mysql
```
**在test数据库中建立表字段如下所示**
```go
CREATE TABLE IF NOT EXISTS `test`.`user` (
`user_id` INT(11) UNSIGNED NOT NULL AUTO_INCREMENT COMMENT '用户编号',
`user_name` VARCHAR(45) NOT NULL COMMENT '用户名称',
`user_age` TINYINT(3) UNSIGNED NOT NULL DEFAULT 0 COMMENT '用户年龄',
`user_sex` TINYINT(3) UNSIGNED NOT NULL DEFAULT 0 COMMENT '用户性别',
PRIMARY KEY (`user_id`))
ENGINE = InnoDB
AUTO_INCREMENT = 1
DEFAULT CHARACTER SET = utf8
COLLATE = utf8_general_ci
COMMENT = '用户表'
```
**实现对数据的增(insert)操作**
```go
package main
import (
"fmt"
"database/sql"
//导入mysql的驱动
_ "github.com/go-sql-driver/mysql"
)
func main(){
//使用database/sql包中的Open连接数据库
db,err := sql.Open("mysql","root:root@tcp(localhost:3306)/test?charset=utf8")
if err != nil {
fmt.Println("连接数据库失败:",err)
return
}
//使用DB结构体实例方法Prepare预处理插入,Prepare会返回一个stmt对象
stmt,err := db.Prepare("insert into `user`(user_name,user_age,user_sex)values(?,?,?)")
if err!=nil{
fmt.Println("预处理失败:",err)
return
}
//使用Stmt对象执行预处理参数
result,err := stmt.Exec("pengjin",33,"男")
if err!=nil{
fmt.Println("执行预处理失败:",err)
return
}else{
rows,_ := result.RowsAffected()
fmt.Println("执行成功,影响行数",rows,"行" )
}
}
```
`如上代码有一种操作php中pdo的感觉`,如上代码实际上也可以不编写Prepare方法直接通过Exec方法直接实现操作,相当于一种简写方式,我们可以尝试使用这种方法直接实现删除操作
**实现对数据的删(delete)操作**
```go
package main
import (
"fmt"
"database/sql"
//导入mysql的驱动
_ "github.com/go-sql-driver/mysql"
)
func main(){
//使用database/sql包中的Open连接数据库
db,err := sql.Open("mysql","root:root@tcp(localhost:3306)/test?charset=utf8")
if err != nil {
fmt.Println("连接数据库失败:",err)
return
}
//直接调用db实例中的Exec方法实现预处理
result,err := db.Exec("delete from `user` where user_id=?",1)
if err!=nil{
fmt.Println("预处理失败:",err)
return
}
if err!=nil{
fmt.Println("执行预处理失败:",err)
return
}else{
rows,_ := result.RowsAffected()
fmt.Println("执行成功,影响行数",rows,"行" )
}
}
```
**实现对数据库的update操作**
```go
package main
import (
"fmt"
"database/sql"
//导入mysql的驱动
_ "github.com/go-sql-driver/mysql"
)
func main(){
//使用database/sql包中的Open连接数据库
db,err := sql.Open("mysql","root:root@tcp(localhost:3306)/test?charset=utf8")
if err != nil {
fmt.Println("连接数据库失败:",err)
return
}
//直接调用db实例中的Exec方法实现预处理
result,err := db.Exec("update `user` set user_age=?,user_name=? where user_id=?",
34,"zhangsan",2)
if err!=nil{
fmt.Println("预处理失败:",err)
return
}
if err!=nil{
fmt.Println("执行预处理失败:",err)
return
}else{
rows,_ := result.RowsAffected()
fmt.Println("执行成功,影响行数",rows,"行" )
}
}
```
有疑问加站长微信联系(非本文作者))