| 注册
请输入搜索内容

热门搜索

Java Linux MySQL PHP JavaScript Hibernate jQuery Nginx
jopen
9年前发布

Hive 0.14 + hadoop 2.4.1 环境下的 jdbc连接

本文记录在Hive 0.14 + hadoop 2.4.1 环境下,如何时用 jdbc连接到hive

hive 的JDBC驱动还是比较好找的,在hive的包里就有 hive-jdbc-0.14.0-standalone.jar 是一个N合一的包,把它放到buildPath

除了这个包,还需要几个hadoop下的包,最后的buildpah如下图:

Hive 0.14 + hadoop 2.4.1 环境下的 jdbc连接

用服务模式启动hive,10010是监听的端口号

hive --service hiveserver 10010

下面是个示例代码,连接到hive以后建立了一个新表

package cn.pior.test;    import java.sql.Connection;  import java.sql.DriverManager;  import java.sql.SQLException;  import java.sql.Statement;    public class HiveTest {        private static final String URLHIVE = "jdbc:hive://192.168.1.201:10010/default";      private static Connection connection = null;        public static Connection getHiveConnection() {          if (null == connection) {              synchronized (HiveTest.class) {                  if (null == connection) {                      try {                          Class.forName("org.apache.hadoop.hive.jdbc.HiveDriver");                          connection = DriverManager.getConnection(URLHIVE, "",                                  "");                      } catch (SQLException e) {                          e.printStackTrace();                      } catch (ClassNotFoundException e) {                          e.printStackTrace();                      }                  }              }          }          return connection;      }        public static void createTable() throws SQLException {          String tweetTableSql = "create table t2 (i int)";          Statement stmt = getHiveConnection().createStatement();          stmt.executeQuery(tweetTableSql);          stmt.close();      }        public static void main(String[] args) throws SQLException {          createTable();          getHiveConnection().close();      }  }



 本文由用户 jopen 自行上传分享,仅供网友学习交流。所有权归原作者,若您的权利被侵害,请联系管理员。
 转载本站原创文章,请注明出处,并保留原始链接、图片水印。
 本站是一个以用户分享为主的开源技术平台,欢迎各类分享!
 本文地址:https://www.open-open.com/lib/view/open1421135599953.html
Hadoop 分布式/云计算/大数据