Inceptor JDBC 连接案例程序

Java 连接Inceptor 方法如下
PS:需要提前向工程中导入Inceptor 访问驱动


import java.sql.*;

public class JDBCExample {

  //Hive2 Driver class name
  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);
    }

    //Hive2 JDBC URL with LDAP
    String jdbcURL = "jdbc:hive2://localhost:10000/default"; 

    String user = "user"; 
    String password = "password"; 
    Connection conn = DriverManager.getConnection(jdbcURL, user, password);
    Statement  stmt = conn.createStatement();
    ResultSet rs = stmt.executeQuery("select c1, c2 from table1"); 
    ResultSetMetaData rsmd = rs.getMetaData();
    int size = rsmd.getColumnCount();
    while(rs.next()) {
      StringBuffer value = new StringBuffer();
      for(int i = 0; i < size; i++) {
        value.append(rs.getString(i+1)).append("\t");
      }
    System.out.println(value.toString());
    }
    rs.close();
    stmt.close();
    conn.close();
  }
}

版权声明:本文为qq_28694119原创文章,遵循CC 4.0 BY-SA版权协议,转载请附上原文出处链接和本声明。