godror

Dec 20, 2023

Changes in this version

+ type Annotation struct

+ Key string

+ Value string

+ type DomainAnnotation struct

+ Annotations []Annotation

+ DomainName string

type ObjectType

+ Annotations []Annotation

Sep 16, 2023

Changes in this version

+ func GuardWithFinalizers(b bool)

+ func LogLingeringResourceStack(b bool)

Aug 11, 2023

Changes in this version

type ObjectCollection

+ func (O ObjectCollection) FromSlice(v []interface{}) error

type Option

+ func NumberAsFloat64() Option

Nov 30, 2022

Changes in this version

+ func ReplaceQuestionPlacholders(qry string) string

Nov 10, 2022

Changes in this version

type ObjectType

+ PackageName string

Jul 21, 2022

Changes in this version

+ const StructTag

+ type ConnPool struct

+ func NewConnPool(pool interface{ ... }, size int) *ConnPool

+ func (p *ConnPool) Close() error

+ func (p *ConnPool) Conn(ctx context.Context) (*PooledConn, error)

type ObjectAttribute

+ Sequence uint32

type ObjectType

+ func (t *ObjectType) AttributeNames() []string

+ type ObjectTypeName struct

type PoolStats

+ func (p PoolStats) AsDBStats() sql.DBStats

+ type PooledConn struct

+ func (c *PooledConn) Close() error

May 17, 2022

Changes in this version

type UserPasswdConnClassTag

+ func (up UserPasswdConnClassTag) String() string

Apr 4, 2022

Changes in this version

type LogFunc

+ func (f LogFunc) Enabled(_ int) bool

+ func (f LogFunc) Error(err error, msg string, keyvals ...interface{})

+ func (f LogFunc) Info(level int, msg string, keyvals ...interface{})

+ func (f LogFunc) Init(_ logr.RuntimeInfo)

+ func (f LogFunc) WithName(name string) logr.LogSink

+ func (f LogFunc) WithValues(plusKeyVals ...interface{}) logr.LogSink

Mar 4, 2022

Changes in this version

type Queue

+ func (Q *Queue) PurgeExpired(ctx context.Context) error

Jan 19, 2022

Changes in this version

type Column

+ OrigOracleType C.dpiOracleTypeNum

Jan 4, 2022

Changes in this version

type Object

+ func (O *Object) FromJSON(dec *json.Decoder) error

type ObjectCollection

+ func (O ObjectCollection) FromJSON(dec *json.Decoder) error

type ObjectType

+ func (t *ObjectType) IsObject() bool

Jan 1, 2022

Changes in this version

type Object

+ func (O *Object) AsMap(recursive bool) (map[string]interface{}, error)

+ func (O *Object) FromMap(recursive bool, m map[string]interface{}) error

+ func (O *Object) String() string

+ func (O *Object) ToJSON(w io.Writer) error

type ObjectCollection

+ func (O ObjectCollection) AsMapSlice(recursive bool) ([]map[string]interface{}, error)

+ func (O ObjectCollection) FromMapSlice(recursive bool, m []map[string]interface{}) error

+ func (O ObjectCollection) String() string

+ func (O ObjectCollection) ToJSON(w io.Writer) error

Nov 4, 2021

Changes in this version

+ var ErrBadDate = errors.New("date out of range (year must be between -4713 and 9999, and must not be 0)")

type Conn

+ NewTempLob func(isClob bool) (*DirectLob, error)

Oct 8, 2021

Changes in this version

+ var ErrCLOB = errors.New("CLOB is not supported")

type Lob

+ func (lob *Lob) ReadAt(p []byte, off int64) (int, error)

+ func (lob *Lob) Size() (int64, error)

Oct 1, 2021

Changes in this version

+ func ContextWithLogger(ctx context.Context, logger Logger) context.Context

+ func SetLog(f func(...interface{}) error)

+ func SetLogger(logger Logger)

+ type LogFunc func(keyvals ...interface{}) error

+ func (f LogFunc) Log(keyvals ...interface{}) error

+ type Logger interface

+ Log func(keyvals ...interface{}) error

+ func NewLogfmtLogger(w io.Writer) Logger

Sep 21, 2021

Changes in this version

+ const JSONOptDefault

+ const JSONOptNumberAsString

