ApacheHive一点一点进步(2)–HIVEJDBC

Hive提供了多种方式进行数据的访问。其中对 java 的支持是最好的，而且是其最原生的支持。传说中的JDBC。哈哈！ 在 hive 安装目录下的lib目录中有 hive - jdbc -0.8.1.jar 。以0.8版本的为例来介绍。 当然了，也别忘了要通过hive的server方式将hive启动起来

Hive提供了多种方式进行数据的访问。其中对java的支持是最好的，而且是其最原生的支持。传说中的JDBC。哈哈！

在hive安装目录下的lib目录中有hive-jdbc-0.8.1.jar 。以0.8版本的为例来介绍。

当然了，也别忘了要通过hive的server方式将hive启动起来。命令就不在这里介绍了。

以下是官网提供的一段示例，使用起来比较简单。client端支持的语法在这里都是支持的。

而且可以通过这个进行环境变量设置，这个设置并不会影响server端，只在本次会话中生效，所以不用担心任务间影响。

Java

import java.sql.SQLException;import java.sql.Connection;import java.sql.ResultSet;import java.sql.Statement;import java.sql.DriverManager; public class HiveJdbcClient &＃123;  private static String driverName = "org.apache.hadoop.hive.jdbc.HiveDriver";   /** * @param args * @throws SQLException   */  public static void main&＃40;String&＃91;&＃93; args&＃41; throws SQLException &＃123;      try &＃123;      Class.forName&＃40;driverName&＃41;;    &＃125; catch &＃40;ClassNotFoundException e&＃41; &＃123;      // TODO Auto-generated catch block      e.printStackTrace&＃40;&＃41;;      System.exit&＃40;1&＃41;;    &＃125;    Connection con = DriverManager.getConnection&＃40;"jdbc:hive://localhost:10000/default", "", ""&＃41;;    Statement stmt = con.createStatement&＃40;&＃41;;    String tableName = "testHiveDriverTable";    stmt.executeQuery&＃40;"drop table " + tableName&＃41;;    ResultSet res = stmt.executeQuery&＃40;"create table " + tableName + " (key int, value string)"&＃41;;    // show tables    String sql = "show tables '" + tableName + "'";    System.out.println&＃40;"Running: " + sql&＃41;;    res = stmt.executeQuery&＃40;sql&＃41;;    if &＃40;res.next&＃40;&＃41;&＃41; &＃123;      System.out.println&＃40;res.getString&＃40;1&＃41;&＃41;;    &＃125;    // describe table    sql = "describe " + tableName;    System.out.println&＃40;"Running: " + sql&＃41;;    res = stmt.executeQuery&＃40;sql&＃41;;    while &＃40;res.next&＃40;&＃41;&＃41; &＃123;      System.out.println&＃40;res.getString&＃40;1&＃41; + "\t" + res.getString&＃40;2&＃41;&＃41;;    &＃125;     // 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    String filepath = "/tmp/a.txt";    sql = "load data local inpath '" + filepath + "' into table " + tableName;    System.out.println&＃40;"Running: " + sql&＃41;;    res = stmt.executeQuery&＃40;sql&＃41;;     // select * query    sql = "select * from " + tableName;    System.out.println&＃40;"Running: " + sql&＃41;;    res = stmt.executeQuery&＃40;sql&＃41;;    while &＃40;res.next&＃40;&＃41;&＃41; &＃123;      System.out.println&＃40;String.valueOf&＃40;res.getInt&＃40;1&＃41;&＃41; + "\t" + res.getString&＃40;2&＃41;&＃41;;    &＃125;     // regular hive query    sql = "select count(1) from " + tableName;    System.out.println&＃40;"Running: " + sql&＃41;;    res = stmt.executeQuery&＃40;sql&＃41;;    while &＃40;res.next&＃40;&＃41;&＃41; &＃123;      System.out.println&＃40;res.getString&＃40;1&＃41;&＃41;;    &＃125;  &＃125;&＃125;

Python

#!/usr/bin/env python import sys from hive import ThriftHivefrom hive.ttypes import HiveServerExceptionfrom thrift import Thriftfrom thrift.transport import TSocketfrom thrift.transport import TTransportfrom thrift.protocol import TBinaryProtocol try:    transport = TSocket.TSocket&＃40;'localhost', 10000&＃41;    transport = TTransport.TBufferedTransport&＃40;transport&＃41;    protocol = TBinaryProtocol.TBinaryProtocol&＃40;transport&＃41;     client = ThriftHive.Client&＃40;protocol&＃41;    transport.open&＃40;&＃41;     client.execute&＃40;"CREATE TABLE r(a STRING, b INT, c DOUBLE)"&＃41;    client.execute&＃40;"LOAD TABLE LOCAL INPATH '/path' INTO TABLE r"&＃41;    client.execute&＃40;"SELECT * FROM r"&＃41;    while &＃40;1&＃41;:      row = client.fetchOne&＃40;&＃41;      if &＃40;row == None&＃41;:        break      print row    client.execute&＃40;"SELECT * FROM r"&＃41;    print client.fetchAll&＃40;&＃41;     transport.close&＃40;&＃41; except Thrift.TException, tx:    print '%s' % &＃40;tx.message&＃41;

PHP

open&＃40;&＃41;; // run queries, metadata calls etc$client->execute&＃40;'SELECT * from src'&＃41;;var_dump&＃40;$client->fetchAll&＃40;&＃41;&＃41;;$transport->close&＃40;&＃41;;

原文地址：ApacheHive一点一点进步(2)–HIVEJDBC, 感谢原作者分享。