mirror of
https://github.com/hanzo-ds/driver.git
synced 2026-10-30 20:32:40 +00:00
zeekay
eb74c996a6
Imports read `datastore_driver`, distribution `datastore-driver`, so nothing has to import another product's name to talk to Hanzo Datastore. Cut from upstream 0.2.9 — the version this stack already ran — rather than from upstream HEAD, so it is a PURE RENAME with no behaviour change. Forking from HEAD would have dragged versions along with the name (connect alone jumped 0.8.17 -> 1.6.0, a major), which is a different and much riskier change wearing a rename's clothes. X-ClickHouse-* headers are untouched: they are wire protocol the server sends and expects, and a different token shape from the module name.
27 lines
717 B
Python
27 lines
717 B
Python
from .errors import ServerException
|
|
from .reader import read_binary_str, read_binary_uint8, read_binary_int32
|
|
|
|
|
|
def read_exception(buf, additional_message=None):
|
|
code = read_binary_int32(buf)
|
|
name = read_binary_str(buf)
|
|
message = read_binary_str(buf)
|
|
stack_trace = read_binary_str(buf)
|
|
has_nested = bool(read_binary_uint8(buf))
|
|
|
|
new_message = ''
|
|
|
|
if additional_message:
|
|
new_message += additional_message + '. '
|
|
|
|
if name != 'DB::Exception':
|
|
new_message += name + ". "
|
|
|
|
new_message += message + ". Stack trace:\n\n" + stack_trace
|
|
|
|
nested = None
|
|
if has_nested:
|
|
nested = read_exception(buf)
|
|
|
|
return ServerException(new_message, code, nested=nested)
|