chdbdriver

Documentation

Index

• func NewConnect(opts map[string]string) (ret *connector, err error)
• type Driver
  • func (d Driver) Open(name string) (driver.Conn, error)
  • func (d Driver) OpenConnector(name string) (driver.Connector, error)
• type DriverType
  • func (d DriverType) GetFormat() string
  • func (d DriverType) PrepareRows(result chdbpurego.ChdbResult, buf []byte, bufSize int, useUnsafe bool) (driver.Rows, error)
  • func (d DriverType) PrepareStreamingRows(result chdbpurego.ChdbStreamResult, bufSize int, useUnsafe bool) (driver.Rows, error)
  • func (d DriverType) String() string
  • func (d DriverType) SupportStreaming() bool

Functions

func NewConnect

func NewConnect(opts map[string]string) (ret *connector, err error)

Types

type Driver

type Driver struct{}

func (Driver) Open

func (d Driver) Open(name string) (driver.Conn, error)

Open returns a new connection to the database.

func (Driver) OpenConnector

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

OpenConnector expects the same format as driver.Open

type DriverType

type DriverType int

const (
	ARROW DriverType = iota
	PARQUET
	PARQUET_STREAMING
	INVALID
)

func (DriverType) GetFormat

func (d DriverType) GetFormat() string

func (DriverType) PrepareRows

func (d DriverType) PrepareRows(result chdbpurego.ChdbResult, buf []byte, bufSize int, useUnsafe bool) (driver.Rows, error)

func (DriverType) PrepareStreamingRows

func (d DriverType) PrepareStreamingRows(result chdbpurego.ChdbStreamResult, bufSize int, useUnsafe bool) (driver.Rows, error)

func (DriverType) String

func (d DriverType) String() string

func (DriverType) SupportStreaming

func (d DriverType) SupportStreaming() bool