Python3中使用jaydebeapi先后连接Netezza与MySQL报错求助

我之前也踩过JayDeBeApi跨数据库连接的坑，结合你的情况来看，问题大概率出在JPype的类加载机制上——毕竟JayDeBeApi是靠JPype调用Java驱动的，第一次加载Netezza驱动后，JVM的类加载上下文没正确重置，导致第二次找MySQL驱动时找不到对应的jar包。给你几个实测有效的解决思路：

1. 用独立JVM环境隔离两个数据库连接 #

JPype默认是全局单例JVM，第一次启动后不会重新初始化。你可以把两个数据库的查询逻辑拆成独立函数，每个函数单独启停JVM，彻底隔离类加载环境：

import jpype
import jaydebeapi

def fetch_netezza_data():
    # 启动JVM并加载Netezza驱动
    if not jpype.isJVMStarted():
        jpype.startJVM(
            jpype.getDefaultJVMPath(),
            "-Djava.class.path=/absolute/path/to/netezza-driver.jar"
        )
    # 建立Netezza连接
    conn = jaydebeapi.connect(
        driver_class="org.netezza.Driver",
        url="jdbc:netezza://your-netezza-host:port/your-db",
        credentials=["username", "password"],
        jars="/absolute/path/to/netezza-driver.jar"
    )
    cursor = conn.cursor()
    cursor.execute("SELECT * FROM your_netezza_table")
    result = cursor.fetchall()
    # 清理资源
    cursor.close()
    conn.close()
    # 关闭JVM
    jpype.shutdownJVM()
    return result

def fetch_mysql_data():
    # 重新启动JVM并加载MySQL驱动
    if not jpype.isJVMStarted():
        jpype.startJVM(
            jpype.getDefaultJVMPath(),
            "-Djava.class.path=/absolute/path/to/mysql-connector-java.jar"
        )
    # 建立MySQL连接
    conn = jaydebeapi.connect(
        driver_class="com.mysql.jdbc.Driver",  # 8.x+版本用com.mysql.cj.jdbc.Driver
        url="jdbc:mysql://your-mysql-host:port/your-db?useSSL=false",
        credentials=["username", "password"],
        jars="/absolute/path/to/mysql-connector-java.jar"
    )
    cursor = conn.cursor()
    cursor.execute("SELECT * FROM your_mysql_table")
    result = cursor.fetchall()
    # 清理资源
    cursor.close()
    conn.close()
    # 关闭JVM
    jpype.shutdownJVM()
    return result

# 依次执行查询
netezza_result = fetch_netezza_data()
mysql_result = fetch_mysql_data()

2. 一次性加载所有驱动jar到JVM类路径 #

如果不想频繁启停JVM，可以把Netezza和MySQL的驱动jar都加到JVM启动的classpath里，一次加载所有驱动，后续连接就不会出现类找不到的问题：

import jpype
import jaydebeapi

# 拼接两个驱动的jar路径，Linux/macOS用冒号分隔，Windows用分号
driver_jars = "/path/to/netezza-driver.jar:/path/to/mysql-connector-java.jar"
# 启动JVM并加载所有驱动
if not jpype.isJVMStarted():
    jpype.startJVM(
        jpype.getDefaultJVMPath(),
        f"-Djava.class.path={driver_jars}"
    )

# 查询Netezza
conn_netezza = jaydebeapi.connect(
    "org.netezza.Driver",
    "jdbc:netezza://your-netezza-host:port/your-db",
    ["username", "password"]
)
cursor_netezza = conn_netezza.cursor()
cursor_netezza.execute("SELECT * FROM your_netezza_table")
netezza_result = cursor_netezza.fetchall()
cursor_netezza.close()
conn_netezza.close()

# 查询MySQL
conn_mysql = jaydebeapi.connect(
    "com.mysql.jdbc.Driver",  # 注意8.x+版本的类名变化
    "jdbc:mysql://your-mysql-host:port/your-db?useSSL=false&serverTimezone=UTC",
    ["username", "password"]
)
cursor_mysql = conn_mysql.cursor()
cursor_mysql.execute("SELECT * FROM your_mysql_table")
mysql_result = cursor_mysql.fetchall()
cursor_mysql.close()
conn_mysql.close()

# 最后关闭JVM
jpype.shutdownJVM()

这里要注意，connect方法里不需要再传jars参数了，因为驱动已经在JVM启动时加载到类路径中。

3. 检查MySQL驱动的版本与类名 #

如果你用的是MySQL 8.0及以上版本，驱动类名已经从com.mysql.jdbc.Driver更新为com.mysql.cj.jdbc.Driver，而且必须指定时区参数（比如serverTimezone=UTC）。如果还是用旧类名，必然会报“类找不到”的错误。同时要确保你的驱动jar路径是绝对路径，没有拼写错误。

内容的提问来源于stack exchange，提问作者Mostafa Ghafoori