python jdbc连接hive

在Python中，我们可以使用jdbc库来连接数据库。jdbc是Java数据库连接（Java Database Connectivity）的缩写，它是Java语言中用于连接和操作数据库的一种技术，虽然jdbc是Java的库，但是Python可以通过JPype库来调用Java代码，从而实现在Python中使用jdbc连接数据库的目的。

我们需要安装JPype库，在命令行中输入以下命令进行安装：

pip install JPype1

接下来，我们以连接MySQL数据库为例，介绍如何在Python中使用jdbc连接数据库。

1、导入所需库

import jpype
import jpype.driver as driver

2、启动JVM

jpype.startJVM(jpype.getDefaultJVMPath(), "-ea", f"-Djava.class.path=/path/to/mysql-connector-java-{version}.jar")

/path/to/mysql-connector-java-{version}.jar需要替换为实际的MySQL驱动包路径，{version}为驱动包的版本号，如果驱动包位于/usr/local/mysql-connector-java-8.0.26.jar，则上述代码应修改为：

jpype.startJVM(jpype.getDefaultJVMPath(), "-ea", f"-Djava.class.path=/usr/local/mysql-connector-java-8.0.26.jar")

3、加载驱动类

Class = jpype.JClass("com.mysql.cj.jdbc.Driver")

4、创建数据库连接

connection = Class()
connection_url = f"jdbc:mysql://localhost:3306/{database_name}?useSSL=false&serverTimezone=UTC"
connection_properties = {"user": user, "password": password}
connection_attributes = {"autoReconnect": True}
connection = connection.connect(url=connection_url, properties=connection_properties, attributes=connection_attributes)

database_name为要连接的数据库名称，user和password分别为数据库的用户名和密码。

5、创建Statement对象并执行SQL语句

statement = connection.createStatement()
result_set = statement.executeQuery("SELECT * FROM table_name")
while result_set.next():
    print(result_set[1])   输出查询结果的第一列数据

6、关闭资源

result_set.close()
statement.close()
connection.close()
jpype.shutdownJVM()

至此，我们已经完成了在Python中使用jdbc连接MySQL数据库的操作，需要注意的是，由于jdbc是Java的库，因此在Python中使用它可能会有一定的性能损失，不同的数据库可能需要不同的驱动包，因此在使用时需要根据实际情况选择合适的驱动包。