golang 数据库开发神器 sqlx使用指南
sqlx使用指南这边文章主要基于Illustrated guide to SQLX翻译而成。 资源如果对于go语言的sql用法不熟悉,可以到下面网站学习: 如果对于golang语言不熟悉,可以到下面网站学习: 由于database/sql接口是sqlx的子集,当前文档中所有关于database/sql的用法同样用于sqlx 开始安装sqlx 驱动 $ go get github.com/jmoiron/sqlx
本文访问sqlite数据库 $ go get github.com/mattn/go-sqlite3
Handle Typessqlx设计和database/sql使用方法是一样的。包含有4中主要的handle types: 所有的handler types都提供了对database/sql的兼容,意味着当你调用sqlx.DB.Query时,可以直接替换为sql.DB.Query.这就使得sqlx可以很容易的加入到已有的数据库项目中。 此外,sqlx还有两个cursor类型: 连级到数据库一个DB实例并不是一个链接,但是抽象表示了一个数据库。这就是为什么创建一个DB时并不会返回错误和panic。它内部维护了一个连接池,当需要进行连接的时候尝试连接。你可以通过Open创建一个sqlx.DB或通过NewDb从已存在的sql.DB中创建一个新的sqlx.DB var db *sqlx.DB
// exactly the same as the built-in
db = sqlx.Open("sqlite3",":memory:")
// from a pre-existing sql.DB; note the required driverName
db = sqlx.NewDb(sql.Open("sqlite3",":memory:"),"sqlite3")
// force a connection and test that it worked
err = db.Ping()
在一些环境下,你可能需要同时打开一个DB并链接。可以调用connect,这个函数打开一个新的DB并尝试Ping。MustConnect函数在链接出错时会panic。 var err error
// open and connect at the same time:
db,err = sqlx.Connect("sqlite3",":memory:")
// open and connect at the same time,panicing on error
db = sqlx.MustConnect("sqlite3",":memory:")
Querying 101sqlx中的handle types实现了数据库查询相同的基本的操作语法。 对内置语法的扩展 还有下面新的语法
ExecExec和MustExec从连接池中获取一个连接然后只想对应的query操作。对于不支持ad-hoc query execution的驱动,在操作执行的背后会创建一个prepared statement。在结果返回前这个connection会返回到连接池中。 schema := `CREATE TABLE place ( country text,city text NULL,telcode integer);`
// execute a query on the server
result,err := db.Exec(schema)
// or,you can use MustExec,which panics on error
cityState := `INSERT INTO place (country,telcode) VALUES (?,?)` countryCity := `INSERT INTO place (country,city,?,?)` db.MustExec(cityState,"Hong Kong",852) db.MustExec(cityState,"Singapore",65) db.MustExec(countryCity,"South Africa","Johannesburg",27)
上面代码中 result有两个可能的数据LastInsertId() or RowsAffected(),依赖不同的驱动。 bindvars代码中?占位符,称为bindvars,非常重要,你可以总是使用它们来向数据库发送数据,可以用来组织SQL Injection攻击。 其他数据库可能还不一样。你可以使用sqlx.DB.Rebind(string) string函数利用?语法来得到一个适合在当前数据库上执行的query语句。 关于bindvars常见的误解是他们用于插值。他们只用于参数化,不允许改变sql语句的合法接口。例如,下面的用法是会报错的 // doesn't work
db.Query("SELECT * FROM ?","mytable") // also doesn't work db.Query("SELECT ?,? FROM people","name","location")
QueryQuery是database/sql中执行查询主要使用的方法,该方法返回row结果。Query返回一个sql.Rows对象和一个error对象。 // fetch all places from the db
rows,err := db.Query("SELECT country,telcode FROM place")
// iterate over each row
for rows.Next() {
var country string
// note that city can be NULL,so we use the NullString type
var city sql.NullString
var telcode int
err = rows.Scan(&country,&city,&telcode)
}
在使用的时候应该吧Rows当成一个游标而不是一系列的结果。尽管数据库驱动缓存的方法不一样,通过Next()迭代每次获取一列结果,对于查询结果非常巨大的情况下,可以有效的限制内存的使用,Scan()利用reflect把sql每一列结果映射到go语言的数据类型如string,[]byte等。如果你没有遍历完全部的rows结果,一定要记得在把connection返回到连接池之前调用rows.Close()。 Query返回的error有可能是在server准备查询的时候发生的,也有可能是在执行查询语句的时候发生的。例如可能从连接池中获取一个坏的连级(尽管数据库会尝试10次去发现或创建一个工作连接)。一般来说,错误主要由错误的sql语句,错误的类似匹配,错误的域名或表名等。 在大部分情况下,Rows.Scan()会把从驱动获取的数据进行拷贝,无论驱动如何使用缓存。特殊类型sql.RawBytes可以用来从驱动返回的数据总获取一个zero-copy的slice byte。当下一次调用Next的时候,这个值就不在有效了,因为它指向的内存已经被驱动重写了别的数据。 Query使用的connection在所有的rows通过Next()遍历完后或者调用rows.Close()后释放。 type Place struct { Country string City sql.NullString TelephoneCode int `db:"telcode"` }
rows,err := db.Queryx("SELECT * FROM place")
for rows.Next() {
var p Place
err = rows.StructScan(&p)
}
sqlx.Rowx的主要扩展就是StructScan,可以自动把查下结果扫描到对应结构体中的域(fileld)中。注意结构体中域(field)必须是可导出(exported)的,这样sqlx才能够写入值到结构体中。 QueryRowQueryRow从数据库server中获取一列数据。它从连接池中获取一个连级,然后执行Query,返回一个Row对象,这个对象有一个自己的内部的Rows对象。 row := db.QueryRow("SELECT * FROM place WHERE telcode=?",852)
var telcode int
err = row.Scan(&telcode)
不像Query,QueryRow只返回一个Row类型,并不返回error,如果在执行查询过程中出错,则错误通过Scan返回,如果查询结果为空,则返回sql.ErrNoRows。如果Scan本身出错,error同样由scan返回。 QueryRow使用的connection当result返回的时候就关闭了,也就意味着使用QueryRow的时候不能够使用sql.RawByes,因为driver使用sql.RawBytes引用内存,在connection回收后可能也会无效。 QueryRowx返回一个sqlx.Row而不是sql.Row,它实现了跟Rows相同的scan方法如上,同时还有高级的scan方法如下:(更高级的scan方法advanced scanning section) var p Place
err := db.QueryRowx("SELECT city,telcode FROM place LIMIT 1").StructScan(&p)
Get and SelectGet和Select是一个非常省时的扩展。它们把query和非常灵活的scan语法结合起来。为了更加清晰的介绍它们,我们先讨论下什么是scannalbe:
Get和Select对scannable的类型使用rows.scan,对non-scannable的类型使用rows.StructScan。Get用来获取单个结果然后Scan,Select用来获取结果切片。 p := Place{}
pp := []Place{}
// this will pull the first place directly into p
err = db.Get(&p,"SELECT * FROM place LIMIT 1") // this will pull places with telcode > 50 into the slice pp err = db.Select(&pp,"SELECT * FROM place WHERE telcode > ?",50) // they work with regular types as well var id int err = db.Get(&id,"SELECT count(*) FROM place") // fetch at most 10 place names var names []string err = db.Select(&names,"SELECT name FROM place LIMIT 10")
Get和Select在执行完查询后就会关闭Rows,并且在执行阶段遇到任何问题都会返回错误。由于它们内部使用的StructScan,所以 下文中advanced scanning section讲的特征也适用与Get和Select。 Select可以提高编码小路,但是要注意Select和Queryx是有很大不同的,因为Select会把整个结果一次放入内存。如果查询结果没有限制特定的大小,那么最好使用Query/StructScan迭代方法。 Transactions为了使用transactions,必须使用DB.Begin()来创建,下面的代码是错误的: db.MustExec("BEGIN;")
db.MustExec(...)
db.MustExec("COMMIT;")
Exec和其他查询语句会向DB请求一个connection,执行完后就返回到连接池中,并不能保证每次获取的connection就是BEGIN执行时使用的那个,所以正确的做法要使用DB.Begin: tx,err := db.Begin()
err = tx.Exec(...)
err = tx.Commit()
DB除了Begin之外,还可以使用扩展Beginx()和MustBegin(),返回sqlx.Tx: tx := db.MustBegin()
tx.MustExec(...)
err = tx.Commit()
sqlx.Tx拥有sqlx.DB拥有的所有的handle extensions. 最后,Tx对象仅仅执行了一个BEGIN语句和绑定了一个connection,它其实并没有在server上执行任何操作。而transaction真实的行为包含locking和isolation,在不同数据库上实现是不同的。 Prepared Statements对于大部分的数据库来说,当一个query执行的时候,在数据库内部statements其实已经准备好了。然后你可以通过sqlx.DB.Prepare()准备statements,便于后面在别的地方使用。 stmt,err := db.Prepare(`SELECT * FROM place WHERE telcode=?`) row = stmt.QueryRow(65) tx,err := db.Begin() txStmt,err := tx.Prepare(`SELECT * FROM place WHERE telcode=?`) row = txStmt.QueryRow(852)
Prepare实际上在数据库上执行preparation操作,所以它需要一个connection和它的connection state。 sql.Tx对象含有一个Stmt()方法,从已存在的statement中返回一个特定于改transaction的statement。 Query Helpers“In” Queries由于database/sql并不会分析你的查询语句然后直接把参数传递给driver,这样对于IN (编辑:李大同) 【声明】本站内容均来自网络,其相关言论仅代表作者个人观点,不代表本站立场。若无意侵犯到您的权利,请及时与联系站长删除相关内容! |