+ var ErrInvalidJSON = errors.New("Invalid JSON Document")

+ var ErrInvalidType = errors.New("Invalid JSON Scalar Type")

+ var ErrNotImplemented = errors.New("not implemented")

type Data

+ func (d *Data) GetJSON() JSON

+ func (d *Data) GetJSONArray() JSONArray

+ func (d *Data) GetJSONObject() JSONObject

+ type JSON struct

+ func (j JSON) Get(data *Data, opts JSONOption) error

+ func (j JSON) GetJSONArray(opts JSONOption) (JSONArray, error)

+ func (j JSON) GetJSONObject(opts JSONOption) (JSONObject, error)

+ func (j JSON) GetJSONScalar(opts JSONOption) (JSONScalar, error)

+ func (j JSON) GetValue(opts JSONOption) (interface{}, error)

+ func (j JSON) String() string

+ type JSONArray struct

+ func (j JSONArray) Get(nodes []Data) []Data

+ func (j JSONArray) GetElement(i int) Data

+ func (j JSONArray) GetValue() (nodes []interface{}, err error)

+ func (j JSONArray) Len() int

+ type JSONObject struct

+ func (j JSONObject) Get() map[string]Data

+ func (j JSONObject) GetInto(v interface{})

+ func (j JSONObject) GetValue() (m map[string]interface{}, err error)

+ func (j JSONObject) Len() int

+ type JSONOption uint8

+ type JSONScalar struct

+ func (j JSONScalar) GetValue() (val interface{}, err error)

+ type JSONString struct

+ Flags JSONStringFlags

+ Value string

+ type JSONStringFlags uint

+ type JSONValue struct

+ Value interface{}

Sep 21, 2021

Changes in this version

+ const DefaultBatchLimit

+ type Batch struct

+ Limit int

+ Stmt *sql.Stmt

+ func (b *Batch) Add(ctx context.Context, values ...interface{}) error

+ func (b *Batch) Flush(ctx context.Context) error

+ func (b *Batch) Size() int

Sep 9, 2021

Changes in this version

type Option

+ func DeleteFromCache() Option

Apr 13, 2021

Changes in this version

+ func IsBadConn(err error) bool

Feb 23, 2021

Changes in this version

type Lob

+ func (lob *Lob) NewBufferedReader(size int) *bufio.Reader

+ func (lob *Lob) WriteTo(w io.Writer) (n int64, err error)

+ type UserPasswdConnClassTag struct

+ ConnClass string

+ Password dsn.Password

+ Username string

Jan 7, 2021

Changes in this version

+ func NewDriver() *drv

Nov 8, 2020

Changes in this version

type Number

+ func (N *Number) Compose(form byte, negative bool, coefficient []byte, exponent int32) error

+ func (N Number) Decompose(buf []byte) (form byte, negative bool, coefficient []byte, exponent int32)

Sep 5, 2020

Changes in this version

type DirectLob

+ func (dl *DirectLob) GetFileName() (dir, file string, err error)

type Message

+ func (M Message) IsZero() bool

Aug 28, 2020

Changes in this version

+ func WithDeqOptions(o DeqOptions) queueOption

+ func WithEnqOptions(o EnqOptions) queueOption

Aug 6, 2020

Changes in this version

+ func NewLogfmtLog(w io.Writer) func(...interface{}) error

type ConnectionParams

+ func ParseDSN(dataSourceName string) (P ConnectionParams, err error)

Jul 27, 2020

Changes in this version

type CommonParams

+ func (P CommonParams) String() string

type ConnParams

+ func (P ConnParams) String() string

+ type Password struct

+ func NewPassword(secret string) Password

+ func (P *Password) Reset()

+ func (P Password) IsZero() bool

+ func (P Password) Len() int

+ func (P Password) String() string

+ func (P Password) Unhide() string

type PoolParams

+ func (P PoolParams) String() string

type TraceTag

+ func (tt TraceTag) String() string

Jul 20, 2020

Changes in this version

type CommonParams

+ ConfigDir string

+ LibDir string

Jun 26, 2020

Changes in this version

+ const DefaultFetchArraySize

+ const DefaultPrefetchCount

type Option

+ func FetchArraySize(rowCount int) Option

+ func PrefetchCount(rowCount int) Option

type OraErr

+ func (oe *OraErr) IsWarning() bool

