internal: make Tx.queries a pointer

Author: nalgeon

internal/rhash/tx.go

@@ -32,7 +32,7 @@ type queries struct {
 type Tx struct {
 	dialect sqlx.Dialect
 	tx      sqlx.Tx
-	sql     queries
+	sql     *queries
 }
 
 // NewTx creates a hash repository transaction
@@ -458,13 +458,13 @@ type ScanResult struct {
 }
 
 // getSQL returns the SQL queries for the specified dialect.
-func getSQL(dialect sqlx.Dialect) queries {
+func getSQL(dialect sqlx.Dialect) *queries {
 	switch dialect {
 	case sqlx.DialectSqlite:
-		return sqlite
+		return &sqlite
 	case sqlx.DialectPostgres:
-		return postgres
+		return &postgres
 	default:
-		return queries{}
+		return &queries{}
 	}
 }

internal/rkey/tx.go

@@ -34,7 +34,7 @@ type queries struct {
 type Tx struct {
 	dialect sqlx.Dialect
 	tx      sqlx.Tx
-	sql     queries
+	sql     *queries
 }
 
 // NewTx creates a key repository transaction
@@ -342,13 +342,13 @@ func (tx *Tx) deleteExpired(n int) (int, error) {
 }
 
 // getSQL returns the SQL queries for the specified dialect.
-func getSQL(dialect sqlx.Dialect) queries {
+func getSQL(dialect sqlx.Dialect) *queries {
 	switch dialect {
 	case sqlx.DialectSqlite:
-		return sqlite
+		return &sqlite
 	case sqlx.DialectPostgres:
-		return postgres
+		return &postgres
 	default:
-		return queries{}
+		return &queries{}
 	}
 }

internal/rlist/tx.go

@@ -33,7 +33,7 @@ type queries struct {
 type Tx struct {
 	dialect sqlx.Dialect
 	tx      sqlx.Tx
-	sql     queries
+	sql     *queries
 }
 
 // NewTx creates a list repository transaction
@@ -370,13 +370,13 @@ func (tx *Tx) push(key string, elem any, query string) (int, error) {
 }
 
 // getSQL returns the SQL queries for the specified dialect.
-func getSQL(dialect sqlx.Dialect) queries {
+func getSQL(dialect sqlx.Dialect) *queries {
 	switch dialect {
 	case sqlx.DialectSqlite:
-		return sqlite
+		return &sqlite
 	case sqlx.DialectPostgres:
-		return postgres
+		return &postgres
 	default:
-		return queries{}
+		return &queries{}
 	}
 }

internal/rset/tx.go

@@ -41,7 +41,7 @@ type queries struct {
 type Tx struct {
 	dialect sqlx.Dialect
 	tx      sqlx.Tx
-	sql     queries
+	sql     *queries
 }
 
 // NewTx creates a set repository transaction
@@ -498,13 +498,13 @@ type ScanResult struct {
 }
 
 // getSQL returns the SQL queries for the specified dialect.
-func getSQL(dialect sqlx.Dialect) queries {
+func getSQL(dialect sqlx.Dialect) *queries {
 	switch dialect {
 	case sqlx.DialectSqlite:
-		return sqlite
+		return &sqlite
 	case sqlx.DialectPostgres:
-		return postgres
+		return &postgres
 	default:
-		return queries{}
+		return &queries{}
 	}
 }

internal/rstring/tx.go

@@ -22,7 +22,7 @@ type queries struct {
 type Tx struct {
 	dialect sqlx.Dialect
 	tx      sqlx.Tx
-	sql     queries
+	sql     *queries
 }
 
 // NewTx creates a string repository transaction
@@ -231,13 +231,13 @@ func (tx *Tx) update(key string, value any) error {
 }
 
 // getSQL returns the SQL queries for the specified dialect.
-func getSQL(dialect sqlx.Dialect) queries {
+func getSQL(dialect sqlx.Dialect) *queries {
 	switch dialect {
 	case sqlx.DialectSqlite:
-		return sqlite
+		return &sqlite
 	case sqlx.DialectPostgres:
-		return postgres
+		return &postgres
 	default:
-		return queries{}
+		return &queries{}
 	}
 }

internal/rzset/tx.go

@@ -42,7 +42,7 @@ type queries struct {
 type Tx struct {
 	dialect sqlx.Dialect
 	tx      sqlx.Tx
-	sql     queries
+	sql     *queries
 }
 
 // NewTx creates a sorted set repository transaction
@@ -401,13 +401,13 @@ type ScanResult struct {
 }
 
 // getSQL returns the SQL queries for the specified dialect.
-func getSQL(dialect sqlx.Dialect) queries {
+func getSQL(dialect sqlx.Dialect) *queries {
 	switch dialect {
 	case sqlx.DialectSqlite:
-		return sqlite
+		return &sqlite
 	case sqlx.DialectPostgres:
-		return postgres
+		return &postgres
 	default:
-		return queries{}
+		return &queries{}
 	}
 }