Java(115)Java通过jdbc接口连接hive3.1.2

这篇具有很好参考价值的文章主要介绍了Java(115)Java通过jdbc接口连接hive3.1.2。希望对大家有所帮助。如果存在错误或未考虑完全的地方,请大家不吝赐教,您也可以点击"举报违法"按钮提交疑问。

Java通过jdbc接口连接hive

1、版本信息

hive版本:3.1.2

jdbc:hive-jdbc-uber-2.6.5.0-292.jar

下载驱动地址:https://github.com/timveil/hive-jdbc-uber-jar/releases/tag/v1.9-2.6.5

java 链接hive,java相关,# 大数据,hive,java,大数据

2、pom.xml引用

<dependency>
    <groupId>org.appache.hive</groupId>
    <artifactId>hive-jdbc-uber</artifactId>
    <version>2.6.5.0-292</version>
    <scope>system</scope>
    <systemPath>${pom.basedir}/src/main/resources/lib/hive-jdbc-uber-2.6.5.0-292.jar</systemPath>
</dependency>

3、对应的数据库表

CREATE TABLE regre_one.hive2_varchar(

ID int,

aes varchar(1000),

sm4 varchar(1000),

sm4_a varchar(1000),

email varchar(1000),

phone varchar(1000),

ssn varchar(1000),

military varchar(1000),

passport varchar(1000),

intelssn varchar(1000),

intelpassport varchar(1000),

intelmilitary varchar(1000),

intelganghui varchar(1000),

inteltaitonei varchar(1000),

credit_card_short varchar(1000),

credit_card_long varchar(1000),

job varchar(1000));文章来源地址https://www.toymoban.com/news/detail-743347.html

4、Java通过jdbc接口连接hive的Java代码

package utils;


import java.sql.Connection;
import java.sql.DriverManager;
import java.sql.ResultSet;
import java.sql.Statement;

/**
 * Description :
 *
 * @author : HMF
 * Date : Created in 15:28 2023/3/21
 * @version :
 */
public class dbTest_hive {
    public Connection conn;
    public dbTest_hive(){
        //String driver="org.apache.hive.jdbc.HiveDriver";
        String driver="com.ciphergateway.aoe.plugin.engine.AOEDriver";
        String url="jdbc:hive2:aoe://10.1.1.242:10000/default";
        String user="xxx";
        String password="xxx";

        try{
            Class.forName(driver);
            conn= DriverManager.getConnection(url,user,password);
        }catch (Exception e){
            e.printStackTrace();
            System.exit(1);
        }

    }
    public static void main(String[] args)  {
        dbTest_hive db=new dbTest_hive();
        String insertSql="INSERT INTO default.hive_char (id,aes, sm4, sm4_a, email, phone, ssn, military, passport, intelssn, intelpassport, intelmilitary, intelganghui, inteltaitonei, credit_card_short, credit_card_long, job) VALUES (1,'小芬', '北京xx网络技术有限公司', '北京市', 'hmf@yahoo.com', '15652996964', '210302199608124861', '武水电字第3632734号', 'BWP018930705', '210302199608124861', 'BWP018930705', '武水电字第3632734号', 'H21157232', '9839487602', '117', '6227612145830440', '高级测试开发工程师')";
        String selectSql="select id,aes, sm4, sm4_a, email, phone, ssn, military, passport, intelssn, intelpassport, intelmilitary, intelganghui, inteltaitonei, credit_card_short, credit_card_long, job from default.hive_char";
        //String deleteSql="truncate table regre_one.hivetest_varchar";
        //db.DBExecute(deleteSql);
        db.DBExecute(insertSql);
        db.DBQuery(selectSql);
        System.exit(0);
    }

    void DBExecute(String sqlStr){
        try{
            Statement stmt=conn.createStatement();
            boolean result=stmt.execute(sqlStr);
            System.out.println("+++++sqlStr:"+sqlStr);
            stmt.close();
        }catch (Exception e){
            e.printStackTrace();
        }
    }

    void DBQuery(String sqlStr){
        try{
             Statement statement=conn.createStatement();
             ResultSet rs=statement.executeQuery(sqlStr);
             int columnCount=rs.getMetaData().getColumnCount();
             System.out.println("+++++sqlStr:"+sqlStr);
             while (rs.next()){
                 String result="";
                 for(int i=0;i<columnCount;i++){
                     result +="\t"+rs.getString(i+1);
                 }
                 System.out.println(result);
             }
             rs.close();
             statement.close();
        }catch (Exception e){
            e.printStackTrace();
        }
    }


}

到了这里,关于Java(115)Java通过jdbc接口连接hive3.1.2的文章就介绍完了。如果您还想了解更多内容,请在右上角搜索TOY模板网以前的文章或继续浏览下面的相关文章,希望大家以后多多支持TOY模板网!

本文来自互联网用户投稿,该文观点仅代表作者本人,不代表本站立场。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。如若转载,请注明出处: 如若内容造成侵权/违法违规/事实不符,请点击违法举报进行投诉反馈,一经查实,立即删除!

领支付宝红包 赞助服务器费用

