GitHub - 事务最终一致性 - MQ保证消息一致性

SET NAMES utf8mb4;
SET FOREIGN_KEY_CHECKS = 0;

-- ----------------------------
-- Table structure for consumer_mq_tab
-- ----------------------------
DROP TABLE IF EXISTS `consumer_mq_tab`;
CREATE TABLE `consumer_mq_tab` (
  `messageId` varchar(255) NOT NULL,
  `messageContent` varchar(255) NOT NULL,
  `messageStatus` int(11) NOT NULL,
  `addTime` timestamp NOT NULL DEFAULT CURRENT_TIMESTAMP,
  PRIMARY KEY (`messageId`)
) ENGINE=InnoDB DEFAULT CHARSET=utf8;

-- ----------------------------
-- Table structure for order_mq_tab
-- ----------------------------
DROP TABLE IF EXISTS `order_mq_tab`;
CREATE TABLE `order_mq_tab` (
  `messageId` varchar(255) NOT NULL,
  `messageContent` varchar(255) NOT NULL,
  `messageStatus` int(11) NOT NULL,
  `addTime` timestamp NOT NULL DEFAULT CURRENT_TIMESTAMP,
  PRIMARY KEY (`messageId`)
) ENGINE=InnoDB DEFAULT CHARSET=utf8;

-- ----------------------------
-- Table structure for order_tab
-- ----------------------------
DROP TABLE IF EXISTS `order_tab`;
CREATE TABLE `order_tab` (
  `orderId` varchar(255) NOT NULL,
  `messageId` varchar(255) NOT NULL,
  `orderContent` varchar(255) NOT NULL,
  PRIMARY KEY (`orderId`)
) ENGINE=InnoDB DEFAULT CHARSET=utf8;

SET FOREIGN_KEY_CHECKS = 1;