cdbc 0.0.12

Common Database Connector

Common Database Connector

Cache / Redis

from cdbc.cache import redis_connection_pool as redis_pool

redis_host = 'redis'
redis_port = 15603
redis_db = 0

_pool = redis_pool(redis_host=redis_host, redis_port=redis_port, redis_db=redis_db)

Samples

redis_host = 'redis'
redis_port = 6379
redis_db = 1
_pool = redis_connection_pool(redis_host=redis_host, redis_port=redis_port, redis_db=redis_db)

_kvs = get_all_kvs(pool=_pool)

SQL / PostgreSQL

import cdbc.postgresql

host = 'postgresql'
database = 'test'
port = 5432
user = 'test-user'
password = 'test-passsword'
_conn = conn(host=host, port=port, database=database, user=user, password=password)

Samples

### Select

n = 1
while n < 200:
    sql = 'select count(*) from table1'
    _conn = conn(host=host, port=port, database=database, user=user, password=password)
    _cursor = _conn.cursor()
    select(cursor=_cursor,sql=sql)
    n = n + 1
    time.sleep(1)

### Insert

import random
import string

_conn = conn(host=host, port=port, database=database, user=user, password=password)

table = 'sample'
columns = 'col1, col2, col3'

for _ in range(100):
    value1 = ''.join([random.choice(string.ascii_lowercase + string.digits) for _n in range(10)])
    value2 = ''.join([random.choice(string.ascii_lowercase + string.digits) for _n in range(10)])
    k = ''.join([random.choice(string.ascii_lowercase + string.digits) for _n in range(5)])
    v = ''.join([random.choice(string.ascii_lowercase + string.digits) for _n in range(5)])
    values = "'" + value1 + "'" + ', '\
         + "'" + value2 + "'" + ', '\
         + "'" + json.dumps({k:v}) + "'"
    cvs = [columns, values]
    insert(conn=_conn, table=table, cvs=cvs)
    n = n + 1