为什么我的 Golang Sqlite3 代码出现'数据库已锁定”错误，如何修复？

如何修复 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中文网其他相关文章！