java连hive数据库

<?xml version="1.0" encoding="UTF-8"?>

4.0.0

<groupId>org.example</groupId>
<artifactId>HiveServiceConnect</artifactId>
<version>1.0-SNAPSHOT</version>
<dependencies><dependency><groupId>com.oracle.database.jdbc</groupId><artifactId>ojdbc6</artifactId><version>11.2.0.4</version></dependency><dependency><groupId>org.apache.hadoop</groupId><artifactId>hadoop-common</artifactId><version>2.8.5</version></dependency><!-- https://mvnrepository.com/artifact/org.apache.hadoop/hadoop-client --><dependency><groupId>org.apache.hadoop</groupId><artifactId>hadoop-client</artifactId><version>2.8.5</version></dependency><!-- https://mvnrepository.com/artifact/org.apache.hive/hive-jdbc

数据库的驱动 连接的是何种数据库
–>

org.apache.hive
hive-jdbc
1.2.1

    <!-- https://mvnrepository.com/artifact/org.apache.hive/hive-metastore --><dependency><groupId>org.apache.hive</groupId><artifactId>hive-metastore</artifactId><version>1.2.1</version></dependency><!-- https://mvnrepository.com/artifact/org.apache.hive/hive-metastore --><dependency><groupId>org.apache.hive</groupId><artifactId>hive-exec</artifactId><version>1.2.1</version></dependency></dependencies>
<properties><maven.compiler.source>8</maven.compiler.source><maven.compiler.target>8</maven.compiler.target>
</properties>

import java.sql.SQLException;
import java.sql.Connection;
import java.sql.ResultSet;
import java.sql.Statement;
import java.sql.DriverManager;
public class HiveServer2Connect {
private static String driverName = “org.apache.hive.jdbc.HiveDriver”;
public static void main(String[] args) throws SQLException {
//加载hive驱动
try {
Class.forName(driverName);
} catch (ClassNotFoundException e) {
e.printStackTrace();
System.exit(1);
}
Connection conn = DriverManager.getConnection(“jdbc:hive2://10.50.103.12:10000/default”,“hive”,“Ab123456”);
Statement stmt = conn.createStatement();
String sql = “SELECT sk_date\\n” +
" ,bk_fundacct\\n" +
" ,custname\\n" +
" ,bk_fundcode\\n" +
" ,saleorg\\n" +
" ,tradetypedesc\\n" +
" ,f_shares_ori\\n" +
" ,f_amt\\n" +
" ,f_shares\\n" +
" ,netvalue\\n" +
" ,sk_reqdate\\n" +
" ,transserialno\\n" +
" ,appsheetserialno\\n" +
" ,investorname\\n" +
" FROM ddm.d_pec101_fundcompany_detail";
//查询数据
System.out.println("Running: " + sql);
ResultSet res = stmt.executeQuery(sql);
while (res.next()){

        System.out.println(res.getString(1));}conn.close();
}

}