Add: support config single thread

pkg/database/database.go

@@ -10,10 +10,34 @@ import (
 type Database struct {
 	sqlConn *sql.DB
 	stmt    *Stmt
-	singleThreadLock *sync.Mutex
+	singleThreadLock SingleThreadLock
 }
 
-func NewDatabase(dbName string) (*Database, error) {
+func NewSingleThreadLock(enabled bool) SingleThreadLock {
+	return SingleThreadLock{
+		lock: sync.Mutex{},
+		enabled: enabled,
+	}
+}
+
+type SingleThreadLock struct {
+	lock sync.Mutex
+	enabled bool
+}
+
+func (stl *SingleThreadLock) Lock() {
+	if stl.enabled {
+		stl.lock.Lock()
+	}
+}
+
+func (stl *SingleThreadLock) Unlock() {
+	if stl.enabled {
+		stl.lock.Unlock()
+	}
+}
+
+func NewDatabase(dbName string, singleThread bool) (*Database, error) {
 	var err error
 
 	// open database
@@ -32,7 +56,7 @@ func NewDatabase(dbName string) (*Database, error) {
 	database := &Database{
 		sqlConn: sqlConn,
 		stmt:    stmt,
-		singleThreadLock: &sync.Mutex{},
+		singleThreadLock: NewSingleThreadLock(singleThread),
 	}
 
 	return database, nil