impala

Apr 4, 2025

Changes in this version

+ type AuthError = sasl.AuthError

+ type ColumnName = hive.ColumnName

type Metadata

+ func (m Metadata) GetColumns(ctx context.Context, schemaPattern string, tableNamePattern string, ...) ([]ColumnName, error)

Jan 13, 2025

Changes in this version

+ type ConnRawAccess interface

+ Raw func(func(driverConn any) error) error

type Metadata

+ func NewMetadataFromConn(conn ConnRawAccess) *Metadata

+ func (m Metadata) GetSchemas(ctx context.Context, schemaPattern string) ([]string, error)

+ type TableName = hive.TableName

Dec 29, 2024

Changes in this version

+ type Metadata struct

+ func NewMetadata(db *sql.DB) *Metadata

+ func (m Metadata) GetTables(ctx context.Context, schemaPattern string, tableNamePattern string) ([]hive.TableName, error)

Nov 24, 2024

Changes in this version

+ var DefaultOptions = Options

+ var ErrNotSupported = errors.New("impala: 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

+ BatchSize int

+ BufferSize int

+ CACertPath string

+ Host string

+ LogOut io.Writer

+ MemoryLimit string

+ Password string

+ Port string

+ QueryTimeout int

+ UseLDAP bool

+ UseTLS bool

+ Username 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)