1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
|
package node
import (
"database/sql"
"fmt"
"github.com/mattn/go-sqlite3"
)
func init() {
sql.Register("sqlite3_with_fk", &sqlite3.SQLiteDriver{ConnectHook: sqliteEnableForeignKeys})
}
// Opens the node-level database with the correct parameters.
func sqliteOpen(path string) (*sql.DB, error) {
timeout := 5 // TODO - make this command-line configurable?
// These are used to tune the transaction BEGIN behavior instead of using the
// similar "locking_mode" pragma (locking for the whole database connection).
openPath := fmt.Sprintf("%s?_busy_timeout=%d&_txlock=exclusive", path, timeout*1000)
// Open the database. If the file doesn't exist it is created.
return sql.Open("sqlite3_with_fk", openPath)
}
func sqliteEnableForeignKeys(conn *sqlite3.SQLiteConn) error {
_, err := conn.Exec("PRAGMA foreign_keys=ON;", nil)
return err
}
|
