cratedb_conversion.py

#!/usr/bin/env python3

import sys
from datetime import datetime
from crate.client import connect


def main():
    now = datetime.utcnow()
    with connect('localhost:4200') as conn:
        cur = conn.cursor()
        cur.execute('CREATE TABLE IF NOT EXISTS t2 (col_str STRING, col_long LONG, col_ts TIMESTAMP)')
        cur.execute('INSERT INTO t2 (col_str, col_long, col_ts) VALUES (?, ?, ?)',
                    (now, now, now))
        cur.execute('REFRESH TABLE t2')
        cur.execute('SELECT col_str, col_long, col_ts FROM t2')
        cols = [c[0] for c in cur.description]
        for idx, val in enumerate(cur.fetchone()):
            print('{} => {} ({})'.format(cols[idx], val,type(val)))


if __name__ == '__main__':
    sys.exit(main())