通过JDBC驱动连接Hive操作实例笔记

2024-08-17 05:09:41 222人阅读

package com.yuxipacific;

import java.sql.Connection;

import java.sql.DriverManager;

import java.sql.ResultSet;

import java.sql.Statement;

public class Hive {

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)";

//String insterSQL="LOAD DATA LOCAL INPATH ‘/work/hive/examples/files/kv1.txt‘ OVERWRITE INTO TABLE javabloger";

//String querySQL="SELECT a.* FROM javabloger a";

String querySQL="SELECT * FROM pokes";

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

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));

}

通过JDBC驱动连接Hive操作实例笔记

声明：以上内容来自用户投稿及互联网公开渠道收集整理发布，本网站不拥有所有权，未作人工编辑处理，也不承担相关法律责任，若内容有误或涉及侵权可进行投诉：投诉/举报工作人员会在5个工作日内联系你，一经查实，本站将立刻删除涉嫌侵权内容。

联系
我们