Function countSQLiteRows

internal/database/sqlite_to_postgres.go:508–518

(ctx context.Context, db *sql.DB, tables []string)

}

func countSQLiteRows(ctx context.Context, db *sql.DB, tables []string) (map[string]int64, error) {
	counts := make(map[string]int64, len(tables))
	for _, table := range tables {
		var count int64
		if err := db.QueryRowContext(ctx, "SELECT COUNT(*) FROM "+quoteIdent(table)).Scan(&count); err != nil {
			return nil, fmt.Errorf("count sqlite rows for %s: %w", table, err)
		}
		counts[table] = count
	}
	return counts, nil
}

func listPostgresTables(ctx context.Context, pool *pgxpool.Pool) (map[string]struct{}, error) {
	rows, err := pool.Query(ctx, `