数据仓库-拉链表

在数据仓库中制作拉链表，可以按照以下步骤进行：

确定需求：首先明确需要使用拉链表的场景和需求。例如，可能需要记录历史数据的变化，以便进行时间序列分析等。
设计表结构：在数据仓库中，拉链表通常由两个表组成：当前表和历史表。当前表存储最新的数据，历史表存储过去的数据。两个表的结构应该相同，包含相同的字段。
建立当前表：创建一个当前表，用于存储最新的数据。该表应包含需要记录的所有字段，以及一个表示有效期的字段。有效期字段用于标识该条数据在何时失效。
建立历史表：创建一个历史表，用于存储过去的数据。该表的结构与当前表相同，但还应包含一个表示生效日期的字段。生效日期字段用于标识该条数据在何时生效。
数据插入与更新：当有新数据插入时，将其插入到当前表中，并设置相应的有效期。同时，将过期的数据从当前表中移动到历史表中，并更新它们的生效日期和有效期。
数据查询：在查询数据时，同时查询当前表和历史表。根据查询的时间范围，确定在哪个表中查找数据。
定期维护：定期对历史表进行维护，例如删除过期的数据、优化索引等，以确保拉链表的性能和存储空间的有效利用。

需要注意的是，拉链表在数据仓库中的应用可能因具体需求和场景而有所不同。因此，在实际制作拉链表时，建议根据数据仓库的设计规范、业务需求和数据特点进行调整和优化。同时，也要确保数据的完整性、一致性和准确性。

参考：漫谈数据仓库之拉链表（原理、设计以及在Hive中的实现）_拉链表实现方式_小强签名设计的博客-CSDN博客

二、什么是拉链表

拉链表是针对数据仓库设计中表存储数据的方式而定义的，顾名思义，所谓拉链，就是记录历史。记录一个事物从开始，一直到当前状态的所有变化的信息。

我们先看一个示例，这就是一张拉链表，存储的是用户的最基本信息以及每条记录的生命周期。我们可以使用这张表拿到最新的当天的最新数据以及之前的历史数据

1. 拉链表的使用场景

在数据仓库的数据模型设计过程中，经常会遇到下面这种表的设计：

有一些表的数据量很大，比如一张用户表，大约10亿条记录，50个字段，这种表，即使使用 ORC 压缩，单张表的存储也会超过100G，在 HDFS 使用双备份或者三备份的话就更大一些。
表中的部分字段会被 update 更新操作，如用户联系方式，产品的描述信息，订单的状态等等。
需要查看某一个时间点或者时间段的历史快照信息，比如，查看某一个订单在历史某一个时间点的状态。
表中的记录变化的比例和频率不是很大，比如，总共有10亿的用户，每天新增和发生变化的有200万左右，变化的比例占的很小。

那么对于这种表我该如何设计呢？下面有几种方案可选：

方案一：每天只留最新的一份，比如我们每天用Sqoop抽取最新的一份全量数据到Hive中。
方案二：每天保留一份全量的切片数据。
方案三：使用拉链表。

拉链表

拉链表在使用上基本兼顾了我们的需求。
首先它在空间上做了一个取舍，虽说不像方案一那样占用量那么小，但是它每日的增量可能只有方案二的千分之一甚至是万分之一。
其实它能满足方案二所能满足的需求，既能获取最新的数据，也能添加筛选条件也获取历史的数据。

所以我们还是很有必要来使用拉链表的。

三、拉链表的设计和实现

1. 如何设计一张拉链表

我们先看一下在 Mysql 关系型数据库里的 user 表中信息变化。

在 2017-01-01 这一天表中的数据是：

在 2017-01-02 这一天表中的数据是，用户 002 和 004 资料进行了修改，005 是新增用户：

在 2017-01-03 这一天表中的数据是，用户 004 和 005 资料进行了修改，006 是新增用户：

如果在数据仓库中设计成历史拉链表保存该表，则会有下面这样一张表，这是最新一天（即 2017-01-03 ）的数据：

说明：

t_start_date 表示该条记录的生命周期开始时间，t_end_date 表示该条记录的生命周期结束时间。
t_end_date = ‘9999-12-31’ 表示该条记录目前处于有效状态。
如果查询当前所有有效的记录，则 select * from user where t_end_date = ‘9999-12-31’。
如果查询 2017-01-02 的历史快照，则 select * from user where t_start_date <= ‘2017-01-02’ and t_end_date >= ‘2017-01-02’。（此处要好好理解，是拉链表比较重要的一块。 where条件筛选当前有效数据，开始日期小于等于当前日期并且结束日期大于等于当前日期，则为有效。）

2. 在Hive中实现拉链表

在现在的大数据场景下，大部分的公司都会选择以 Hdfs 和 Hive 为主的数据仓库架构。目前的 Hdfs 版本来讲，其文件系统中的文件是不能做改变的，也就是说 Hive 的表只能进行删除和添加操作，而不能进行 update。基于这个前提，我们来实现拉链表。

还是以上面的用户表为例，我们要实现用户的拉链表。在实现它之前，我们需要先确定一下我们有哪些数据源可以用。

我们需要一张ODS层的用户全量表。至少需要用它来初始化。
每日的用户更新表。

而且我们要确定拉链表的时间粒度，比如说拉链表每天只取一个状态，也就是说如果一天有3个状态变更，我们只取最后一个状态，这种天粒度的表其实已经能解决大部分的问题了。

另外，补充一下每日的用户更新表该怎么获取，据笔者的经验，有3种方式拿到或者间接拿到每日的用户增量，因为它比较重要，所以详细说明：

