feat: added Query and QueryWithCtx functions to pgxpool Service interface and implementation

Author: ralvarezdev

sql/pgxpool/service.go

@@ -24,6 +24,12 @@ type (
 			query *string,
 			params ...interface{},
 		) (*pgconn.CommandTag, error)
+		Query(query *string, params ...interface{}) (pgx.Rows, error)
+		QueryWithCtx(
+			ctx context.Context,
+			query *string,
+			params ...interface{},
+		) (pgx.Rows, error)
 		QueryRow(query *string, params ...interface{}) pgx.Row
 		QueryRowWithCtx(
 			ctx context.Context,
@@ -143,6 +149,29 @@ func (d *DefaultService) QueryRowWithCtx(
 	return d.pool.QueryRow(ctx, *query, params...)
 }
 
+// QueryWithCtx runs a query with parameters and returns the result with a context
+func (d *DefaultService) QueryWithCtx(
+	ctx context.Context,
+	query *string,
+	params ...interface{},
+) (pgx.Rows, error) {
+	// Check if the query is nil
+	if query == nil {
+		return nil, godatabases.ErrNilQuery
+	}
+
+	// Run the query
+	return d.pool.Query(ctx, *query, params...)
+}
+
+// Query runs a query with parameters and returns the result
+func (d *DefaultService) Query(
+	query *string,
+	params ...interface{},
+) (pgx.Rows, error) {
+	return d.QueryWithCtx(context.Background(), query, params...)
+}
+
 // QueryRow runs a query row with parameters and returns the result row
 func (d *DefaultService) QueryRow(
 	query *string,