大数据java操作hive.pdf

【文件属性】：
文件名称：大数据java操作hive.pdf
文件大小：193KB
文件格式：PDF
更新时间：2022-12-24 11:39:00
文档资料 ⼤数据java操作hive ⼤数据 ⼤数据 java操作 操作hive 版权声明： 本⽂为博主学习整理原创⽂章，如有不正之处请多多指教。 未经博主允许不得转载。 虚拟机上操作，保证 虚拟机上操作，保证hive数据库能正常连接进⼊。 数据库能正常连接进⼊。 如因退出没有⽤到命令（quit;），第⼆次进⼊则会报错。解决⽅法，切换到 [root@xcl ~]# cd apache-hive-2.1.1-bin/conf/ [root@xcl conf]# vi hive-site.xml 最后进⾏初始化命令为：schematool -initSchema -dbType mysql 在任意⽬录下输⼊hive，则ok。 创建数据库、在数据库中创建数据表，在本地 创建数据库、在数据库中创建数据表，在本地"造数据 造数据" Create databases text； 例： CREATE TABLE t4(name String ,age int,likes ARRAY,relation MAP,location struct) ROW FORMAT DELIMITED FIELDS TERMINATED BY ',' COLLECTION ITEMS TERMINATED BY '^' MAP KEYS TERMINATED BY ':'; "造的数据"已经分好类 # 字段分割符是逗号 # 数组类型分隔符是^号 # map数据类型分割符是冒号 tom,18,lol^篮球^⾳乐,father:tom1^mother:lili,US^LOS^16 ⽤load上传本地数据到表中 load data local inpath '/usr/local/apps/test1.txt' into table t4; eclipse操作步骤（要配好 操作步骤（要配好maven创建 创建maven项⽬） 项⽬） maven项⽬需要的包，在 项⽬需要的包，在"pom.xml"中添加 中添加 org.apache.hive hive-jdbc 2.1.1 java连接 连接hive代码： 代码： //加载驱动 Class.forName("org.apache.hive.jdbc.HiveDriver"); //获取连接 String url="jdbc:hive2://192.168.1.90:10000/test"; Connection connection= DriverManager.getConnection(url,"root",""); //执⾏sql PreparedStatement ps=connection.prepareStatement("SELECT * FROM table01 "); //获取结果 ResultSet rs=ps.executeQuery(); while (rs.next()){ System.out.println("测试数据输出结果是："+rs.getString(1)); } //关闭连接 rs.close(); ps.close(); connection.close(); 在代码中添加 注意：引的包全是sql包 引完后会报异常，抛出异常即可 如出现这个问题 解决⽅法： jdk.tools jdk.tools 1.7 system ${JAVA_HOME}/lib/tools.jar