Go基础之--操作Mysql(一)
关于标准库database/sql
database/sql是golang的标准库之一,它提供了一系列接口方法,用于访问关系数据库。它并不会提供数据库特有的方法,那些特有的方法交给数据库驱动去实现。
database/sql库提供了一些type。这些类型对掌握它的用法非常重要。
DB 数据库对象。 sql.DB类型代表了数据库。和其他语言不一样,它并是数据库连接。golang中的连接来自内部实现的连接池,连接的建立是惰性的,当你需要连接的时候,连接池会自动帮你创建。通常你不需要操作连接池。一切都有go来帮你完成。
Results 结果集。数据库查询的时候,都会有结果集。sql.Rows类型表示查询返回多行数据的结果集。sql.Row则表示单行查询结果的结果集。当然,对于插入更新和删除,返回的结果集类型为sql.Result。
Statements 语句。sql.Stmt类型表示sql查询语句,例如DDL,DML等类似的sql语句。可以把当成prepare语句构造查询,也可以直接使用sql.DB的函数对其操作。
而通常工作中我们可能更多的是用https://github.com/jmoiron/sqlx包来操作数据库 sqlx是基于标准库database/sql的扩展,并且我们可以通过sqlx操作各种类型的数据如
和其他语言不通的是,查询数据库的时候需要创建一个连接,对于go而言则是需要创建一个数据库对象,连接将会在查询需要的时候,由连接池创建并维护,使用sql.Open函数创建数据库对象,第一个参数是数据库驱动名,第二个参数是一个连接字符串
关于数据库的增删查改
增加数据
关于增加数据几个小知识点:
- 关于插入数据的时候占位符是通过问号:?
- 插入数据的后可以通过LastInsertId可以获取插入数据的id
- 通过RowsAffected可以获取受影响的行数
- 执行sql语句是通过exec
一个简单的使用例子:
package main
import (
"github.com/jmoiron/sqlx"
_ "github.com/go-sql-driver/mysql"
"fmt"
)
func main() {
Db,err:=sqlx.Open("mysql","root:123456@tcp(192.168.14.7:3306)/godb")
if err != nil{
fmt.Println("connect to mysql failed,",err)
return
}
defer Db.Close()
fmt.Println("connect to mysql success")
//执行sql语句,切记这里的占位符是?
result,err := Db.Exec("INSERT INTO user_info(username,sex,email)VALUES (?,?,?)","user01","男","8989@qq.com")
if err != nil{
fmt.Println("insert failed,",err)
}
// 通过LastInsertId可以获取插入数据的id
userId,err:= result.LastInsertId()
// 通过RowsAffected可以获取受影响的行数
rowCount,err:=result.RowsAffected()
fmt.Println("user_id:",userId)
fmt.Println("rowCount:",rowCount)
}
通过Exec方法插入数据,返回的结果是一个sql.Result类型
查询数据
下面是一个查询的例子代码:
//执行查询操作
rows,err := Db.Query("SELECT email FROM user_info WHERE user_id>=5")
if err != nil{
fmt.Println("select db failed,err:",err)
return
}
// 这里获取的rows是从数据库查的满足user_id>=5的所有行的email信息,rows.Next(),用于循环获取所有
for rows.Next(){
var s string
err = rows.Scan(&s)
if err != nil{
fmt.Println(err)
return
}
fmt.Println(s)
}
rows.Close()
使用了Query方法执行select查询语句,返回的是一个sql.Rows类型的结果集 迭代后者的Next方法,然后使用Scan方法给变量s赋值,以便取出结果。最后再把结果集关闭(释放连接)。 同样的我们还可以通过Exec方式执行查询语句 但是因为Exec返回的是一个sql.Result类型,从官网这里: https://golang.google.cn/pkg/database/sql/#type Result 我们可以直接这个接口里只有两个方法:LastInsertId(),RowsAffected()
我们还可以通过Db.Get()方法获取查询的数据,将查询的数据保存到一个结构体中
//Get执行查询操作
type user_info struct {
Username string `db:"username"`
Email string `db:"email"`
}
var userInfo user_info
err = Db.Get(&userInfo,"SELECT username,email FROM user_info WHERE user_id=5")
if err != nil{
fmt.Println(err)
return
}
fmt.Println(userInfo)
这样获取的一个数据,如果我们需要获取多行数据信息还可以通过Db.Select方法获取数据,代码例子为:
var userList []*user_info
err = Db.Select(&userList,"SELECT username,email FROM user_info WHERE user_id>5")
if err != nil{
fmt.Println(err)
return
}
fmt.Println(userList)
for _,v:= range userList{
fmt.Println(v)
}
通过Db.Select方法将查询的多行数据保存在一个切片中,然后就可以通过循环的方式获取每行数据
更新数据
下面是一个更新的例子,这里是通过Exec的方式执行的
//更新数据
results,err := Db.Exec("UPDATE user_info SET username=? where user_id=?","golang",5)
if err != nil{
fmt.Println("update data fail,err:",err)
return
}
fmt.Println(results.RowsAffected())
删除数据
下面是一个删除的例子,同样是通过Exec的方式执行的
//删除数据
results,err := Db.Exec("DELETE from user_info where user_id=?",5)
if err != nil{
fmt.Println("delete data fail,err:",err)
return
}
fmt.Println(results.RowsAffected())
通过上面的简单例子,对golang操作mysql的增删查改,有了一个基本的了解,下面整理一下重点内容
sql.DB
当我们调用sqlx.Open()可以获取一个sql.DB对象,sql.DB是数据库的抽象,切记它不是数据库连接,sqlx.Open()只是验证数据库参数,并没不创建数据库连接。sql.DB提供了和数据库交互的函数,同时也管理维护一个数据库连接池,并且对于多gegoroutines也是安全的
sql.DB表示是数据库抽象,因此你有几个数据库就需要为每一个数据库创建一个sql.DB对象。因为它维护了一个连接池,因此不需要频繁的创建和销毁。
连接池
只用sql.Open函数创建连接池,可是此时只是初始化了连接池,并没有创建任何连接。连接创建都是惰性的,只有当真正使用到连接的时候,连接池才会创建连接。连接池很重要,它直接影响着你的程序行为。
连接池的工作原来却相当简单。当你的函数(例如Exec,Query)调用需要访问底层数据库的时候,函数首先会向连接池请求一个连接。如果连接池有空闲的连接,则返回给函数。否则连接池将会创建一个新的连接给函数。一旦连接给了函数,连接则归属于函数。函数执行完毕后,要不把连接所属权归还给连接池,要么传递给下一个需要连接的(Rows)对象,最后使用完连接的对象也会把连接释放回到连接池。
请求连接的函数有几个,执行完毕处理连接的方式也不同:
- db.Ping() 调用完毕后会马上把连接返回给连接池。
- db.Exec() 调用完毕后会马上把连接返回给连接池,但是它返回的Result对象还保留这连接的引用,当后面的代码需要处理结果集的时候连接将会被重用。
- db.Query() 调用完毕后会将连接传递给sql.Rows类型,当然后者迭代完毕或者显示的调用.Clonse()方法后,连接将会被释放回到连接池。
- db.QueryRow()调用完毕后会将连接传递给sql.Row类型,当.Scan()方法调用之后把连接释放回到连接池。
- db.Begin() 调用完毕后将连接传递给sql.Tx类型对象,当.Commit()或.Rollback()方法调用后释放连接。
每个连接都是惰性的,如何验证sql.Open调用之后,sql.DB对象可用,通过db.Ping()初始化
代码例子:
package main
import (
"github.com/jmoiron/sqlx"
_ "github.com/go-sql-driver/mysql"
"fmt"
)
func main() {
Db, err := sqlx.Open("mysql", "root:123456@tcp(192.168.50.166:3306)/godb")
if err != nil {
fmt.Println("connect to mysql failed,", err)
return
}
defer Db.Close()
fmt.Println("connect to mysql success")
err = Db.Ping()
if err != nil{
fmt.Println(err)
return
}
fmt.Println("ping success")
}
需要知道:当调用了ping之后,连接池一定会初始化一个数据连接
连接失败
database/sql 其实帮我们做了很多事情,我们不用见擦汗连接失败的情况,当我们进行数据库操作的时候,如果连接失败,database/sql 会帮我们处理,它会自动连接2次,这个如果查看源码中我们可以看到如下的代码:
// ExecContext executes a query without returning any rows.
// The args are for any placeholder parameters in the query.
func (db *DB) ExecContext(ctx context.Context, query string, args ...interface{}) (Result, error) {
var res Result
var err error
for i := 0; i < maxBadConnRetries; i++ {
res, err = db.exec(ctx, query, args, cachedOrNewConn)
if err != driver.ErrBadConn {
break
}
}
if err == driver.ErrBadConn {
return db.exec(ctx, query, args, alwaysNewConn)
}
return res, err
}
上述代码中变量maxBadConnRetries小时如果连接失败尝试的次数,默认是2
关于连接池配置
db.SetMaxIdleConns(n int) 设置连接池中的保持连接的最大连接数。默认也是0,表示连接池不会保持释放会连接池中的连接的连接状态:即当连接释放回到连接池的时候,连接将会被关闭。这会导致连接再连接池中频繁的关闭和创建。
db.SetMaxOpenConns(n int) 设置打开数据库的最大连接数。包含正在使用的连接和连接池的连接。如果你的函数调用需要申请一个连接,并且连接池已经没有了连接或者连接数达到了最大连接数。此时的函数调用将会被block,直到有可用的连接才会返回。设置这个值可以避免并发太高导致连接mysql出现too many connections的错误。该函数的默认设置是0,表示无限制。
db.SetConnMaxLifetime(d time.Duration) 设置连接可以被使用的最长有效时间,如果过期,连接将被拒绝
- 大数据面试题整理
- 02-移动端开发教程-CSS3新特性(中)
- 强悍!Java 9 中的9个新特性
- 神经网络反向传播梯度计算数学原理
- Spring Boot 1.5.10 发布:修复重要安全漏洞!!!
- 从零开始写项目第三篇【在线聊天和个人收藏夹】
- TiDB 源码阅读系列文章(六)Select 语句概览
- 从零开始写项目第四篇【搭建Linux环境】
- salesforce零基础学习(八十六)Ajax Toolkit (VF页面中使用及javascript action使用)
- salesforce零基础学习(八十五)streaming api 简单使用(接近实时获取你需要跟踪的数据的更新消息状态)
- 深入nDPI
- 44个Java代码性能优化总结
- 干货:Java正确获取客户端真实IP方法整理
- sublime学习笔记
- MySQL 教程
- MySQL 安装
- MySQL 管理与配置
- MySQL PHP 语法
- MySQL 连接
- MySQL 创建数据库
- MySQL 删除数据库
- MySQL 选择数据库
- MySQL 数据类型
- MySQL 创建数据表
- MySQL 删除数据表
- MySQL 插入数据
- MySQL 查询数据
- MySQL where 子句
- MySQL UPDATE 查询
- MySQL DELETE 语句
- MySQL LIKE 子句
- mysql order by
- Mysql Join的使用
- MySQL NULL 值处理
- MySQL 正则表达式
- MySQL 事务
- MySQL ALTER命令
- MySQL 索引
- MySQL 临时表
- MySQL 复制表
- 查看MySQL 元数据
- MySQL 序列 AUTO_INCREMENT
- MySQL 处理重复数据
- MySQL 及 SQL 注入
- MySQL 导出数据
- MySQL 导入数据
- MYSQL 函数大全
- MySQL Group By 实例讲解
- MySQL Max()函数实例讲解
- mysql count函数实例
- MYSQL UNION和UNION ALL实例
- MySQL IN 用法
- MySQL between and 实例讲解
- Python装饰器实现函数动态类型检查
- 如何自动填充SQL语句中的公共字段
- 面试官喜欢问的Java编译期与运行期问题总结全了
- 面试5年25K程序员回答不出来为什么Java的main方法必须是public static void?
- Python装饰器
- 3分钟短文:十年窖藏,Laravel告诉你表单验证的“正确姿势”
- 面试官:说说SpringBoot中Spring容器的启动过程
- Python IO
- Python解析式
- 面试官:Tomcat 的调优怎么做?你的最佳实践有哪些?
- Tomcat源码分析
- lazy-mock ,一个生成后端模拟数据的懒人工具
- Python拉链法和开地址法实现字典
- Springboot2 整合redis发布订阅 解决订阅多个频道重复代码过多 创建很多bean问题
- 爬虫选择器算法漫谈