Java学习者论坛

 找回密码
 立即注册

QQ登录

只需一步,快速开始

手机号码,快捷登录

恭喜Java学习者论坛(https://www.javaxxz.com)已经为数万Java学习者服务超过8年了!积累会员资料超过10000G+
成为本站VIP会员,下载本站10000G+会员资源,购买链接:点击进入购买VIP会员
JAVA高级面试进阶视频教程Java架构师系统进阶VIP课程

分布式高可用全栈开发微服务教程

Go语言视频零基础入门到精通

Java架构师3期(课件+源码)

Java开发全终端实战租房项目视频教程

SpringBoot2.X入门到高级使用教程

大数据培训第六期全套视频教程

深度学习(CNN RNN GAN)算法原理

Java亿级流量电商系统视频教程

互联网架构师视频教程

年薪50万Spark2.0从入门到精通

年薪50万!人工智能学习路线教程

年薪50万!大数据从入门到精通学习路线年薪50万!机器学习入门到精通视频教程
仿小米商城类app和小程序视频教程深度学习数据分析基础到实战最新黑马javaEE2.1就业课程从 0到JVM实战高手教程 MySQL入门到精通教程
查看: 688|回复: 0

[默认分类] 通过JDBC访问phoenix

[复制链接]
  • TA的每日心情
    开心
    2021-12-13 21:45
  • 签到天数: 15 天

    [LV.4]偶尔看看III

    发表于 2018-7-2 10:37:28 | 显示全部楼层 |阅读模式

    应用场景
    既然Hbase支持sql语句对数据进行操作,那么我们能不能通过代码连接Hbase,通过phoenix,在代码中书写sql语句,对phoenix进行操作呢?
    操作方案
    1. 新建maven项目

      为什么要建maven项目,因为引用的包实在太多了!
    2. 代码
    1. [code]package com.epoint.test.phoenix;
    2. import java.sql.Connection;
    3. import java.sql.DriverManager;
    4. import java.sql.ResultSet;
    5. import java.sql.SQLException;
    6. import java.sql.Statement;
    7. public class Phoenix {
    8.     private static String driver = "org.apache.phoenix.jdbc.PhoenixDriver";
    9.     public static void main(String[] args) throws SQLException {
    10.         try {
    11.             Class.forName(driver);
    12.         } catch (ClassNotFoundException e) {
    13.             e.printStackTrace();
    14.         }
    15.         Statement stmt = null;
    16.         ResultSet rs = null;
    17.         Connection con = DriverManager.getConnection("jdbc:phoenix:hadoop0,hadoop1,hadoop2:2181");
    18.         stmt = con.createStatement();
    19.         String sql = "select * from test";
    20.         rs = stmt.executeQuery(sql);
    21.         while (rs.next()) {
    22.             System.out.print("id:"+rs.getString("id"));
    23.             System.out.println(",name:"+rs.getString("name"));
    24.         }
    25.         stmt.close();
    26.         con.close();
    27.     }
    28. }
    复制代码
    [/code]
    3. pom中加入如下dependency
    1. [code]  <dependency>
    2.      <groupId>org.apache.phoenix</groupId>
    3.      <artifactId>phoenix-core</artifactId>
    4.      <version>4.10.0-HBase-1.2</version>
    5.   </dependency>
    复制代码
    [/code]
    maven下载的依赖包如下所示:



    4. 运行代码,右击run as java application


                $(function () {                $("pre.prettyprint code").each(function () {                    var lines = $(this).text().split("\n").length;                    var $numbering = $("").addClass("pre-numbering").hide();                    $(this).addClass("has-numbering").parent().append($numbering);                    for (i = 1; i ").text(i));                    };                    $numbering.fadeIn(1700);                });            });        
    回复

    使用道具 举报

    您需要登录后才可以回帖 登录 | 立即注册

    本版积分规则

    QQ|手机版|Java学习者论坛 ( 声明:本站资料整理自互联网,用于Java学习者交流学习使用,对资料版权不负任何法律责任,若有侵权请及时联系客服屏蔽删除 )

    GMT+8, 2024-3-28 20:31 , Processed in 0.353738 second(s), 38 queries .

    Powered by Discuz! X3.4

    © 2001-2017 Comsenz Inc.

    快速回复 返回顶部 返回列表