dbsql

Jul 31, 2024

Changes in this version

+ type ConnOption func(*config.Config)

May 28, 2024

Changes in this version

+ func WithSkipTLSHostVerify() connOption

Apr 30, 2024

Changes in this version

type SqlType

+ const SqlVoid

Oct 2, 2023

Changes in this version

+ func Succeeded(response *http.Response) bool

+ func WithClientCredentials(clientID, clientSecret string) connOption

+ type Parameter struct

+ Name string

+ Type SqlType

+ Value any

+ type SqlType int

+ const SqlBigInt

+ const SqlBoolean

+ const SqlDate

+ const SqlDecimal

+ const SqlDouble

+ const SqlFloat

+ const SqlInteger

+ const SqlIntervalDay

+ const SqlIntervalMonth

+ const SqlSmallInt

+ const SqlString

+ const SqlTimestamp

+ const SqlTinyInt

+ const SqlUnkown

+ func (s SqlType) String() string

Aug 8, 2023

Changes in this version

+ func WithCloudFetch(useCloudFetch bool) connOption

+ func WithMaxDownloadThreads(numThreads int) connOption

+ func WithTransport(t http.RoundTripper) connOption

Jun 7, 2023

Changes in this version

+ func WithAuthenticator(authr auth.Authenticator) connOption

Mar 7, 2023

Changes in this version

+ var DriverVersion = "1.1.0"

+ func WithRetries(retryMax int, retryWaitMin time.Duration, retryWaitMax time.Duration) connOption

Dec 5, 2022

Changes in this version

+ func NewRows(connID string, corrId string, client cli_service.TCLIService, ...) driver.Rows

Nov 19, 2022

Changes in this version

+ const DateFormat

+ const TimestampFormat

+ var ErrNotImplemented = "databricks: not implemented"

+ var ErrParametersNotSupported = "databricks: query parameters are not supported"

+ var ErrTransactionsNotSupported = "databricks: transactions are not supported"

+ func WithAccessToken(token string) connOption

+ func WithHTTPPath(path string) connOption

+ func WithInitialNamespace(catalog, schema string) connOption

+ func WithMaxRows(n int) connOption

+ func WithPort(port int) connOption

+ func WithServerHostname(host string) connOption

+ func WithSessionParams(params map[string]string) connOption

+ func WithTimeout(n time.Duration) connOption

+ func WithUserAgentEntry(entry string) connOption

Jun 16, 2022

Changes in this version

+ const TimeFmt

+ func EscapeArg(arg driver.NamedValue) (string, error)

May 19, 2022

Changes in this version

+ var DefaultOptions = Options

+ var ErrNotSupported = errors.New("databricks: not supported")

+ func NewConnector(opts *Options) driver.Connector

+ type Conn struct

+ func (c *Conn) Begin() (driver.Tx, error)

+ func (c *Conn) CheckNamedValue(val *driver.NamedValue) error

+ func (c *Conn) Close() error

+ func (c *Conn) ExecContext(ctx context.Context, q string, args []driver.NamedValue) (driver.Result, error)

+ func (c *Conn) OpenSession(ctx context.Context) (*hive.Session, error)

+ func (c *Conn) Ping(ctx context.Context) error

+ func (c *Conn) Prepare(query string) (driver.Stmt, error)

+ func (c *Conn) PrepareContext(ctx context.Context, query string) (driver.Stmt, error)

+ func (c *Conn) QueryContext(ctx context.Context, q string, args []driver.NamedValue) (driver.Rows, error)

+ func (c *Conn) ResetSession(ctx context.Context) error

+ type Driver struct

+ func (d *Driver) Open(uri string) (driver.Conn, error)

+ func (d *Driver) OpenConnector(name string) (driver.Connector, error)

+ type Options struct

+ HTTPPath string

+ Host string

+ LogOut io.Writer

+ MaxRows int64

+ Port string

+ Timeout int

+ Token string

+ type Rows struct

+ func (r *Rows) Close() error

+ func (r *Rows) ColumnTypeDatabaseTypeName(index int) string

+ func (r *Rows) ColumnTypeScanType(index int) reflect.Type

+ func (r *Rows) Columns() []string

+ func (r *Rows) Next(dest []driver.Value) error

+ type Stmt struct

+ func (s *Stmt) CheckNamedValue(val *driver.NamedValue) error

+ func (s *Stmt) Close() error

+ func (s *Stmt) Exec(args []driver.Value) (driver.Result, error)

+ func (s *Stmt) ExecContext(ctx context.Context, args []driver.NamedValue) (driver.Result, error)

+ func (s *Stmt) NumInput() int

+ func (s *Stmt) Query(args []driver.Value) (driver.Rows, error)

+ func (s *Stmt) QueryContext(ctx context.Context, args []driver.NamedValue) (driver.Rows, error)