-
-
Notifications
You must be signed in to change notification settings - Fork 212
Commit
This commit does not belong to any branch on this repository, and may belong to a fork outside of the repository.
Merge pull request #383 from MichaelS11/cursor
Added ref cursor sub query
- Loading branch information
Showing
7 changed files
with
256 additions
and
31 deletions.
There are no files selected for viewing
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
| Original file line number | Diff line number | Diff line change |
|---|---|---|
| @@ -0,0 +1,149 @@ | ||
| // +build go1.12 | ||
|
|
||
| package oci8 | ||
|
|
||
| import ( | ||
| "context" | ||
| "database/sql" | ||
| "testing" | ||
| ) | ||
|
|
||
| // TestDestructiveNumberCursor checks select cursor | ||
| func TestDestructiveNumberCursor(t *testing.T) { | ||
| if TestDisableDatabase || TestDisableDestructive { | ||
| t.SkipNow() | ||
| } | ||
|
|
||
| tableName := "number_cursor_" + TestTimeString | ||
| err := testExec(t, "create table "+tableName+" ( A INTEGER )", nil) | ||
| if err != nil { | ||
| t.Fatal("create table error:", err) | ||
| } | ||
|
|
||
| defer testDropTable(t, tableName) | ||
|
|
||
| testDestructiveNumberCursorInsert(t, tableName) | ||
|
|
||
| testDestructiveNumberCursorSelect(t, tableName) | ||
| } | ||
|
|
||
| func testDestructiveNumberCursorInsert(t *testing.T, tableName string) { | ||
| ctx, cancel := context.WithTimeout(context.Background(), TestContextTimeout) | ||
| stmt, err := TestDB.PrepareContext(ctx, "insert into "+tableName+" ( A ) values (:1)") | ||
| cancel() | ||
| if err != nil { | ||
| t.Fatal("prepare error:", err) | ||
| } | ||
|
|
||
| defer func() { | ||
| err = stmt.Close() | ||
| if err != nil { | ||
| if t.Failed() { | ||
| t.Logf("stmt close error: %v", err) | ||
| } else { | ||
| t.Fatal("stmt close error:", err) | ||
| } | ||
| } | ||
| }() | ||
|
|
||
| ctx, cancel = context.WithTimeout(context.Background(), TestContextTimeout) | ||
| _, err = stmt.ExecContext(ctx, 1) | ||
| cancel() | ||
| if err != nil { | ||
| t.Fatal("exec error:", err) | ||
| } | ||
|
|
||
| ctx, cancel = context.WithTimeout(context.Background(), TestContextTimeout) | ||
| _, err = stmt.ExecContext(ctx, 2) | ||
| cancel() | ||
| if err != nil { | ||
| stmt.Close() | ||
| t.Fatal("exec error:", err) | ||
| } | ||
| } | ||
|
|
||
| func testDestructiveNumberCursorSelect(t *testing.T, tableName string) { | ||
| ctx, cancel := context.WithTimeout(context.Background(), TestContextTimeout) | ||
| stmt, err := TestDB.PrepareContext(ctx, "select 1.5, cursor(select A from "+tableName+" order by A) from dual") | ||
| cancel() | ||
| if err != nil { | ||
| t.Fatal("prepare error:", err) | ||
| } | ||
|
|
||
| defer func() { | ||
| err = stmt.Close() | ||
| if err != nil { | ||
| if t.Failed() { | ||
| t.Logf("stmt close err: %v", err) | ||
| } else { | ||
| t.Fatal("stmt close error:", err) | ||
| } | ||
| } | ||
| }() | ||
|
|
||
| var rows *sql.Rows | ||
| ctx, cancel = context.WithTimeout(context.Background(), TestContextTimeout) | ||
| rows, err = stmt.QueryContext(ctx) | ||
| if err != nil { | ||
| cancel() | ||
| t.Fatal("query error:", err) | ||
| } | ||
|
|
||
| defer func() { | ||
| cancel() | ||
| err = rows.Close() | ||
| if err != nil { | ||
| if t.Failed() { | ||
| t.Logf("rows close error: %v", err) | ||
| } else { | ||
| t.Fatal("rows close error:", err) | ||
| } | ||
| } | ||
| }() | ||
|
|
||
| if !rows.Next() { | ||
| t.Fatal("expected row") | ||
| } | ||
|
|
||
| var float float64 | ||
| var subRows *sql.Rows | ||
| err = rows.Scan(&float, &subRows) | ||
| if err != nil { | ||
| t.Fatal("scan error:", err) | ||
| } | ||
|
|
||
| if float != 1.5 { | ||
| t.Fatal("float != 1.5") | ||
| } | ||
|
|
||
| if subRows == nil { | ||
| t.Fatal("subRows is nil") | ||
| } | ||
|
|
||
| if !subRows.Next() { | ||
| t.Fatal("expected row") | ||
| } | ||
|
|
||
| var aInt int64 | ||
| err = subRows.Scan(&aInt) | ||
| if err != nil { | ||
| t.Fatal("scan error:", err) | ||
| } | ||
|
|
||
| if aInt != 1 { | ||
| t.Fatal("aInt != 1") | ||
| } | ||
|
|
||
| if !subRows.Next() { | ||
| t.Fatal("expected row") | ||
| } | ||
|
|
||
| err = subRows.Scan(&aInt) | ||
| if err != nil { | ||
| t.Fatal("scan error:", err) | ||
| } | ||
|
|
||
| if aInt != 2 { | ||
| t.Fatal("aInt != 2") | ||
| } | ||
| } |
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters