使用用Phoenix的Java api操作HBase

使用Phoenix Java api操作HBase,对hbase进行增,删,查。这个过程就想是JDBC一样使用就可以了。

 

①先将phoenix的 core.jar包 和 phoenix的client.jar 包放到lib里。

 

②创建连接,过程和mysql类似

 

public Connection GetConnection() {
	Connection cc = null;
	String driver = "org.apache.phoenix.jdbc.PhoenixDriver";
	// String url = "jdbc:phoenix:192.168.206.21:2181";

	try {
		Class.forName(driver);
	} catch (ClassNotFoundException e) {
		e.printStackTrace();
	}

	if (cc == null) {
		try {
			cc = DriverManager.getConnection(url);
		} catch (SQLException e) {
			e.printStackTrace();
		}
	}
	return cc;
}

 

③执行sql语句,对用phoenix对hbase中表进行查询。

QQ截图20141202101221

:代码有点问题,我忘记释放链接了。注意加上。

④ 增,删,操作和查询类似,都是一条sql(略)。

 

⑤说明一下phoenix对hbase修改操作

QQ截图20150311194947

 

OK 搞定了。

 

推荐阅读,系列文章

在SQuirrel中使用Phoenix操作HBase——创建表和视图

在SQuirrel中使用Phoenix操作HBase——基本的sql查询

用SHELL命令来操作phoenix

使用用Phoenix的Java api操作HBase

发表评论

电子邮件地址不会被公开。 必填项已用*标注