使用Starrocks制作拉链表

news2025/5/22 22:52:07

5月1日向ods_order_info插入3条数据：

CREATE TABLE ods_order_info(
  `dt` string,
  `id` string COMMENT '订单编号',
  `total_amount` decimal(10,2) COMMENT '订单金额'
)
PRIMARY KEY(`dt`, `id`)
PARTITION BY (`dt`)
DISTRIBUTED BY HASH(`id`)
PROPERTIES (
"replication_num" = "1"
);

insert into ods_order_info
select 
    '2025-05-01'          as dt
    ,9527                 as id
    ,2000                 as total_amount
;

insert into ods_order_info
select 
    '2025-05-01'          as dt
    ,9528                 as id
    ,3000                 as total_amount
;

insert into ods_order_info
select 
    '2025-05-01'          as dt
    ,9529                 as id
    ,4000                 as total_amount
;

查询结果：

MySQL [tmp]> select * from ods_order_info;
+------------+------+--------------+
| dt         | id   | total_amount |
+------------+------+--------------+
| 2025-05-01 | 9529 |      4000.00 |
| 2025-05-01 | 9528 |      3000.00 |
| 2025-05-01 | 9527 |      2000.00 |
+------------+------+--------------+
3 rows in set (0.01 sec)

制作拉链表dwd_order_info_his：

drop table if exists dwd_order_info_his;
create table dwd_order_info_his( 
  `end_date`  string COMMENT '有效结束日期',
  `id` string COMMENT '订单编号',
  `total_amount` decimal(10,2) COMMENT '订单金额', 
  `start_date`  string COMMENT '有效开始日期',
  `record_status` string COMMENT '是否有效'
)
PRIMARY KEY(`end_date`, `id`)
PARTITION BY (`end_date`)
DISTRIBUTED BY HASH(`id`)
PROPERTIES (
"replication_num" = "1"
);

初始化拉链表：

insert overwrite dwd_order_info_his
select
    '9999-99-99',
    id,
    total_amount,
    '2025-05-01',
    'active'
from ods_order_info di
where di.dt='2025-05-01';

查询结果：

MySQL [tmp]> select * from dwd_order_info_his;
+------------+------+--------------+------------+---------------+
| end_date   | id   | total_amount | start_date | record_status |
+------------+------+--------------+------------+---------------+
| 9999-99-99 | 9527 |      2000.00 | 2025-05-01 | active        |
| 9999-99-99 | 9529 |      4000.00 | 2025-05-01 | active        |
| 9999-99-99 | 9528 |      3000.00 | 2025-05-01 | active        |
+------------+------+--------------+------------+---------------+
3 rows in set (0.01 sec)

创建临时表用于导数据：

drop table if exists dwd_order_info_his_tmp;
create table dwd_order_info_his_tmp( 
  `end_date`  string COMMENT '有效结束日期',
  `id` string COMMENT '订单编号',
  `total_amount` decimal(10,2) COMMENT '订单金额', 
  `start_date`  string COMMENT '有效开始日期'
)
PRIMARY KEY(`end_date`, `id`)
PARTITION BY (`end_date`)
DISTRIBUTED BY HASH(`id`)
PROPERTIES (
"replication_num" = "1"
);

5月2日ODS表发生改变：

insert into ods_order_info
select 
    '2025-05-02'          as dt
    ,9527                 as id
    ,2222                 as total_amount
;

insert into ods_order_info
select 
    '2025-05-02'          as dt
    ,9540                 as id
    ,7000                 as total_amount
;

导入数据：

insert overwrite dwd_order_info_his_tmp
select * from 
(
select 
    '9999-99-99' end_date,
    id,
    total_amount,
    '2025-05-02' start_date
from ods_order_info where dt='2025-05-02'
union all 
select 
    if(oi.id is null, oh.end_date, date_add(oi.dt, -1)) end_date,
    oh.id,
    oh.total_amount,
    oh.start_date
from dwd_order_info_his oh left join 
     (
      select
      *
      from ods_order_info
      where dt='2025-05-02'
) oi
     on oh.id=oi.id and oh.end_date='9999-99-99'  
)his 
order by his.id, start_date;


insert overwrite dwd_order_info_his 
select 
end_date,
id,
total_amount,
start_date,
case when end_date = '9999-99-99' then 'active' else 'expire' end as record_status
from dwd_order_info_his_tmp;

查询结果：

MySQL [tmp]> select * from dwd_order_info_his where start_date = '2025-05-01' and record_status = 'active';
+------------+------+--------------+------------+---------------+
| end_date   | id   | total_amount | start_date | record_status |
+------------+------+--------------+------------+---------------+
| 9999-99-99 | 9529 |      4000.00 | 2025-05-01 | active        |
| 9999-99-99 | 9528 |      3000.00 | 2025-05-01 | active        |
+------------+------+--------------+------------+---------------+
2 rows in set (0.01 sec)

