godatabend

Nov 20, 2023

Changes in this version

+ const ContextKeyQueryID

+ const DatabendQueryIDHeader

+ type QueryIDGenerator func() string

+ type SessionState struct

+ Database string

+ Role string

+ SecondaryRoles *[]string

+ Settings map[string]string

Nov 6, 2023

Changes in this version

type Config

+ Role string

type SessionConfig

+ Role string

Nov 2, 2023

Changes in this version

type APIClient

+ func (c *APIClient) KillQuery(ctx context.Context, killURI string) error

type Config

+ StatsTracker QueryStatsTracker

+ type QueryStatsTracker func(queryID string, stats *QueryStats)

Jul 31, 2023

Changes in this version

+ const UserAgent

Mar 16, 2023

Changes in this version

type QueryResponse

+ Session *SessionConfig

Mar 13, 2023

Changes in this version

+ var ErrDoRequest = errors.New("DoReqeustFailed")

+ var ErrReadResponse = errors.New("ReadResponseFailed")

Mar 3, 2023

Changes in this version

type APIClient

+ AccessTokenLoader AccessTokenLoader

+ Cli *http.Client

+ Database string

+ MaxRowsInBuffer int64

+ MaxRowsPerPage int64

+ WaitTimeSeconds int64

+ func (c *APIClient) GetPresignedURL(stage *StageLocation) (*PresignedResponse, error)

+ func (c *APIClient) UploadToStageByAPI(stage *StageLocation, input *bufio.Reader, size int64) error

+ func (c *APIClient) WaitForQuery(result *QueryResponse) (*QueryResponse, error)

Feb 23, 2023

Changes in this version

type QueryResponse

+ ID string

+ KillURI string

+ SessionID string

type QueryStats

+ ResultProgress QueryProgress

+ WriteProgress QueryProgress

Feb 22, 2023

Changes in this version

+ type CopyOptions struct

+ Purge bool

+ func NewDefaultCopyOptions() *CopyOptions

+ func (o *CopyOptions) ToMap() map[string]string

+ type FileFormatOptions struct

+ FieldDelimiter string

+ RecordDelimiter string

+ SkipHeader int

+ Type string

+ func NewDefaultCSVFormatOptions() *FileFormatOptions

+ func (o *FileFormatOptions) ToMap() map[string]string

+ type StageLocation struct

+ Name string

+ Path string

+ func (sl *StageLocation) String() string

Feb 22, 2023

Changes in this version

type APIClient

+ func (c *APIClient) InsertWithStage(tableSchema, stagePath string) (*QueryResponse, error)

+ func (c *APIClient) QuerySingle(query string, args []driver.Value) (*QueryResponse, error)

+ func (c *APIClient) UploadToStage(stage string, input *bufio.Reader, size int64) error

+ type PresignedResponse struct

+ Headers map[string]string

+ Method string

+ URL string

type QueryRequest

+ StageAttachment *StageAttachmentConfig

+ type StageAttachmentConfig struct

+ CopyOptions map[string]string

+ FileFormatOptions map[string]string

+ Location string

Feb 12, 2023

Changes in this version

+ type AccessTokenLoader interface

+ LoadAccessToken func(ctx context.Context, forceRotate bool) (string, error)

+ type AuthMethod string

+ const AuthMethodAccessToken

+ const AuthMethodUserPassword

type Config

+ AccessTokenFile string

+ AccessTokenLoader AccessTokenLoader

+ MaxRowsInBuffer int64

+ MaxRowsPerPage int64

+ WaitTimeSecs int64

+ type FileAccessTokenData struct

+ AccessToken string

+ type FileAccessTokenLoader struct

+ func NewFileAccessTokenLoader(path string) *FileAccessTokenLoader

+ func (l *FileAccessTokenLoader) LoadAccessToken(ctx context.Context, forceRotate bool) (string, error)

+ type PaginationConfig struct

+ MaxRowsInBuffer int64

+ MaxRowsPerPage int64

