Documentation
¶
Overview ¶
Package oracle implements the TDTP adapter for Oracle Database 18c and 21c.
Index ¶
- Constants
- type Adapter
- func (a *Adapter) BeginTx(ctx context.Context) (adapters.Tx, error)
- func (a *Adapter) Close(context.Context) error
- func (a *Adapter) Connect(ctx context.Context, cfg adapters.Config) error
- func (a *Adapter) CreateTable(ctx context.Context, name string, schema packet.Schema) error
- func (a *Adapter) DropTable(ctx context.Context, name string) error
- func (a *Adapter) ExecuteRawQuery(ctx context.Context, query string) (*packet.DataPacket, error)
- func (a *Adapter) ExportTable(ctx context.Context, table string) ([]*packet.DataPacket, error)
- func (a *Adapter) ExportTableIncremental(ctx context.Context, table string, cfg adapters.IncrementalConfig) ([]*packet.DataPacket, string, error)
- func (a *Adapter) ExportTableWithQuery(ctx context.Context, table string, query *packet.Query, ...) ([]*packet.DataPacket, error)
- func (a *Adapter) GetDatabaseType() string
- func (a *Adapter) GetDatabaseVersion(ctx context.Context) (string, error)
- func (a *Adapter) GetRowCount(ctx context.Context, name string) (int64, error)
- func (a *Adapter) GetTableNames(ctx context.Context) ([]string, error)
- func (a *Adapter) GetTableSchema(ctx context.Context, name string) (packet.Schema, error)
- func (a *Adapter) GetViewNames(ctx context.Context) ([]adapters.ViewInfo, error)
- func (a *Adapter) ImportPacket(ctx context.Context, pkt *packet.DataPacket, strategy adapters.ImportStrategy) error
- func (a *Adapter) ImportPackets(ctx context.Context, packets []*packet.DataPacket, ...) error
- func (a *Adapter) InspectTable(ctx context.Context, name string) (*adapters.TableReport, error)
- func (a *Adapter) ParseFailures() []base.ParseFailure
- func (a *Adapter) Ping(ctx context.Context) error
- func (a *Adapter) ReadAllRows(ctx context.Context, name string, schema packet.Schema) ([][]string, error)
- func (a *Adapter) ReadRowsWithSQL(ctx context.Context, query string, schema packet.Schema) ([][]string, error)
- func (a *Adapter) RenameTable(ctx context.Context, oldName, newName string) error
- func (a *Adapter) SetColumnarLayout(on bool)
- func (a *Adapter) SetMaxFallbackRows(n int64)
- func (a *Adapter) SetMaxMessageSize(n int)
- func (a *Adapter) SetSkipSpecialValues(on bool)
- func (a *Adapter) TableExists(ctx context.Context, name string) (bool, error)
Constants ¶
View Source
const AdapterType = "oracle"
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type Adapter ¶
type Adapter struct {
// contains filtered or unexported fields
}
func (*Adapter) CreateTable ¶
func (*Adapter) ExecuteRawQuery ¶
ExecuteRawQuery loads a pipeline source query. NUMBER columns are selected as decimal text in the outer query so the driver cannot round them to float64.
func (*Adapter) ExportTable ¶
func (*Adapter) ExportTableIncremental ¶
func (a *Adapter) ExportTableIncremental(ctx context.Context, table string, cfg adapters.IncrementalConfig) ([]*packet.DataPacket, string, error)
func (*Adapter) ExportTableWithQuery ¶
func (*Adapter) GetDatabaseType ¶
func (*Adapter) GetDatabaseVersion ¶
func (*Adapter) GetRowCount ¶
func (*Adapter) GetTableNames ¶
func (*Adapter) GetTableSchema ¶
func (*Adapter) GetViewNames ¶
func (*Adapter) ImportPacket ¶
func (a *Adapter) ImportPacket(ctx context.Context, pkt *packet.DataPacket, strategy adapters.ImportStrategy) error
func (*Adapter) ImportPackets ¶
func (a *Adapter) ImportPackets(ctx context.Context, packets []*packet.DataPacket, strategy adapters.ImportStrategy) error
Oracle DDL commits implicitly. Create a missing table before the DML transaction, then keep all rows of all packets in one real *sql.Tx.
func (*Adapter) InspectTable ¶
func (*Adapter) ParseFailures ¶
func (a *Adapter) ParseFailures() []base.ParseFailure
ParseFailures implements base.ParseFailureReporter: values this adapter's exports could not convert to their declared type, since the previous call.
func (*Adapter) ReadAllRows ¶
func (*Adapter) ReadRowsWithSQL ¶
func (*Adapter) RenameTable ¶
func (*Adapter) SetColumnarLayout ¶
func (*Adapter) SetMaxFallbackRows ¶
func (*Adapter) SetMaxMessageSize ¶
func (*Adapter) SetSkipSpecialValues ¶
Click to show internal directories.
Click to hide internal directories.