phoenix客户端API使用

本文主要是介绍phoenix客户端API使用，希望对大家解决编程问题提供一定的参考价值，需要的开发者们随着小编来一起学习吧！

1.准备条件

phoenix与Hbase已经安装好
phoenix-4.3.0
hbase-0.98

2.客户端使用（服务器上使用客户端）

在客户端创建如下文件test.java：

import java.sql.Connection;
import java.sql.DriverManager;
import java.sql.ResultSet;
import java.sql.SQLException;
import java.sql.PreparedStatement;
import java.sql.Statement;public class test {public static void main(String[] args) throws SQLException {Statement stmt = null;ResultSet rset = null;Connection con = DriverManager.getConnection("jdbc:phoenix:[zookeeper]");stmt = con.createStatement();stmt.executeUpdate("create table test (mykey integer not null primary key, mycolumn varchar)");stmt.executeUpdate("upsert into test values (1,'Hello')");stmt.executeUpdate("upsert into test values (2,'World!')");con.commit();PreparedStatement statement = con.prepareStatement("select * from test");rset = statement.executeQuery();while (rset.next()) {System.out.println(rset.getString("mycolumn"));}statement.close();con.close();}
}

编译：

$javac test.java

执行：
$ java -cp "../phoenix-[version]-client.jar:." test

3.参考文献

http://phoenix.apache.org/faq.html

这篇关于phoenix客户端API使用的文章就介绍到这儿，希望我们推荐的文章对编程师们有所帮助！

---