+ WaitTime int64

type QueryRequest

+ Pagination *PaginationConfig

+ Session *SessionConfig

+ type SessionConfig struct

+ Database string

+ KeepServerSessionSecs uint64

+ Settings map[string]string

+ type StaticAccessTokenLoader struct

+ AccessToken string

+ func NewStaticAccessTokenLoader(accessToken string) *StaticAccessTokenLoader

+ func (l *StaticAccessTokenLoader) LoadAccessToken(ctx context.Context, forceRotate bool) (string, error)

Jan 20, 2023

Changes in this version

type APIClient

+ func NewAPIClientFromConfig(cfg *Config) *APIClient

Jan 16, 2023

Changes in this version

type DataField

+ Type string

Dec 28, 2022

Changes in this version

+ const WarehouseRoute

Dec 14, 2022

Changes in this version

+ type Pagination struct

+ WaitTime int32

Dec 12, 2022

Changes in this version

type Config

+ func (cfg *Config) AddParams(params map[string][]string) (err error)

Dec 12, 2022

Changes in this version

+ const SSL_MODE_DISABLE

Dec 7, 2022

Changes in this version

type Config

+ SSLMode string

Dec 6, 2022

Changes in this version

+ var ProvisionWarehouseTimeout = "ProvisionWarehouseTimeout"

+ func IsAuthFailed(err error) bool

+ func IsNotFound(err error) bool

+ func IsProxyErr(err error) bool

+ func NewAPIError(hint string, status int, respBuf []byte) error

+ type APIError struct

+ Hint string

+ RespBody APIErrorResponseBody

+ RespText string

+ StatusCode int

+ func (e APIError) Error() string

+ type APIErrorResponseBody struct

+ Error string

+ Message string

+ func RespBody(err error) APIErrorResponseBody

Dec 6, 2022

Changes in this version

type QueryError

+ func (e *QueryError) Error() string

Dec 1, 2022

Changes in this version

+ const DatabendTenantHeader

+ const DatabendWarehouseHeader

type APIClient

+ PresignedURLDisabled bool

+ Tenant string

+ Warehouse string

type Config

+ PresignedURLDisabled bool

+ Tenant string

type DatabendConn

+ func (dc *DatabendConn) ExecContext(ctx context.Context, query string, args []driver.NamedValue) (driver.Result, error)

+ func (dc *DatabendConn) QueryContext(ctx context.Context, query string, args []driver.NamedValue) (driver.Rows, error)

Nov 12, 2022

Changes in this version

+ const Authorization

+ const DatabendCloudTenantHeader

+ const DatabendCloudWarehouseHeader

type APIClient

+ User string

Nov 6, 2022

Changes in this version

type APIClient

+ func (c *APIClient) UploadToStageByPresignURL(presignURL, fileName string, header map[string]interface{}) error

Oct 21, 2022

Changes in this version

type APIClient

+ func (c *APIClient) RefreshTokens() error

Oct 20, 2022

Changes in this version

+ const DBSessionIDKey

+ const SFSessionUserKey

+ var ErrNoLastInsertID = errors.New("no LastInsertId available")

+ var ErrNoRowsAffected = errors.New("no RowsAffected available")

+ var ErrPlaceholderCount = errors.New("databend: wrong placeholder count")

+ var LogKeys = [...]contextKey

+ func Array(v interface{}) driver.Valuer

+ func DBCallerPrettyfier(frame *runtime.Frame) (string, string)

+ func Date(t time.Time) driver.Valuer

+ func Decimal128(v interface{}, s int32) driver.Valuer

+ func Decimal32(v interface{}, s int32) driver.Valuer

+ func Decimal64(v interface{}, s int32) driver.Valuer

+ func DeregisterTLSConfig(key string)

+ func IP(i net.IP) driver.Valuer

+ func Map(v interface{}) driver.Valuer

+ func RegisterTLSConfig(key string, config *tls.Config) error

+ func SetLogger(inLogger *DBLogger)

