easy_sql.sql_processor.backend.sql_dialect.clickhouse

Module Contents

Classes

ChSqlDialect

class easy_sql.sql_processor.backend.sql_dialect.clickhouse.ChSqlDialect(sql_expr, partitions_table_name)

Bases: easy_sql.sql_processor.backend.sql_dialect.SqlDialect

digraph inheritanced62305c69f { bgcolor=transparent; rankdir=LR; size="8.0, 12.0"; "ChSqlDialect" [URL="#easy_sql.sql_processor.backend.sql_dialect.clickhouse.ChSqlDialect",fillcolor=white,fontname="Vera Sans, DejaVu Sans, Liberation Sans, Arial, Helvetica, sans",fontsize=10,height=0.25,shape=box,style="setlinewidth(0.5),filled",target="_top"]; "SqlDialect" -> "ChSqlDialect" [arrowsize=0.5,style="setlinewidth(0.5)"]; "SqlDialect" [URL="../index.html#easy_sql.sql_processor.backend.sql_dialect.SqlDialect",fillcolor=white,fontname="Vera Sans, DejaVu Sans, Liberation Sans, Arial, Helvetica, sans",fontsize=10,height=0.25,shape=box,style="setlinewidth(0.5),filled",target="_top"]; }

Parameters

• sql_expr (easy_sql.sql_processor.backend.sql_dialect.SqlExpr) –

• partitions_table_name (str) –

create_db_sql(self, db)

Parameters

db (str) –

create_partition_automatically(self)

create_pt_meta_table_sql(self, db)

Parameters

db (str) –

Return type

str

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

create_table_sql(self, table_name, select_sql)

Parameters

• table_name (str) –

• select_sql (str) –

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]) –

create_temp_table_schema_as_target(self)

create_temp_table_with_schema_sql(self, temp_table_name)

Parameters

temp_table_name (str) –

create_view_sql(self, table_name, select_sql)

Parameters

• table_name (str) –

• select_sql (str) –

Return type

str

delete_partition_sql(self, table_name, partitions)

Parameters

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

Return type

List[str]

drop_db_sql(self, db)

Parameters

db (str) –

Return type

List[str]

drop_table_sql(self, table)

Parameters

table (str) –

Return type

List[str]

drop_view_sql(self, table)

Parameters

table (str) –

Return type

str

extract_partition_cols(self, native_partitions_sql_result)

Parameters

native_partitions_sql_result (sqlalchemy.engine.ResultProxy) –

Return type

List[str]

get_dbs_sql(self)

Return type

str

get_tables_sql(self, db)

Parameters

db (str) –

Return type

str

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

List[str]

insert_pt_metadata_sql(self, table_name, partitions)

Parameters

• table_name (str) –

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

Return type

str

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]

native_partitions_sql(self, table_name)

Parameters

table_name (str) –

Return type

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

rename_table_db_sql(self, table_name, schema)

Parameters

• table_name (str) –

• schema (str) –

rename_table_sql(self, from_table, to_table)

Parameters

• from_table (str) –

• to_table (str) –

Return type

str

rename_view_sql(self, from_table, to_table)

Parameters

• from_table (str) –

• to_table (str) –

Return type

str

support_move_individual_partition(self)

Return type

bool

support_native_partition(self)

Return type

bool

support_static_partition(self)

use_db_sql(self, db)

Parameters

db (str) –