Dear Wiki user,

You have subscribed to a wiki page or wiki category on "Hadoop Wiki" for change 
notification.

The following page has been changed by JonathanSmith:
http://wiki.apache.org/hadoop/Hive/HiveClient

------------------------------------------------------------------------------
  
  public class HiveJdbcClient {
    private static String driverName = "org.apache.hadoop.hive.jdbc.HiveDriver";
-   
+ 
-   /** 
+   /**
     * @param args
-    * @throws SQLException 
+    * @throws SQLException
-    */  
+    */
    public static void main(String[] args) throws SQLException {
        try {
        Class.forName(driverName);
@@ -31, +31 @@

        // TODO Auto-generated catch block
        e.printStackTrace();
        System.exit(1);
-     }   
+     }
      Connection con = 
DriverManager.getConnection("jdbc:hive://localhost:10000/default", "", "");
      Statement stmt = con.createStatement();
      String tableName = "testHiveDriverTable";
@@ -43, +43 @@

      res = stmt.executeQuery(sql);
      if (res.next()) {
        System.out.println(res.getString(1));
-     }   
+     }
      // describe table
      sql = "describe " + tableName;
      System.out.println("Running: " + sql);
      res = stmt.executeQuery(sql);
      while (res.next()) {
        System.out.println(res.getString(1) + "\t" + res.getString(2));
-     }   
+     }
-         
+ 
      // load data into table
      // NOTE: filepath has to be local to the hive server
      // NOTE: /tmp/a.txt is a ctrl-A separated file with two fields per line
@@ -59, +59 @@

      sql = "load data local inpath '" + filepath + "' into table " + tableName;
      System.out.println("Running: " + sql);
      res = stmt.executeQuery(sql);
-         
+ 
      // select * query
      sql = "select * from " + tableName;
      System.out.println("Running: " + sql);
      res = stmt.executeQuery(sql);
      while (res.next()) {
        System.out.println(String.valueOf(res.getInt(1)) + "\t" + 
res.getString(2));
-     }   
+     }
-         
+ 
      // regular hive query
      sql = "select count(1) from " + tableName;
      System.out.println("Running: " + sql);
      res = stmt.executeQuery(sql);
      while (res.next()) {
        System.out.println(res.getString(1));
-     }   
+     }
    }
  }
  }}}
@@ -130, +130 @@

  
  = Python =
  Operates only on a standalone server. Set (and export) PYTHONPATH to 
build/dist/lib/py.
- The python modules imported in the code below are generated by building hive.
+ [[BR]]The python modules imported in the code below are generated by building 
hive.
- Please note that the generated python module names have changed in hive trunk.
+ [[BR]]Please note that the generated python module names have changed in hive 
trunk.
  {{{
  #!/usr/bin/env python
  
@@ -167, +167 @@

  }}}
  
  = PHP =
- Operates only on a standalone server. 
+ Operates only on a standalone server.
  {{{
  <?php
  // set THRIFT_ROOT to php directory of the hive distribution
@@ -189, +189 @@

  }}}
  
  = Thrift Java Client =
- Operates both in embedded mode and on standalone server. 
+ Operates both in embedded mode and on standalone server.
  
  = ODBC =
  Operates only on a standalone server. See [wiki:Self:Hive/HiveODBC HiveODBC].

Reply via email to