golang 操做mysql示例（增、删、改、查、事务）

时间  2020-07-19
标签 golang mysql 示例 事务 栏目 Go 繁體版
原文   原文链接

准备

go的系统包里是没有数据库驱动的，首先先从git上下载mysql包，golang下载资源包至关方便，打开命令行，输入命令：go get -u github.com/go-sql-driver/mysql (使用git命令下载资源包，须要先安装git，没安装git的同窗能够手动下载后放入src目录下)。!mysql

2e2be904d71d2926cbe363ee96ca89e.png

下载完成会在GOPATH下的src里多了资源包git

image.png

下载完成后，在项目里import mysql包,用下划线_是表示咱们只须要用到包里的init()函数，而不须要调用里面的方法。github

import (  
    "database/sql"  
    "fmt"  
    _ "github.com/go-sql-driver/mysql" //导入mysql包  
    "time"  
)

准备数据表

咱们来准备一张医生表doctor_tb，包含姓名、年龄、性别、添加时间等，后面咱们会对这张表作增删改查的操做。建表语句以下：golang

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='医生表';

一、打开数据库连接

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，否则解析不了这个类型。sql

//-------一、打开数据库--------  
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()

二、查询单条数据

代码：数据库

//-------二、查询单条数据--------  
//定义接收数据的结构  
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)

执行结果：
90127e15e23b181b21506afe7c0e986.png数组

解析：
查询id=1的数据
rows := db.QueryRow("select * from doctor_tb where id = ?", 1)
rows.Scan 用于把读取的数据赋值到Doctor对象的属性上，要注意字段顺序。app

三、查询数据列表

代码：tcp

//-------三、查询数据列表--------  
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)

执行结果：
d435bde93cc4fa77f88d28ec9a30fd8.png函数

解析：
查询年龄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)

四、新增数据

代码：

//-------四、新增数据--------  
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)

执行结果：
aae9fab1f6dbd77f1a71670fc29f426.png

解析：
新增一位40岁的女性林医生
result, err := db.Exec("insert into doctor_tb(name,age,sex,addTime) values(?,?,?,Now())", "林医生", 40, 2)
新增数据的ID
result.LastInsertId()
受影响行数
result.RowsAffected()

五、修改数据

代码：

//-------五、修改数据--------  
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)

执行结果：
image.png

解析：
编号为1的医生年龄变为20岁
result2, err := db.Exec("update doctor_tb set age=20 where id = ?", 1)

六、删除数据

代码：

//-------六、删除数据--------  
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)

执行结果：
image.png

解析：
删除姓名叫叶子的医生
result3, err := db.Exec("delete from doctor_tb where name = ?", "叶子")

七、事务

代码:

//-------七、事务\--------  
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("回退事务成功")  
}

执行结果：
image.png

解析：
准备事务
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() {  
 //-------一、打开数据库--------  
  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()  
  
   //-------二、查询单条数据--------  
 //定义接收数据的结构  
  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)  
  
   //-------三、查询数据列表--------  
  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)  
  
   //-------四、新增数据--------  
  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)  
  
   //-------五、修改数据--------  
  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)  
  
   //-------六、删除数据--------  
  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)  
  
   //-------七、事务--------  
  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等。改天会写下教程。

相关文章
相关标签/搜索
每日一句
    每一个你不满意的现在，都有一个你没有努力的曾经。
本站公众号
   欢迎关注本站公众号,获取更多信息
联系我们 最近搜索 最新文章 沪ICP备13005482号-10 MyBatis教程 SQL 教程 MySQL教程 Java 教程 Thymeleaf 教程 Hibernate教程 Spring教程 Redis教程