1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
130
131
132
133
134
135
136
137
138
139
140
141
142
143
144
145
146
147
148
149
150
151
152
153
154
155
156
157
158
159
160
161
162
163
164
165
166
167
|
from _typeshed.dbapi import DBAPIConnection, DBAPICursor
from abc import abstractmethod
from collections.abc import Callable, Collection, Mapping
from typing import Any, ClassVar, overload
from ..exc import StatementError
from ..sql.compiler import Compiled as Compiled, IdentifierPreparer, TypeCompiler as TypeCompiler
from ..sql.ddl import DDLElement
from ..sql.elements import ClauseElement
from ..sql.functions import FunctionElement
from ..sql.schema import DefaultGenerator
from .base import Connection, Engine
from .cursor import CursorResult
from .url import URL
class Dialect:
# Sub-classes are required to have the following attributes:
name: str
driver: str
positional: bool
paramstyle: str
encoding: str
statement_compiler: Compiled
ddl_compiler: Compiled
server_version_info: tuple[Any, ...]
# Only available on supporting dialects:
# default_schema_name: str
execution_ctx_cls: ClassVar[type[ExecutionContext]]
execute_sequence_format: type[tuple[Any] | list[Any]]
preparer: IdentifierPreparer
supports_alter: bool
max_identifier_length: int
supports_sane_rowcount: bool
supports_sane_multi_rowcount: bool
preexecute_autoincrement_sequences: bool
implicit_returning: bool
colspecs: dict[Any, Any]
supports_default_values: bool
supports_sequences: bool
sequences_optional: bool
supports_native_enum: bool
supports_native_boolean: bool
dbapi_exception_translation_map: dict[Any, Any]
supports_statement_cache: bool
@abstractmethod
def create_connect_args(self, url: URL) -> None: ...
def initialize(self, connection) -> None: ...
def on_connect_url(self, url) -> Callable[[DBAPIConnection], object] | None: ...
def on_connect(self) -> Callable[[DBAPIConnection], object] | None: ...
# The following methods all raise NotImplementedError, but not all
# dialects implement all methods, which is why they can't be marked
# as abstract.
@classmethod
def type_descriptor(cls, typeobj) -> None: ...
def get_columns(self, connection, table_name, schema: Any | None = ..., **kw) -> None: ...
def get_pk_constraint(self, connection, table_name, schema: Any | None = ..., **kw) -> None: ...
def get_foreign_keys(self, connection, table_name, schema: Any | None = ..., **kw) -> None: ...
def get_table_names(self, connection, schema: Any | None = ..., **kw) -> None: ...
def get_temp_table_names(self, connection, schema: Any | None = ..., **kw) -> None: ...
def get_view_names(self, connection, schema: Any | None = ..., **kw) -> None: ...
def get_sequence_names(self, connection, schema: Any | None = ..., **kw) -> None: ...
def get_temp_view_names(self, connection, schema: Any | None = ..., **kw) -> None: ...
def get_view_definition(self, connection, view_name, schema: Any | None = ..., **kw) -> None: ...
def get_indexes(self, connection, table_name, schema: Any | None = ..., **kw) -> None: ...
def get_unique_constraints(self, connection, table_name, schema: Any | None = ..., **kw) -> None: ...
def get_check_constraints(self, connection, table_name, schema: Any | None = ..., **kw) -> None: ...
def get_table_comment(self, connection, table_name, schema: Any | None = ..., **kw) -> None: ...
def normalize_name(self, name) -> None: ...
def denormalize_name(self, name) -> None: ...
def has_table(self, connection, table_name, schema: Any | None = ..., **kw) -> None: ...
def has_index(self, connection, table_name, index_name, schema: Any | None = ...) -> None: ...
def has_sequence(self, connection, sequence_name, schema: Any | None = ..., **kw) -> None: ...
def do_begin(self, dbapi_connection) -> None: ...
def do_rollback(self, dbapi_connection) -> None: ...
def do_commit(self, dbapi_connection) -> None: ...
def do_close(self, dbapi_connection) -> None: ...
def do_set_input_sizes(self, cursor, list_of_tuples, context) -> None: ...
def create_xid(self) -> None: ...
def do_savepoint(self, connection, name) -> None: ...
def do_rollback_to_savepoint(self, connection, name) -> None: ...
def do_release_savepoint(self, connection, name) -> None: ...
def do_begin_twophase(self, connection, xid) -> None: ...
def do_prepare_twophase(self, connection, xid) -> None: ...
def do_rollback_twophase(self, connection, xid, is_prepared: bool = ..., recover: bool = ...) -> None: ...
def do_commit_twophase(self, connection, xid, is_prepared: bool = ..., recover: bool = ...) -> None: ...
def do_recover_twophase(self, connection) -> None: ...
def do_executemany(self, cursor, statement, parameters, context: Any | None = ...) -> None: ...
def do_execute(self, cursor, statement, parameters, context: Any | None = ...) -> None: ...
def do_execute_no_params(self, cursor, statement, parameters, context: Any | None = ...) -> None: ...
def is_disconnect(self, e, connection, cursor) -> None: ...
def connect(self, *cargs, **cparams) -> DBAPIConnection: ...
def reset_isolation_level(self, dbapi_conn) -> None: ...
def set_isolation_level(self, dbapi_conn, level) -> None: ...
def get_isolation_level(self, dbapi_conn) -> None: ...
def get_default_isolation_level(self, dbapi_conn) -> None: ...
@classmethod
def get_dialect_cls(cls, url): ...
@classmethod
def load_provisioning(cls) -> None: ...
@classmethod
def engine_created(cls, engine) -> None: ...
def get_driver_connection(self, connection) -> None: ...
class CreateEnginePlugin:
url: URL
def __init__(self, url: URL, kwargs) -> None: ...
def update_url(self, url) -> None: ...
def handle_dialect_kwargs(self, dialect_cls, dialect_args) -> None: ...
def handle_pool_kwargs(self, pool_cls, pool_args) -> None: ...
def engine_created(self, engine) -> None: ...
class ExecutionContext:
def create_cursor(self) -> None: ...
def pre_exec(self) -> None: ...
def get_out_parameter_values(self, out_param_names) -> None: ...
def post_exec(self) -> None: ...
def get_result_cursor_strategy(self, result) -> None: ...
def handle_dbapi_exception(self, e) -> None: ...
def should_autocommit_text(self, statement) -> None: ...
def lastrow_has_defaults(self) -> None: ...
def get_rowcount(self) -> None: ...
class Connectable:
@abstractmethod
def connect(self, **kwargs) -> Connection: ...
@property
def engine(self) -> Engine | None: ...
@abstractmethod
@overload
def execute(
self,
object_: ClauseElement | FunctionElement | DDLElement | DefaultGenerator | Compiled,
*multiparams: Mapping[str, Any],
**params: Any,
) -> CursorResult: ...
@abstractmethod
@overload
def execute(self, object_: str, *multiparams: Any | tuple[Any, ...] | Mapping[str, Any], **params: Any) -> CursorResult: ...
@abstractmethod
@overload
def scalar(
self,
object_: ClauseElement | FunctionElement | DDLElement | DefaultGenerator | Compiled,
*multiparams: Mapping[str, Any],
**params: Any,
) -> Any: ...
@abstractmethod
@overload
def scalar(self, object_: str, *multiparams: Any | tuple[Any, ...] | Mapping[str, Any], **params: Any) -> Any: ...
class ExceptionContext:
connection: Connection | None
engine: Engine | None
cursor: DBAPICursor | None
statement: str | None
parameters: Collection[Any] | None
original_exception: BaseException | None
sqlalchemy_exception: StatementError | None
chained_exception: BaseException | None
execution_context: ExecutionContext | None
is_disconnect: bool | None
invalidate_pool_on_disconnect: bool
class AdaptedConnection:
@property
def driver_connection(self): ...
|