MySQL [tmp]> select * from dwd_order_info_his where start_date = '2025-05-02' and record_status = 'active';
+------------+------+--------------+------------+---------------+
| end_date   | id   | total_amount | start_date | record_status |
+------------+------+--------------+------------+---------------+
| 9999-99-99 | 9527 |      2222.00 | 2025-05-02 | active        |
| 9999-99-99 | 9540 |      7000.00 | 2025-05-02 | active        |
+------------+------+--------------+------------+---------------+
2 rows in set (0.01 sec)

5月3日ODS层数据再次改变：

insert into ods_order_info
select 
    '2025-05-03'          as dt
    ,9528                 as id
    ,3333                 as total_amount
;

insert into ods_order_info
select 
    '2025-05-03'          as dt
    ,9541                 as id
    ,8000                 as total_amount
;

导入数据：

insert overwrite dwd_order_info_his_tmp
select * from 
(
select 
    '9999-99-99' end_date,
    id,
    total_amount,
    '2025-05-03' start_date
from ods_order_info where dt='2025-05-03'
union all 
select 
    if(oi.id is null, oh.end_date, date_add(oi.dt, -1)) end_date,
    oh.id,
    oh.total_amount,
    oh.start_date
from dwd_order_info_his oh left join 
     (
      select
      *
      from ods_order_info
      where dt='2025-05-03'
) oi
     on oh.id=oi.id and oh.end_date='9999-99-99'  
)his 
order by his.id, start_date;

查询数据：

MySQL [tmp]> select * from dwd_order_info_his;
+---------------------+------+--------------+------------+---------------+
| end_date            | id   | total_amount | start_date | record_status |
+---------------------+------+--------------+------------+---------------+
| 9999-99-99          | 9529 |      4000.00 | 2025-05-01 | active        |
| 9999-99-99          | 9541 |      8000.00 | 2025-05-03 | active        |
| 2025-05-01 00:00:00 | 9527 |      2000.00 | 2025-05-01 | expire        |
| 9999-99-99          | 9528 |      3333.00 | 2025-05-03 | active        |
| 9999-99-99          | 9540 |      7000.00 | 2025-05-02 | active        |
| 9999-99-99          | 9527 |      2222.00 | 2025-05-02 | active        |
| 2025-05-02 00:00:00 | 9528 |      3000.00 | 2025-05-01 | expire        |
+---------------------+------+--------------+------------+---------------+
7 rows in set (0.01 sec)


MySQL [tmp]> select * from dwd_order_info_his where start_date = '2025-05-01' and record_status = 'active';
+------------+------+--------------+------------+---------------+
| end_date   | id   | total_amount | start_date | record_status |
+------------+------+--------------+------------+---------------+
| 9999-99-99 | 9529 |      4000.00 | 2025-05-01 | active        |
+------------+------+--------------+------------+---------------+
1 row in set (0.03 sec)

MySQL [tmp]> select * from dwd_order_info_his where start_date = '2025-05-02' and record_status = 'active';
+------------+------+--------------+------------+---------------+
| end_date   | id   | total_amount | start_date | record_status |
+------------+------+--------------+------------+---------------+
| 9999-99-99 | 9540 |      7000.00 | 2025-05-02 | active        |
| 9999-99-99 | 9527 |      2222.00 | 2025-05-02 | active        |
+------------+------+--------------+------------+---------------+
2 rows in set (0.01 sec)

MySQL [tmp]> select * from dwd_order_info_his where start_date = '2025-05-03' and record_status = 'active';
+------------+------+--------------+------------+---------------+
| end_date   | id   | total_amount | start_date | record_status |
+------------+------+--------------+------------+---------------+
| 9999-99-99 | 9541 |      8000.00 | 2025-05-03 | active        |
| 9999-99-99 | 9528 |      3333.00 | 2025-05-03 | active        |
+------------+------+--------------+------------+---------------+
2 rows in set (0.01 sec)

本文来自互联网用户投稿，该文观点仅代表作者本人，不代表本站立场。本站仅提供信息存储空间服务，不拥有所有权，不承担相关法律责任。如若转载，请注明出处：http://www.coloradmin.cn/o/2383441.html

如若内容造成侵权/违法违规/事实不符，请联系多彩编程网进行投诉反馈，一经查实，立即删除！

相关文章

Oracle 11g 单实例使用+asm修改主机名导致ORA-29701 故障分析

Oracle 11g 单实例使用+asm修改主机名导致ORA-29701 故障分析

