Documentation ¶
Index ¶
- Constants
- func CreateTable(ctx context.Context, dbOpt dbutil.DBOpt, opt offline.CreateTableOpt) error
- func DoExport(ctx context.Context, dbOpt dbutil.DBOpt, opt DoExportOpt) (*types.ExportResult, error)
- func DoJoin(ctx context.Context, dbOpt dbutil.DBOpt, opt DoJoinOpt) (*types.JoinResult, error)
- func Export(ctx context.Context, db *sqlx.DB, opt offline.ExportOpt, ...) (*types.ExportResult, error)
- func Import(ctx context.Context, db *sqlx.DB, opt offline.ImportOpt, loadData LoadData, ...) (int64, error)
- func Join(ctx context.Context, db *sqlx.DB, opt offline.JoinOpt, ...) (*types.JoinResult, error)
- func Push(ctx context.Context, dbOpt dbutil.DBOpt, pushOpt offline.PushOpt) error
- func Snapshot(ctx context.Context, dbOpt dbutil.DBOpt, opt offline.SnapshotOpt) error
- func SqlxTableSchema(ctx context.Context, db *sqlx.DB, backend types.BackendType, rows *sqlx.Rows, ...) (*types.DataTableSchema, error)
- type DoExportOpt
- type DoJoinOpt
- type LoadData
- type QueryExportResults
- type QueryResults
- type QueryTableTimeRange
Constants ¶
View Source
const CDC_JOIN_QUERY = `` /* 777-byte string literal not displayed */
View Source
const EXPORT_QUERY = `` /* 934-byte string literal not displayed */
View Source
const (
InsertBatchSize = 20
)
View Source
const JOIN_QUERY = `` /* 379-byte string literal not displayed */
View Source
const READ_JOIN_RESULT_QUERY = `` /* 438-byte string literal not displayed */
View Source
const SNAPSHOT_QUERY = `` /* 1202-byte string literal not displayed */
View Source
const UNION_ENTITY_QUERY = `
INSERT INTO {{ qt .TableName }}
{{ snapshot .SnapshotTables }}
{{ cdc .CdcTables }}
`
Variables ¶
This section is empty.
Functions ¶
func CreateTable ¶
func DoExport ¶ added in v0.1.0
func DoExport(ctx context.Context, dbOpt dbutil.DBOpt, opt DoExportOpt) (*types.ExportResult, error)
func SqlxTableSchema ¶
func SqlxTableSchema(ctx context.Context, db *sqlx.DB, backend types.BackendType, rows *sqlx.Rows, opt offline.TableSchemaOpt) (*types.DataTableSchema, error)
SqlxTableSchema returns the schema of the given table.
Types ¶
type DoExportOpt ¶ added in v0.1.0
type DoExportOpt struct { offline.ExportOpt QueryResults QueryExportResults }
type DoJoinOpt ¶
type DoJoinOpt struct { offline.JoinOpt QueryResults QueryResults QueryTableTimeRange QueryTableTimeRange ReadJoinResultQuery string }
type QueryExportResults ¶ added in v0.1.0
type QueryResults ¶
type QueryResults func(ctx context.Context, dbOpt dbutil.DBOpt, query string, header dbutil.ColumnList, dropTableNames []string, backendType types.BackendType) (*types.JoinResult, error)
type QueryTableTimeRange ¶ added in v0.1.0
Click to show internal directories.
Click to hide internal directories.