+ func Tuple(v interface{}) driver.Valuer

+ func UInt64(u uint64) driver.Valuer

+ type APIClient struct

+ AccessToken string

+ AccountID uint64

+ ApiEndpoint string

+ CurrentOrgSlug string

+ CurrentWarehouse string

+ Host string

+ Password string

+ RefreshToken string

+ UserEmail string

+ func (c *APIClient) CheckQueryStatus(queryId string) (*QueryResponse, error)

+ func (c *APIClient) DoQuery(ctx context.Context, query string, args []driver.Value) (*QueryResponse, error)

+ func (c *APIClient) DoRequest(method, path string, headers http.Header, req interface{}, resp interface{}) error

+ func (c *APIClient) Login() error

+ func (c *APIClient) QueryPage(queryId, path string) (*QueryResponse, error)

+ func (c *APIClient) QuerySync(ctx context.Context, query string, args []driver.Value, ...) error

+ type Config struct

+ AccessToken string

+ Database string

+ Debug bool

+ GzipCompression bool

+ Host string

+ IdleTimeout time.Duration

+ Location *time.Location

+ Org string

+ Params map[string]string

+ Password string

+ ReadTimeout time.Duration

+ RefreshToken string

+ Scheme string

+ TLSConfig string

+ Timeout time.Duration

+ UseDBLocation bool

+ User string

+ Warehouse string

+ WriteTimeout time.Duration

+ func NewConfig() *Config

+ func ParseDSN(dsn string) (*Config, error)

+ func (cfg *Config) FormatDSN() string

+ type DBLogger interface

+ SetLogLevel func(level string) error

+ SetOutput func(output io.Writer)

+ WithContext func(ctx context.Context) *rlog.Entry

+ func CreateDefaultLogger() DBLogger

+ func GetLogger() DBLogger

+ type DataField struct

+ DataType TypeDetail

+ Name string

+ type DataParser interface

+ Parse func(io.RuneScanner) (driver.Value, error)

+ Type func() reflect.Type

+ func NewDataParser(t *TypeDesc, opt *DataParserOptions) (DataParser, error)

+ type DataParserOptions struct

+ Location *time.Location

+ UseDBLocation bool

+ type DataSchema struct

+ Fields []DataField

+ type DatabendConn struct

+ SQLState string

+ func (dc *DatabendConn) Begin() (driver.Tx, error)

+ func (dc *DatabendConn) BeginTx(ctx context.Context, opts driver.TxOptions) (driver.Tx, error)

+ func (dc *DatabendConn) Close() error

+ func (dc *DatabendConn) Commit() (err error)

+ func (dc *DatabendConn) Exec(query string, args []driver.Value) (driver.Result, error)

+ func (dc *DatabendConn) Prepare(query string) (driver.Stmt, error)

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

+ func (dc *DatabendConn) Query(query string, args []driver.Value) (driver.Rows, error)

+ func (dc *DatabendConn) Rollback() error

+ type DatabendDriver struct

+ func (d DatabendDriver) Open(dsn string) (driver.Conn, error)

+ func (d DatabendDriver) OpenWithConfig(ctx context.Context, config Config) (driver.Conn, error)

+ type Error struct

+ Code int

+ Message string

+ func (e *Error) Error() string

+ type QueryError struct

+ Code int

+ Kind string

+ Message string

+ type QueryProgress struct

+ Bytes uint64

+ Rows uint64

+ type QueryRequest struct

+ SQL string

+ type QueryResponse struct

+ Data [][]interface{}

+ Error *QueryError

+ FinalURI string

+ Id string

+ NextURI string

+ Schema DataSchema

+ State string

+ Stats QueryStats

+ StatsURI string

+ type QueryStats struct

+ RunningTimeMS float64

+ ScanProgress QueryProgress

+ type TypeDesc struct

+ Args []*TypeDesc

+ Name string

+ func ParseTypeDesc(s string) (*TypeDesc, error)

+ type TypeDetail struct

+ Type string