解决 把服务器名修改为原来的，重启服务器。 故障 建表空间失败。 分析 查看告警日志 ORA-1119 signalled during: create tablespace splex datafile ‘DATA’ size 2000M… Tue May 20 18:04:28 2025 create tablespace splex datafile ‘DATA/option/dataf…
阅读更多...
OpenCV CUDA模块图像过滤------用于创建一个最大值盒式滤波器（Max Box Filter）函数createBoxMaxFilter()

OpenCV CUDA模块图像过滤------用于创建一个最大值盒式滤波器（Max Box Filter）函数createBoxMaxFilter()

操作系统：ubuntu22.04 OpenCV版本：OpenCV4.9 IDE:Visual Studio Code 编程语言：C11 算法描述 createBoxMaxFilter()函数创建的是一个 最大值滤波器（Maximum Filter），它对图像中每个像素邻域内的像素值取最…
阅读更多...
Redis数据库-消息队列

Redis数据库-消息队列

一、消息队列介绍 二、基于List结构模拟消息队列 总结： 三、基于PubSub实现消息队列 (1)PubSub介绍 PubSub是publish与subscribe两个单词的缩写，见明知意，PubSub就是发布与订阅的意思。 可以到Redis官网查看通配符的书写规则： …
阅读更多...
破解充电安全难题：智能终端的多重防护体系构建

破解充电安全难题：智能终端的多重防护体系构建

随着智能终端的普及，充电安全问题日益凸显。从电池过热到短路起火，充电过程中的安全隐患不仅威胁用户的生命财产安全，也制约了行业的发展。如何构建一套高效、可靠的多重防护体系，成为破解充电安全难题的关键。通过技术创新和系统…
阅读更多...
apptrace 三大策略，助力电商 App 在 618 突围

apptrace 三大策略，助力电商 App 在 618 突围

随着 5 月 13 日 “618” 电商大促预售战的打响，各大平台纷纷祭出百亿补贴、消费券等大招，投入超百亿流量与数十亿现金，意图在这场年度商战中抢占先机。但这场流量争夺战远比想象中艰难，中国互联网络信息中心数据显示，…
阅读更多...
SuperVINS：应对挑战性成像条件的实时视觉-惯性SLAM框架【全流程配置与测试！！！】【2025最新版！！！！】

SuperVINS：应对挑战性成像条件的实时视觉-惯性SLAM框架【全流程配置与测试！！！】【2025最新版！！！！】

一、项目背景及意义 SuperVINS是一个改进的视觉-惯性SLAM（同时定位与地图构建）框架，旨在解决在挑战性成像条件下的定位和地图构建问题。该项目基于经典的VINS-Fusion框架，但通过引入深度学习方法进行了显著改进。 视觉-惯性导航系…
阅读更多...
Node-Red通过开疆智能Profinet转ModbusTCP采集西门子PLC数据配置案例

Node-Red通过开疆智能Profinet转ModbusTCP采集西门子PLC数据配置案例

一、内容简介 本篇内容主要介绍Node-Red通过node-red-contrib-modbus插件与开疆智能ModbusTCP转Profinet设备进行通讯，这里Profinet转ModbusTCP网关作为从站设备，Node-Red作为主站分别从0地址开始读取10个线圈状态和10个保持寄存器，分别用Mo…
阅读更多...
【性能测试】jvm监控

【性能测试】jvm监控

使用本地jvisualvm远程监控服务器 参考文章：https://blog.csdn.net/yeyuningzi/article/details/140261411 jvisualvm工具默认是监控本地jvm，如果需要监控远程就要修改配置参数 1、先查看是否打开 ps -ef|java 如果打开杀掉进程 2、进入项目服务路径下…
阅读更多...
Uniapp开发鸿蒙应用时如何运行和调试项目

Uniapp开发鸿蒙应用时如何运行和调试项目

经过前几天的分享，大家应该应该对uniapp开发鸿蒙应用的开发语法有了一定的了解，可以进行一些简单的应用开发，今天分享一下在使用uniapp开发鸿蒙应用时怎么运行到鸿蒙设备，并且在开发中怎么调试程序。 运行 Uniapp项目支持运行到…
阅读更多...
QT+RSVisa控制LXI仪器

QT+RSVisa控制LXI仪器

1.下载并安装visa R&SVISA - Rohde & Schwarz China 2.安装后的目录说明 安装了64位visa会默认把32位的安装上； 64位库和头文件目录为：C:\Program Files\IVI Foundation 32位库和头文件目录为：C:\Program Files (x86)\IVI Foundation…
阅读更多...
springboot3+vue3融合项目实战-大事件文章管理系统-文章分类也表查询（条件分页）

