oh...

James Cor · James Cor · commit aaa30654d7ac · 2025-10-15T15:56:35.000-07:00
diff --git a/sql/table_iter.go b/sql/table_iter.go
@@ -175,6 +175,7 @@ func (i *TableRowIter) NextRowFrame(ctx *Context, rowFrame *RowFrame) error {
 		}
 		i.rows2 = rows.(RowIter2)
 	}
+
 	rows, ok := i.rows2.(RowFrameIter)
 	if !ok {
 		panic(fmt.Sprintf("%T does not implement sql.RowFrameIter", i.rows))
@@ -189,7 +190,7 @@ func (i *TableRowIter) NextRowFrame(ctx *Context, rowFrame *RowFrame) error {
 		i.rows2 = nil
 		err = i.NextRowFrame(ctx, rowFrame)
 	}
-	return nil
+	return err
 }
 
 func (i *TableRowIter) Close(ctx *Context) error {

Original file line number	Diff line number	Diff line change
`@@ -175,6 +175,7 @@ func (i TableRowIter) NextRowFrame(ctx Context, rowFrame *RowFrame) error {`
`175`	`175`	`}`
`176`	`176`	`i.rows2 = rows.(RowIter2)`
`177`	`177`	`}`
	`178`	`+`
`178`	`179`	`rows, ok := i.rows2.(RowFrameIter)`
`179`	`180`	`if !ok {`
`180`	`181`	`panic(fmt.Sprintf("%T does not implement sql.RowFrameIter", i.rows))`
`@@ -189,7 +190,7 @@ func (i TableRowIter) NextRowFrame(ctx Context, rowFrame *RowFrame) error {`
`189`	`190`	`i.rows2 = nil`
`190`	`191`	`err = i.NextRowFrame(ctx, rowFrame)`
`191`	`192`	`}`
`192`		`- return nil`
	`193`	`+ return err`
`193`	`194`	`}`
`194`	`195`
`195`	`196`	`func (i TableRowIter) Close(ctx Context) error {`