snapshot

Documentation

Index

• func NewParallelTableSource(sqlxDB *sqlx.DB, splitTransaction *sqlx.Tx, config *oracle.OracleSource, ...) (*oracleParallelTableSource, error)
• func NewTableSource(sqlxDB *sqlx.DB, config *oracle.OracleSource, position *common.LogPosition, ...) (*oracleTableSource, error)
• type OracleDataObject
  • func NewOracleDataObject(table *schema.Table) *OracleDataObject
  • func (dataObject *OracleDataObject) Close()
  • func (dataObject *OracleDataObject) Err() error
  • func (dataObject *OracleDataObject) FullName() string
  • func (dataObject *OracleDataObject) Name() string
  • func (dataObject *OracleDataObject) Next() bool
  • func (dataObject *OracleDataObject) Part() (base.DataObjectPart, error)
  • func (dataObject *OracleDataObject) Table() *schema.Table
  • func (dataObject *OracleDataObject) ToOldTableDescription() (*abstract.TableDescription, error)
  • func (dataObject *OracleDataObject) ToOldTableID() (*abstract.TableID, error)
  • func (dataObject *OracleDataObject) ToTablePart() (*abstract.TableDescription, error)
• type OracleDataObjects
  • func NewOracleDataObjects(database *schema.Database, filter base.DataObjectFilter) *OracleDataObjects
  • func (dataObjects *OracleDataObjects) Close()
  • func (dataObjects *OracleDataObjects) Database() *schema.Database
  • func (dataObjects *OracleDataObjects) Err() error
  • func (dataObjects *OracleDataObjects) Next() bool
  • func (dataObjects *OracleDataObjects) Object() (base.DataObject, error)
  • func (dataObjects *OracleDataObjects) ToOldTableMap() (abstract.TableMap, error)
• type TablePartRow

Functions

func NewParallelTableSource

func NewParallelTableSource(
	sqlxDB *sqlx.DB,
	splitTransaction *sqlx.Tx,
	config *oracle.OracleSource,
	position *common.LogPosition,
	table *schema.Table,
	logger log.Logger,
) (*oracleParallelTableSource, error)

func NewTableSource

func NewTableSource(
	sqlxDB *sqlx.DB,
	config *oracle.OracleSource,
	position *common.LogPosition,
	table *schema.Table,
	logger log.Logger,
) (*oracleTableSource, error)

Types

type OracleDataObject

type OracleDataObject struct {
	// contains filtered or unexported fields
}

func NewOracleDataObject

func NewOracleDataObject(table *schema.Table) *OracleDataObject

func (*OracleDataObject) Close

func (dataObject *OracleDataObject) Close()

func (*OracleDataObject) Err

func (dataObject *OracleDataObject) Err() error

func (*OracleDataObject) FullName

func (dataObject *OracleDataObject) FullName() string

func (*OracleDataObject) Name

func (dataObject *OracleDataObject) Name() string

func (*OracleDataObject) Next

func (dataObject *OracleDataObject) Next() bool

func (*OracleDataObject) Part

func (dataObject *OracleDataObject) Part() (base.DataObjectPart, error)

func (*OracleDataObject) Table

func (dataObject *OracleDataObject) Table() *schema.Table

func (*OracleDataObject) ToOldTableDescription

func (dataObject *OracleDataObject) ToOldTableDescription() (*abstract.TableDescription, error)

func (*OracleDataObject) ToOldTableID

func (dataObject *OracleDataObject) ToOldTableID() (*abstract.TableID, error)

func (*OracleDataObject) ToTablePart

func (dataObject *OracleDataObject) ToTablePart() (*abstract.TableDescription, error)

type OracleDataObjects

type OracleDataObjects struct {
	// contains filtered or unexported fields
}

func NewOracleDataObjects

func NewOracleDataObjects(database *schema.Database, filter base.DataObjectFilter) *OracleDataObjects

func (*OracleDataObjects) Close

func (dataObjects *OracleDataObjects) Close()

func (*OracleDataObjects) Database

func (dataObjects *OracleDataObjects) Database() *schema.Database

func (*OracleDataObjects) Err

func (dataObjects *OracleDataObjects) Err() error

func (*OracleDataObjects) Next

func (dataObjects *OracleDataObjects) Next() bool

func (*OracleDataObjects) Object

func (dataObjects *OracleDataObjects) Object() (base.DataObject, error)

func (*OracleDataObjects) ToOldTableMap

func (dataObjects *OracleDataObjects) ToOldTableMap() (abstract.TableMap, error)

type TablePartRow

type TablePartRow struct {
	WhereClause                string    `db:"WHERE_CLAUSE"`
	ExtentCount                int       `db:"EXTENT_COUNT"`
	OracleResultPartitionCount int       `db:"ORACLE_RESULT_PARTITION_COUNT"`
	CurrentSCN                 uint64    `db:"CURRENT_SCN"`
	CurrentTimestamp           time.Time `db:"CURRENT_TIMESTAMP"`
	MaxBytes                   string    `db:"MAX_BYTES"`
	MinBytes                   string    `db:"MIN_BYTES"`
}