`
ganliang13
  • 浏览: 252528 次
  • 性别: Icon_minigender_1
  • 来自: 北京
社区版块
存档分类
最新评论

java 利用jdbc连接hive查询示例

    博客分类:
  • hive
阅读更多

1.千万记得执行这个命令bin/hive --service hiveserver >/dev/null 2>/dev/null &,

否则就会出现hive ,Connection refuse 的异常。

 

2.加入包,我这里的环境是hadoop1.01,hive0.8.1

 

antlr-runtime-3.0.1.jar

commons-logging-api-1.0.4.jar

hadoop-core-1.0.1.jar

hive-exec-0.8.1.jar

hive-jdbc-0.8.1.jar

hive-metastore-0.8.1.jar

hive-service-0.8.1.jar

jdo2-api-2.3-ec.jar

libfb303.jar

log4j-1.2.15.jar

slf4j-api-1.4.3.jar

slf4j-log4j12-1.4.3.jar

 

3.代码

 

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

public class HiveTestCase {
	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)";
		// hive插入数据支持两种方式一种:load文件,令一种为从另一个表中查询进行插入(感觉这是个鸡肋)
		// hive是不支持insert into...values(....)这种操作的
		//String insterSQL = "LOAD DATA LOCAL INPATH '/work/hive/examples/files/kv1.txt' OVERWRITE INTO TABLE javabloger";
		String querySQL = "SELECT name,address FROM people_test a";

		Connection con = DriverManager.getConnection(
				"jdbc:hive://localhost:10000/default", "root", "****");
		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) + "  –>  value:" + res.getString(2));
		}
	}
}

 

4.运行结果
Result: key:阿里马马  –>  value:北京海淀西四环
Result: key:甘亮  –>  value:湖北咸宁
分享到:
评论
2 楼 ganliang13 2013-03-24  
是啊,呵呵
1 楼 JustDone 2013-03-20  
你是咸宁人?

相关推荐

    java jdbc连接hive所需要所有jar包,请测有效。

    以下是一段基本的Java代码示例,展示了如何使用JDBC连接到Hive: ```java import java.sql.Connection; import java.sql.DriverManager; import java.sql.ResultSet; import java.sql.Statement; public class ...

    使用javaJDBC连接hive数据,实现简单的操作!

    Hive JDBC的使用使得在Java应用中无缝集成Hive成为可能,从而可以利用Hadoop的分布式计算能力处理大规模数据。然而,需要注意的是,由于Hive的延迟较高,它更适合于离线批处理而不是实时查询。 以上就是使用Java ...

    jdbc 连接impala或者jdbc连接hive

    在这个场景下,JDBC提供了连接Hive和Impala的功能,使得开发者可以通过编写Java程序或使用支持JDBC的任何其他工具来执行查询和操作数据。下面将详细介绍如何使用JDBC连接Hive和Impala。 1. **JDBC连接Hive** Hive...

    jdbc 通过impala 连接hive库

    总结来说,本文介绍了如何在Maven项目中配置ImpalaJDBC4依赖,以及如何使用Java的JDBC API连接到Hive库。这个过程包括了对`pom.xml`的编辑,JDBC驱动的加载,以及基本的数据库连接和查询操作。在实际开发中,你可能...

    Hive_JDBC.zip_hive java_hive jdbc_hive jdbc pom_java hive_maven连

    Hive JDBC(Java Database Connectivity)是Hive提供的一种接口,使得其他编程语言,如Java,能够通过JDBC驱动程序与Hive进行交互,实现数据查询、分析和操作。本教程将深入讲解如何使用Hive JDBC在Java项目中建立与...

    jdbc连接hive

    【jdbc连接Hive】 ...通过以上步骤,你可以在Java应用程序中利用JDBC连接CDH中的Hive,进行数据的查询、插入、更新和删除操作。了解这些知识点后,你可以根据实际需求灵活运用到项目中,实现高效的数据交互。

    hive2-jdbc:Hive JDBC连接示例,包括简单和kerberos身份验证方法

    Hive JDBC连接示例该项目展示了如何使用各种不同的方法连接到Hiveserver2。 所有类仅适用于Hiveserver2。 正在使用Cloudera JDBC驱动程序,可以从下载。 在撰写本文时,最新版本为v2.5.15 。要求: 您需要下载驱动...

    hive-jdbc-1.1.0驱动相关jar包

    Hive JDBC驱动是连接Hadoop Hive数据库的重要组件,它允许用户通过Java编程语言或任何支持JDBC的工具(如SQL客户端)与Hive进行交互。Hive JDBC 1.1.0版本是这个驱动的一个特定迭代,提供了对Hive查询、数据操作和...

    SpringBoot整合hive-jdbc示例

    Hive-JDBC是Hive提供的一个客户端接口,允许Java应用程序通过JDBC连接到Hive服务器,执行SQL查询并获取结果。它为Hive提供了标准的数据库访问方式,使得开发者能够像操作关系型数据库一样操作Hive。 ### 2. ...

    Hive-jdbc-3.1.1.zip

    Hive JDBC是Apache Hive项目的一部分,它为Hive数据仓库提供了与Java数据库连接(JDBC)接口的兼容性。这使得开发人员能够使用标准的JDBC驱动程序来连接到Hive服务器,从而在各种应用程序中方便地进行大数据查询和...

    java_hive简单查询

    `hive-java`可能是指Hive的Java API或用于运行Hive查询的Java程序的示例代码。在实际项目中,你可能需要构建一个包含Hive查询逻辑的Java类,并将其打包成jar文件,然后在Hadoop集群上运行。 7. **提交Java作业到...

    通过jdbc链接hive所需要的jar包

    在Java编程环境中,使用JDBC(Java Database Connectivity)来连接Hive数据库是一项常见的任务。Hive是基于Hadoop的数据仓库工具,它允许我们对存储在HDFS上的大规模数据集进行结构化查询。JDBC作为Java与数据库之间...

    java操作Hive源码之HiveJDBC实例(mysql数据库)

    HiveJDBC是Hive提供的一种JDBC驱动,使得任何支持JDBC的应用程序,如Java,都能连接到Hive服务器,执行查询和操作Hive中的数据。在这个实例中,我们将使用它来连接到运行MySQL作为元数据存储的Hive服务。 2. **...

    hive jdbc连接Demo

    jdbc连接hive的小示例程序,使用方法: 1、在Hadoop服务器上启动远程服务接口,命令: nohup hive --service hiveserver 10000 & (指定端口启动) 2、将test主程序里的IP改为自己用的Hadoop服务器ip,即可使用。

    开发hive JDBC

    而JDBC(Java Database Connectivity)是Java语言中用于与数据库交互的一种标准接口,它提供了连接、查询、更新数据库的一系列方法。通过Hive JDBC,我们可以用Java程序直接执行Hive查询,并获取结果。 首先,确保...

    java连接hive数据库的demo

    Java连接Hive数据库的示例(Demo)是一个用于演示如何在Java应用程序中与Hive进行交互的代码片段。Hive是基于Hadoop的数据仓库工具,它允许用户使用SQL语法(称为HQL,Hive SQL)对大数据集进行查询、分析和处理。在...

    Java连接Hadoop hive数据库jar包合集

    要通过Java连接Hive,你需要引入Hive的JDBC驱动,这通常包含在`hive-jdbc`或者`hadoop-hive-jdbc`的jar包中。虽然这个列表里没有明确的Hive JDBC jar,但`inceptor-*`系列的jar可能是Inceptor(也称为Hive)的相关库...

    使用IDEA工具连接CDH集群里面的hive组件

    创建一个新的Java类,例如`App.java`,在这里你可以使用Hive JDBC驱动来建立与Hive服务的连接,执行SQL查询,并处理结果。 下面是一个简单的Java连接Hive的例子: ```java import java.sql.Connection; import ...

    hive客户端java代码示例.zip

    接下来,我们来看一个简单的Java代码示例,该示例展示了如何连接到Hive服务器、执行SQL查询并获取结果: ```java import org.apache.hadoop.conf.Configuration; import org.apache.hadoop.hive.jdbc.HiveDriver; ...

    hive_jdbc_2.6.1.1001

    标题中的"hive_jdbc_2.6.1.1001"指的是Hive JDBC驱动程序的一个特定版本,这是用于连接Hive数据仓库系统与Java应用程序的桥梁。Hive是Apache Hadoop生态系统中的一个组件,它提供了一个SQL-like查询语言(HQL)来...

Global site tag (gtag.js) - Google Analytics