i use following java code

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

  public class DemoHive {
            public static void main(String[] args) throws  Exception {
                Class.forName("org.apache.hadoop.hive.jdbc.HiveDriver");

                String dropSQL="drop table javabloger";
                String createSQL="create table javabloger (key int, value
string)";
                String insterSQL="LOAD DATA LOCAL INPATH
'/work/hive/examples/files/kv1.txt' OVERWRITE INTO TABLE javabloger";
                String querySQL="SELECT * FROM hb_dmp_pageview";

                Connection con = DriverManager.getConnection("jdbc:hive2://
192.168.10.22:10000/default", "", "");
                Statement stmt = con.createStatement();
       //         stmt.executeQuery(dropSQL);  // 执行删除语句
         //       stmt.executeQuery(createSQL);  // 执行建表语句
        //        stmt.executeQuery(insterSQL);  // 执行插入语句
                ResultSet res = stmt.executeQuery(querySQL);   // 执行查询语句

                  while (res.next()) {
                    System.out.println("Result: key:"+res.getString(1) +"
�C>  value:" +res.getString(2));
                }
            }
        }


Exception in thread "main" java.sql.SQLException: Invalid URL: jdbc:hive2://
192.168.10.22:10000/default
 at
org.apache.hadoop.hive.jdbc.HiveConnection.<init>(HiveConnection.java:85)
 at org.apache.hadoop.hive.jdbc.HiveDriver.connect(HiveDriver.java:104)
 at java.sql.DriverManager.getConnection(Unknown Source)
 at java.sql.DriverManager.getConnection(Unknown Source)
 at DemoHive.main(DemoHive.java:17)


and in hive server

# nohup hive --service hiveserver &

# netstat -utlpn|grep 10000
tcp        0      0 0.0.0.0:10000               0.0.0.0:*
LISTEN      18430/java

Reply via email to