springboot3+vue3融合项目实战-大事件文章管理系统-文章分类也表查询（条件分页）

在pojo实体类中增加pagebean实体类 Data NoArgsConstructor AllArgsConstructor public class PageBean <T>{private Long total;//总条数private List<T> items;//当前页数据集合 }articlecontroller增加代码 GetMappingpublic Result<PageBean<Article&g…
阅读更多...
Canvas进阶篇：鼠标交互动画

Canvas进阶篇：鼠标交互动画

Canvas进阶篇&#xff1a;鼠标交互动画 前言获取鼠标坐标鼠标事件点击事件监听代码示例效果预览 拖动事件监听代码示例效果预览 结语 前言 在上一篇文章Canvas进阶篇&#xff1a;基本动画详解 中&#xff0c;我们讲述了在Canvas中实现动画的基本步骤和动画的绘制方法。本文将进…
阅读更多...
【Node.js】Web开发框架

【Node.js】Web开发框架

个人主页&#xff1a;Guiat 归属专栏&#xff1a;node.js 文章目录 1. Node.js Web框架概述1.1 Web框架的作用1.2 Node.js主要Web框架生态1.3 框架选择考虑因素 2. Express.js2.1 Express.js概述2.2 基本用法2.2.1 安装Express2.2.2 创建基本服务器 2.3 路由2.4 中间件2.5 请求…
阅读更多...
使用Vite创建一个动态网页的前端项目

使用Vite创建一个动态网页的前端项目

1. 引言 虽然现在的前端更新换代的速度很快&#xff0c;IDE和工具一批批的换&#xff0c;但是我们始终要理解一点基本的程序构建的思维&#xff0c;这些环境和工具都是为了帮助我们更快的发布程序。笔者还记得以前写前端代码的时候&#xff0c;只使用文本编辑器&#xff0c;然…
阅读更多...
系统架构设计师案例分析题——web篇

系统架构设计师案例分析题——web篇

软考高项系统架构设计师&#xff0c;其中的科二案例分析题为5选3&#xff0c;总分75达到45分即合格。本贴来归纳web设计题目中常见的知识点即细节&#xff1a; 目录 一.核心知识 1.常见英文名词 2.私有云 3.面向对象三模型 4.计网相关——TCP和UDP的差异 5.MQTT和AMQP协…
阅读更多...
MySQL--day5--多表查询

MySQL--day5--多表查询

&#xff08;以下内容全部来自上述课程&#xff09; 多表查询 1. 为什么要用多表查询 # 如果不用多表查询 #查询员工名为Abel的人在哪个城市工作? SELECT* FROM employees WHERE last_name Abel;SELECT * FROM departments WHERE department_id 80;SELECT * FROM locati…
阅读更多...
leetcode hot100刷题日记——7.最大子数组和

leetcode hot100刷题日记——7.最大子数组和

class Solution { public:int maxSubArray(vector<int>& nums) {//方法一&#xff1a;动态规划//dp[i]表示以i下标结尾的数组的最大子数组和//那么在i0时&#xff0c;dp[0]nums[0]//之后要考虑的就是我们要不要把下一个数加进来&#xff0c;如果下一个数加进来会使结…
阅读更多...
基于Spring Boot和Vue的在线考试系统架构设计与实现(源码+论文+部署讲解等)

基于Spring Boot和Vue的在线考试系统架构设计与实现(源码+论文+部署讲解等)

源码项目获取联系 请文末卡片dd我获取更详细的演示视频 系统介绍 基于Spring Boot和Vue的在线考试系统。为学生和教师/管理员提供一个高效、便捷的在线学习、考试及管理平台。系统采用前后端分离的架构&#xff0c;后端基于成熟稳定的Spring Boot框架&#xff0c;负责数据处理…
阅读更多...
Android 绘制折线图

Android 绘制折线图

用了一段时间的 Jetpack Compose ，感觉写 UI 的效率确实会提升不少 。 配合 AI 编程绘制了一个折线图。供大家学习参考！ @Composable fun TemperatureChart() {val timeLabels = listOf("7:00", "8:00", "9:00", "10:00", "11:…
阅读更多...
自建srs实时视频服务器支持RTMP推流和拉流

自建srs实时视频服务器支持RTMP推流和拉流

文章目录 一、整体示意图二、服务器端1.srs简介及架构2.docker方式安装3.k8s方式安装4.端口 三、推流端1.OBS Studio2.ffmpeg推流3.streamlabs苹果手机4.twire安卓手机5.网络推流摄像头 四、拉流端1.vlc2.srs 参考awesome系列&#xff1a;https://github.com/juancarlospaco/aw…
阅读更多...
推荐文章
最新文章

Copyright @ 2022~2023