大数据-261 及时数仓 - 业务数据库表布局 生意业务订单、订单产品、产品分 ...

点一下关注吧！！！非常感谢！！持续更新！！！

Java篇开始了！

• MyBatis 更新完毕
  
• 现在开始更新 Spring，一起深入浅出！
  

现在已经更新到了：

• Hadoop（已更完）
  
• HDFS（已更完）
  
• MapReduce（已更完）
  
• Hive（已更完）
  
• Flume（已更完）
  
• Sqoop（已更完）
  
• Zookeeper（已更完）
  
• HBase（已更完）
  
• Redis （已更完）
  
• Kafka（已更完）
  
• Spark（已更完）
  
• Flink（已更完）
  
• ClickHouse（已更完）
  
• Kudu（已更完）
  
• Druid（已更完）
  
• Kylin（已更完）
  
• Elasticsearch（已更完）
  
• DataX（已更完）
  
• Tez（已更完）
  
• 数据挖掘（已更完）
  
• Prometheus（已更完）
  
• Grafana（已更完）
  
• 离线数仓（已更完）
  
• 及时数仓（正在更新…）
  

章节内容

• 及时数仓 - 项目配景与需求
  
• 及时数仓架构 需求分析
  
• 技能选型
  
• 逻辑架构
  

及时数仓的定义

及时数仓是一种数据堆栈系统，区别于传统批处理数仓，它强调低延迟、高吞吐和高可用性。及时数仓可以或许处理流式数据或近及时的数据流，使企业可以或许及时监控关键指标并做出决策。
及时数仓的关键特性

• 低延迟数据处理：数据从采集到可查询分析的时间极短，通常在秒级或毫秒级。
  
• 高并发查询支持：可以或许支持多用户同时查询，满足业务需求。
  
• 高可用性和可靠性：系统在高负载下仍能保持稳定，支持数据冗余和容错机制。
  
• 流批一体：既支持及时流式盘算，也支持批量数据分析，满足多样化需求。
  
• 可扩展性：可以或许通太过布式架构动态扩展存储和盘算资源，满足不断增长的业务需求。
  

及时数仓的发展趋势

• 云原生及时数仓：越来越多企业选择基于云平台搭建及时数仓，提升资源管理与成本控制本领。
  
• 湖仓一体化：结合数据湖和数据堆栈的优势，支持布局化与非布局化数据的同一分析。
  
• AI 与呆板学习集成：及时数仓将与 AI 和呆板学习深度结合，实现智能分析与预测。
  
• 开源生态发展：更多开源工具不断涌现，低落企业建立及时数仓的门槛。
  

业务数据库表布局

业务数据库：

• 生意业务订单表（trade_orders）
  
• 订单产品表（order_product）
  
• 产品信息表（product_info）
  
• 产品分类表（product_category）
  
• 商家店铺表（shops）
  
• 商家地区组织表（shop_admin_org）
  
• 付出方式表（payments）
  

生意业务订单表