我们可以监听 Mysql 数据的变化，比如说用 Canal，最后合并每日的变化，获取到最后的一个状态。
假设我们每天都会获得一份切片数据，我们可以通过取两天切片数据的不同来作为每日更新表，这种情况下我们可以对所有的字段先进行 concat，再取 md5，这样就 ok 了。
流水表！有每日的变更流水表。
通过 etl 工具对操作型数据库按照时间字段增量抽取到 ods 或者数据仓库（每天抽取前一天的数据），形成每天的增量数据（实际中使用最多的情形）。

（1）拉链表实现方式一

ods 层的 user 表：

现在我们来看一下我们 ods 层的用户资料切片表的结构：

CREATE EXTERNAL TABLE ods.user (
  user_num STRING COMMENT '用户编号',
  mobile STRING COMMENT '手机号码',
  reg_date STRING COMMENT '注册日期'
COMMENT '用户资料表'
PARTITIONED BY (dt string)
ROW FORMAT DELIMITED FIELDS TERMINATED BY '\t' LINES TERMINATED BY '\n'
STORED AS ORC
LOCATION '/ods/user';
)

ods 层的 user_update 表：

然后我们还需要一张用户每日更新表，前面已经分析过该如果得到这张表，现在我们假设它已经存在。

CREATE EXTERNAL TABLE ods.user_update (
  user_num STRING COMMENT '用户编号',
  mobile STRING COMMENT '手机号码',
  reg_date STRING COMMENT '注册日期'
COMMENT '每日用户资料更新表'
PARTITIONED BY (dt string)
ROW FORMAT DELIMITED FIELDS TERMINATED BY '\t' LINES TERMINATED BY '\n'
STORED AS ORC
LOCATION '/ods/user_update';
)

拉链表：

现在我们创建一张拉链表：

CREATE EXTERNAL TABLE dws.user_his (
  user_num STRING COMMENT '用户编号',
  mobile STRING COMMENT '手机号码',
  reg_date STRING COMMENT '用户编号',
  t_start_date ,
  t_end_date
COMMENT '用户资料拉链表'
ROW FORMAT DELIMITED FIELDS TERMINATED BY '\t' LINES TERMINATED BY '\n'
STORED AS ORC
LOCATION '/dws/user_his';
)

现在我们假设我们已经已经初始化了 2017-01-01 的日期，然后需要更新 2017-01-02 那一天的数据，我们有了下面的 Sql。

然后把两个日期设置为变量就可以了。

INSERT OVERWRITE TABLE dws.user_his
SELECT * FROM
(
    SELECT A.user_num,
           A.mobile,
           A.reg_date,
           A.t_start_time,
           CASE
                WHEN A.t_end_time = '9999-12-31' AND B.user_num IS NOT NULL THEN '2017-01-01'
                ELSE A.t_end_time
           END AS t_end_time
    FROM dws.user_his AS A
    LEFT JOIN ods.user_update AS B
    ON A.user_num = B.user_num
UNION
    SELECT C.user_num,
           C.mobile,
           C.reg_date,
           '2017-01-02' AS t_start_time,
           '9999-12-31' AS t_end_time
    FROM ods.user_update AS C
) AS T

（2）拉链表实现方式二

操作型数据库的用户表结构：

CREATE EXTERNAL TABLE ods.user ( 
  user_num STRING COMMENT '用户编号', 
  mobile STRING COMMENT '手机号码', 
  reg_date STRING COMMENT '注册日期' ,
  last_modify_date STRING COMMENT '‘最后修改时间’ 
COMMENT '用户资料表' 
PARTITIONED BY (dt string) 
ROW FORMAT DELIMITED FIELDS TERMINATED BY '\t' LINES TERMINATED BY '\n' 
STORED AS ORC 
LOCATION '/ods/user';

每天增量抽取的用户表结构和抽取条件：

1）表结构和上面的表结构保持一致，我们取表名为 ods.user_update

2）增量抽取条件：select * from ods.user where last_modify_date = '$date'

拉链表：

现在我们创建一张拉链表：

CREATE EXTERNAL TABLE dws.user_his ( 
  user_num STRING COMMENT '用户编号', 
  mobile STRING COMMENT '手机号码', 
  reg_date STRING COMMENT '用户编号',
  last_modify_date STRING COMMENT '‘最后修改时间’ 
  t_start_date , 
  t_end_date 
COMMENT '用户资料拉链表' 
ROW FORMAT DELIMITED FIELDS TERMINATED BY '\t' LINES TERMINATED BY '\n' 
STORED AS ORC 
LOCATION '/dws/user_his'; 
)

实现 sql：

1）

merge into dws.user_his tar 
using
(
　　select user_num,mobile from ods.user_update 
) sou on tar.user_num=sou.user_num 
and tar.mobile=sou.mobile 
and tar.t_start_date < '$date' 
and tar.t_end_date >  '$date' 
when matched then 
update set tar.t_end_date='9999-12-31';

按照主键筛选，在 dws.user_his 表中出现过的并且现在为有效数据的，全部更新为闭链数据。

INSERT  TABLE dws.user_his 
SELECT 
　　C.user_num, 
        C.mobile, 
        C.reg_date, 
         c.last_modify_date
         '2017-01-02' AS t_start_time, 
         '9999-12-31' AS t_end_time 
  FROM ods.user_update AS C;

比如我们要1月2号的数据，取出来的数据为 select from user where t_start_date <= ‘2017-01-02’ and t_end_date >= ‘2017-01-02’；