更新时间:2026-07-03 GMT+08:00
分享

Table APIs

insert(data, overwrite=False)

描述:用于将Dataset插入到数据库表中。

输入参数:

  • data (dataset.Dataset):要插入的Dataset对象,必须是aura_frame.multimodal.dataset.Dataset类型。
  • overwrite (bool):是否覆盖已存在的数据,默认为False。

返回值类型:None

show(limit=10)

描述:用于显示表的前N行数据。

输入参数:

limit(int) - 限制输出的行数,默认为10。

返回值类型:None

to_dataset()

描述:将当前表对象转换为Dataset对象。

输入参数:无

返回值类型:Dataset

add_columns(new_cols)

描述:向表中添加一个或多个新列。

输入参数:

new_cols (Dict[str, str]) :要添加的列的字典,键为列名(str),值为列类型(str)。

返回值类型:None

drop_columns(*columns)

描述:用于从表中删除一个或多个列。

输入参数:

*columns (str):要删除的列名,可以是多个字符串参数。

返回值类型:None

alter_column_type(column_name, new_type)

描述:修改表中指定列的数据类型。

输入参数:

  • column_name (str) :要修改类型的列名。
  • new_type (str) : 新的数据类型名称。

返回值类型:None

rename_column(column_name, new_name)

描述:重命名表中的列名。

输入参数:

  • column_name (str) : 当前列名。
  • new_name (str) : 新列名。

返回值类型:None

delete(where)

描述:从表中删除满足指定条件的数据。

输入参数:

where (str) - SQL WHERE子句:用于指定删除条件。

返回值类型:None

update(values_expr, where)

描述:更新表中满足指定条件的行数据。

输入参数:

  • values_expr (Dict[str, ValueExpression]) :键为列名(str),值为用于更新该列的表达式(ValueExpression)。
  • where (Union[ir.BooleanValue, list[ir.BooleanValue], IfAnyAll, None]) :用于过滤要更新的行的条件。如果为None,则更新所有行。

返回值类型:None

create_table(name, /, *, schema, table_format, database=None, temp=False, external=False, overwrite=False, if_not_exists=False, partition_by=None, table_properties=None, location=None)

描述:在指定数据库中创建一个新表。

输入参数:

  • name (str) - 表的名称。
  • schema (ibis.Schema) :表的定义。
  • table_format (str) :表的存储格式。
  • database (Optional[str]) :要创建表的数据库名称。如果未指定,则使用默认数据库。
  • temp (bool) :如果为True,则创建临时表。
  • external (bool):如果为True,则创建外部表。
  • overwrite (bool) :如果为True,则在表已存在时覆盖原表。
  • if_not_exists (bool):如果为True,则仅在表不存在时创建表。
  • partition_by (Optional[ibis.Schema]) :用于对表进行分区的架构。
  • table_properties (Optional[dict]) :表的其他属性。
  • location (Optional[str]):表数据存储的位置。

返回值类型: Dataset。

delete_table(name, /, *, database=None, if_it_exists=False)

描述:从数据库中删除指定的Dataset。

输入参数:

  • name (str) :要删除的表的名称。
  • database (Optional[str]) :要删除表的数据库名称。如果未提供,则使用默认数据库。
  • if_it_exists (bool) :如果设置为True,则仅在表存在时删除,避免因不存在而报错。

返回值类型 :str。

describe_table(name, /, *, database=None)

描述:描述指定数据库中的表。

输入参数:

  • name (str) :函数名称。
  • database (Optional[str]) :表所在的数据库名称。

返回值类型:str,表的元数据信息。

drop_table(name, *, database=None, force=False)

描述:从指定数据库中删除一个表。

输入参数:

  • name (str) :要删除的表的名称。
  • database (Optional[str]) :要删除表的数据库名称。如果未提供,则使用默认数据库。
  • force (bool) :如果设置为True,则即使表包含数据也会强制删除。默认为False。

返回值类型 :None。

list_tables(database=None)

描述:列出指定数据库或默认数据库中的所有表。

输入参数:

database (Optional[str]) :要列出表的数据库名称。如果为None,则使用默认数据库。

返回值类型:list[tuple],包含表名称的元组列表。

open_table(name, *, database=None)

描述:打开指定数据库中的表。

输入参数:

  • name (str) :要打开的表的名称。
  • database (Optional[str]) :包含该表的数据库名称。如果未提供,则使用默认数据库。

返回值类型 :Table。

相关文档