easy_sql.sql_processor.backend.sql_dialect.bigquery

Module Contents

Classes

BqSqlDialect

class easy_sql.sql_processor.backend.sql_dialect.bigquery.BqSqlDialect(db, sql_expr)

Bases: easy_sql.sql_processor.backend.sql_dialect.SqlDialect

digraph inheritanced413a023d7 { bgcolor=transparent; rankdir=LR; size="8.0, 12.0"; "BqSqlDialect" [URL="#easy_sql.sql_processor.backend.sql_dialect.bigquery.BqSqlDialect",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" -> "BqSqlDialect" [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

• db (str) –

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

static contains_db(table_name)

Parameters

table_name (str) –

Return type

bool

create_db_sql(self, db)

Parameters

db (str) –

Return type

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

Return type

str

create_table_with_partitions_sql(self, table_name, cols, partitions)

Parameters

• table_name (str) –

• cols (List[Dict[str, sqlalchemy.types.TypeEngine]]) –

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

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

str

delete_pt_metadata_sql(self, table_name, partitions)

Parameters

• table_name (str) –

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

Return type

str

drop_db_sql(self, db)

Parameters

db (str) –

Return type

str

drop_table_sql(self, table)

Parameters

table (str) –

drop_view_sql(self, table)

Parameters

table (str) –

Return type

str

extract_partition_cols(self, native_partitions_sql_result)

get_dbs_sql(self)

Return type

str

get_tables_sql(self, db)

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

insert_pt_metadata_sql(self, table_name, partitions)

Parameters

• table_name (str) –

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

Return type

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)

support_native_partition(self)

Return type

bool

support_static_partition(self)

static transaction(statement)

Parameters

statement (str) –

Return type

str

use_db_sql(self, db)

Parameters

db (str) –

Return type

str