golang sqlite数据库连接池

Question

当我在与读取相同的时间调用数据库写入时,我遇到了SQLite在我的机器中抛出扳手的问题.当不同的方法尝试在同一时间访问数据库时会发生这种情况.

我正在做的与此线程中的操作类似,接受的答案解释了如何使用数据库事务来避免数据库锁定.

这是我的一些代码:

stmt, err := dbtx.Prepare(`statement`)
if err != nil {
    log.Fatal(err)
}

_, err = stmt.Exec(values, values, values)
if err != nil {        
    log.Fatal(err)
}

err = dbtx.Commit()
if err != nil {
    fmt.Println("database lock?")
    fmt.Println(err)
    dbtx.Rollback()
}

fmt.Println("Database storage complete!")

令人困惑的是输出后该程序存在:

database lock?
database is locked
Database storage complete!
2014/09/09 18:33:11 database is locked
exit status 1

我不希望我的程序暂停数据库锁,我希望它将数据存储在内存中并继续其业务直到数据库解锁,我可以再试一次.

是否有一些标准方法可以实现这一点,可能是某种类型的队列或数据结构,还是有特定于数据库的方法来解决这个问题？

输出后为什么程序会退出Database storage complete!？

编辑:

我相信我已经解决了这个问题,但我无法确定.我正在使用goroutines和一个程序包范围的数据库连接.以前,我的代码中的每个函数都在调用时初始化数据库连接.现在,我有一个"全局"变量用于在包顶部定义的数据库连接,并在任何例程开始之前进行初始化.这里的代码简而言之:

var nDB *sql.DB

后来在主要功能...

mypkg.InitDB()
go mypkg.RunDatabaseOperations()
mypkg.BeginHTTPWatcher(rtr)

InitDB() 定义如下:

func InitDB() {
    fmt.Println("Init DB ...")
    var err error
    nDB, err = sql.Open("sqlite3", "./first.db")
    if err != nil {
        log.Fatal(err)
    }
    if nDB == nil {
        log.Fatal(err)
    }
    fmt.Printf("nDB: %v\n", ODB)
    fmt.Println("testing db connection...")
    err2 := nDB.Ping()
    if err2 != nil {
        log.Fatalf("Error on opening database connection: %s", err2.Error())
    }
}

因此,RunDatabaseOperations定期扫描在线资源以获取数据,并在发生更改时将其存储到数据库中(每隔几秒钟一次).BeginHTTPWatcher侦听HTTP请求,以便可以从正在运行的程序中读取数据,并通过线程将数据传输到数据的请求者,无论是本地请求还是外部请求.我还没有遇到任何问题.

Answer 1

该文件说:

单个连接实例及其所有派生对象(预处理语句,备份操作等)可能无法在没有外部同步的情况下从多个goroutine同时使用.

(这是一个不同的SQLite驱动程序,但此限制也适用于您的.)

使用goroutine时,必须使用单独的数据库连接.

默认情况下,SQLite在遇到另一个事务锁定的数据库时立即中止.为了允许更多的并发性,您可以通过设置忙超时告诉它等待另一个事务完成.

如果您的SQLite驱动程序有,请使用BusyTimeout函数,或直接执行PRAGMA busy_timeout SQL命令.