一.环境搭建(Hadoop+Hive)

window7: eclipse4.5.1

linux: hadoop-01 192.168.33.01

hadoop-01 要有 Hdfs namenode(active),Yarn resourcemanager(active),Hive metastore 和hiveserver2进程.

二.启动hive metastore和hiveserver2服务命令

[root@hadoop-01 bin]# hive --service metastore &

[root@hadoop-01 bin]# hive --service hiveserver2 &

hadoop-2.7.2.tar.gz到window7的D:\Hadoop\hadoop-2.7.2

apache-hive-2.0.0-bin.tar.gz 到window7的D:\Hadooop\apache-hive-2.0.0-bin

a.导入hive的lib文件夹下所有的包

b.导入hadoop的D:\Hadoop\hadoop-2.7.2\share\hadoop\common\hadoop-common-2.7.2.jar

点击(此处)折叠或打开

package com.hadoop.hive;
import java.sql.Connection;
import java.sql.DriverManager;
import java.sql.ResultSet;
import java.sql.SQLException;
import java.sql.Statement;
public class hiveserver2Test {
public boolean run() {
Connection con=null;
Statement stmt =null;
ResultSet rs=null;
String tableName="studentinfo";//表名
try {
String driver="org.apache.hive.jdbc.HiveDriver";//Hive的驱动字符串
Class.forName(driver); //加载Hive驱动
con = DriverManager.getConnection("jdbc:hive2://192.168.33.01:10000", "root", "");//获取hive2的jdbc连接，注意默认的数据库是default
stmt = con.createStatement();
rs=stmt.executeQuery("select * from "+tableName+" ");//查询所有,直接运行
while(rs.next()){
System.out.println("id:"+rs.getString(1)+" "+"name:"+rs.getString(2)+" "+"age:"+rs.getString(3)+" "+"tel:"+rs.getString(4)+" ");
}
System.out.println("查询成功!");
stmt.close();
con.close();
return true;
} catch (Exception e) {
e.printStackTrace();
System.out.println("error");
return false;
}
}
public static void main(String[] args) throws SQLException {
hiveserver2Test hiveJdbcClient = new hiveserver2Test();
hiveJdbcClient.run();
}
}

这句意思就是没有找到log4j2的配置文件

log4j2.xml文件

点击(此处)折叠或打开