easy_sql.sql_processor.backend.sql_dialect

Submodules

• easy_sql.sql_processor.backend.sql_dialect.bigquery
• easy_sql.sql_processor.backend.sql_dialect.clickhouse
• easy_sql.sql_processor.backend.sql_dialect.postgres

Package Contents

Classes

SqlDialect
SqlExpr

class easy_sql.sql_processor.backend.sql_dialect.SqlDialect(sql_expr)

Parameters

sql_expr (SqlExpr) –

convert_pt_col_expr(self, all_cols, partition_cols)

Parameters

• all_cols (List[str]) –

• partition_cols (List[str]) –

Return type

List[str]

abstract create_db_sql(self, db)

Parameters

db (str) –

Return type

str

abstract create_partition_automatically(self)

Return type

bool

abstract create_partition_sql(self, target_table_name, partitions, if_not_exists=False)

Parameters

• target_table_name (str) –

• partitions (List[easy_sql.sql_processor.backend.base.Partition]) –

• if_not_exists (bool) –

Return type

str

abstract create_partitions_with_data_sqls(self, source_table_name, target_table_name, col_names, partitions)

Parameters

• source_table_name (str) –

• target_table_name (str) –

• col_names (List[str]) –

• partitions (List[List[easy_sql.sql_processor.backend.base.Partition]]) –

abstract create_pt_meta_table_sql(self, db)

Parameters

db (str) –

Return type

str

abstract create_table_like_sql(self, target_table_name, source_table_name, partitions)

Parameters

• target_table_name (str) –

• source_table_name (str) –

• partitions (List[easy_sql.sql_processor.backend.base.Partition]) –

Return type

str

abstract create_table_sql(self, table_name, select_sql)

Parameters

• table_name (str) –

• select_sql (str) –

Return type

str

abstract create_table_with_partitions_sql(self, table_name, cols, partitions)

Parameters

• table_name (str) –

• cols (List[Dict]) –

• partitions (List[easy_sql.sql_processor.backend.base.Partition]) –

abstract create_view_sql(self, table_name, select_sql)

Parameters

• table_name (str) –

• select_sql (str) –

Return type

str

abstract delete_partition_sql(self, table_name, partitions)

Parameters

partitions (List[easy_sql.sql_processor.backend.base.Partition]) –

Return type

Union[str, List[str]]

abstract delete_pt_metadata_sql(self, table_name, partitions)

Parameters

• table_name (str) –

• partitions (List[easy_sql.sql_processor.backend.base.Partition]) –

Return type

str

abstract drop_db_sql(self, db)

Parameters

db (str) –

Return type

Union[str, List[str]]

abstract drop_table_sql(self, table)

Parameters

table (str) –

Return type

str

abstract drop_view_sql(self, table)

Parameters

table (str) –

Return type

str

abstract get_dbs_sql(self)

Return type

str

abstract get_tables_sql(self, db)

Return type

str

abstract insert_data_sql(self, table_name, col_names_expr, select_sql, partitions)

Parameters

• table_name (str) –

• col_names_expr (str) –

• select_sql (str) –

• partitions (List[easy_sql.sql_processor.backend.base.Partition]) –

Return type

Union[str, List[str]]

abstract insert_pt_metadata_sql(self, table_name, partitions)

Parameters

• table_name (str) –

• partitions (List[easy_sql.sql_processor.backend.base.Partition]) –

Return type

str

abstract move_data_sql(self, target_table_name, temp_table_name, partitions)

Parameters

• target_table_name (str) –

• temp_table_name (str) –

• partitions (List[easy_sql.sql_processor.backend.base.Partition]) –

Return type

List[str]

abstract native_partitions_sql(self, table_name)

Parameters

table_name (str) –

Return type

Tuple[str, Callable[[sqlalchemy.engine.ResultProxy], List[str]]]

abstract rename_table_db_sql(self, table_name, schema)

Parameters

• table_name (str) –

• schema (str) –

abstract rename_table_sql(self, from_table, to_table)

Parameters

• from_table (str) –

• to_table (str) –

Return type

str

abstract rename_view_sql(self, from_table, to_table)

Parameters

• from_table (str) –

• to_table (str) –

Return type

str

abstract support_move_individual_partition(self)

Return type

bool

abstract support_native_partition(self)

Return type

bool

abstract support_static_partition(self)

Return type

bool

abstract use_db_sql(self, db)

Parameters

db (str) –

Return type

str

class easy_sql.sql_processor.backend.sql_dialect.SqlExpr(value_to_sql_expr=None, column_sql_type_converter=None, partition_col_converter=None, partition_value_converter=None, partition_expr=None)

Parameters

• value_to_sql_expr (Optional[Callable[[Any], Optional[str]]]) –

• column_sql_type_converter (Optional[Callable[[str, str, sqlalchemy.types.TypeEngine], Optional[str]]]) –

• partition_col_converter (Optional[Callable[[str], str]]) –

• partition_value_converter (Optional[Callable[[str, str], Any]]) –

• partition_expr (Optional[Callable[[str, str], str]]) –

bigquery_partition_expr(self, partition_col)

Parameters

partition_col (str) –

Return type

str

convert_partition_col(self, partition_col)

Parameters

partition_col (str) –

Return type

str

convert_partition_value(self, partition_col, value)

Parameters

• partition_col (str) –

• value (str) –

Return type

Any

for_bigquery_type(self, col_name, col_type)

Parameters

• col_name (str) –

• col_type (Union[str, sqlalchemy.types.TypeEngine]) –

Return type

str

for_value(self, value)

Parameters

value (Union[str, int, float, datetime.datetime, datetime.date]) –

Return type

str