linux怎么连hive数据库

# 启动HiveServer2服务（如果尚未启动）
$HIVE_HOME/bin/hiveserver2

# 使用Beeline连接
beeline -u "jdbc:hive2://<HiveServer2_IP>:<port>/<database>;principal=<kerberos_principal>" -n <username> -p <password>

import java.sql.*;

public class HiveJdbcClient {
    private static String driverName = "org.apache.hive.jdbc.HiveDriver";

    public static void main(String[] args) throws SQLException {
        try {
            Class.forName(driverName);
        } catch (ClassNotFoundException e) {
            e.printStackTrace();
            System.exit(1);
        }

        Connection con = DriverManager.getConnection("jdbc:hive2://<HiveServer2_IP>:<port>/<database>;principal=<kerberos_principal>", "<username>", "<password>");
        Statement stmt = con.createStatement();
        String sql = "SELECT * FROM my_table LIMIT 10";
        ResultSet res = stmt.executeQuery(sql);
        while (res.next()) {
            System.out.println(res.getString(1));
        }
        res.close();
        stmt.close();
        con.close();
    }
}

from thrift.transport import TSocket
from thrift.transport import TTransport
from thrift.protocol import TBinaryProtocol
from hive_service import ThriftHive

transport = TSocket.TSocket('<HiveServer2_IP>', <port>)
transport = TTransport.TBufferedTransport(transport)
protocol = TBinaryProtocol.TBinaryProtocol(transport)

client = ThriftHive.Client(protocol)
transport.open()

client.execute("SELECT * FROM my_table LIMIT 10")
while True:
    row = client.fetchOne()
    if not row:
        break
    print(row)

transport.close()