hive mysql远程模式

SET GLOBAL wait_timeout = 28800;
SET GLOBAL interactive_timeout = 28800;

GRANT ALL PRIVILEGES ON *.* TO 'hiveuser'@'%' IDENTIFIED BY 'password';
FLUSH PRIVILEGES;

# 示例：下载 MySQL JDBC 驱动程序
wget https://dev.mysql.com/get/Downloads/Connector-J/mysql-connector-java-8.0.26.jar

import java.sql.Connection;
import java.sql.DriverManager;
import java.sql.ResultSet;
import java.sql.Statement;

public class HiveMySQLExample {
    public static void main(String[] args) {
        try {
            // 加载 JDBC 驱动程序
            Class.forName("com.mysql.cj.jdbc.Driver");
            
            // 连接到 MySQL 数据库
            Connection conn = DriverManager.getConnection("jdbc:mysql://mysql-server:3306/database", "hiveuser", "password");
            
            // 创建 Statement 对象
            Statement stmt = conn.createStatement();
            
            // 执行查询
            ResultSet rs = stmt.executeQuery("SELECT * FROM table");
            
            // 处理结果集
            while (rs.next()) {
                System.out.println(rs.getString("column"));
            }
            
            // 关闭连接
            rs.close();
            stmt.close();
            conn.close();
        } catch (Exception e) {
            e.printStackTrace();
        }
    }
}

import pyodbc

# 连接到 MySQL 数据库
conn = pyodbc.connect('DRIVER={MySQL ODBC 8.0 Unicode Driver};SERVER=mysql-server;DATABASE=database;UID=hiveuser;PWD=password')

# 创建游标对象
cursor = conn.cursor()

# 执行查询
cursor.execute("SELECT * FROM table")

# 处理结果集
for row in cursor:
    print(row.column)

# 关闭连接
cursor.close()
conn.close()