release 0.109.1

RELEASENOTES.md

@@ -3,6 +3,10 @@ Release Notes
 
 ## Release 0.109
 
+Release 0.109.1 (upgrade urgency: no need for upgrade)
+
+- Some minor source code cleanups
+
 #### Release Notes
 
 - Moved prometheus collector from ./driver/prometheus to ./prometheus (incompatible change)

driver/connector.go

@@ -18,7 +18,8 @@ type Connector struct {
 	*connAttrs
 	*authAttrs
 
-	newConn func(ctx context.Context, connAttrs *connAttrs, authAttrs *authAttrs) (driver.Conn, error)
+	connHook func(driver.Conn) driver.Conn
+	newConn  func(ctx context.Context, connAttrs *connAttrs, authAttrs *authAttrs) (driver.Conn, error)
 }
 
 // NewConnector returns a new Connector instance with default values.
@@ -35,18 +36,18 @@ func NewConnector() *Connector {
 // NewBasicAuthConnector creates a connector for basic authentication.
 func NewBasicAuthConnector(host, username, password string) *Connector {
 	c := NewConnector()
-	c.connAttrs._host = host
-	c.authAttrs._username = username
-	c.authAttrs._password = password
+	c._host = host
+	c._username = username
+	c._password = password
 	return c
 }
 
 // NewX509AuthConnector creates a connector for X509 (client certificate) authentication.
 func NewX509AuthConnector(host string, clientCert, clientKey []byte) *Connector {
 	c := NewConnector()
-	c.connAttrs._host = host
-	c.authAttrs._clientCert = clientCert
-	c.authAttrs._clientKey = clientKey
+	c._host = host
+	c._clientCert = clientCert
+	c._clientKey = clientKey
 	return c
 }
 
@@ -67,24 +68,24 @@ func NewX509AuthConnectorByFiles(host, clientCertFile, clientKeyFile string) (*C
 // NewJWTAuthConnector creates a connector for token (JWT) based authentication.
 func NewJWTAuthConnector(host, token string) *Connector {
 	c := NewConnector()
-	c.connAttrs._host = host
-	c.authAttrs._token = token
+	c._host = host
+	c._token = token
 	return c
 }
 
 func newDSNConnector(dsn *DSN) (*Connector, error) {
 	c := NewConnector()
-	c.connAttrs._host = dsn.host
-	c.connAttrs._pingInterval = dsn.pingInterval
-	c.connAttrs._defaultSchema = dsn.defaultSchema
-	c.connAttrs.setTimeout(dsn.timeout)
+	c._host = dsn.host
+	c._pingInterval = dsn.pingInterval
+	c._defaultSchema = dsn.defaultSchema
+	c.setTimeout(dsn.timeout)
 	if dsn.tls != nil {
 		if err := c.connAttrs.setTLS(dsn.tls.ServerName, dsn.tls.InsecureSkipVerify, dsn.tls.RootCAFiles); err != nil {
 			return nil, err
 		}
 	}
-	c.authAttrs._username = dsn.username
-	c.authAttrs._password = dsn.password
+	c._username = dsn.username
+	c._password = dsn.password
 	return c, nil
 }
 
@@ -102,8 +103,19 @@ func (c *Connector) NativeDriver() Driver { return stdHdbDriver }
 
 // Connect implements the database/sql/driver/Connector interface.
 func (c *Connector) Connect(ctx context.Context) (driver.Conn, error) {
-	return c.newConn(ctx, c.connAttrs.clone(), c.authAttrs)
+	conn, err := c.newConn(ctx, c.connAttrs.clone(), c.authAttrs)
+	if err != nil {
+		return nil, err
+	}
+	if c.connHook != nil {
+		conn = c.connHook(conn)
+	}
+	return conn, err
 }
 
 // Driver implements the database/sql/driver/Connector interface.
 func (c *Connector) Driver() driver.Driver { return stdHdbDriver }
+
+// SetConnHook sets a function for intercepting connection creation.
+// This is for internal use only and might be changed or disabled in future.
+func (c *Connector) SetConnHook(fn func(driver.Conn) driver.Conn) { c.connHook = fn }

driver/driver.go

@@ -14,7 +14,7 @@ import (
 )
 
 // DriverVersion is the version number of the hdb driver.
-const DriverVersion = "0.109.0"
+const DriverVersion = "0.109.1"
 
 // DriverName is the driver name to use with sql.Open for hdb databases.
 const DriverName = "hdb"