gravitl/netmaker
1
1
Fork 0
mirror of https://github.com/gravitl/netmaker.git synced 2025-10-06 11:56:39 +08:00
Code Issues Projects Releases Packages Wiki Activity

set max open conns to 1 for sqlite

Browse source
This commit is contained in:
0xdcarns 2022-03-21 09:14:04 -04:00
parent 24f292c934
commit 5e327fdea4
1 changed files with 1 additions and 11 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

12
database/sqlite.go
View file

@ -5,7 +5,6 @@ import (
"errors" "errors"
"os" "os"
"path/filepath" "path/filepath"
"sync"
_ "github.com/mattn/go-sqlite3" // need to blank import this package _ "github.com/mattn/go-sqlite3" // need to blank import this package
) )
@ -28,8 +27,6 @@ var SQLITE_FUNCTIONS = map[string]interface{}{
CLOSE_DB: sqliteCloseDB, CLOSE_DB: sqliteCloseDB,
} }
var mutex sync.Mutex
func initSqliteDB() error { func initSqliteDB() error {
// == create db file if not present == // == create db file if not present ==
if _, err := os.Stat("data"); os.IsNotExist(err) { if _, err := os.Stat("data"); os.IsNotExist(err) {
@ -45,6 +42,7 @@ func initSqliteDB() error {
if dbOpenErr != nil { if dbOpenErr != nil {
return dbOpenErr return dbOpenErr
} }
SqliteDB.SetMaxOpenConns(1)
return nil return nil
} }
@ -63,8 +61,6 @@ func sqliteCreateTable(tableName string) error {
func sqliteInsert(key string, value string, tableName string) error { func sqliteInsert(key string, value string, tableName string) error {
if key != "" && value != "" && IsJSONString(value) { if key != "" && value != "" && IsJSONString(value) {
mutex.Lock()
defer mutex.Unlock()
insertSQL := "INSERT OR REPLACE INTO " + tableName + " (key, value) VALUES (?, ?)" insertSQL := "INSERT OR REPLACE INTO " + tableName + " (key, value) VALUES (?, ?)"
statement, err := SqliteDB.Prepare(insertSQL) statement, err := SqliteDB.Prepare(insertSQL)
if err != nil { if err != nil {
@ -82,8 +78,6 @@ func sqliteInsert(key string, value string, tableName string) error {
func sqliteInsertPeer(key string, value string) error { func sqliteInsertPeer(key string, value string) error {
if key != "" && value != "" && IsJSONString(value) { if key != "" && value != "" && IsJSONString(value) {
mutex.Lock()
defer mutex.Unlock()
err := sqliteInsert(key, value, PEERS_TABLE_NAME) err := sqliteInsert(key, value, PEERS_TABLE_NAME)
if err != nil { if err != nil {
return err return err
@ -94,8 +88,6 @@ func sqliteInsertPeer(key string, value string) error {
} }
func sqliteDeleteRecord(tableName string, key string) error { func sqliteDeleteRecord(tableName string, key string) error {
mutex.Lock()
defer mutex.Unlock()
deleteSQL := "DELETE FROM " + tableName + " WHERE key = \"" + key + "\"" deleteSQL := "DELETE FROM " + tableName + " WHERE key = \"" + key + "\""
statement, err := SqliteDB.Prepare(deleteSQL) statement, err := SqliteDB.Prepare(deleteSQL)
if err != nil { if err != nil {
@ -109,8 +101,6 @@ func sqliteDeleteRecord(tableName string, key string) error {
} }
func sqliteDeleteAllRecords(tableName string) error { func sqliteDeleteAllRecords(tableName string) error {
mutex.Lock()
defer mutex.Unlock()
deleteSQL := "DELETE FROM " + tableName deleteSQL := "DELETE FROM " + tableName
statement, err := SqliteDB.Prepare(deleteSQL) statement, err := SqliteDB.Prepare(deleteSQL)
if err != nil { if err != nil {