友情提示：Phoenix 实现 SQL On HBase

Maven 依赖

部署Maven：https://blog.csdn.net/yitengtongweishi/article/details/81946562

        <!--Phoenix-->
        <dependency>
            <groupId>org.apache.phoenix</groupId>
            <artifactId>phoenix-core</artifactId>
            <version>${phoenix.version}</version>
        </dependency>

下面，直接上代码

import java.sql.*;

/**
 * Created by blockchain on 18-9-5 上午10:34 in Beijing.
 */

public class PhoenixJdbc {
    public static void main(String[] args) throws ClassNotFoundException, SQLException {

        Class.forName("org.apache.phoenix.jdbc.PhoenixDriver");

        //这里配置zookeeper的地址 可以是域名或者ip 可单个或者多个(用","分隔)
        String url = "jdbc:phoenix:localhost:2181";
        Connection conn = DriverManager.getConnection(url);
        Statement statement = conn.createStatement();

        ResultSet rs = statement.executeQuery("select * from PhoenixTest");
        while (rs.next()) {
            int pk = rs.getInt("PK");
            String col1 = rs.getString("COL1");

            System.out.println("PK=" + pk + ", COL1=" + col1);
        }
        // 关闭连接
        rs.close();

        statement.close();
        conn.close();
    }
}

输出

PK=1, COL1=Hello
PK=2, COL1=World
PK=3, COL1=HBase
PK=4, COL1=Phoenix