(connection: Connection, plan: TablePlan)
| 129 | |
| 130 | |
| 131 | def fetch_source_rows(connection: Connection, plan: TablePlan) -> list[dict]: |
| 132 | stmt = select(*(plan.source_table.c[column_name] for column_name in plan.columns)) |
| 133 | result = connection.execute(stmt) |
| 134 | return [dict(row._mapping) for row in result] |
| 135 | |
| 136 | |
| 137 | def copy_table( |