mirror of
https://github.com/hanzo-ds/connect.git
synced 2026-10-30 20:31:24 +00:00
Joe SpadolaandGitHub
19ffd53f86
* implement native async client * add pylint exceptions * linting * improve test config setup * fix some tests * enable log tables on startup * improve error handling * linting * fix deprecation warning in aiohttp * error handling * separate sync/async stream failure tests * more error handling issues * linting * test updates and improvements * test adjustments * increase async stream buffer size * don't parallelize cloud tests * apply consistency settings to client factory fixture * up cloud par to 4 * enforce sequential consistency in helper * update enable_cleanup_closed vers * add conn abort to wrong port assertion * small test refactor * more consistency * add deadlock check in async queue * enforce consistent use of async iter stream consumption * linting * DO materialize non-streaming queries * accept either concurrent session error * update async client to always reset context * add pipelining to arrow methods * feature parity with recent sync client changes * fix jwt test after bad merge conflict resolution * 0.12.0rc1 release prep * fix assertion in racy test * clean up streaming source on exception * linting * more linting * deprecate legacy async client and replace with async native * update changelog
12 lines
640 B
Python
12 lines
640 B
Python
from clickhouse_connect.driver import Client
|
|
|
|
|
|
def test_uint64_format(param_client: Client, call):
|
|
# Default should be unsigned
|
|
result = call(param_client.query, "SELECT toUInt64(9523372036854775807) as value")
|
|
assert result.result_set[0][0] == 9523372036854775807
|
|
result = call(param_client.query, "SELECT toUInt64(9523372036854775807) as value", query_formats={"UInt64": "signed"})
|
|
assert result.result_set[0][0] == -8923372036854775809
|
|
result = call(param_client.query, "SELECT toUInt64(9523372036854775807) as value", query_formats={"UInt64": "native"})
|
|
assert result.result_set[0][0] == 9523372036854775807
|