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

栏目: IT技术 · 发布时间: 5年前

内容简介：go的系统包里是没有数据库驱动的，首先先从git上下载mysql包，golang下载资源包相当方便，打开命令行，输入命令：下载完成会在GOPATH下的src里多了资源包

准备

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

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

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

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

下载完成后，在项目里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)

执行结果：

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

解析：

查询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)

执行结果：

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

解析：

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

执行结果：

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

解析：

新增一位40岁的女性林医生

result, err := db.Exec("insert into doctor_tb(name,age,sex,addTime) values(?,?,?,Now())", "林医生", 40, 2)

新增数据的ID

result.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)

执行结果：

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

解析：

编号为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)

执行结果：

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

解析：

删除姓名叫叶子的医生

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

执行结果：

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

解析：

准备事务

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等。改天会写下教程。

以上就是本文的全部内容，希望对大家的学习有所帮助，也希望大家多多支持码农网

查看所有标签

猜你喜欢:

本站部分资源来源于网络，本站转载出于传递更多信息之目的，版权归原作者或者来源机构所有，如转载稿涉及版权问题，请联系我们。

码农书籍

黑客大曝光

Joel Scambray、Vincent Liu、Caleb Sima / 姚军 / 机械工业出版社华章公司 / 2011-10 / 65.00元

在网络技术和电子商务飞速发展的今天，Web应用安全面临着前所未有的挑战。所有安全技术人员有必要掌握当今黑客们的武器和思维过程，保护Web应用免遭恶意攻击。本书由美国公认的安全专家和精神领袖打造，对上一版做了完全的更新，覆盖新的网络渗透方法和对策，介绍如何增强验证和授权、弥补Firefox和IE中的漏洞、加强对注入攻击的防御以及加固Web 2.0安全，还介绍了如何将安全技术整合在Web开发以及更广泛......一起来看看《黑客大曝光》这本书的介绍吧!

码农工具

HTML 压缩/解压工具

在线压缩/解压 HTML 代码

XML 在线格式化

在线 XML 格式化压缩工具