ipad.database package

meta private:

class ipad.database.BaseExt

基类：object

classmethod as_df_types()

ipad.database.uri()

ipad.database.engine()

ipad.database.read(*, schema, query, types=[], cur=None)

执行 sql 语句并回读数据。

types: 可选显式指定返回列的类型。支持输入

表 (如 database.stock.stock_in_day): 使用表中所有列的类型
列 (如 database.stock.stock_in_day.high): 使用给定列的类型
名称到 py 类型映射 (如 {“col1”: float, “col2”: str}): str, int, float, bool
名称到 df 类型映射 (如 {“col1”: polars.Int32, “col2”: polars.Boolean})
上述内容的列表 (如 [database.stock.stock_in_day, {“col1”: float}]): 重复项取最后出现的类型

例：

import ipad.database
import ipad.stock

df = ipad.read(
    schema="stock",
    query="""
    select open,high,close,low,stock_code,candle_end_time,hushen300,zhongzheng500
    from stock_in_day
    where candle_end_time
        between '2022-01-01' and '2022-01-09'
    """,
    types=ipad.stock.stock_in_day,
)

print(df)

参数:

schema (Literal['b'] | ~typing.Literal['stock']) –
query (str) –
types (type[BaseExt] | Column | dict[str, type[DataType] | type[int] | type[float] | type[str] | type[bool]] | list[type[BaseExt] | Column | dict[str, type[DataType] | type[int] | type[float] | type[str] | type[bool]]]) –
cur (DBAPICursor | None) –

ipad.database.write(table, df, *, cur=None)

写入 DataFrame 到数据库。需手动确保输入各列类型与数据库兼容

参数:

table (Any) –
df (DataFrame) –
cur (DBAPICursor | None) –

ipad.database package

Submodules