1、首先要保证自己的phoenix已经下载,且能够正常运行
所谓正常运行,即能够正常地使用增删改查的相关操作,而不产生错误,比如不允许啥啥的情况;
2、注意phoenix的命令格式(需要保证表中必须有primary key)
增加/修改(在phoenix里面,这两种情况被合并了,若是primary key已经存在,那么就是修改;不存在则是增加):
upsert into 表名 values(?,?,?);
删除:
delete from 表名 where 条件;
查询:
select * from 表名 where 查询条件(查询所有的话,查询条件可省略);
3、借助phoenix连接hbase数据库的Connection作用类
//首先加载驱动
Class.forName("org.apache.phoenix.jdbc.PhoenixDriver");
//之后定义我们自身虚拟机的url
String url="jdbc:phoenix:node1.node2,node3:2181";
//配置对象,没有用户名密码
Properties properties=new Properties();
properties.put("phoenix.schema.isNamespaceMappingEnabled","true");
//获取Connection对象链接
Connection connection=DriverManager.getConnection(url,properties);
//之后就自己通过简单的JDBC知识执行PrepareStatement对象的sql语句就能实现增删改查啦!
对于第三条,可以用一个方法将它封装起来,之后要是再需要调用到Connection的话,直接使用这个方法得到Connection对象就ok啦!
就像这样: