如何修复 Golang 中的 Sqlite3 错误:数据库被锁定
在 Golang 中,使用 Sqlite3 数据库时,您可能会遇到以下错误,“数据库已锁定。”此错误表明多个线程不能同时使用同一个数据库文件。
问题根源
即使您的程序中可能只有一个连接并关闭对于所有查询结果,您可能仍然会得到数据库文件的多个句柄。可以使用 Opendfileview 程序验证此问题。
创建多个数据库文件句柄的代码
以下代码演示了如何创建两个数据库文件句柄:
import "log" import ( "database/sql" "fmt" ) func main() { database, tx, err := getDatabaseHandle() if err != nil { log.Fatal(err) } defer database.Close() dosomething(database, tx) } func dosomething(database *sql.DB, tx *sql.Tx) error { rows, err := database.Query("select * from sometable where name=?", "some") if err != nil { return err } defer rows.Close() // Missing defer if rows.Next() { ... } rows.Close() //some insert queries tx.Commit() } func getDatabaseHandle() (*sql.DB, *sql.Tx, error) { database, err := sql.Open("sqlite3", dbPath) if err != nil { fmt.Println("Failed to create the handle") return nil, nil, err } if err2 := database.Ping(); err2 != nil { fmt.Println("Failed to keep connection alive") return nil, nil, err } tx, err := database.Begin() if err != nil { return nil, nil, err } return database, tx, nil }
解决方案
解决问题,您可以推迟 rows.Close() 调用,如下所示:
if err != nil { return err } defer rows.Close() // Move defer here if rows.Next() { ... }
通过推迟 rows.Close() 调用,您可以确保即使在执行过程中发生恐慌或错误,行也会关闭迭代。这有助于防止创建额外的数据库文件句柄并解决“数据库已锁定”错误。
以上是为什么我的 Golang Sqlite3 代码出现'数据库已锁定”错误,如何修复?的详细内容。更多信息请关注PHP中文网其他相关文章!