Oracle数据迁移至HBase操作记录

近期需要把Oracle数据库中的十几张表T级别的数据迁移至hbase中，过程中遇到了许多苦难和疑惑，在此记录一下希望能帮到一些有同样需求的兄弟。

HBase表设计

首先，是根据oracle的数据规划HBase的表和表结构。
从业务上看，十几张表大概可以分为两大部分：

• 交易信息
• 客户操作

刚开始的计划是将所有表都导入HBase中的一张大表，但是思索讨论之后发现是行不通的：

1、由于各个表之间的业务关系复杂，无法设定一个理想的Rowkey。
2、各个表的数据量也是相差万别的，都放入一张大表中会造成列簇的数据倾斜问题。
3、建立HBase表的目的理论上和建立关系型数据库的目的是一致的，想想为什么Oracle中为什么要分为十几张表而不是一张就明白了，方便业务逻辑。

接下来的思路就是根据业务逻辑划分出来的两大部分，建立两张HBase表。

由于系统业务和建表逻辑是另外一组的人负责的，交给我们的文档就是一堆sql文件，隔壁的大神根据这堆sql文件整理除了表的关联关系，为建HBase表提供了基础依据，功不可没:-)

那么接下来的事情就是为两张表设计Rowkey和列簇了。
关于Rowkey和列簇的设计原则可以参考：
https://blog.csdn.net/qq1010885678/article/details/50504941

根据业务逻辑和表字段信息，发现交易和客户信息都是以手机号码为中心的，Rowkey可以使用手机号码来实现，为了避免数据热点的问题，决定将手机号码反转之后的值作为Rowkey。

关于列簇的敲定，由于HBase列簇最好是控制在1-2个，超过3个可能会有性能问题，所以我们根据业务逻辑，分别对属于交易和客户信息两大类下的各个表再次进行划分。

第一次划分出两大类是为了建HBase表，这次的划分是为了建立表中的列簇。

例如：交易这一大部分的6个表中，有4个是经常一起做连接查询的，而另外2个表则是另一组业务逻辑经常使用的 ，那么就HBase中的交易表就可以分为两个列簇:交易业务，个人操作，分别存储着原本Oracle中4个表和2个表的数据。

客户信息表中列簇的设计同理，根据表之间的关联程度划分出三个列簇，大致可以称为：基本属性，行为属性，签署协议。

敲定了HBase的表结构之后，建表就是分分钟的事情了。

数据迁移部分

现在我们在HBase中有两张表，结构如下。

交易表：

Rowkey	交易业务列簇	个人操作列簇
手机号码反转	4张Oracle表数据	2张Oracle表数据

客户表：

Rowkey	基本属性	行为属性	签署协议
手机号码反转	4张Oracle表数据	2张Oracle表数据	3张Orale表数据

使用Sqoop进行数据迁移工作，详细操作说明见：Sqoop操作实践

但是开始迁移操作的时候发现两个问题：

• 1、个人操作列簇中有张表的数据量是20亿，而交易业务列簇中最大的数据量才5千万，差了40倍。
• 2、交易表的交易业务列簇中，4张表在导入HBase的时候时间戳是入库时间，但是在业务上需要使用一个该数据的生产时间。

对于第一个问题，我们采取的解决方案是：直接将20亿的个人操作列簇单独拆分为一张HBase表。
理由：避免HBase表中数据稀疏、倾斜造成性能问题，而个人操作列簇从业务和数据量上看完成可以单独作为一张表使用。

对于第二个问题，采取的方案是：先将这四张表分别导入为四张HBase临时表，之后使用mr程序修改时间戳统一导入最终的交易表。
理由：使用临时表第一是为了避免数据损坏，第二是方便mr程序修改时间戳属性。

而对于客户表，业务逻辑比较简单，可以直接使用Sqoop进行导入。

建立HBase始终是要在业务逻辑之上的，没有分析业务根本没办法知道HBase该分为几个表，每个表有几个列簇，每个列簇分别存储哪些数据，以及Rowkey的定义。

1.13更新

关于交易表的的数据版本问题，因为业务是根据手机号码和某个月份来查询的，平均每个月每个用户会查5次，那么之前的rowkey设计就是不合理的：

之前的rowkey是手机号码反转，其中一列为时间戳字段，那么每次有新的交易数据进来就会发生覆盖，之前我们一直在想设定值的版本为多少个比较好，12*5=60，也就是说每个列的值要设置为60个版本，这是极其不合理的。

现在，解决的思路是，既然是根据时间戳和手机号码来取数据的，因为每次数据入库的时候相同用户的交易数据会被新数据覆盖，那么把时间戳和手机号的组合设置为rowkey就完全可以解决这个问题。

那么这个rowkey的格式就是手机号码反转+时间戳，理由如下：

• 手机号码提供业务查询
• 反转避免数据热点
• 时间戳避免每月数据被覆盖（其实最后还是只用手机号码的话rowkey会重复的问题，也就是确保rowkey的唯一性）

另注：hbase统计数据量大的表可以使用其自带的一个mr程序：$HBASE_HOME/bin/hbase org.apache.Hadoop.hbase.mapreduce.RowCounter tableName

1.21更新

从传统数据库到HBase，表设计的思路与步骤大概如下：

• 根据业务划分hbase表
• 根据业务划分各个表的列族
• 判断各个列族所对应的表是否有关联关系
• 根据关联关系和查询的业务逻辑来确定rowkey的设计
• 如果一个列族中的表关键字或者字段有冲突，可以在rowkey后面添加后缀。
• 如果有关联关系，导入数据时需要注意对应问题

1.25更新

oracle表中如果没有合适的字段来给–split-by参数的话，可以用rownum这个默认的字段。

--split-by rownum

• 1
  • 1

其余遇到的困惑会再进行后续更新。