`airflow.providers.ydb.hooks._vendor.dbapi.cursor`¶

Module Contents¶

Classes¶

`YdbQuery`
`Cursor`
`AsyncCursor`

Functions¶

get_column_type(type_obj)

Attributes¶

airflow.providers.ydb.hooks._vendor.dbapi.cursor.logger[source]¶

airflow.providers.ydb.hooks._vendor.dbapi.cursor.get_column_type(type_obj)[source]¶

class airflow.providers.ydb.hooks._vendor.dbapi.cursor.YdbQuery[source]¶

yql_text: str[source]¶

parameters_types: Dict[str, Union[ydb.PrimitiveType, ydb.AbstractTypeBuilder]][source]¶

is_ddl: bool = False[source]¶

class airflow.providers.ydb.hooks._vendor.dbapi.cursor.Cursor(session_pool, tx_mode, tx_context=None, table_path_prefix='')[source]¶

property rowcount[source]¶

describe_table(abs_table_path)[source]¶

check_exists(abs_table_path)[source]¶

get_table_names(abs_dir_path)[source]¶

execute(operation, parameters=None)[source]¶

executemany(operation, seq_of_parameters)[source]¶

executescript(script)[source]¶

fetchone()[source]¶

fetchmany(size=None)[source]¶

fetchall()[source]¶

nextset()[source]¶

setinputsizes(sizes)[source]¶

setoutputsize(column=None)[source]¶

close()[source]¶

class airflow.providers.ydb.hooks._vendor.dbapi.cursor.AsyncCursor(session_pool, tx_mode, tx_context=None, table_path_prefix='')[source]¶

Bases: Cursor

Was this entry helpful?