Databricks调用jaydebeapi.connect()连接Teradata报错：驱动类未找到

我能在Databricks与Teradata之间通过JDBC读写数据，但调用jaydebeapi.connect()时失败，报错找不到驱动类。

代码示例 #

import jaydebeapi
jdbc_driver_loc ='dbfs:/FileStore/jars/bad3070d_dcf9_445a_ad2f_a83066001166-terajdbc_20_00_00_06-6121b.jar,dbfs:/FileStore/jars/008ecc1e_67f3_44f6_b2a4_51753cd1fd07-tdgssconfig.jar' 
config_dict={"JDBCURL":"jdbc:?,LOGMECH=LDAP","JDBCDriver":"com.teradata.jdbc.TeraDriver","DB_User":"?","DB_PWD":"?"} 
jdbcUrl=config_dict["JDBCURL"]
jdbcDriver =config_dict["JDBCDriver"]
user=config_dict["DB_User"]
password=config_dict["DB_PWD"]
print(jdbcDriver)
print(jdbcUrl)
jars=["dbfs:/FileStore/jars/bad3070d_dcf9_445a_ad2f_a83066001166-terajdbc_20_00_00_06-6121b.jar","dbfs:/FileStore/jars/008ecc1e_67f3_44f6_b2a4_51753cd1fd07-tdgssconfig.jar"]
conn = jaydebeapi.connect('com.teradata.jdbc.TeraDriver',jdbcUrl,[user,password],jars)

报错信息 #

error : TypeError: Class com.teradata.jdbc.TeraDriver is not found

已确认：

• 相同的Teradata连接参数手动连接成功
• 尝试过更换驱动版本及路径，问题依旧

核心问题 #

Databricks的Python进程无法直接加载DBFS路径下的jar文件，jaydebeapi需要访问本地文件系统中的驱动文件，而非DBFS远程路径。同时原代码中的JDBC URL格式不完整，也会导致连接失败。

修复步骤 #

1. 将DBFS上的Teradata驱动jar复制到Databricks节点的本地临时目录
2. 使用本地路径作为jaydebeapi.connect()的jar参数
3. 补全JDBC URL的服务器地址等必要信息

修复后代码 #

import jaydebeapi
import os
import shutil

# DBFS上的驱动jar路径
dbfs_jar_paths = [
    "dbfs:/FileStore/jars/bad3070d_dcf9_445a_ad2f_a83066001166-terajdbc_20_00_00_06-6121b.jar",
    "dbfs:/FileStore/jars/008ecc1e_67f3_44f6_b2a4_51753cd1fd07-tdgssconfig.jar"
]

# 创建本地临时目录存放驱动
local_temp_dir = "/tmp/teradata_jars"
os.makedirs(local_temp_dir, exist_ok=True)

# 从DBFS复制jar到本地（Databricks中dbfs:/可通过/dbfs/路径本地访问）
local_jar_paths = []
for dbfs_path in dbfs_jar_paths:
    local_dbfs_path = f"/dbfs{dbfs_path[5:]}"
    local_jar_path = os.path.join(local_temp_dir, os.path.basename(dbfs_path))
    shutil.copy(local_dbfs_path, local_jar_path)
    local_jar_paths.append(local_jar_path)

# 配置连接参数（补全Teradata服务器地址）
config_dict = {
    "JDBCURL": "jdbc:teradata://<你的Teradata服务器地址>/LOGMECH=LDAP",
    "JDBCDriver": "com.teradata.jdbc.TeraDriver",
    "DB_User": "<你的用户名>",
    "DB_PWD": "<你的密码>"
}
jdbcUrl = config_dict["JDBCURL"]
jdbcDriver = config_dict["JDBCDriver"]
user = config_dict["DB_User"]
password = config_dict["DB_PWD"]

# 建立连接
conn = jaydebeapi.connect(jdbcDriver, jdbcUrl, [user, password], local_jar_paths)

额外提示 #

• 标准Teradata JDBC URL格式为jdbc:teradata://<server_name_or_ip>/DATABASE=<db_name>,LOGMECH=LDAP，可根据业务需求添加其他参数
• 验证驱动jar版本与Teradata服务器版本兼容
• 若运行在集群模式，可将驱动jar安装为集群全局库，避免每次复制文件

内容的提问来源于stack exchange，提问作者Shobhit Jain