码迷,mamicode.com
首页 > 数据库 > 详细

jdbc连接hive0.14

时间:2014-11-05 19:48:33      阅读:219      评论:0      收藏:0      [点我收藏+]

标签:jdbc连接hive0.14版本

Jdbc连接hive0.14版本

目前官网最新版本是hive0.13,要想下载最新的hive得去git上去clone一个。

Hive0.14最大特点是支持直接插入。

现在做一个jdbc连接hive0.14的例子。

需要的jar包:

 bubuko.com,布布扣

不要去引入单独的一个集成hivejar因为那个包含了tomcat里面的几个jar包。当建立hive工程时,会冲突导致hive的集成包加载不上。

1.hive连接的工具类:

package com.fish;

 

import java.sql.Connection;

import java.sql.DriverManager;

import java.sql.PreparedStatement;

import java.sql.ResultSet;

import java.sql.SQLException;

import java.util.ResourceBundle;

 

/**

 * 连接数据库的工具类,被定义成不可继承且是私有访问

 */

public final class DBTool {

 

final private static String OPTION_FILE_NAME = "hivedatabase";

private static Connection conn;

static ResourceBundle res;

 

static {

res = ResourceBundle.getBundle(OPTION_FILE_NAME);

try {

String driver = res.getString("jdbc.driver");

Class.forName(driver);

catch (ClassNotFoundException e) {

e.printStackTrace();

throw new RuntimeException(e);

}

}

 

/**

 * 获取数据库的连接

 * 

 * @return conn

 */

public static Connection getConnection() {

if (null == conn) {

try {

String url = res.getString("jdbc.url");

String user = res.getString("jdbc.username");

String password = res.getString("jdbc.password");

conn = DriverManager.getConnection(url, user, password);

catch (SQLException e) {

e.printStackTrace();

throw new RuntimeException(e);

}

}

return conn;

}

 

/**

 * 释放资源

 * 

 * @param conn

 * @param pstmt

 * @param rs

 */

public static void closeJDBC(Connection conn, PreparedStatement pstmt,

ResultSet rs) {

if (null != rs) {

try {

rs.close();

catch (SQLException e) {

e.printStackTrace();

throw new RuntimeException(e);

finally {

if (null != pstmt) {

try {

pstmt.close();

catch (SQLException e) {

e.printStackTrace();

throw new RuntimeException(e);

finally {

if (null != conn) {

try {

conn.close();

catch (SQLException e) {

e.printStackTrace();

throw new RuntimeException(e);

}

}

}

}

}

}

}

}

 

2.hivedatabase.properties

#hive database setting

jdbc.type=hive

jdbc.driver=org.apache.hive.jdbc.HiveDriver

jdbc.url=jdbc:hive2://192.168.2.150:10000/default

jdbc.username=hadoop

jdbc.password=

 

3.test是类

public class Test {

public static void main(String[] args) throws Exception {

 

Connection connection = DBTool.getConnection();

System.out.println(connection);}

}

如果能连接通说明你已经成功连接上hive了。

 

 

 

jdbc连接hive0.14

标签:jdbc连接hive0.14版本

原文地址:http://blog.csdn.net/yucongyong/article/details/40826899

(0)
(0)
   
举报
评论 一句话评论(0
登录后才能评论!
© 2014 mamicode.com 版权所有  联系我们:gaon5@hotmail.com
迷上了代码!