1,terry 2,alex 3,jimmy 4,mike 5,kate

Class.forName("org.apache.hive.jdbc.HiveDriver");

Connection con = DriverManager.getConnection("jdbc:hive2://host1:10000/default", "hive", "");

stmt.execute("drop table if exists " + tableName);

stmt.execute("create table " + tableName + " (key int, value string) ROW FORMAT DELIMITED FIELDS TERMINATED BY '54'");

ResultSet res = stmt.executeQuery("select * from " + tableName);

stmt.execute("load data local inpath '" + filepath + "' into table " + tableName);

<project xmlns="http://maven.apache.org/POM/4.0.0" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven⑷.0.0.xsd"> <modelVersion>4.0.0</modelVersion> <groupId>org.crazycake</groupId> <artifactId>play-hive</artifactId> <version>0.0.1-SNAPSHOT</version> <packaging>jar</packaging> <name>play-hive</name> <url>http://maven.apache.org</url> <properties> <project.build.sourceEncoding>UTF⑻</project.build.sourceEncoding> </properties> <dependencies> <dependency> <groupId>junit</groupId> <artifactId>junit</artifactId> <version>3.8.1</version> <scope>test</scope> </dependency> <dependency> <groupId>org.apache.hive</groupId> <artifactId>hive-jdbc</artifactId> <version>0.14.0</version> </dependency> <dependency> <groupId>org.apache.hadoop</groupId> <artifactId>hadoop-common</artifactId> <version>2.2.0</version> </dependency> </dependencies> <build> <plugins> <plugin> <artifactId>maven-compiler-plugin</artifactId> <version>2.0.2</version> <configuration> <source>1.6</source> <target>1.6</target> <encoding>UTF⑻</encoding> <optimise>true</optimise> <compilerArgument>-nowarn</compilerArgument> </configuration> </plugin> <plugin> <groupId>org.apache.maven.plugins</groupId> <artifactId>maven-shade-plugin</artifactId> <version>2.3</version> <configuration> <transformers> <transformer implementation="org.apache.maven.plugins.shade.resource.ApacheLicenseResourceTransformer"> </transformer> </transformers> </configuration> <executions> <execution> <phase>package</phase> <goals> <goal>shade</goal> </goals> </execution> </executions> </plugin> </plugins> </build> </project>

<dependency> <groupId>org.apache.hive</groupId> <artifactId>hive-jdbc</artifactId> <version>0.14.0</version> </dependency> <dependency> <groupId>org.apache.hadoop</groupId> <artifactId>hadoop-common</artifactId> <version>2.2.0</version> </dependency>

package org.crazycake.play_hive; import java.sql.SQLException; import java.sql.Connection; import java.sql.ResultSet; import java.sql.Statement; import java.sql.DriverManager; /** * 测试hive 的客户端连接 * @author alexxiyang (https://github.com/alexxiyang) * */ public class HiveJdbcClient { /** * 注意：hive-server2 援用的driver是 org.apache.hive.* 而 hive-server 是 org.apache.hadoop.hive.* */ private static String driverName = "org.apache.hive.jdbc.HiveDriver"; /** * @param args * @throws SQLException */ public static void main(String[] args) throws SQLException { try { Class.forName(driverName); } catch (ClassNotFoundException e) { // TODO Auto-generated catch block e.printStackTrace(); System.exit(1); } //hive的默许端口是 10000，如果要修改就修改 hive-site.xml 文件的hive.server2.thrift.port 属性值 //默许用户名hive，默许密码为空 Connection con = DriverManager.getConnection("jdbc:hive2://host1:10000/default", "hive", ""); Statement stmt = con.createStatement(); //测试的表名 testhivedrivertable String tableName = "testhivedrivertable"; //如果已存在就删除 stmt.execute("drop table if exists " + tableName); //创建这张表 stmt.execute("create table " + tableName + " (key int, value string) ROW FORMAT DELIMITED FIELDS TERMINATED BY '54'"); //看下创建是不是成功 String sql = "show tables '" + tableName + "'"; System.out.println("Running: " + sql); ResultSet res = stmt.executeQuery(sql); if (res.next()) { System.out.println(res.getString(1)); } //看下表结构 sql = "describe " + tableName; System.out.println("Running: " + sql); res = stmt.executeQuery(sql); while (res.next()) { System.out.println(res.getString(1) + " " + res.getString(2)); } // 加载数据到表里面 // NOTE: filepath 是本地文件所在的位置，注意这个本地不是你的电脑！ // 你得先把这个文件上传到服务器，然后这里的路径是服务器上这个文件的路径 // NOTE: /data/a.txt String filepath = "/data/a.txt"; sql = "load data local inpath '" + filepath + "' into table " + tableName; System.out.println("Running: " + sql); stmt.execute(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)) + " " + res.getString(2)); } // count 1下看有多少条数据 sql = "select count(1) from " + tableName; System.out.println("Running: " + sql); res = stmt.executeQuery(sql); if (res.next()) { System.out.println(res.getString(1)); } } }

Running: show tables 'testhivedrivertable' testhivedrivertable Running: describe testhivedrivertable key int value string Running: load data local inpath '/data/a.txt' into table testhivedrivertable Running: select * from testhivedrivertable 1 terry 2 alex 3 jimmy 4 mike 5 kate Running: select count(1) from testhivedrivertable