准备
go的系统包里是没有数据库驱动的，首先先从git上下载mysql包，golang下载资源包相当方便，打开命令行，输入命令：go get -u github.com/go-sql-driver/mysql (使用git命令下载资源包，需要先安装git，没安装git的同学可以手动下载后放入src目录下)。!
下载完成会在GOPATH下的src里多了资源包
下载完成后，在项目里import mysql包,用下划线_是表示我们只需要用到包里的init()函数，而不需要调用里面的方法。
import (
"database/sql"
"fmt"
_ "github.com/go-sql-driver/mysql" //导入mysql包
"time"
)准备数据表
我们来准备一张医生表doctor_tb，包含姓名、年龄、性别、添加时间等，后面我们会对这张表做增删改查的操作。建表语句如下：
CREATE TABLE `doctor_tb` (
`id` int(11) NOT NULL AUTO_INCREMENT,
`name` varchar(50) DEFAULT '' COMMENT '姓名',
`age` int(11) DEFAULT '0' COMMENT '年龄',
`sex` int(11) DEFAULT '0' COMMENT '性别',
`addTime` datetime DEFAULT NULL,
PRIMARY KEY (`id`)
) ENGINE=InnoDB AUTO_INCREMENT=1 DEFAULT CHARSET=utf8 COMMENT='医生表';
1、打开数据库链接
db, err := sql.Open("mysql", "root:112233@tcp(127.0.0.1:3305)/test?charset=utf8&parseTime=True")
mysql数据库的链接字符串组织：用户名:密码@tcp(数据库IP:端口)/数据库名?charset=utf8&parseTime=True，如果你的表里有应用到datetime字段，记得要加上parseTime=True，不然解析不了这个类型。
//-------1、打开数据库--------
db, err := sql.Open("mysql", "root:112233@tcp(127.0.0.1:3305)/test?charset=utf8&parseTime=True")
if err != nil {
fmt.Println("数据库链接错误", err)
return
}
//延迟到函数结束关闭链接
defer db.Close()2、查询单条数据
代码：
//-------2、查询单条数据--------
//定义接收数据的结构
var doc Doctor
//执行单条查询
rows := db.QueryRow("select * from doctor_tb where id = ?", 1)
rows.Scan(&doc.ID, &doc.Name, &doc.Age, &doc.Sex, &doc.AddTime)
fmt.Println("单条数据结果：", doc)执行结果：
解析：
查询id=1的数据rows := db.QueryRow("select * from doctor_tb where id = ?", 1) rows.Scan 用于把读取的数据赋值到Doctor对象的属性上，要注意字段顺序。
3、查询数据列表
代码：
//-------3、查询数据列表--------
rows2, err := db.Query("select * from doctor_tb where age > ?", 18)
if err != nil {
fmt.Println("多条数据查询错误", err)
return
}
//定义对象数组,用于接收数据
var docList []Doctor
for rows2.Next() {
var doc2 Doctor
rows2.Scan(&doc2.ID, &doc2.Name, &doc2.Age, &doc2.Sex, &doc2.AddTime)
//加入数组
docList = append(docList, doc2)
}
fmt.Println("多条数据查询结果", docList)执行结果：
解析：
查询年龄age大于18岁的成年医生rows2, err := db.Query("select * from doctor_tb where age > ?", 18)
迭代数据查询rows2.Next()
赋值rows2.Scan(&doc2.ID, &doc2.Name, &doc2.Age, &doc2.Sex, &doc2.AddTime)
加入数组docList = append(docList, doc2)
4、新增数据
代码：
//-------4、新增数据--------
result, err := db.Exec("insert into doctor_tb(name,age,sex,addTime) values(?,?,?,Now())", "林医生", 40, 2)
if err != nil {
fmt.Println("新增数据错误", err)
return
}
newID, _ := result.LastInsertId() //新增数据的ID
i, _ := result.RowsAffected() //受影响行数
fmt.Printf("新增的数据ID：%d , 受影响行数：%d \n", newID, i)执行结果：
解析：
新增一位40岁的女性林医生result, err := db.Exec("insert into doctor_tb(name,age,sex,addTime) values(?,?,?,Now())", "林医生", 40, 2)
新增数据的IDresult.LastInsertId()
受影响行数result.RowsAffected()
5、修改数据
代码：
//-------5、修改数据--------
result2, err := db.Exec("update doctor_tb set age=20 where id = ?", 1)
if err != nil {
fmt.Println("修改数据错误", err)
return
}
i2, _ := result2.RowsAffected() //受影响行数
fmt.Printf("受影响行数：%d \n", i2)执行结果：
解析：
编号为1的医生年龄变为20岁result2, err := db.Exec("update doctor_tb set age=20 where id = ?", 1)
6、删除数据
代码：
//-------6、删除数据--------
result3, err := db.Exec("delete from doctor_tb where name = ?", "叶子")
if err != nil {
fmt.Println("删除数据错误", err)
return
}
i3, _ := result3.RowsAffected()
fmt.Printf("受影响行数：%d \n", i3)执行结果：
解析：
删除姓名叫叶子的医生result3, err := db.Exec("delete from doctor_tb where name = ?", "叶子")
7、事务
代码:
//-------7、事务\--------
tx, _ := db.Begin()
result4, _ := tx.Exec("update doctor_tb set age = age + 1 where name = ?", "钟南山")
result5, _ := tx.Exec("update doctor_tb set age = age + 1 where name = ?", "叶子")
//影响行数，为0则失败
i4, _ := result4.RowsAffected()
i5, _ := result5.RowsAffected()
if i4 > 0 && i5 > 0 {
//2条数据都更新成功才提交事务
err = tx.Commit()
if err != nil {
fmt.Println("事务提交失败", err)
return
}
fmt.Println("事务提交成功")
} else {
//否则回退事务
err = tx.Rollback()
if err != nil {
fmt.Println("回退事务失败", err)
return
}
fmt.Println("回退事务成功")
}执行结果：
解析：
准备事务tx, _ := db.Begin()
钟南山年龄加1岁result4, _ := tx.Exec("update doctor_tb set age = age + 1 where name = ?", "钟南山")
叶子年龄加1岁result5, _ := tx.Exec("update doctor_tb set age = age + 1 where name = ?", "叶子")
如果2条数据更新能成功则提交事务err = tx.Commit()
否则回退事务,一切就当没发生过tx.Rollback()
完整demo代码
package main
import (
"database/sql"
"fmt"
_ "github.com/go-sql-driver/mysql" //导入mysql包
"time"
)
type Doctor struct {
ID int64
Name string
Age int
Sex int
AddTime time.Time
}
func main() {
//-------1、打开数据库--------
db, err := sql.Open("mysql", "root:112233@tcp(127.0.0.1:3305)/test?charset=utf8&parseTime=True")
if err != nil {
fmt.Println("数据库链接错误", err)
return
}
//延迟到函数结束关闭链接
defer db.Close()
//-------2、查询单条数据--------
//定义接收数据的结构
var doc Doctor
//执行单条查询
rows := db.QueryRow("select * from doctor_tb where id = ?", 1)
rows.Scan(&doc.ID, &doc.Name, &doc.Age, &doc.Sex, &doc.AddTime)
fmt.Println("单条数据结果：", doc)
//-------3、查询数据列表--------
rows2, err := db.Query("select * from doctor_tb where age > ?", 18)
if err != nil {
fmt.Println("多条数据查询错误", err)
return
}
//定义对象数组,用于接收数据
var docList []Doctor
for rows2.Next() {
var doc2 Doctor
rows2.Scan(&doc2.ID, &doc2.Name, &doc2.Age, &doc2.Sex, &doc2.AddTime)
//加入数组
docList = append(docList, doc2)
}
fmt.Println("多条数据查询结果", docList)
//-------4、新增数据--------
result, err := db.Exec("insert into doctor_tb(name,age,sex,addTime) values(?,?,?,Now())", "林医生", 40, 2)
if err != nil {
fmt.Println("新增数据错误", err)
return
}
newID, _ := result.LastInsertId() //新增数据的ID
i, _ := result.RowsAffected() //受影响行数
fmt.Printf("新增的数据ID：%d , 受影响行数：%d \n", newID, i)
//-------5、修改数据--------
result2, err := db.Exec("update doctor_tb set age=20 where id = ?", 1)
if err != nil {
fmt.Println("修改数据错误", err)
return
}
i2, _ := result2.RowsAffected() //受影响行数
fmt.Printf("受影响行数：%d \n", i2)
//-------6、删除数据--------
result3, err := db.Exec("delete from doctor_tb where name = ?", "叶子")
if err != nil {
fmt.Println("删除数据错误", err)
return
}
i3, _ := result3.RowsAffected()
fmt.Printf("受影响行数：%d \\n", i3)
//-------7、事务--------
tx, _ := db.Begin()
result4, _ := tx.Exec("update doctor_tb set age = age + 1 where name = ?", "钟南山")
result5, _ := tx.Exec("update doctor_tb set age = age + 1 where name = ?", "叶子")
//影响行数，为0则失败
i4, _ := result4.RowsAffected()
i5, _ := result5.RowsAffected()
if i4 > 0 && i5 > 0 {
//2条数据都更新成功才提交事务
err = tx.Commit()
if err != nil {
fmt.Println("事务提交失败", err)
return
}
fmt.Println("事务提交成功")
} else {
//否则回退事务
err = tx.Rollback()
if err != nil {
fmt.Println("回退事务失败", err)
return
}
fmt.Println("回退事务成功")
}
}总结
以上就是golang操作mysql的示例。当然还有很多优秀的golang的orm能更方便于我们日常的业务开发，例如grom，xorm等。改天会写下教程。
有疑问加站长微信联系（非本文作者）