May 17, 2020

Changes in this version

+ const DefaultStandaloneConnection

type Conn

+ GetPoolStats func() (PoolStats, error)

type Option

+ func NullDateAsZeroTime() Option

+ type PoolStats struct

+ Busy uint32

+ Max uint32

+ MaxLifetime time.Duration

+ Open uint32

+ Timeout time.Duration

+ WaitTimeout time.Duration

+ func (s PoolStats) String() string

May 4, 2020

Changes in this version

+ const DefaultSessionIncrement

+ func ContextWithParams(ctx context.Context, commonParams CommonParams, connParams ConnParams) context.Context

+ func Raw(ctx context.Context, ex Execer, f func(driverConn Conn) error) error

+ type CommonParams struct

+ DSN string

+ EnableEvents bool

+ OnInit func(driver.Conn) error

+ Password string

+ Timezone *time.Location

+ Username string

+ type ConnParams struct

+ ConnClass string

+ IsPrelim bool

+ IsSysASM bool

+ IsSysDBA bool

+ IsSysOper bool

+ NewPassword string

+ ShardingKey []interface{}

+ SuperShardingKey []interface{}

type ConnectionParams

+ func (P ConnectionParams) IsStandalone() bool

type Data

+ func (d *Data) GetTimeIn(serverTZ *time.Location) time.Time

type Message

+ func (M Message) Deadline() time.Time

type ObjectType

+ func (t *ObjectType) Close() error

+ func (t ObjectType) NewData(baseType interface{}, sliceLen, bufSize int) ([]*Data, error)

+ type PoolParams struct

+ ExternalAuth bool

+ Heterogeneous bool

+ MaxLifeTime time.Duration

+ MaxSessions int

+ MinSessions int

+ SessionIncrement int

+ SessionTimeout time.Duration

+ WaitTimeout time.Duration

Mar 6, 2020

Changes in this version

type OraErr

+ func (oe *OraErr) Action() string

+ func (oe *OraErr) FunName() string

+ func (oe *OraErr) Offset() int

+ func (oe *OraErr) Recoverable() bool

+ func (oe *OraErr) SQLState() string

+ type SubscriptionOption func(*subscriptionParams)

+ func SubscrClientInitiated(b bool) SubscriptionOption

+ func SubscrHostPort(address string, port uint32) SubscriptionOption

Feb 13, 2020

Changes in this version

type Option

+ func BoolToString(trueVal, falseVal string) Option

Jan 22, 2020

Changes in this version

+ type NullTime = sql.NullTime

Jan 12, 2020

Changes in this version

type ConnectionParams

+ func (P *ConnectionParams) Comb()

Jan 2, 2020

Changes in this version

type ConnectionParams

+ OnInit []string

+ func (P *ConnectionParams) SetSessionParamOnInit(k, v string)

type Subscription

+ ID uint64

Dec 12, 2019

Changes in this version

+ const DefaultArraySize

+ const DefaultConnectionClass

+ const DefaultFetchRowCount

+ const DefaultMaxLifeTime

+ const DefaultPoolIncrement

+ const DefaultPoolMaxSessions

+ const DefaultPoolMinSessions

+ const DefaultSessionTimeout

+ const DefaultWaitTimeout

+ const DeliverBuffered

+ const DeliverPersistent

+ const DeliverPersistentOrBuffered

+ const DeqBrowse

+ const DeqLocked

+ const DeqPeek

+ const DeqRemove

+ const DpiMajorVersion

+ const DpiMinorVersion

+ const DpiPatchLevel

+ const DpiVersionNumber

+ const DriverName

+ const EvtAQ

+ const EvtDereg

+ const EvtObjChange

+ const EvtQueryChange

+ const EvtShutdown

+ const EvtShutdownAny

+ const EvtStartup

+ const MsgIDLength

+ const MsgStateExpired

+ const MsgStateProcessed

+ const MsgStateReady

+ const MsgStateWaiting

+ const NavFirst

+ const NavNext

+ const NavNextTran

+ const NoConnectionPoolingConnectionClass

+ const NoWait

+ const OpAll

+ const OpAllRows

+ const OpAlter

+ const OpDelete

+ const OpDrop

+ const OpInsert

+ const OpUnknown

+ const OpUpdate

