feat: added database/sql RunQueriesConcurrently function

Author: ralvarezdev

mongodb/transactions.go renamed to mongodb/transaction.go

@@ -49,6 +49,8 @@ func Connect(
 	// Set the maximum idle connections
 	db.SetMaxIdleConns(config.MaxIdleConnections)
 
+	db.Set
+
 	// Set the connection max lifetime
 	db.SetConnMaxLifetime(config.ConnectionMaxLifetime)
 

sql/connection.go

@@ -0,0 +1,57 @@
+package sql
+
+import (
+	"context"
+	"database/sql"
+	"sync"
+)
+
+// RunQueriesConcurrently runs multiple queries concurrently
+func RunQueriesConcurrently(
+	db *sql.DB,
+	queries ...func(db *sql.DB, ctx context.Context) error,
+) *[]error {
+	// Create a context with a cancellation function
+	ctx, cancel := context.WithCancel(context.Background())
+	defer cancel()
+
+	// Create a wait group
+	var wg sync.WaitGroup
+	wg.Add(len(queries))
+
+	// Create a channel to handle errors
+	errCh := make(chan error)
+
+	// Execute the queries concurrently
+	for _, query := range queries {
+		go func(query func(db *sql.DB, ctx context.Context) error) {
+			defer wg.Done()
+			if err := query(db, ctx); err != nil {
+				// Send the error to the channel
+				errCh <- err
+
+				// Cancel the other queries
+				cancel()
+			}
+		}(query)
+	}
+
+	// Wait for all queries to complete
+	wg.Wait()
+
+	// Close the error channel
+	close(errCh)
+
+	// Return the errors if any
+	var errors []error
+	for err := range errCh {
+		errors = append(errors, err)
+	}
+
+	// Check if there are any errors
+	if len(errors) == 0 {
+		return nil
+	}
+
+	return &errors
+}

sql/queries.go

@@ -1,9 +1,11 @@
 package service
 
 import (
+	"context"
 	"database/sql"
 	godatabases "github.com/ralvarezdev/go-databases"
 	godatabasessql "github.com/ralvarezdev/go-databases/sql"
+	godatabasessqltransaction "github.com/ralvarezdev/go-databases/sql/transaction"
 	"strings"
 )
 
@@ -34,7 +36,7 @@ func NewDefaultService(db *sql.DB) (
 		return nil, godatabases.ErrNilDatabase
 	}
 
-	// Create the instance
+	// CreateTransaction the instance
 	instance = &DefaultService{
 		db: db,
 	}
@@ -70,6 +72,13 @@ func (d *DefaultService) RunTransaction(fn func(tx *sql.Tx) error) error {
 	return godatabasessql.CreateTransaction(d.db, fn)
 }
 
+// RunQueriesConcurrently runs queries concurrently
+func (d *DefaultService) RunQueriesConcurrently(
+	queries ...func(db *sql.DB, ctx context.Context) error,
+) *[]error {
+	return godatabasessql.RunQueriesConcurrently(d.db, queries...)
+}
+
 // Exec executes a query with parameters and returns the result
 func (d *DefaultService) Exec(query *string, params ...interface{}) (
 	sql.Result,

sql/service/service.go

@@ -19,8 +19,7 @@ func CreateTransaction(db *sql.DB, fn func(tx *sql.Tx) error) error {
 	}
 
 	// Execute the transaction function
-	fnErr := fn(tx)
-	if fnErr != nil {
+	if fnErr := fn(tx); fnErr != nil {
 		err = tx.Rollback()
 		if err != nil {
 			return err