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

admin

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

  为什么要建maven项目，因为引用的包实在太多了！

2. 代码

1. [code]package com.epoint.test.phoenix;
3. import java.sql.Connection;
4. import java.sql.DriverManager;
5. import java.sql.ResultSet;
6. import java.sql.SQLException;
7. import java.sql.Statement;
9. public class Phoenix {
10.     private static String driver = "org.apache.phoenix.jdbc.PhoenixDriver";
12.     public static void main(String[] args) throws SQLException {
13.         try {
14.             Class.forName(driver);
15.         } catch (ClassNotFoundException e) {
16.             e.printStackTrace();
17.         }
18.         Statement stmt = null;
19.         ResultSet rs = null;
21.         Connection con = DriverManager.getConnection("jdbc:phoenix:hadoop0,hadoop1,hadoop2:2181");
22.         stmt = con.createStatement();
23.         String sql = "select * from test";
24.         rs = stmt.executeQuery(sql);
25.         while (rs.next()) {
26.             System.out.print("id:"+rs.getString("id"));
27.             System.out.println(",name:"+rs.getString("name"));
28.         }
29.         stmt.close();
30.         con.close();
31.     }
32. }

复制代码

[/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);                });            });