相关文章

  • 【大数据笔记】java jdbc连接hive数据库;java hive连接kerberos

    1、pom.xml配置         dependency             groupIdorg.apache.hive/groupId             artifactIdhive-jdbc/artifactId             scope2.1.1/scope         /dependency 2、驱动 org.apache.hive.jdbc.HiveDriver 3、用传统改的Class.forName,然后DriverManager去拿。 二、java hive连接kerberos

    2024年01月19日
    浏览(46)
  • hadoop3.2.1+hive3.1.2-docker安装

    建立hadoop用的内部网络(此步出错,若与其它网段冲突,可省略) #指定固定ip号段 建立Master容器,映射端口 10000端口为hiveserver2端口,后面本地客户端要通过beeline连接hive使用,有其他组件要安装的话可以提前把端口都映射出来 若创建了网段则可指定网段运行 创建slave1 172.17.

    2024年02月08日
    浏览(40)
  • java : 通过jdbc读取hive(2.3)中的数据

    一、准备好hive的环境,创建表(例如userinfo),添加数据。 二、启动hive服务 hive --service hiveserver2 三、项目中添加依赖 四、读取数据demo:

    2024年01月16日
    浏览(45)
  • Ubuntu下安装Hive3.1.2教程(附MySQL安装方法及安装包)

    Hive 的安装需要建立在 Hadoop 的之上(类似于Hbase) ,关于 Hadoop 的单机安装以及伪分布式安装可以参考作者的另两篇博客: Ubuntu下单机安装Hadoop详细教程(附所需安装包下载) Ubuntu下伪分布式安装Hadoop详细教程 本文安装的 Hadoop 及 Java 环境基于林子雨老师的《大数据技术原

    2024年02月04日
    浏览(50)
  • [sqoop]hive3.1.2 hadoop3.1.1安装sqoop1.4.7

    Hadoop3.2.4+Hive3.1.2+sqoop1.4.7安装部署_hadoop sqoop安装_alicely07的博客-CSDN博客 sqoop-env.sh 末尾添加 环境变量 先创建目录,解决警告:accumulo does not exist! (1)添加jdbc驱动包:将MySQL数据库的JDBC驱动包mysql-connector-java-5.1.37.jar添加到Sqoop安装目录的lib目录中。 (2)删除Sqoop安装目录的

    2024年02月07日
    浏览(60)
  • Hive连接异常:无法通过JDBC连接打开客户端传输(JDBC Uri: jdbc:hive2:// 大数据)

    Hive连接异常:无法通过JDBC连接打开客户端传输(JDBC Uri: jdbc:hive2:// 大数据) 在大数据领域中,Hive是一个常用的数据仓库解决方案,可以用于处理和分析大规模的结构化数据。然而,在使用Hive时,我们有时会遇到一些连接问题。其中之一就是\\\"Hive连接报错:Could not open clien

    2024年02月08日
    浏览(45)
  • jdbc通过kerberos认证连接hive

    根据实际情况添加依赖,主要看服务器hive版本 配置文件krb5.conf,认证文件krb5.keytab,一般由服务器生成后获取 放到resources目录下     指定krb5配置文件:krb5.conf,根据实际情况替换 认证文件:krb5.keytab,根据实际情况替换 认证用户:hive,根据实际情况修改 这里是通过将配置文

    2024年02月10日
    浏览(62)
  • java代码实现,利用JDBC接口-连接Mysql数据库

    1、JDBC本质上是一个接口,也就是java语言操作数据库的一套API(应用程序编程接口), 接口就规则,也就是sun公司创建了一个jdbc接口,各个sql(数据库管理系统)去实现接口提供jar包。其优点JDBC不是指单一操作某一个数据库。各个厂商使用相同的接口。不同的sql厂家实现

    2024年02月09日
    浏览(71)
  • 通过JDBC连接数据库并用Java把数据写入数据库

    目录 1.新建项目 2.在src包下新建lib包,用来存放jar包(下载对应jar包复制到lib包里) 3.右键导入的jar包,找到并单击\\\"添加到库\\\"(add....) 4.在src包下新建bean包,新建class类 5.class类中写数据库表中对应的列名的set get方法、空参、有参(String方法)注意:类名为私有类(private),新建类时数

    2024年02月02日
    浏览(69)
  • 使用DataX工具连接hive数据库:java.sql.SQLException: Could not establish connection to jdbc:hive2://master:1000

    Code:[DBUtilErrorCode-10], Description:[连接数据库失败. 请检查您的 账号、密码、数据库名称、IP、Port或者向 DBA 寻求帮助(注意网络环境).]. - 具体错误信息为:java.sql.SQLException: Could not establish connection to jdbc:hive2://master:10000/datax: Required field \\\'serverProtocolVersion\\\' is unset! Struct:TOpenSessionRe

    2024年04月09日
    浏览(73)

觉得文章有用就打赏一下文章作者

支付宝扫一扫打赏

博客赞助

微信扫一扫打赏

请作者喝杯咖啡吧~博客赞助

支付宝扫一扫领取红包,优惠每天领

二维码1

领取红包

二维码2

领红包