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
|
"""
The driver exception classes here include all named exceptions required by th DB API 2.0 specification. It's not clear
how useful that naming convention is, but the convention is used for potential improved compatibility with other
libraries. In most cases docstring are taken from the DBIApi 2.0 documentation
"""
class ClickHouseError(Exception):
"""Exception related to operation with ClickHouse."""
# pylint: disable=redefined-builtin
class Warning(Warning, ClickHouseError):
"""Exception raised for important warnings like data truncations
while inserting, etc."""
class Error(ClickHouseError):
"""Exception that is the base class of all other error exceptions
(not Warning)."""
class InterfaceError(Error):
"""Exception raised for errors that are related to the database
interface rather than the database itself."""
class DatabaseError(Error):
"""Exception raised for errors that are related to the
database."""
class DataError(DatabaseError):
"""Exception raised for errors that are due to problems with the
processed data like division by zero, numeric value out of range,
etc."""
class OperationalError(DatabaseError):
"""Exception raised for errors that are related to the database's
operation and not necessarily under the control of the programmer,
e.g. an unexpected disconnect occurs, the data source name is not
found, a transaction could not be processed, a memory allocation
error occurred during processing, etc."""
class IntegrityError(DatabaseError):
"""Exception raised when the relational integrity of the database
is affected, e.g. a foreign key check fails, duplicate key,
etc."""
class InternalError(DatabaseError):
"""Exception raised when the database encounters an internal
error, e.g. the cursor is not valid anymore, the transaction is
out of sync, etc."""
class ProgrammingError(DatabaseError):
"""Exception raised for programming errors, e.g. table not found
or already exists, syntax error in the SQL statement, wrong number
of parameters specified, etc."""
class NotSupportedError(DatabaseError):
"""Exception raised in case a method or database API was used
which is not supported by the database, e.g. requesting a
.rollback() on a connection that does not support transaction or
has transactions turned off."""
class StreamClosedError(ProgrammingError):
"""Exception raised when a stream operation is executed on a closed stream."""
def __init__(self):
super().__init__('Executing a streaming operation on a closed stream')
class StreamCompleteException(Exception):
""" Internal exception used to indicate the end of a ClickHouse query result stream."""
class StreamFailureError(Exception):
""" Stream failed unexpectedly """
|
