Versions in this module Expand all Collapse all v0 v0.11.3 Feb 10, 2020 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, connClass 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 + OnInit []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) Comb() + func (P *ConnectionParams) SetSessionParamOnInit(k, v string) + 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 NullTime = sql.NullTime + 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 + ID uint64 + 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 uint8 + PortRelease uint8 + PortUpdate uint8 + Release uint8 + ServerRelease string + Update uint8 + Version uint8 + 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
Go to main page