fetch

func CollectAndAssociateContext ¶

func CollectAndAssociateContext[P associer[C, P], C any](ctx context.Context, n string, args any, parents []P, rowto rowToFunc[C]) ([]P, int, error)

CollectAndAssociateContext queries child objects

Returns parents with associated components and the count of components.

If a component does not match an existing parent, skip to next component and search starting from last associated parent. Fails after 8 unassociated components.

Use this to query table columns, keys, etc.

func CollectMapContext ¶

func CollectMapContext(ctx context.Context, n string) (map[string]any, error)

func CollectObjectsContext ¶

func CollectObjectsContext[T any](ctx context.Context, n string, args any, rowto rowToFunc[T]) ([]T, error)

CollectObjectsContext accumulates rows

func CopyTables ¶

func CopyTables(p *dispatch.Plan, tables []catalog.Table, srcModel any)

CopyTables instanciates COPY operations for a list of tables

func CopyTask ¶

func CopyTask(source any, target catalog.Table, reqs []string) dispatch.Task

CopyTask instanciates a COPY operation for a table

Task weight is source table row count. Generates a COPY statement for each batch of rows. Use SetupExecute to configure query output.

func ForEachContext ¶

func ForEachContext(ctx context.Context, n string, args any, f func(*sql.Rows) error) (int, error)

func ForEachItemAssociateContext ¶

func ForEachItemAssociateContext[P associer[C, P], C any](ctx context.Context, parents []P, query func(P) string, rowto rowToFunc[C]) ([]P, int, error)

ForEachItemAssociateContext execute a query for each item

Use it to inspect extra information for item with per-item query like `SHOW CREATE`.

func QueryRowContext ¶

func QueryRowContext(ctx context.Context, n string, args any) *sql.Row

QueryRowContext executes a query that is expected to return a single row

Panics if connexion to database is not already established.

func Render ¶

func Render(name string, o any) string

Render execute an SQL template

func RestartIdentities ¶

func RestartIdentities(tables []catalog.Table, src any) dispatch.Task

RestartIdentities fetches identities start from source and generates ALTER COLUMN.

Returns nil if no tables have identity column.

Requires source connection in context from database.WithConnection.

func RestartSequences ¶

func RestartSequences(seqs []catalog.Sequence, src any) dispatch.Task

RestartSequences fetches sequences start from source and generates ALTER SEQUENCE.

Returns nil if no sequences are given. Group sequence restart by schema.

Requires catalog.FilterSchemas to be set with schemas containing sequences. Requires source connection in context from database.WithConnection.

func Setup ¶

func Setup(sqlFS fs.FS, f func(int) string, funcs template.FuncMap)

Setup initialize catalog inspection for a specific RDMS

Not calling Setup() before inspecting is a bug.

func Value ¶

func Value(path, from, to string) valueFactory

Value instanciates converters for a single column value.

If data does not requires conversion, copy to a new memory segment so that initial data can be freed.