1. CREATE TABLE `wzk_trade_orders` (
2.   `orderId` bigint(11) NOT NULL DEFAULT 0 COMMENT '订单id',
3.   `orderNo` varchar(20) NOT NULL COMMENT '订单编号',
4.   `userId` bigint(11) NOT NULL COMMENT '用户id',
5.   `status` tinyint(4) NOT NULL DEFAULT -2 COMMENT '订单状态 -3:用户拒收 -2:未付款的订单 -1：用户取消 0:待发货 1:配送中 2:用户确认收货',
6.   `productMoney` decimal(11,2) NOT NULL COMMENT '商品金额',
7.   `totalMoney` decimal(11,2) NOT NULL COMMENT '订单金额（包括运费）',
8.   `payMethod` tinyint(4) NOT NULL DEFAULT 0 COMMENT '支付方式,0:未知;1:支付宝，2：微信;3、现金；4、其他',
9.   `isPay` tinyint(4) NOT NULL DEFAULT 0 COMMENT '是否支付        0:未支付 1:已支付',
10.   `areaId` int(11) NOT NULL COMMENT '区域最低一级',
11.   `tradeSrc` tinyint(4) NOT NULL DEFAULT 0 COMMENT '订单来源        0:商城 1:微信 2:手机版 3:安卓App 4:苹果App',
12.   `tradeType` int(11) DEFAULT 0 COMMENT '订单类型',
13.   `isRefund` tinyint(4) NOT NULL DEFAULT 0 COMMENT '是否退款        0:否 1：是',
14.   `dataFlag` tinyint(4) NOT NULL DEFAULT 1 COMMENT '订单有效标志        -1：删除 1:有效',
15.   `createTime` varchar(25) NOT NULL COMMENT '下单时间',
16.   `payTime` varchar(25) DEFAULT NULL COMMENT '支付时间',
17.   `modifiedTime` timestamp NOT NULL DEFAULT current_timestamp() ON UPDATE current_timestamp() COMMENT '订单更新时间'
18. ) ENGINE=InnoDB DEFAULT CHARSET=utf8 COLLATE=utf8_general_ci;

复制代码

备注：

• 记录订单的信息
  
• status 订单状态
  
• createTime、payTime、modifiedTime
  

订单产品表

1. CREATE TABLE `wzk_order_product` (
2.   `id` bigint(11) NOT NULL DEFAULT 0,
3.   `orderId` bigint(11) NOT NULL COMMENT '订单id',
4.   `productId` bigint(11) NOT NULL COMMENT '商品id',
5.   `productNum` bigint(11) NOT NULL DEFAULT 0 COMMENT '商品数量',
6.   `productPrice` decimal(11,2) NOT NULL DEFAULT 0.00 COMMENT '商品价格',
7.   `money` decimal(11,2) DEFAULT 0.00 COMMENT '付款金额',
8.   `extra` text DEFAULT NULL COMMENT '额外信息',
9.   `createTime` varchar(25) DEFAULT NULL COMMENT '创建时间'
10. ) ENGINE=InnoDB DEFAULT CHARSET=utf8 COLLATE=utf8_general_ci;

复制代码

备注：

• 记录订单中购买产品的信息，包括产品的数量、单价等
  

产品信息表

1. CREATE TABLE `wzk_product_info` (
2.   `productId` bigint(11) NOT NULL DEFAULT 0 COMMENT '商品id',
3.   `productName` varchar(200) NOT NULL COMMENT '商品名称',
4.   `shopId` bigint(11) NOT NULL COMMENT '门店ID',
5.   `price` decimal(11,2) NOT NULL DEFAULT 0.00 COMMENT '门店价',
6.   `isSale` tinyint(4) NOT NULL DEFAULT 1 COMMENT '是否上架        0:不上架 1:上架',
7.   `status` tinyint(4) NOT NULL DEFAULT 0 COMMENT '是否新品        0:否 1:是',
8.   `categoryId` int(11) NOT NULL COMMENT 'goodsCatId        最后一级商品分类ID',
9.   `createTime` varchar(25) NOT NULL,
10.   `modifyTime` datetime DEFAULT NULL ON UPDATE current_timestamp() COMMENT '修改时间'
11. ) ENGINE=InnoDB DEFAULT CHARSET=utf8 COLLATE=utf8_general_ci

复制代码

备注：

• 记录产品的详细信息，对应商家 ID、商品属性（是否新品、是否上架）
  
• createTime、modifyTime、创建时间、修改时间
  

产品分类表

1. CREATE TABLE `wzk_product_category` (
2.   `catId` int(11) NOT NULL DEFAULT 0 COMMENT '品类ID',
3.   `parentId` int(11) NOT NULL COMMENT '父ID',
4.   `catName` varchar(20) NOT NULL COMMENT '分类名称',
5.   `isShow` tinyint(4) NOT NULL DEFAULT 1 COMMENT '是否显示        0:隐藏 1:显示',
6.   `sortNum` int(11) NOT NULL DEFAULT 0 COMMENT '排序号',
7.   `isDel` tinyint(4) NOT NULL DEFAULT 1 COMMENT '删除标志        1:有效 -1：删除',
8.   `createTime` varchar(25) NOT NULL COMMENT '建立时间',
9.   `level` tinyint(4) DEFAULT 0 COMMENT '分类级别，共3级'
10. ) ENGINE=InnoDB DEFAULT CHARSET=utf8 COLLATE=utf8_general_ci;

