java代码将mysql表数据导入HBase表
目录
一、项目目录介绍
二、主要接口方法与调用
三、全局配置文件
四、执行方式和输出介绍
五、项目依赖
一、项目目录介绍
![](https://img-blog.csdnimg.cn/direct/7b551e6f5bac4759af0ba3e413fa51ed.png)
主要包含四个接口:Com、RDB、HBase、RDBToHBase和其实现类xxxImpl。
两个配置文件:log4j日志配置文件log4j.properties
和全局配置文件tranfer.properties
(具体见下面展示)
备注:这里用的关系型数据库是Mysql。即:RDB为Mysql
二、主要接口方法与调用
1、Com接口
一些通用方法
void close() // 释放资源
void init() // 初始化资源
Properties config() // 获取properties文件配置对象,为方法checkAndGetConfig服务
default String checkAndGetConfig(String key){} // 检查transfer.properties中是否有key这个配置项并放回其值,含默认实现
default void closeAll(AutoCloseable...acs){} // 统一资源释放调用,含默认实现
2、RDB接口:继承Com接口
其实现类主要实现:关系型数据库连接,执行sql语句将返回的结果集转化为Put对象
boolean hashNextBatch() throws SQLException; // 是否还有下一批次数据要传输
List<Put> nextBatch() throws SQLException; // 获取下一批数据
3、HBase接口:继承Com接口
其实现类主要实现:连接HBase,获取HBase表,上传数据
void putBatch