# 演示表
DROP TABLE IF EXISTS `biz_order`;
CREATE TABLE `biz_order`  (
  `id` bigint NOT NULL AUTO_INCREMENT COMMENT 'id',
  `order_no` varchar(20) NOT NULL COMMENT '訂單編號(hào)',
  `order_status` tinyint NOT NULL COMMENT '訂單狀態(tài)(1:成功 2:失敗 3:支付中)',
  ..... 省略N個(gè)字段
  `gmt_create` datetime NOT NULL COMMENT '創(chuàng)建時(shí)間',
  PRIMARY KEY (`id`) USING BTREE
) ENGINE = InnoDB CHARACTER SET = utf8mb4 COLLATE = utf8mb4_0900_ai_ci COMMENT = '訂單表' ROW_FORMAT = Dynamic;
# 這里非常重要，歷史表必需與原表結(jié)構(gòu)保持一致，即使可能原表上會(huì)有N個(gè)索引影響遷移的性能
CREATE TABLE biz_order_history LIKE biz_order;

# 歸檔日志記錄表
DROP TABLE IF EXISTS `biz_archive_log`;
CREATE TABLE `biz_archive_log`  (
  `id` bigint NOT NULL AUTO_INCREMENT COMMENT '自增id',
  `src_table` varchar(100) CHARACTER SET utf8mb4 COLLATE utf8mb4_0900_ai_ci NULL DEFAULT NULL COMMENT '歸檔的表名',
  `sql_text` varchar(1024) CHARACTER SET utf8mb4 COLLATE utf8mb4_0900_ai_ci NULL DEFAULT NULL COMMENT '執(zhí)行的腳本',
  `paras` varchar(1024) CHARACTER SET utf8mb4 COLLATE utf8mb4_0900_ai_ci NULL DEFAULT NULL COMMENT '實(shí)際執(zhí)行參數(shù)',
  `flag` varchar(50) CHARACTER SET utf8mb4 COLLATE utf8mb4_0900_ai_ci NULL DEFAULT NULL COMMENT '是否執(zhí)行成功:成功,失敗',
  `result_text` text CHARACTER SET utf8mb4 COLLATE utf8mb4_0900_ai_ci NULL COMMENT '執(zhí)行結(jié)果描述',
  `row_num` int NULL DEFAULT NULL COMMENT '影響行數(shù)',
  `exec_times` int NULL DEFAULT NULL COMMENT '執(zhí)行耗時(shí)ms',
  `create_time` timestamp NOT NULL DEFAULT CURRENT_TIMESTAMP,
  `update_time` timestamp NOT NULL DEFAULT CURRENT_TIMESTAMP ON UPDATE CURRENT_TIMESTAMP,
  PRIMARY KEY (`id`) USING BTREE,
  INDEX `flag`(`flag` ASC) USING BTREE,
  INDEX `create_time`(`create_time` ASC) USING BTREE
) ENGINE = InnoDB AUTO_INCREMENT = 1 CHARACTER SET = utf8mb4 COLLATE = utf8mb4_0900_ai_ci COMMENT = '歸檔日志表' ROW_FORMAT = Dynamic;

# 因?yàn)槲覀兒罄m(xù)將會(huì)以此條件去刪除原表數(shù)據(jù)，繼而寫(xiě)入目標(biāo)表(若無(wú)索引在千萬(wàn)級(jí)表中想刪除部分?jǐn)?shù)據(jù)那可真難哦)
ALTER TABLE `biz_order` ADD INDEX `idx_create_status`(`gmt_create`, `order_status`);

# 拿按小時(shí)歸檔舉例
LocalDate startDate = '2023-07-01'; # 舉例直觀說(shuō)明，非實(shí)際Api
LocalDate endDate = '2023-07-31';
for (LocalDate tmpDate = startDate; tmpDate.isBefore(endDate;
    tmpDate = tmpDate.plusHours(1)) {
    1. 開(kāi)啟事務(wù)
    2. insert into biz_order_history select * from payment where create_time >= '2023-07-01 00:00' and create_time < '2023-07-01 01:00' and order_status in (1, 2);
    3. delete from biz_order where create_time >= '2023-07-01 00:00' and create_time < '2023-07-01 01:00' and order_status in (1, 2);
    # 以上任何一個(gè)步驟異常都將進(jìn)行回滾并記錄 biz_archive_log 日志
    # 若插入 biz_archive_log 日志也失敗則忽略，不影響業(yè)務(wù)
    4. insert into biz_archive_log
    5. 提交事務(wù)
}
# 具體使用什么歸檔方式取決于具體要?dú)w檔的表，需慎重評(píng)估：粒度太大會(huì)執(zhí)行較慢，形成慢SQL大事務(wù)影響業(yè)務(wù)。粒度太小則也會(huì)造成歸檔時(shí)間過(guò)長(zhǎng)，從服務(wù)器延遲高(埋個(gè)伏筆，下面會(huì)提到)

# 首先分析異步主從為什么會(huì)有延遲(這里使用的是異步復(fù)制)
a. 主庫(kù)執(zhí)行完一個(gè)事務(wù)，寫(xiě)入binlog，我們把這個(gè)時(shí)刻記為T1
b. 主庫(kù)同步數(shù)據(jù)給從庫(kù)，從庫(kù)接收完這個(gè)binlog的時(shí)刻，記錄為T2
c. 從庫(kù)執(zhí)行完這個(gè)事務(wù)，這個(gè)時(shí)刻記錄為T3
所謂主從延遲，其實(shí)就是指同一個(gè)事務(wù)，在從庫(kù)執(zhí)行完的時(shí)間和在主庫(kù)執(zhí)行完的時(shí)間差值，即T3-T1

# 主從延遲出現(xiàn)原因
a. 機(jī)器性能差
b. 從庫(kù)的壓力大
c. 大事務(wù)
d. 網(wǎng)絡(luò)延遲
e. 從庫(kù)數(shù)量多，復(fù)制壓力大
f. 低版本只支持單線程復(fù)制，高版本是支持多線程復(fù)制