首页 > 数据库> 文章详细

关于golang database_sql 包

2020-09-05 23:00:37 阅读：376 来源： 互联网

标签：rows name err database age db golang sql

golang中的标准库database/sql 包为SQL和类SQL数据库的操作提供了通用的接口。
database/sql 包必须与数据库driver 配套使用。
目前已有的SQL database drivers 见链接。
这里面就包括比较常用的MySQL driver go-sql-driver/mysql 。

database/sql 包的设计可以说是很巧妙。
它对于上层应用提供了标准的API接口，对下层驱动driver暴露了简单的驱动接口。
并且实现了连接池的管理。这意味着，不同数据库的驱动只需要实现驱动接口，不需要关心连接池的实现细节。

在这里插入图片描述

常用的API操作接口

连接数据库

db, err := sql.Open(driver, dataSourceName)

连接MySQL，这里driver就是"mysql".
dataSourceName 定义了具体的连接参数。

执行SQL

ExecContext 常用执行没有rows返回的场景。
例如新建、删除

result, err := db.ExecContext(ctx,
	"INSERT INTO users (name, age) VALUES ($1, $2)",
	"gopher",
	27,
)

QueryContext 常用于查询数据集rows。
例如，查询select

rows, err := db.QueryContext(ctx, "SELECT name FROM users WHERE age = $1", age)
if err != nil {
	log.Fatal(err)
}
defer rows.Close()
for rows.Next() {
	var name string
	if err := rows.Scan(&name); err != nil {
		log.Fatal(err)
	}
	fmt.Printf("%s is %d\n", name, age)
}
if err := rows.Err(); err != nil {
	log.Fatal(err)
}

QueryRowContext 用于查询一条记录。

var age int64
err := db.QueryRowContext(ctx, "SELECT age FROM users WHERE name = $1", name).Scan(&age)

Prepared statements可以防止sql注入。

age := 27
stmt, err := db.PrepareContext(ctx, "SELECT name FROM users WHERE age = $1")
if err != nil {
   log.Fatal(err)
}
rows, err := stmt.Query(age)
// process rows

在一个statements上，也可以执行ExecContext, QueryContext and QueryRowContext 。
statements使用完后，需要Close。

事务Transactions

可以使用以下方式开始一个事务Transactions：

tx, err := db.BeginTx(ctx, nil)
if err != nil {
	log.Fatal(err)
}

在一个事务Transactions上，可以执行ExecContext, QueryContext, QueryRowContext 以及PrepareContext。
一个Transactions的结束，或者调用 Commit 或者调用 Rollback。

NULL的处理

sql.NullString 类型可用于处理字段值为NULL的情况。
如果name字段值可能为null，可以这样处理：

var name sql.NullString
err := db.QueryRowContext(ctx, "SELECT name FROM names WHERE id = $1", id).Scan(&name)
...
if name.Valid {
	// use name.String
} else {
	// value is NULL
}

标准库 database/sql 目前支持NullBool, NullFloat64, NullInt64, NullInt32, NullString and NullTime 。

参考

golang package sql

SQL操作接口

标签：rows,name,err,database,age,db,golang,sql
来源： https://www.cnblogs.com/lanyangsh/p/13620193.html

本站声明： 1. iCode9 技术分享网（下文简称本站）提供的所有内容，仅供技术学习、探讨和分享；
2. 关于本站的所有留言、评论、转载及引用，纯属内容发起人的个人观点，与本站观点和立场无关；
3. 关于本站的所有言论和文字，纯属内容发起人的个人观点，与本站观点和立场无关；
4. 本站文章均是网友提供，不完全保证技术分享内容的完整性、准确性、时效性、风险性和版权归属；如您发现该文章侵犯了您的权益，可联系我们第一时间进行删除；
5. 本站为非盈利性的个人网站，所有内容不会用来进行牟利，也不会利用任何形式的广告来间接获益，纯粹是为了广大技术爱好者提供技术内容和技术思想的分享性交流网站。