import (
	"context"
	"database/sql"
	"testing"
	"time"

	_ "gopkg.in/goracle.v2"
)

func TestCursor(t *testing.T) {
	cn := "user/pass@hostname:port/instance"
	db, err := sql.Open("goracle", cn)
	defer db.Close()

	ctx, cancel := context.WithTimeout(context.Background(), time.Second*30)
	defer cancel()

	db.ExecContext(ctx, `drop table TestQuery`)

	defer db.ExecContext(ctx, `drop table TestQuery`)
	_, err = db.ExecContext(ctx, `
create table TestQuery (
	IntCol number(9) not null,
	StringCol varchar2(30) not null
);
begin
	for i in 1..10 loop
		insert into TestQuery values (power(3, i), '3 ^ ' || to_char(i));
	end loop;
	commit;
end;
	`)
	if err != nil {
		t.Fatal(err)
	}

	rows, err := db.QueryContext(ctx, `
select cursor(select * from TestQuery) from dual`)
	if err != nil {
		t.Fatal(err)
	}
	defer rows.Close()

	if !rows.Next() {
		t.Fatal("no rows")
	}
	var cursor = &sql.Rows{}
	err = rows.Scan(cursor)
	if err != nil {
		t.Fatal(err)
	}
	defer cursor.Close()

	var n int64
	var s string
	for cursor.Next() {
		err = cursor.Scan(&n, &s)
		if err != nil {
			t.Fatal(err)
		}
		t.Log(n, s)
	}

}