mirror of
https://github.com/hanzo-ds/connect.git
synced 2026-10-30 20:31:24 +00:00
Joe SpadolaandGitHub
55dcd7db4c
* migrate from pylint to ruff * ruff format/lint switch over * add formatting commit * update changelog
84 lines
2.8 KiB
Python
84 lines
2.8 KiB
Python
"""
|
|
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."""
|
|
|
|
|
|
class Warning(Warning, ClickHouseError): # noqa: N818
|
|
"""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): # noqa: N818
|
|
"""Internal exception used to indicate the end of a ClickHouse query result stream."""
|
|
|
|
|
|
class StreamFailureError(Exception):
|
|
"""Stream failed unexpectedly"""
|