英文:
Sqlite3 error: database is locked in golang
问题
我正在使用golang中的sqlite3数据库，并且遇到了错误："数据库被锁定"。
我知道不能有多个线程使用同一个数据库文件。
尽管我在程序中只获取了一个连接，并且关闭了所有查询结果，但它总是创建2或3个数据库文件句柄。
我可以通过使用Opendfileview程序来检查这个问题。
以下代码创建了两个数据库文件句柄。
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
}
if rows.Next() {
// ...
}
rows.Close()
// 一些插入查询
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
}
希望对你有帮助！
英文:
I'm using sqlite3 database in golang and I got the error: "database is locked."
I know there can't be multiple threads using same database file.
Although I get only one connection in my program I close all query results, but it always creates 2 or 3 handles of the database file.
I could check this out by using the Opendfileview program.
The following code creates two database file handles.
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
}
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
}
答案1
得分: 26
尝试延迟执行 rows.Close()：
if err != nil {
return err
}
defer rows.Close()
if rows.Next() {
...
}
请注意，defer 关键字用于在函数返回之前执行 rows.Close()，以确保资源的正确释放。
英文:
Try defering the rows.Close():
if err != nil {
return err
}
defer rows.Close()
if rows.Next() {
...
}
通过集体智慧和协作来改善编程学习和解决问题的方式。致力于成为全球开发者共同参与的知识库，让每个人都能够通过互相帮助和分享经验来进步。
评论