版权声明:本文为博主原创文章,未经博主允许不得转载。 https://blog.csdn.net/yitengtongweishi/article/details/82419926
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