+ const ShutdownAbort

+ const ShutdownDefault

+ const ShutdownFinal

+ const ShutdownImmediate

+ const ShutdownTransactional

+ const ShutdownTransactionalLocal

+ const StartupDefault

+ const StartupForce

+ const StartupRestrict

+ const Version

+ const VisibleImmediate

+ const VisibleOnCommit

+ const WaitForever

+ var DefaultDeqOptions = DeqOptions

+ var DefaultEnqOptions = EnqOptions

+ var ErrNoSuchKey = errors.New("no such key")

+ var ErrNotCollection = errors.New("not collection")

+ var ErrNotExist = errors.New("not exist")

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

+ var Float64 = floatType

+ var Int64 = intType

+ var Log func(...interface{}) error

+ var Num = numType

+ func CallbackSubscr(ctx unsafe.Pointer, message *C.dpiSubscrMessage)

+ func ContextWithLog(ctx context.Context, logF func(...interface{}) error) context.Context

+ func ContextWithTraceTag(ctx context.Context, tt TraceTag) context.Context

+ func ContextWithUserPassw(ctx context.Context, user, password string) context.Context

+ func EnableDbmsOutput(ctx context.Context, conn Execer) error

+ func MapToSlice(qry string, metParam func(string) interface{}) (string, []interface{})

+ func NamedToOrdered(qry string, namedParams map[string]interface{}) (string, []interface{})

+ func NewConnector(name string, onInit func(driver.Conn) error) (driver.Connector, error)

+ func NewSessionIniter(m map[string]string) func(driver.Conn) error

+ func ReadDbmsOutput(ctx context.Context, w io.Writer, conn preparer) error

+ func Timezone(ctx context.Context, ex Execer) (*time.Location, error)

+ func WrapRows(ctx context.Context, q Querier, rset driver.Rows) (*sql.Rows, error)

+ type Column struct

+ DBSize C.uint32_t

+ Name string

+ NativeType C.dpiNativeTypeNum

+ Nullable bool

+ ObjectType *C.dpiObjectType

+ OracleType C.dpiOracleTypeNum

+ Precision C.int16_t

+ Scale C.int8_t

+ Size C.uint32_t

+ SizeInChars C.uint32_t

+ type CompileError struct

+ Code int64

+ Line int64

+ Name string

+ Owner string

+ Position int64

+ Text string

+ Type string

+ Warning bool

+ func GetCompileErrors(queryer queryer, all bool) ([]CompileError, error)

+ func (ce CompileError) Error() string

+ type Conn interface

+ Break func() error

+ ClientVersion func() (VersionInfo, error)

+ Commit func() error

+ GetObjectType func(name string) (ObjectType, error)

+ NewData func(baseType interface{}, SliceLen, BufSize int) ([]*Data, error)

+ NewSubscription func(string, func(Event)) (*Subscription, error)

+ Rollback func() error

+ ServerVersion func() (VersionInfo, error)

+ Shutdown func(ShutdownMode) error

+ Startup func(StartupMode) error

+ Timezone func() *time.Location

+ func DriverConn(ctx context.Context, ex Execer) (Conn, error)

+ type ConnectionParams struct

+ ConnClass string

+ EnableEvents bool

+ HeterogeneousPool bool

+ IsPrelim bool

+ IsSysASM bool

+ IsSysDBA bool

+ IsSysOper bool

+ MaxLifeTime time.Duration

+ MaxSessions int

+ MinSessions int

+ NewPassword string

+ Password string

+ PoolIncrement int

+ SID string

+ SessionTimeout time.Duration

+ StandaloneConnection bool

+ Timezone *time.Location

+ Username string

+ WaitTimeout time.Duration

+ func ParseConnString(connString string) (ConnectionParams, error)

+ func (P ConnectionParams) String() string

+ func (P ConnectionParams) StringNoClass() string

+ func (P ConnectionParams) StringWithPassword() string

+ type Data struct

+ NativeTypeNum C.dpiNativeTypeNum

+ ObjectType ObjectType

+ func NewData(v interface{}) (*Data, error)

+ func (d *Data) Get() interface{}

+ func (d *Data) GetBool() bool

+ func (d *Data) GetBytes() []byte

+ func (d *Data) GetFloat32() float32

+ func (d *Data) GetFloat64() float64

