Named parameter support and update Thrift

Updated thrift client code to latest version.
Added support for named query parameters.

Signed-off-by: Raymond Cypher <raymond.cypher@databricks.com>

Author: rcypher-databricks

connection.go

@@ -3,6 +3,7 @@ package dbsql
 import (
 	"context"
 	"database/sql/driver"
+	"fmt"
 	"time"
 
 	"github.com/databricks/databricks-sql-go/driverctx"
@@ -100,9 +101,6 @@ func (c *conn) ExecContext(ctx context.Context, query string, args []driver.Name
 	defer log.Duration(msg, start)
 
 	ctx = driverctx.NewContextWithConnId(ctx, c.id)
-	if len(args) > 0 {
-		return nil, dbsqlerrint.NewDriverError(ctx, dbsqlerr.ErrParametersNotSupported, nil)
-	}
 	exStmtResp, opStatusResp, err := c.runQuery(ctx, query, args)
 
 	if exStmtResp != nil && exStmtResp.OperationHandle != nil {
@@ -142,9 +140,7 @@ func (c *conn) QueryContext(ctx context.Context, query string, args []driver.Nam
 	msg, start := log.Track("QueryContext")
 
 	ctx = driverctx.NewContextWithConnId(ctx, c.id)
-	if len(args) > 0 {
-		return nil, dbsqlerrint.NewDriverError(ctx, dbsqlerr.ErrParametersNotSupported, nil)
-	}
+
 	// first we try to get the results synchronously.
 	// at any point in time that the context is done we must cancel and return
 	exStmtResp, opStatusResp, err := c.runQuery(ctx, query, args)
@@ -284,6 +280,7 @@ func (c *conn) executeStatement(ctx context.Context, query string, args []driver
 			MaxRows: int64(c.cfg.MaxRows),
 		},
 		CanDecompressLZ4Result_: &c.cfg.UseLz4Compression,
+		Parameters:              namedValuesToTSparkParams(args),
 	}
 
 	if c.cfg.UseArrowBatches {
@@ -337,6 +334,83 @@ func (c *conn) executeStatement(ctx context.Context, query string, args []driver
 	return resp, err
 }
 
+func namedValuesToTSparkParams(args []driver.NamedValue) []*cli_service.TSparkParameter {
+	var ts []string = []string{"STRING", "DOUBLE", "BOOLEAN"}
+	var params []*cli_service.TSparkParameter
+	for i := range args {
+		arg := args[i]
+		param := cli_service.TSparkParameter{Value: &cli_service.TSparkParameterValue{}}
+		if arg.Name != "" {
+			param.Name = &arg.Name
+		} else {
+			i := int32(arg.Ordinal)
+			param.Ordinal = &i
+		}
+
+		switch t := arg.Value.(type) {
+		case bool:
+			b := arg.Value.(bool)
+			param.Value.BooleanValue = &b
+			param.Type = &ts[2]
+		case string:
+			s := arg.Value.(string)
+			param.Value.StringValue = &s
+			param.Type = &ts[0]
+		case int:
+			f := float64(t)
+			param.Value.DoubleValue = &f
+			param.Type = &ts[1]
+		case uint:
+			f := float64(t)
+			param.Value.DoubleValue = &f
+			param.Type = &ts[1]
+		case int8:
+			f := float64(t)
+			param.Value.DoubleValue = &f
+			param.Type = &ts[1]
+		case uint8:
+			f := float64(t)
+			param.Value.DoubleValue = &f
+			param.Type = &ts[1]
+		case int16:
+			f := float64(t)
+			param.Value.DoubleValue = &f
+			param.Type = &ts[1]
+		case uint16:
+			f := float64(t)
+			param.Value.DoubleValue = &f
+			param.Type = &ts[1]
+		case int32:
+			f := float64(t)
+			param.Value.DoubleValue = &f
+			param.Type = &ts[1]
+		case uint32:
+			f := float64(t)
+			param.Value.DoubleValue = &f
+			param.Type = &ts[1]
+		case int64:
+			f := float64(t)
+			param.Value.DoubleValue = &f
+			param.Type = &ts[1]
+		case uint64:
+			f := float64(t)
+			param.Value.DoubleValue = &f
+			param.Type = &ts[1]
+		case float32:
+			f := float64(t)
+			param.Value.DoubleValue = &f
+			param.Type = &ts[1]
+		default:
+			s := fmt.Sprintf("%s", arg.Value)
+			param.Value.StringValue = &s
+			param.Type = &ts[0]
+		}
+
+		params = append(params, &param)
+	}
+	return params
+}
+
 func (c *conn) pollOperation(ctx context.Context, opHandle *cli_service.TOperationHandle) (*cli_service.TGetOperationStatusResp, error) {
 	corrId := driverctx.CorrelationIdFromContext(ctx)
 	log := logger.WithContext(c.id, corrId, client.SprintGuid(opHandle.OperationId.GUID))