(ctx context.Context, tx pgx.Tx)
| 318 | } |
| 319 | |
| 320 | func commitImportTx(ctx context.Context, tx pgx.Tx) error { |
| 321 | if err := tx.Commit(ctx); err != nil { |
| 322 | return fmt.Errorf("commit postgres import: %w", err) |
| 323 | } |
| 324 | return nil |
| 325 | } |
| 326 | |
| 327 | func buildDryRunReport(ctx context.Context, pool *pgxpool.Pool, tables []string, sqliteCounts map[string]int64) (*SQLiteToPostgresMigrationReport, error) { |
| 328 | pgTables, err := listPostgresTables(ctx, pool) |
no test coverage detected