复制代码

备注：

• 产品分类表，共分3 个级别
  

1. -- 第一级产品目录
2. select catName, catid from wzk_product_category where level = 1;
3. -- 查看电脑、办公的子类（查看二级目录）
4. select catName, catid from wzk_product_category where level = 2 and parentId
5. = 32;
6. -- 查看电脑整机的子类（查看三级目录）
7. select catName, catid from wzk_product_category where level = 3 and parentId
8. = 10250;

复制代码

实行结果如下图所示：

商家的店铺表

1. CREATE TABLE `wzk_shops` (
2.   `shopId` int(11) NOT NULL DEFAULT 0 COMMENT '商铺ID，自增',
3.   `userId` int(11) NOT NULL COMMENT '商铺联系人ID',
4.   `areaId` int(11) DEFAULT 0,
5.   `shopName` varchar(100) DEFAULT '' COMMENT '商铺名称',
6.   `shopLevel` tinyint(4) NOT NULL DEFAULT 1 COMMENT '店铺等级',
7.   `status` tinyint(4) NOT NULL DEFAULT 1 COMMENT '商铺状态',
8.   `createTime` date DEFAULT NULL,
9.   `modifyTime` datetime DEFAULT NULL COMMENT '修改时间'
10. ) ENGINE=InnoDB DEFAULT CHARSET=utf8 COLLATE=utf8_general_ci;

复制代码

备注：

• 记录店铺的详细信息
  

商家地区组织表

1. CREATE TABLE `wzk_shop_admin_org` (
2.   `id` int(11) NOT NULL DEFAULT 0 COMMENT '组织ID',
3.   `parentId` int(11) NOT NULL COMMENT '父ID',
4.   `orgName` varchar(100) NOT NULL COMMENT '组织名称',
5.   `orgLevel` tinyint(4) NOT NULL DEFAULT 1 COMMENT '组织级别1;总部及大区级部门;2：总部下属的各个部门及基部门;3:具体工作部门',
6.   `isDelete` tinyint(4) NOT NULL DEFAULT 0 COMMENT '删除标志,1:删除;0:有效',
7.   `createTime` varchar(25) DEFAULT NULL COMMENT '创建时间',
8.   `updateTime` varchar(25) DEFAULT NULL COMMENT '最后修改时间',
9.   `isShow` tinyint(4) NOT NULL DEFAULT 1 COMMENT '是否显示,0:是 1:否',
10.   `orgType` tinyint(4) NOT NULL DEFAULT 1 COMMENT '组织类型,0:总裁办;1:研发;2:销售;3:运营;4:产品'
11. ) ENGINE=InnoDB DEFAULT CHARSET=utf8 COLLATE=utf8_general_ci;

复制代码

备注：

• 记录店铺所属地区
  

付出方式表

1. CREATE TABLE `wzk_payments` (
2.   `id` int(11) NOT NULL,
3.   `payMethod` varchar(20) DEFAULT NULL,
4.   `payName` varchar(255) DEFAULT NULL,
5.   `description` varchar(255) DEFAULT NULL,
6.   `payOrder` int(11) DEFAULT 0,
7.   `online` tinyint(4) DEFAULT NULL
8. ) ENGINE=InnoDB DEFAULT CHARSET=utf8 COLLATE=utf8_general_ci;

复制代码

备注：

• 记录付出方式
  

最闭幕果

团体截图：

免责声明：如果侵犯了您的权益，请联系站长，我们会及时删除侵权内容，谢谢合作！更多信息从访问主页：qidao123.com:ToB企服之家，中国第一个企服评测及商务社交产业平台。