This is an automated email from the ASF dual-hosted git repository. francischuang pushed a commit to branch main in repository https://gitbox.apache.org/repos/asf/calcite-avatica-go.git
commit bf6ec6716757ff4eb3da6ddcfa850ca94351ae98 Author: Parag Jain <[email protected]> AuthorDate: Mon Jun 5 19:14:19 2023 +0530 [CALCITE-5753] Propagate user and pwd to connection info --- driver.go | 17 +++++++++++++---- 1 file changed, 13 insertions(+), 4 deletions(-) diff --git a/driver.go b/driver.go index 4a2d342..fff05e1 100644 --- a/driver.go +++ b/driver.go @@ -18,14 +18,14 @@ /* Package avatica provides an Apache Phoenix Query Server/Avatica driver for Go's database/sql package. -Quickstart +# Quickstart Import the database/sql package along with the avatica driver. - import "database/sql" - import _ "github.com/apache/calcite-avatica-go/v5" + import "database/sql" + import _ "github.com/apache/calcite-avatica-go/v5" - db, err := sql.Open("avatica", "http://phoenix-query-server:8765";) + db, err := sql.Open("avatica", "http://phoenix-query-server:8765";) See https://calcite.apache.org/avatica/docs/go_client_reference.html for more details */ @@ -68,6 +68,15 @@ func (c *Connector) Connect(context.Context) (driver.Conn, error) { if err != nil { return nil, fmt.Errorf("unable to open connection: %w", err) } + + // propagate user and password to connector info so that it's available in JDBC context for example + if config.avaticaUser != "" { + c.Info["user"] = config.avaticaUser + } + if config.avaticaPassword != "" { + c.Info["password"] = config.avaticaPassword + } + connectionId, err := uuid.GenerateUUID() if err != nil { return nil, fmt.Errorf("error generating connection id: %w", err)
