Function Scan

internal/server/db/query/objects.go:35–51

Scan runs a query with inArgs and provides the rowFunc with the scan function for each row. It handles closing the rows and errors from the result set.

(ctx context.Context, tx *sql.Tx, query string, rowFunc Dest, inArgs ...any)

// Scan runs a query with inArgs and provides the rowFunc with the scan function for each row.
// It handles closing the rows and errors from the result set.
func Scan(ctx context.Context, tx *sql.Tx, query string, rowFunc Dest, inArgs ...any) error {
	rows, err := tx.QueryContext(ctx, query, inArgs...)
	if err != nil {
		return err
	}

	defer logger.WarnOnError(rows.Close, "Failed to close rows")

	for rows.Next() {
		err = rowFunc(rows.Scan)
		if err != nil {
			return err
		}
	}

	return rows.Err()
}

// Dest is a function that is expected to return the objects to pass to the
// 'dest' argument of sql.Rows.Scan(). It is invoked by SelectObjects once per