+ func (d *Data) GetInt64() int64

+ func (d *Data) GetIntervalDS() time.Duration

+ func (d *Data) GetIntervalYM() IntervalYM

+ func (d *Data) GetLob() *Lob

+ func (d *Data) GetObject() *Object

+ func (d *Data) GetStmt() driver.Stmt

+ func (d *Data) GetTime() time.Time

+ func (d *Data) GetUint64() uint64

+ func (d *Data) IsNull() bool

+ func (d *Data) IsObject() bool

+ func (d *Data) Set(v interface{}) error

+ func (d *Data) SetBool(b bool)

+ func (d *Data) SetBytes(b []byte)

+ func (d *Data) SetFloat32(f float32)

+ func (d *Data) SetFloat64(f float64)

+ func (d *Data) SetInt64(i int64)

+ func (d *Data) SetIntervalDS(dur time.Duration)

+ func (d *Data) SetIntervalYM(ym IntervalYM)

+ func (d *Data) SetLob(lob *DirectLob)

+ func (d *Data) SetNull()

+ func (d *Data) SetObject(o *Object)

+ func (d *Data) SetStmt(s *statement)

+ func (d *Data) SetTime(t time.Time)

+ func (d *Data) SetUint64(u uint64)

+ type DeliveryMode uint32

+ type DeqMode uint32

+ type DeqNavigation uint32

+ type DeqOptions struct

+ Condition string

+ Consumer string

+ Correlation string

+ DeliveryMode DeliveryMode

+ Mode DeqMode

+ MsgID string

+ Navigation DeqNavigation

+ Transformation string

+ Visibility Visibility

+ Wait uint32

+ type DirectLob struct

+ func (dl *DirectLob) Close() error

+ func (dl *DirectLob) ReadAt(p []byte, offset int64) (int, error)

+ func (dl *DirectLob) Set(p []byte) error

+ func (dl *DirectLob) Size() (int64, error)

+ func (dl *DirectLob) Trim(size int64) error

+ func (dl *DirectLob) WriteAt(p []byte, offset int64) (int, error)

+ type EnqOptions struct

+ DeliveryMode DeliveryMode

+ Transformation string

+ Visibility Visibility

+ type Event struct

+ DB string

+ Err error

+ Queries []QueryEvent

+ Tables []TableEvent

+ Type EventType

+ type EventType C.dpiEventType

+ type Execer interface

+ ExecContext func(context.Context, string, ...interface{}) (sql.Result, error)

+ type IntervalYM struct

+ Months int

+ Years int

+ type Lob struct

+ IsClob bool

+ func (lob *Lob) Hijack() (*DirectLob, error)

+ type Message struct

+ Correlation string

+ Delay int32

+ DeliveryMode DeliveryMode

+ Enqueued time.Time

+ ExceptionQ string

+ Expiration int32

+ MsgID [16]byte

+ NumAttempts int32

+ Object *Object

+ OriginalMsgID [16]byte

+ Priority int32

+ Raw []byte

+ State MessageState

+ type MessageState uint32

+ type Number string

+ func (n *Number) Scan(v interface{}) error

+ func (n *Number) UnmarshalJSON(p []byte) error

+ func (n *Number) UnmarshalText(p []byte) error

+ func (n Number) MarshalJSON() ([]byte, error)

+ func (n Number) MarshalText() ([]byte, error)

+ func (n Number) String() string

+ func (n Number) Value() (driver.Value, error)

+ type Object struct

+ func (O *Object) Close() error

+ func (O *Object) Collection() *ObjectCollection

+ func (O *Object) Get(name string) (interface{}, error)

+ func (O *Object) GetAttribute(data *Data, name string) error

+ func (O *Object) ObjectRef() *Object

+ func (O *Object) ResetAttributes() error

+ func (O *Object) Set(name string, v interface{}) error

+ func (O *Object) SetAttribute(name string, data *Data) error

+ type ObjectAttribute struct

+ Name string

+ func (A ObjectAttribute) Close() error

+ type ObjectCollection struct

+ func (O *ObjectCollection) Append(v interface{}) error

+ func (O *ObjectCollection) AppendData(data *Data) error

+ func (O *ObjectCollection) AppendObject(obj *Object) error

+ func (O *ObjectCollection) AsSlice(dest interface{}) (interface{}, error)

