Pass context correctly

Makefile

@@ -10,10 +10,10 @@ lint:
 	golangci-lint run --print-issued-lines=false ./...
 
 test:
-	go test -v -coverprofile=coverage.out ./...
+	go test -count 1 -v -p 1 -coverprofile=coverage.out ./...
 
 testshort:
-	go test -v -short -coverprofile=coverage.out ./...
+	go test -count 1 -v -short -coverprofile=coverage.out ./...
 
 coverage: test
 	go tool cover -html=coverage.out -o coverage.html

doc/changes/changes_1.0.9.md

@@ -1,10 +1,24 @@
-# Exasol Driver go 1.0.9, released 2024-??-??
+# Exasol Driver go 1.0.9, released 2024-06-27
 
-Code name:
+Code name: Fix reading int values
 
 ## Summary
 
-## Features
+This release fixes an issue when calling `rows.Scan(&result)` with an int value. This failed for large values like 100000000 with the following error:
 
-* ISSUE_NUMBER: description
+```
+sql: Scan error on column index 0, name "COL": converting driver.Value type float64 ("1e+08") to a int64: invalid syntax
+```
 
+Please note that reading non-integer numbers like `1.1` into a `int64` variable will still fail with the following error message:
+
+```
+sql: Scan error on column index 0, name "COL": converting driver.Value type string ("1.1") to a int64: invalid syntax
+```
+
+The release also now returns the correct error from `rows.Err()`. Before, this only returned `driver.ErrBadConn`.
+
+## Bugfixes
+
+* #113: Fixed `Scan()` with large integer numbers
+* #111: Return correct error from `rows.Err()`

go.mod

@@ -18,5 +18,4 @@ require (
 	github.com/pmezard/go-difflib v1.0.0 // indirect
 	github.com/rogpeppe/go-internal v1.12.0 // indirect
 	github.com/stretchr/objx v0.5.2 // indirect
-	golang.org/x/net v0.26.0 // indirect
 )

pkg/connection/connection.go

@@ -47,11 +47,11 @@ func (c *Connection) ExecContext(ctx context.Context, query string, args []drive
 }
 
 func (c *Connection) Exec(query string, args []driver.Value) (driver.Result, error) {
-	return c.exec(context.Background(), query, args)
+	return c.exec(c.Ctx, query, args)
 }
 
 func (c *Connection) Query(query string, args []driver.Value) (driver.Rows, error) {
-	return c.query(context.Background(), query, args)
+	return c.query(c.Ctx, query, args)
 }
 
 func (c *Connection) PrepareContext(ctx context.Context, query string) (driver.Stmt, error) {
@@ -64,7 +64,7 @@ func (c *Connection) PrepareContext(ctx context.Context, query string) (driver.S
 	if err != nil {
 		return nil, err
 	}
-	return c.createStatement(response), nil
+	return c.createStatement(ctx, response), nil
 }
 
 func (c *Connection) createPreparedStatement(ctx context.Context, query string) (*types.CreatePreparedStatementResponse, error) {
@@ -82,16 +82,22 @@ func (c *Connection) createPreparedStatement(ctx context.Context, query string)
 	return response, nil
 }
 
-func (c *Connection) createStatement(result *types.CreatePreparedStatementResponse) *Statement {
-	return NewStatement(c, result)
+func (c *Connection) createStatement(ctx context.Context, result *types.CreatePreparedStatementResponse) *Statement {
+	return NewStatement(ctx, c, result)
+}
+
+func (c *Connection) Ping(ctx context.Context) error {
+	fmt.Printf("Ping\n")
+	// FIXME
+	return nil
 }
 
 func (c *Connection) Prepare(query string) (driver.Stmt, error) {
-	return c.PrepareContext(context.Background(), query)
+	return c.PrepareContext(c.Ctx, query)
 }
 
 func (c *Connection) Close() error {
-	return c.close(context.Background())
+	return c.close(c.Ctx)
 }
 
 func (c *Connection) Begin() (driver.Tx, error) {
@@ -102,7 +108,7 @@ func (c *Connection) Begin() (driver.Tx, error) {
 	if c.Config.Autocommit {
 		return nil, errors.ErrAutocommitEnabled
 	}
-	return NewTransaction(c), nil
+	return NewTransaction(c.Ctx, c), nil
 }
 
 func (c *Connection) query(ctx context.Context, query string, args []driver.Value) (driver.Rows, error) {
@@ -125,15 +131,15 @@ func (c *Connection) query(ctx context.Context, query string, args []driver.Valu
 	if err != nil {
 		return nil, err
 	}
-	return ToRow(result, c)
+	return ToRow(ctx, result, c)
 }
 
 func (c *Connection) executeSimpleWithRows(ctx context.Context, query string) (driver.Rows, error) {
 	result, err := c.SimpleExec(ctx, query)
 	if err != nil {
 		return nil, err
 	}
-	return ToRow(result, c)
+	return ToRow(ctx, result, c)
 }
 
 func (c *Connection) executePreparedStatement(ctx context.Context, s *types.CreatePreparedStatementResponse, args []driver.Value) (*types.SqlQueriesResponse, error) {