前言：
今天咱们对“mysqldsn”都比较讲究，咱们都需要学习一些“mysqldsn”的相关内容。那么小编在网上搜集了一些有关“mysqldsn””的相关文章，希望咱们能喜欢，大家快快来了解一下吧！之前，已经讲过一些Golang的基础的东西，感兴趣的可以看看以前的文章，
今天简单介绍下Golang是如何使用mysql数据库的。下面主要从增删查改以及事物等方面介绍go语言中mysql的使用。
一、安装
由于Go本身不提供具体数据库驱动，只提供驱动接口和管理。各个数据库驱动需要第三方实现，并且注册到Go中的驱动管理中。github上面的mysql驱动有好几个，我在这里选择go-sql-driver。
github网址：。
admin:123456@tcp(10.2.1.5)/irisapp
二、连接数据库
使用sql.Open()函数打开数据库连接，数据库的连接字符串（dsn）格式如下：
func (f *mysql_db) mysql_insert() { //insert 添加数据 fmt.Println("开始插入") stmt, err := f.db.Prepare("INSERT INTO depart(departName,memo) VALUES(?,?)") //defer stmt.Close() if err != nil { fmt.Println("插入失败") return } stmt.Exec("dd", "adadcccda") id,_ := result.LastInsertId() fmt.Println("插入成功")}代码如下：
func (f *mysql_db) mysql_open() { db, err := sql.Open("mysql", dbusername+":"+dbpassword+"@tcp("+dbhostsip+")/"+dbname) if err != nil { fmt.Println("链接失败") } fmt.Println("链接成功") f.db = db}说明：返回的DB可以安全的被多个goroutine同时使用，并会维护自身的闲置连接池。这样一来，Open函数只需调用一次。很少需要关闭DB。
三、增删改查
简单说明下是如何实现增删改查的：
通过 Exec() 方法插入、修改和删除数据的操作，返回的结果是 sql.Result 类型通过Query() 方法执行查询操作。支持预备表达式，可以用来优化SQL查询提高性能，减少SQL注入的风险, db.Prepare()和 tx.Prepare 都提供了对于预备表达式的支持。LastInsertId() 获取插入第一条的id。RowsAffected() 获取影响/插入的条数。
1、插入
func (f *mysql_db) mysql_insert() { //insert 添加数据 fmt.Println("开始插入") stmt, err := f.db.Prepare("INSERT INTO depart(departName,memo) VALUES(?,?)") //defer stmt.Close() if err != nil { fmt.Println("插入失败") return } stmt.Exec("dd", "adadcccda") id,_ := result.LastInsertId() fmt.Println("插入成功")}说明：
1. 可以通过LastInsertId() 获取插入的id 。
2. 提供了对于预备表达式的支持 db.Prepare()，减少SQL注入的风险,。
2、查询
func (f *mysql_db) mysql_select(sql_data string) { //select 查询数据 sql_data :="select departID,departName,memo from depart" fmt.Println("sql:", sql_data) rows, err := f.db.Query(sql_data) if err != nil { fmt.Println("查询失败") } for rows.Next() { var departID int var departName string var memo string err = rows.Scan(&departID, &departName, &memo) if err != nil { panic(err) } fmt.Println("departName:", departName) }}3、更新
func (f *mysql_db) mysql_update() { //update 修改数据 stmt, err := f.db.Prepare("update depart set departName=?,memo =? where departId=?") //defer stmt.Close() if err != nil { //错误处理 } result,_ := stmt.Exec("aa","asdfadsadsfa",1) if result == nil { fmt.Println("修改失败") } affect_count,_ := result.RowsAffected() //返回影响的条数,注意有两个返回值 fmt.Println("%v",affect_count)}说明：RowsAffected() 返回影响的条数,注意有两个返回值。
4、删除
func (f *mysql_db) mysql_delete() { //delete 删除数据 stmt, err := f.db.Prepare("delete from depart where departId=?") //defer stmt.Close() if err != nil { //错误处理 } stmt.Exec(2) //不返回任何结果 fmt.Println("删除成功")}四、使用事物
func (f *mysql_db) mysql_tran(){ //事务 tx,err := f.db.Begin() //声明一个事务的开始 if err != nil { fmt.Println(err) return } insert_sql := "insert into depart (departName,memo) VALUES(?,?)" insert_stmt,insert_err := tx.Prepare(insert_sql) if insert_err != nil { fmt.Println(insert_err) return } insert_res,insert_err := insert_stmt.Exec("ff","ff") last_insert_id,_ := insert_res.LastInsertId() fmt.Println(last_insert_id) // defer tx.Rollback() //回滚之前上面的last_login_id是有的，但在回滚后该操作没有被提交，被回滚了，所以上面打印的Last_login_id的这条数据是不存在与数据库表中的 tx.Commit() //这里提交了上面的操作，所以上面的执行的sql 会在数据库中产生一条数据}五、测试
func main() { db := &mysql_db{} db.mysql_open() db.mysql_insert() db.mysql_update() db.mysql_delete() db.mysql_tran() db.mysql_select() db.mysql_close() //关闭}启动后输出如下：
D:\Go_Path\go\src\mysqldemo>go run mysqldemo.go链接成功开始插入插入成功0删除成功10sql: select departID,departName,memo from departdepartName: aadepartName: dddepartName: dddepartName: dddepartName: dddepartName: dddepartName: ffdepartName: dddepartName: ff
总结
这里只是简单介绍了go语言开发中mysql在go语言开发中的基本使用，其实真正开发过程中还是主要使用orm相关第三方框架，但是底层原理还是要学的。分享关注（章为忠学架构）获取完整代码。
推荐阅读：
Golang 入门系列（八）如何实现定时任务，极简版！
Golang 入门系列（六）理解Go协程Goroutine，这篇就够了！
Golang 入门系列（四）Golang中的interface，一看就明白
Golang 入门系列（三）打好基本功: Golang 语法基础！
SpringBoot入门系列（一）如何快速创建SpringBoot项目
Nginx总结（六）nginx实现负载均衡
标签： #mysqldsn
