Versions in this module Expand all Collapse all v1 v1.4.3 Aug 16, 2023 v1.4.2 Aug 16, 2023 Changes in this version + const DfvLevel0 + const DfvLevel1 + const DfvLevel2 + const DfvLevel3 + const DfvLevel4 + const DfvLevel5 + const DfvLevel6 + const DfvLevel7 + const DfvLevel8 + const HdbErrAuthenticationFailed + const HdbErrWhileParsingProtocol + const MaxNumArg + const RaExecutionFailed + const TcTableRows + var ErrDecimalOutOfRange = errors.New("decimal out of range error") + var ErrFloatOutOfRange = errors.New("float out of range error") + var ErrIntegerOutOfRange = errors.New("integer out of range error") + var ErrUint64OutOfRange = errors.New("uint64 values with high bit set are not supported") + func IsSupportedDfv(dfv int) bool + func RegisterScanType(dt DataType, scanType, scanNullType reflect.Type) bool + func SupportedDfvs(defaultOnly bool) []int + type AuthFinalReply struct + func (r *AuthFinalReply) String() string + type AuthFinalRequest struct + func (r *AuthFinalRequest) String() string + type AuthHnd struct + func NewAuthHnd(logonname string) *AuthHnd + func (a *AuthHnd) AddBasic(username, password string) + func (a *AuthHnd) AddJWT(token string) + func (a *AuthHnd) AddSessionCookie(cookie []byte, logonname, clientID string) + func (a *AuthHnd) AddX509(certKey *x509.CertKey) + func (a *AuthHnd) FinalReply() (*AuthFinalReply, error) + func (a *AuthHnd) FinalRequest() (*AuthFinalRequest, error) + func (a *AuthHnd) InitReply() (*AuthInitReply, error) + func (a *AuthHnd) InitRequest() (*AuthInitRequest, error) + func (a *AuthHnd) Selected() auth.Method + func (a *AuthHnd) String() string + type AuthInitReply struct + func (r *AuthInitReply) String() string + type AuthInitRequest struct + func (r *AuthInitRequest) String() string + type Cdm byte + const CdmConnection + const CdmConnectionStatement + const CdmOff + const CdmStatement + func (i Cdm) String() string + type ClientContextOption int8 + const CcoClientApplicationProgram + const CcoClientType + const CcoClientVersion + func (i ClientContextOption) String() string + type ClientID []byte + func (id ClientID) String() string + type Command []byte + func (c Command) String() string + type ConnectOption int8 + const CoClientDistributionMode + const CoClientLocale + const CoCompleteArrayExecution + const CoDataFormatVersion2 + const CoDatabaseName + const CoDistributionProtocolVersion + const CoFullVersionString + const CoSelectForUpdateSupported + const CoSplitBatchCommands + func (i ConnectOption) String() string + type ConvertError struct + func (e *ConvertError) Error() string + func (e *ConvertError) Unwrap() error + type DBConnectInfoType int8 + const CiDatabaseName + const CiHost + const CiIsConnected + const CiPort + func (i DBConnectInfoType) String() string + type DataType byte + const DtBigint + const DtBoolean + const DtBytes + const DtDecimal + const DtDouble + const DtInteger + const DtLob + const DtReal + const DtRows + const DtSmallint + const DtString + const DtTime + const DtTinyint + const DtUnknown + func (dt DataType) ScanType(nullable bool) reflect.Type + func (i DataType) String() string + type DecodeError struct + func (e *DecodeError) Error() string + type DecodeErrors []*DecodeError + func (errors DecodeErrors) RowError(row int) error + type Fetchsize int32 + func (s Fetchsize) String() string + type FieldTypeCtx struct + func NewFieldTypeCtx(dfv int, emptyDateAsNull bool) *FieldTypeCtx + type FunctionCode int16 + const FcDDL + func (fc FunctionCode) IsProcedureCall() bool + func (i FunctionCode) String() string + type HdbError struct + func (e *HdbError) Code() int + func (e *HdbError) Error() string + func (e *HdbError) IsError() bool + func (e *HdbError) IsFatal() bool + func (e *HdbError) IsWarning() bool + func (e *HdbError) Level() int + func (e *HdbError) Position() int + func (e *HdbError) StmtNo() int + func (e *HdbError) String() string + func (e *HdbError) Text() string + type HdbErrors struct + func (e *HdbErrors) Code() int + func (e *HdbErrors) Error() string + func (e *HdbErrors) ErrorsFunc(fn func(err error)) + func (e *HdbErrors) HasOnlyWarnings() bool + func (e *HdbErrors) IsError() bool + func (e *HdbErrors) IsFatal() bool + func (e *HdbErrors) IsWarning() bool + func (e *HdbErrors) Level() int + func (e *HdbErrors) NumError() int + func (e *HdbErrors) Position() int + func (e *HdbErrors) SetIdx(idx int) + func (e *HdbErrors) StmtNo() int + func (e *HdbErrors) String() string + func (e *HdbErrors) Text() string + func (e *HdbErrors) Unwrap() []error + type InputParameters struct + InputFields []*ParameterField + func NewInputParameters(inputFields []*ParameterField, nvargs []driver.NamedValue) (*InputParameters, error) + func (p *InputParameters) String() string + type LobDecoderSetter interface + SetDecoder func(fn func(descr *LobOutDescr, wr io.Writer) error) + type LobInDescr struct + Opt LobOptions + func (d *LobInDescr) FetchNext(chunkSize int) error + func (d *LobInDescr) String() string + type LobOptions int8 + func (o LobOptions) IsLastData() bool + func (o LobOptions) String() string + type LobOutDescr struct + B []byte + ID LocatorID + IsCharBased bool + NumChar int64 + Opt LobOptions + func (d *LobOutDescr) Scan(wr io.Writer) error + func (d *LobOutDescr) SetDecoder(decoder func(descr *LobOutDescr, wr io.Writer) error) + func (d *LobOutDescr) String() string + type LobScanner interface + Scan func(w io.Writer) error + type LocatorID uint64 + type MessageType int8 + const MtAuthenticate + const MtCloseResultset + const MtCommit + const MtConnect + const MtDBConnectInfo + const MtDisconnect + const MtDropStatementID + const MtExecute + const MtExecuteDirect + const MtFetchNext + const MtPrepare + const MtReadLob + const MtRollback + const MtWriteLob + func (i MessageType) String() string + func (mt MessageType) ClientInfoSupported() bool + type Options map[K]any + func (ops Options[K]) String() string + type OutputParameters struct + DecodeErrors DecodeErrors + FieldValues []driver.Value + OutputFields []*ParameterField + func (p *OutputParameters) String() string + type ParameterField struct + func NewTableRowsParameterField(idx int) *ParameterField + func (f *ParameterField) Convert(t transform.Transformer, v any) (any, error) + func (f *ParameterField) In() bool + func (f *ParameterField) InOut() bool + func (f *ParameterField) IsLob() bool + func (f *ParameterField) Name() string + func (f *ParameterField) Nullable() bool + func (f *ParameterField) Out() bool + func (f *ParameterField) ScanType() reflect.Type + func (f *ParameterField) String() string + func (f *ParameterField) TypeLength() (int64, bool) + func (f *ParameterField) TypeName() string + func (f *ParameterField) TypePrecisionScale() (int64, int64, bool) + type ParameterMetadata struct + FieldTypeCtx *FieldTypeCtx + ParameterFields []*ParameterField + func (m *ParameterMetadata) String() string + type ParameterMode int8 + const PmIn + const PmOut + func (k ParameterMode) String() string + type PartAttributes int8 + func (k PartAttributes) LastPacket() bool + func (k PartAttributes) ResultsetClosed() bool + func (k PartAttributes) String() string + type PartHeader struct + PartAttributes PartAttributes + PartKind PartKind + func (h *PartHeader) String() string + type PartKind int8 + const PkAuthentication + const PkClientContext + const PkClientID + const PkClientInfo + const PkCommand + const PkConnectOptions + const PkDBConnectInfo + const PkError + const PkFetchSize + const PkOutputParameters + const PkParameterMetadata + const PkParameters + const PkReadLobReply + const PkReadLobRequest + const PkResultMetadata + const PkResultset + const PkResultsetID + const PkRowsAffected + const PkStatementContext + const PkStatementID + const PkTopologyInformation + const PkTransactionFlags + const PkWriteLobReply + const PkWriteLobRequest + func (i PartKind) String() string + type ReadLobReply struct + B []byte + ID LocatorID + Opt LobOptions + func (r *ReadLobReply) String() string + type ReadLobRequest struct + ChunkSize int32 + ID LocatorID + Ofs int64 + func (r *ReadLobRequest) String() string + type ReadProvider interface + Reader func() io.Reader + type Reader interface + FunctionCode func() FunctionCode + IterateParts func(ctx context.Context, partFn func(ph *PartHeader)) error + Read func(ctx context.Context, part partReader) error + ReadProlog func(ctx context.Context) error + ReadSkip func(ctx context.Context) error + SessionID func() int64 + func NewClientReader(rd io.Reader, protTrace bool, logger *slog.Logger, ...) Reader + func NewDBReader(rd io.Reader, protTrace bool, logger *slog.Logger, ...) Reader + type ResultField struct + func (f *ResultField) Name() string + func (f *ResultField) Nullable() bool + func (f *ResultField) ScanType() reflect.Type + func (f *ResultField) String() string + func (f *ResultField) TypeLength() (int64, bool) + func (f *ResultField) TypeName() string + func (f *ResultField) TypePrecisionScale() (int64, int64, bool) + type ResultMetadata struct + FieldTypeCtx *FieldTypeCtx + ResultFields []*ResultField + func (r *ResultMetadata) String() string + type Resultset struct + DecodeErrors DecodeErrors + FieldValues []driver.Value + ResultFields []*ResultField + func (r *Resultset) String() string + type ResultsetID uint64 + func (id ResultsetID) String() string + type RowsAffected struct + Ofs int + func (r RowsAffected) String() string + func (r RowsAffected) Total() int64 + type StatementID uint64 + func (id StatementID) String() string + type WriteLobDescr struct + ID LocatorID + LobInDescr *LobInDescr + Opt LobOptions + func (d *WriteLobDescr) FetchNext(chunkSize int) error + func (d WriteLobDescr) String() string + type WriteLobReply struct + IDs []LocatorID + func (r *WriteLobReply) String() string + type WriteLobRequest struct + Descrs []*WriteLobDescr + func (r *WriteLobRequest) String() string + type Writer interface + Write func(ctx context.Context, sessionID int64, messageType MessageType, commit bool, ...) error + WriteProlog func(ctx context.Context) error + func NewWriter(wr *bufio.Writer, protTrace bool, logger *slog.Logger, ...) Writer