+ func (O *ObjectCollection) Delete(i int) error

+ func (O *ObjectCollection) First() (int, error)

+ func (O *ObjectCollection) Get(i int) (interface{}, error)

+ func (O *ObjectCollection) GetItem(data *Data, i int) error

+ func (O *ObjectCollection) Last() (int, error)

+ func (O *ObjectCollection) Len() (int, error)

+ func (O *ObjectCollection) Next(i int) (int, error)

+ func (O *ObjectCollection) Set(i int, v interface{}) error

+ func (O *ObjectCollection) SetItem(i int, data *Data) error

+ func (O *ObjectCollection) Trim(n int) error

+ type ObjectScanner interface

+ type ObjectType struct

+ Attributes map[string]ObjectAttribute

+ CharSize int

+ ClientSizeInBytes int

+ CollectionOf *ObjectType

+ DBSize int

+ FsPrecision uint8

+ Name string

+ NativeTypeNum C.dpiNativeTypeNum

+ OracleTypeNum C.dpiOracleTypeNum

+ Precision int16

+ Scale int8

+ Schema string

+ func GetObjectType(ctx context.Context, ex Execer, typeName string) (ObjectType, error)

+ func (t ObjectType) FullName() string

+ func (t ObjectType) NewCollection() (*ObjectCollection, error)

+ func (t ObjectType) NewObject() (*Object, error)

+ func (t ObjectType) String() string

+ type ObjectWriter interface

+ WriteObject func() error

+ type Operation C.dpiOpCode

+ type Option func(*stmtOptions)

+ var PlSQLArrays Option = func(o *stmtOptions) { ... }

+ func ArraySize(arraySize int) Option

+ func CallTimeout(d time.Duration) Option

+ func ClobAsString() Option

+ func FetchRowCount(rowCount int) Option

+ func LobAsReader() Option

+ func MagicTypeConversion() Option

+ func NumberAsString() Option

+ func ParseOnly() Option

+ type OraErr struct

+ func AsOraErr(err error) (*OraErr, bool)

+ func (oe *OraErr) Code() int

+ func (oe *OraErr) Error() string

+ func (oe *OraErr) Message() string

+ type Querier interface

+ QueryContext func(context.Context, string, ...interface{}) (*sql.Rows, error)

+ type QueryColumn struct

+ Length int

+ Name string

+ Nullable bool

+ Precision int

+ Scale int

+ Type int

+ func DescribeQuery(ctx context.Context, db Execer, qry string) ([]QueryColumn, error)

+ type QueryEvent struct

+ ID uint64

+ Tables []TableEvent

+ type Queue struct

+ PayloadObjectType ObjectType

+ func NewQueue(ctx context.Context, execer Execer, name string, payloadObjectTypeName string) (*Queue, error)

+ func (Q *Queue) Close() error

+ func (Q *Queue) DeqOptions() (DeqOptions, error)

+ func (Q *Queue) Dequeue(messages []Message) (int, error)

+ func (Q *Queue) EnqOptions() (EnqOptions, error)

+ func (Q *Queue) Enqueue(messages []Message) error

+ func (Q *Queue) Name() string

+ func (Q *Queue) SetDeqCorrelation(correlation string) error

+ func (Q *Queue) SetDeqOptions(D DeqOptions) error

+ func (Q *Queue) SetEnqOptions(E EnqOptions) error

+ type RowEvent struct

+ Rowid string

+ type ShutdownMode C.dpiShutdownMode

+ type StartupMode C.dpiStartupMode

+ type Subscription struct

+ func (s *Subscription) Close() error

+ func (s *Subscription) Register(qry string, params ...interface{}) error

+ type TableEvent struct

+ Name string

+ Rows []RowEvent

+ type TraceTag struct

+ Action string

+ ClientIdentifier string

+ ClientInfo string

+ DbOp string

+ Module string

+ type VersionInfo struct

+ Full int

+ PortRelease int

+ PortUpdate int

+ Release int

+ ServerRelease string

+ Update int

+ Version int

+ func ClientVersion(ctx context.Context, ex Execer) (VersionInfo, error)

+ func ServerVersion(ctx context.Context, ex Execer) (VersionInfo, error)

+ func (V VersionInfo) String() string

+ type Visibility uint32