Function normalize_postgres_url

scripts/migrate_sqlite_to_postgres.py:55–65

(value: str)

def normalize_postgres_url(value: str) -> str:
    raw = str(value or "").strip()
    if not raw:
        raise MigrationError("PostgreSQL 目标库 URL 不能为空")
    if raw.startswith("postgres://"):
        raw = "postgresql://" + raw[len("postgres://"):]
    if get_database_backend(raw) != "postgresql":
        raise MigrationError("目标库必须是 PostgreSQL 连接字符串")
    if raw.startswith("postgresql://"):
        return "postgresql+psycopg://" + raw[len("postgresql://"):]
    return raw


def chunked_rows(rows: Sequence[dict], chunk_size: int) -> Iterator[list[dict]]: