feat(be): sqlite support, options

Author: mgukov

db/sql/SqlDb.go

@@ -128,27 +128,23 @@ func (d *SqlDb) PrepareQuery(query string) string {
 }
 
 func (d *SqlDb) insert(primaryKeyColumnName string, query string, args ...any) (int, error) {
-	return d.insertBy(d.sql, primaryKeyColumnName, query, args...)
-}
-
-func (d *SqlDb) insertBy(executor gorp.SqlExecutor, primaryKeyColumnName string, query string, args ...any) (int, error) {
 	var insertId int64
 
 	switch d.sql.Dialect.(type) {
 	case gorp.PostgresDialect:
 		var err error
 		if primaryKeyColumnName != "" {
 			query += " returning " + primaryKeyColumnName
-			err = executor.QueryRow(d.PrepareQuery(query), args...).Scan(&insertId)
+			err = d.sql.QueryRow(d.PrepareQuery(query), args...).Scan(&insertId)
 		} else {
-			_, err = executor.Exec(d.PrepareQuery(query), args...)
+			_, err = d.sql.Exec(d.PrepareQuery(query), args...)
 		}
 
 		if err != nil {
 			return 0, err
 		}
 	default:
-		res, err := executor.Exec(d.PrepareQuery(query), args...)
+		res, err := d.sql.Exec(d.PrepareQuery(query), args...)
 		if err != nil {
 			return 0, err
 		}

util/config.go

@@ -1017,23 +1017,8 @@ func (d *DbConfig) GetConnectionString(includeDbName bool) (connectionString str
 		}
 		connectionString += mapToQueryString(d.Options)
 	case DbDriverSQLite:
-		connectionString = fmt.Sprintf("file:%s?_busy_timeout=5000&_journal_mode=WAL&_synchronous=NORMAL", dbHost)
-
-		//if includeDbName {
-		//	connectionString = fmt.Sprintf(
-		//		"postgres://%s:%s@%s/%s",
-		//		dbUser,
-		//		url.QueryEscape(dbPass),
-		//		dbHost,
-		//		dbName)
-		//} else {
-		//	connectionString = fmt.Sprintf(
-		//		"postgres://%s:%s@%s/postgres",
-		//		dbUser,
-		//		url.QueryEscape(dbPass),
-		//		dbHost)
-		//}
-		//connectionString += mapToQueryString(d.Options)
+		connectionString = "file:" + dbHost
+		connectionString += mapToQueryString(d.Options)
 	default:
 		err = fmt.Errorf("unsupported database driver: %s", d.Dialect)
 	}