Expose internal jet.Rows type

internal/jet/statement.go

@@ -30,7 +30,7 @@ type Statement interface {
 	Rows(ctx context.Context, db qrm.Queryable) (*Rows, error)
 }
 
-// Rows wraps sql.Rows type to add query result mapping for Scan method
+// Rows wraps sql.Rows type with a support for query result mapping
 type Rows struct {
 	*sql.Rows
 

mysql/types.go

@@ -5,6 +5,9 @@ import "github.com/go-jet/jet/v2/internal/jet"
 // Statement is common interface for all statements(SELECT, INSERT, UPDATE, DELETE, LOCK)
 type Statement = jet.Statement
 
+// Rows wraps sql.Rows type with a support for query result mapping
+type Rows = jet.Rows
+
 // Projection is interface for all projection types. Types that can be part of, for instance SELECT clause.
 type Projection = jet.Projection
 

postgres/types.go

@@ -5,6 +5,9 @@ import "github.com/go-jet/jet/v2/internal/jet"
 // Statement is common interface for all statements(SELECT, INSERT, UPDATE, DELETE, LOCK)
 type Statement = jet.Statement
 
+// Rows wraps sql.Rows type with a support for query result mapping
+type Rows = jet.Rows
+
 // Projection is interface for all projection types. Types that can be part of, for instance SELECT clause.
 type Projection = jet.Projection
 

sqlite/types.go

@@ -5,6 +5,9 @@ import "github.com/go-jet/jet/v2/internal/jet"
 // Statement is common interface for all statements(SELECT, INSERT, UPDATE, DELETE, LOCK)
 type Statement = jet.Statement
 
+// Rows wraps sql.Rows type with a support for query result mapping
+type Rows = jet.Rows
+
 // Projection is interface for all projection types. Types that can be part of, for instance SELECT clause.
 type Projection = jet.Projection
 

tests/mysql/raw_statement_test.go

@@ -92,7 +92,10 @@ func TestRawStatementRows(t *testing.T) {
 		FROM dvds.actor
 		ORDER BY actor.actor_id`)
 
-	rows, err := stmt.Rows(context.Background(), db)
+	var rows *Rows
+	var err error
+
+	rows, err = stmt.Rows(context.Background(), db)
 	require.NoError(t, err)
 
 	for rows.Next() {

tests/postgres/raw_statements_test.go

@@ -149,7 +149,10 @@ func TestRawStatementRows(t *testing.T) {
 		FROM dvds.actor
 		ORDER BY actor.actor_id`)
 
-	rows, err := stmt.Rows(context.Background(), db)
+	var rows *Rows
+	var err error
+
+	rows, err = stmt.Rows(context.Background(), db)
 	require.NoError(t, err)
 
 	for rows.Next() {

tests/sqlite/raw_statement_test.go

@@ -90,7 +90,10 @@ func TestRawStatementRows(t *testing.T) {
 		FROM actor
 		ORDER BY actor.actor_id`)
 
-	rows, err := stmt.Rows(context.Background(), db)
+	var rows *Rows
+	var err error
+
+	rows, err = stmt.Rows(context.Background(), db)
 	require.NoError(t, err)
 
 	for rows.Next() {