python jdbc操作数据库

pip install JPype1 >= 1.1.1

# encoding: utf-8
import jpype.imports
from jpype import JInt, JShort
from jpype import dbapi2
# 配置数据库jar包路径
jpype.startJVM(classpath=['hgdb-jdbc42-6.0.5.jar'])
# 导入数据Driver
from com.highgo.jdbc import *

# 配置jdbc连接地址
conn_url = "jdbc:highgo://IP地址:端口号/数据库"

# 数据库连接用户名密码
driver_args = {
    "user": "xxx",
    "password": "xxx"
}

# 组装
conn = dbapi2.connect(conn_url, driver="com.highgo.jdbc.Driver", driver_args=driver_args)
# 指定jdbc返回结果字段对应数据类型转换
conn.converters[JInt] = str
conn.converters[JShort] = str
# 获取连接游标
cur = conn.cursor()
# 执行查询
cur.execute("SELECT * FROM table1 WHERE org_code = ?", ("参数",))
res = cur.fetchone()
# 直接打印结果
print(res)
# 结果已字典形式输出
columns = [column[0] for column in cur.description]
dict_res = dict(zip(columns, res))
print(dict_res)

# encoding: utf-8
try:
    import jpype.imports
    from jpype import JInt, JShort, JClass
    from jpype import dbapi2
    # 配置数据库jar包路径
    jpype.startJVM(classpath=['trino-jdbc-384.jar'])
    # 导入数据Driver
    importlib.invalidate_caches()
    # from io.trino.jdbc import TrinoDriver
    JClass('io.trino.jdbc.TrinoDriver')
    if jpype.__version__ < '1.1.0':
        raise EnvironmentError('jpype1 need version >= 1.1.0, please check jpype1 version')
except ImportError:
    raise ImportError('import jpype occurred an error')

# 配置jdbc连接地址
conn_url = "jdbc:trino://host:port/catalog"

# 数据库连接用户名密码
driver_args = {
    "user": "admin"
}

# 组装
conn = dbapi2.connect(conn_url, driver="io.trino.jdbc.TrinoDriver", driver_args=driver_args, catalog='hive')
# 指定jdbc返回结果字段对应数据类型转换
conn.converters[JInt] = str
conn.converters[JShort] = str
# 获取连接游标
cur = conn.cursor()
# 执行查询
cur.execute("SELECT * FROM xxxx WHERE date_str = ?", ("xxx",))
res = cur.fetchone()
# 直接打印结果
print(res)
# 结果已字典形式输出
columns = [column[0] for column in cur.description]
dict_res = dict(zip(columns, res))
print(dict_res)