Databend Driver Python Binding
Project description
databend-driver
Build
cd bindings/python
maturin develop
Usage
Blocking
from databend_driver import BlockingDatabendClient
client = BlockingDatabendClient('databend+http://root:root@localhost:8000/?sslmode=disable')
conn = client.get_conn()
conn.exec(
"""
CREATE TABLE test (
i64 Int64,
u64 UInt64,
f64 Float64,
s String,
s2 String,
d Date,
t DateTime
)
"""
)
rows = conn.query_iter("SELECT * FROM test")
for row in rows:
print(row.values())
Asyncio
import asyncio
from databend_driver import AsyncDatabendClient
async def main():
client = AsyncDatabendClient('databend+http://root:root@localhost:8000/?sslmode=disable')
conn = await client.get_conn()
await conn.exec(
"""
CREATE TABLE test (
i64 Int64,
u64 UInt64,
f64 Float64,
s String,
s2 String,
d Date,
t DateTime
)
"""
)
rows = await conn.query_iter("SELECT * FROM test")
async for row in rows:
print(row.values())
asyncio.run(main())
Type Mapping
General Data Types
Databend | Python |
---|---|
BOOLEAN |
bool |
TINYINT |
int |
SMALLINT |
int |
INT |
int |
BIGINT |
int |
FLOAT |
float |
DOUBLE |
float |
DECIMAL |
decimal.Decimal |
DATE |
datetime.date |
TIMESTAMP |
datetime.datetime |
VARCHAR |
str |
BINARY |
bytes |
Semi-Structured Data Types
Databend | Python |
---|---|
ARRAY |
list |
TUPLE |
tuple |
MAP |
dict |
VARIANT |
str |
BITMAP |
str |
GEOMETRY |
str |
Note: VARIANT
is a json encoded string. Example:
CREATE TABLE example (
data VARIANT
);
INSERT INTO example VALUES ('{"a": 1, "b": "hello"}');
row = await conn.query_row("SELECT * FROM example limit 1;")
data = row.values()[0]
value = json.loads(data)
print(value)
APIs
AsyncDatabendClient
class AsyncDatabendClient:
def __init__(self, dsn: str): ...
async def get_conn(self) -> AsyncDatabendConnection: ...
AsyncDatabendConnection
class AsyncDatabendConnection:
async def info(self) -> ConnectionInfo: ...
async def version(self) -> str: ...
async def exec(self, sql: str) -> int: ...
async def query_row(self, sql: str) -> Row: ...
async def query_iter(self, sql: str) -> RowIterator: ...
async def stream_load(self, sql: str, data: list[list[str]]) -> ServerStats: ...
BlockingDatabendClient
class BlockingDatabendClient:
def __init__(self, dsn: str): ...
def get_conn(self) -> BlockingDatabendConnection: ...
BlockingDatabendConnection
class BlockingDatabendConnection:
def info(self) -> ConnectionInfo: ...
def version(self) -> str: ...
def exec(self, sql: str) -> int: ...
def query_row(self, sql: str) -> Row: ...
def query_iter(self, sql: str) -> RowIterator: ...
def stream_load(self, sql: str, data: list[list[str]]) -> ServerStats: ...
Row
class Row:
def values(self) -> tuple: ...
RowIterator
class RowIterator:
def schema(self) -> Schema: ...
def __iter__(self) -> RowIterator: ...
def __next__(self) -> Row: ...
def __aiter__(self) -> RowIterator: ...
async def __anext__(self) -> Row: ...
Field
class Field:
@property
def name(self) -> str: ...
@property
def data_type(self) -> str: ...
Schema
class Schema:
def fields(self) -> list[Field]: ...
ServerStats
class ServerStats:
@property
def total_rows(self) -> int: ...
@property
def total_bytes(self) -> int: ...
@property
def read_rows(self) -> int: ...
@property
def read_bytes(self) -> int: ...
@property
def write_rows(self) -> int: ...
@property
def write_bytes(self) -> int: ...
@property
def running_time_ms(self) -> float: ...
ConnectionInfo
class ConnectionInfo:
@property
def handler(self) -> str: ...
@property
def host(self) -> str: ...
@property
def port(self) -> int: ...
@property
def user(self) -> str: ...
@property
def database(self) -> str | None: ...
@property
def warehouse(self) -> str | None: ...
Development
cd tests
make up
cd bindings/python
pipenv install --dev
pipenv run maturin develop
pipenv run behave tests/*
Project details
Release history Release notifications | RSS feed
Download files
Download the file for your platform. If you're not sure which to choose, learn more about installing packages.
Source Distributions
No source distribution files available for this release.See tutorial on generating distribution archives.
Built Distributions
Close
Hashes for databend_driver-0.20.1-cp37-abi3-win_amd64.whl
Algorithm | Hash digest | |
---|---|---|
SHA256 | 089f19c729e766a12796f14e384350cdc39560bb4976952ee8b867aa326c80c5 |
|
MD5 | 189dd8ea2638e3c66882767f96c14eec |
|
BLAKE2b-256 | 5551d2c04e8b04aa1d284b2331d3a80f17a371de67e03a4557181c007580b0e5 |
Close
Hashes for databend_driver-0.20.1-cp37-abi3-manylinux_2_28_aarch64.whl
Algorithm | Hash digest | |
---|---|---|
SHA256 | c0546d1d829f9777fd1e5ab01789ed74b62d4ce95d012732d93353b243c09702 |
|
MD5 | 42df02981308e8c0c227986d11664743 |
|
BLAKE2b-256 | c2f81fe0269b4d3b748987cf9a145feebd76243c506614bf9a8fdbe9818d9d4c |
Close
Hashes for databend_driver-0.20.1-cp37-abi3-manylinux_2_17_x86_64.manylinux2014_x86_64.whl
Algorithm | Hash digest | |
---|---|---|
SHA256 | d3e028c81e4d2e8809daf520680615bc9ac51fb098c5b56ce78f5d450e02f68b |
|
MD5 | e6532de7011d28ec9e387c1dcf55ba91 |
|
BLAKE2b-256 | 2561e3b26b6c087571d97d65042f4d6f057a8f62bcc2b5a201f1002f471143da |
Close
Hashes for databend_driver-0.20.1-cp37-abi3-macosx_11_0_arm64.whl
Algorithm | Hash digest | |
---|---|---|
SHA256 | c3ab36a2400862f3fcfde06999e332c923bd53430e31b0caa682e93a64cf6008 |
|
MD5 | c97ad9ac88b3b51e9958ed81b36ccb1f |
|
BLAKE2b-256 | 203fccdb1f811d8edb3e469365bcc27905b3b2197ea42c6076b73b649766854e |
Close
Hashes for databend_driver-0.20.1-cp37-abi3-macosx_10_12_x86_64.whl
Algorithm | Hash digest | |
---|---|---|
SHA256 | 1b19fd074ee6b187d974e3668559e9c48b70c15f83a25b7379250da85696d877 |
|
MD5 | c8232bf336ffa9c96f6efa147ee4816a |
|
BLAKE2b-256 | 02050e09479567629e5af611980bed0361d62fe3946721a317587757bdbe2106 |