下载 jdo2-api-2.3-ec hive hdfs 所需jar
http://download.csdn.net/download/knight_black_bob/9725194
常见命令
hive 常见命令 create table test(uid string,name string)row format delimited fields terminated by '/t' 见表语句 desc formatted test; 表的约束 desc test; 表的约束 LOAD DATA local INPATH '/root/test3.log' OVERWRITE INTO TABLE test; 本地文件添加数据到hive LOAD DATA INPATH '/user/hadoop/test5.log' OVERWRITE INTO TABLE test; hdfs 添加数据到hive select * from test; 查询数据 select count(1) from test; 做mapreduce操作运算需要 hadoop 权限 hdfs 常见命令 hdfs dfs -copyFromLocal test3.log /user/hadoop/test5.log 拷贝 hdfs dfs -cat /user/hadoop/test5.log 查看文件内容 hdfs dfs -lsr /user/hadoop 遍历目录 hdfs dfs -rmr /user/hadoop/storm/ 删除 hdfs dfs -appendToFile test3.log /user/hadoop/test5.log 添加
pom
<dependency> <groupId>org.apache.hive</groupId> <artifactId>hive-jdbc</artifactId> <version>0.11.0</version> </dependency> <dependency> <groupId>org.apache.hadoop</groupId> <artifactId>hadoop-common</artifactId> <version>2.2.0</version> </dependency>
/**
* @Type HiveTest.java
* @Desc
* @author hadoop
* @date 2016年12月29日 下午2:20:46
* @version
*/
public class HiveTest {
private static String driverName = "org.apache.hive.jdbc.HiveDriver";
public static void main(String[] args)
throws SQLException {
try {
Class.forName(driverName);
} catch (ClassNotFoundException e) {
e.printStackTrace();
System.exit(1);
}
Connection con = DriverManager.getConnection("jdbc:hive2://172.23.27.120:10000/default", "hive", "hive");
Statement stmt = con.createStatement();
String tableName = "test";
//stmt.execute("drop table if exists " + tableName);
//stmt.execute("create table " + tableName + " (key int, value string) row format delimited fields terminated by ','");
// show tables
String sql = "show tables '" + tableName + "'";
ResultSet res = stmt.executeQuery(sql);
if (res.next()) {
System.out.println(res.getString(1));
}
System.out.println("==================================");
sql = "describe " + tableName;
System.out.println("Running: " + sql);
res = stmt.executeQuery(sql);
while (res.next()) {
System.out.println(res.getString(1) + "\t" + res.getString(2));
}
System.out.println("==================================");
sql = "select * from " + tableName;
res = stmt.executeQuery(sql);
while (res.next()) {
System.out.println(String.valueOf(res.getInt(1)) + "\t" + res.getString(2));
}
System.out.println("==================================");
sql = "select * from " + tableName +" where key ='1' ";
res = stmt.executeQuery(sql);
while (res.next()) {
System.out.println(String.valueOf(res.getInt(1)) + "\t" + res.getString(2));
}
sql = "select count(1) from " + tableName;
System.out.println("Running: " + sql);
res = stmt.executeQuery(sql);
while (res.next()) {
System.out.println(res.getString(1));
}
System.out.println("==================================");
}
}
捐助开发者
在兴趣的驱动下,写一个免费的东西，有欣喜，也还有汗水，希望你喜欢我的作品，同时也能支持一下。 当然，有钱捧个钱场（右上角的爱心标志，支持支付宝和PayPal捐助），没钱捧个人场，谢谢各位。
谢谢您的赞助，我会做的更好！
