# -*- coding: utf-8 -*-
r"""标准仓读写接口（**组件接入点：TiDB community**）。

现在：仓库是本地 parquet 目录（`outputs/<场>/windscada/*.parquet`）。
目标：同一接口下新增 TiDB 实现（表 ↔ 仓映射、事务边界在这一层），算法层不受影响。

P0 只立契约，**没有任何实现**（默认走现有本地实现，故零行为变化）。
"""
from __future__ import annotations

from abc import ABC, abstractmethod


class Warehouse(ABC):
    """标准仓：按"表名"读写产物（与存储介质无关）。"""

    @abstractmethod
    def list_tables(self) -> list[str]: ...

    @abstractmethod
    def read_table(self, name: str): ...

    @abstractmethod
    def write_table(self, name: str, data, *, overwrite: bool = True) -> None: ...

    @abstractmethod
    def exists(self, name: str) -> bool: ...