python使用jdbc连接phoeni

发布时间:2019-08-09 08:50:59编辑:auto阅读(1954)


    lib使用jaydebeapi,依赖jpype

    链接:https://pypi.python.org/pypi/JayDeBeApi/


    代码里面有说明 threadsafety = 1,我试了跨线程访问创建的连接对象,进程直接挂了,后来改成使用一个线程专门做jdbc,其他线程用队列交互。


    64位整形查询出来的结果是一个java对象,<jpype._jclass.java.lang.Long object at 0xxxxxxxx>,jaydebeapi默认没有转换,需要自己在__init__.py添加

    _to_bigint = _java_to_py('longValue')

    同时在_DEFAULT_CONVERTERS里面添加BIGINT转换:

    _DEFAULT_CONVERTERS = {
        # see
        # http://download.oracle.com/javase/6/docs/api/java/sql/Types.html
        # for possible keys
        'TIMESTAMP': _to_datetime,
        'TIME': _to_time,
        'DATE': _to_date,
        'BINARY': _to_binary,
        'DECIMAL': _to_double,
        'NUMERIC': _to_double,
        'DOUBLE': _to_double,
        'FLOAT': _to_double,
        'INTEGER': _to_int,
        'BIGINT': _to_bigint,
        'SMALLINT': _to_int,
        'BOOLEAN': _java_to_py('booleanValue'),
    }

    其他未转换的类型用同样的方法添加,

    附:

    http://docs.oracle.com/javase/6/docs/api/constant-values.html#java.sql.Types.BIGINT


关键字