IDEA使用连接JDBC连接带有phoenix加持的hbase数据库

发布时间 2023-09-16 14:38:34作者: yesyes1

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啦!

就像这样: