引入分布式事务seata，有问题，日志问题，待解决
This commit is contained in:
zjf committed
1 parent
887512c5fe
commit
59fc017933
285 files changed
+3464
No files matched your search
@@ -0,0 +1,76 @@
|
||||
-- -------------------------------- The script used when storeMode is 'db' --------------------------------
|
||||
|
||||
-- the table to store GlobalSession data
|
||||
CREATE TABLE "SEATA"."GLOBAL_TABLE"
|
||||
(
|
||||
"XID" VARCHAR2(128) NOT NULL,
|
||||
"TRANSACTION_ID" BIGINT,
|
||||
"STATUS" TINYINT NOT NULL,
|
||||
"APPLICATION_ID" VARCHAR2(32),
|
||||
"TRANSACTION_SERVICE_GROUP" VARCHAR2(32),
|
||||
"TRANSACTION_NAME" VARCHAR2(128),
|
||||
"TIMEOUT" INT,
|
||||
"BEGIN_TIME" BIGINT,
|
||||
"APPLICATION_DATA" VARCHAR2(2000),
|
||||
"GMT_CREATE" TIMESTAMP(0),
|
||||
"GMT_MODIFIED" TIMESTAMP(0),
|
||||
PRIMARY KEY ("XID")
|
||||
);
|
||||
|
||||
CREATE INDEX "IDX_GMT_MODIFIED_STATUS" ON "SEATA"."GLOBAL_TABLE"("GMT_MODIFIED" ASC,"STATUS" ASC);
|
||||
CREATE INDEX "IDX_TRANSACTION_ID" ON "SEATA"."GLOBAL_TABLE"("TRANSACTION_ID" ASC);
|
||||
|
||||
|
||||
-- the table to store BranchSession data
|
||||
CREATE TABLE "SEATA"."BRANCH_TABLE"
|
||||
(
|
||||
"BRANCH_ID" BIGINT NOT NULL,
|
||||
"XID" VARCHAR2(128) NOT NULL,
|
||||
"TRANSACTION_ID" BIGINT,
|
||||
"RESOURCE_GROUP_ID" VARCHAR2(32),
|
||||
"RESOURCE_ID" VARCHAR2(256),
|
||||
"BRANCH_TYPE" VARCHAR2(8),
|
||||
"STATUS" TINYINT,
|
||||
"CLIENT_ID" VARCHAR2(64),
|
||||
"APPLICATION_DATA" VARCHAR2(2000),
|
||||
"GMT_CREATE" TIMESTAMP(0),
|
||||
"GMT_MODIFIED" TIMESTAMP(0),
|
||||
PRIMARY KEY ("BRANCH_ID")
|
||||
);
|
||||
|
||||
CREATE INDEX "IDX_XID" ON "SEATA"."BRANCH_TABLE"("XID" ASC);
|
||||
|
||||
|
||||
-- the table to store lock data
|
||||
CREATE TABLE "SEATA"."LOCK_TABLE"
|
||||
(
|
||||
"ROW_KEY" VARCHAR2(128) NOT NULL,
|
||||
"XID" VARCHAR2(128),
|
||||
"TRANSACTION_ID" BIGINT,
|
||||
"BRANCH_ID" BIGINT NOT NULL,
|
||||
"RESOURCE_ID" VARCHAR2(256),
|
||||
"TABLE_NAME" VARCHAR2(32),
|
||||
"PK" VARCHAR2(36),
|
||||
"STATUS" TINYINT NOT NULL DEFAULT 0,
|
||||
"GMT_CREATE" TIMESTAMP(0),
|
||||
"GMT_MODIFIED" TIMESTAMP(0),
|
||||
PRIMARY KEY ("ROW_KEY")
|
||||
);
|
||||
|
||||
COMMENT ON COLUMN "SEATA"."LOCK_TABLE"."STATUS" IS '0:locked ,1:rollbacking';
|
||||
|
||||
CREATE INDEX "IDX_BRANCH_ID" ON "SEATA"."LOCK_TABLE" ("BRANCH_ID" ASC);
|
||||
CREATE INDEX "IDX_STATUS" ON "SEATA"."LOCK_TABLE" ("STATUS" ASC);
|
||||
|
||||
CREATE TABLE "SEATA"."DISTRIBUTED_LOCK"
|
||||
(
|
||||
"LOCK_KEY" VARCHAR2(20) NOT NULL,
|
||||
"LOCK_VALUE" VARCHAR2(20) NOT NULL,
|
||||
"EXPIRE" BIGINT NOT NULL,
|
||||
PRIMARY KEY ("LOCK_KEY")
|
||||
);
|
||||
|
||||
INSERT INTO "SEATA"."DISTRIBUTED_LOCK" ("LOCK_KEY", "LOCK_VALUE", "EXPIRE") VALUES ('AsyncCommitting', ' ', 0);
|
||||
INSERT INTO "SEATA"."DISTRIBUTED_LOCK" ("LOCK_KEY", "LOCK_VALUE", "EXPIRE") VALUES ('RetryCommitting', ' ', 0);
|
||||
INSERT INTO "SEATA"."DISTRIBUTED_LOCK" ("LOCK_KEY", "LOCK_VALUE", "EXPIRE") VALUES ('RetryRollbacking', ' ', 0);
|
||||
INSERT INTO "SEATA"."DISTRIBUTED_LOCK" ("LOCK_KEY", "LOCK_VALUE", "EXPIRE") VALUES ('TxTimeoutCheck', ' ', 0);
|
||||
@@ -0,0 +1,73 @@
|
||||
-- -------------------------------- The script used when storeMode is 'db' --------------------------------
|
||||
-- the table to store GlobalSession data
|
||||
CREATE TABLE IF NOT EXISTS `global_table`
|
||||
(
|
||||
`xid` VARCHAR(128) NOT NULL,
|
||||
`transaction_id` BIGINT,
|
||||
`status` TINYINT NOT NULL,
|
||||
`application_id` VARCHAR(32),
|
||||
`transaction_service_group` VARCHAR(32),
|
||||
`transaction_name` VARCHAR(128),
|
||||
`timeout` INT,
|
||||
`begin_time` BIGINT,
|
||||
`application_data` VARCHAR(2000),
|
||||
`gmt_create` DATETIME,
|
||||
`gmt_modified` DATETIME,
|
||||
PRIMARY KEY (`xid`),
|
||||
KEY `idx_status_gmt_modified` (`status` , `gmt_modified`),
|
||||
KEY `idx_transaction_id` (`transaction_id`)
|
||||
) ENGINE = InnoDB
|
||||
DEFAULT CHARSET = utf8mb4;
|
||||
|
||||
-- the table to store BranchSession data
|
||||
CREATE TABLE IF NOT EXISTS `branch_table`
|
||||
(
|
||||
`branch_id` BIGINT NOT NULL,
|
||||
`xid` VARCHAR(128) NOT NULL,
|
||||
`transaction_id` BIGINT,
|
||||
`resource_group_id` VARCHAR(32),
|
||||
`resource_id` VARCHAR(256),
|
||||
`branch_type` VARCHAR(8),
|
||||
`status` TINYINT,
|
||||
`client_id` VARCHAR(64),
|
||||
`application_data` VARCHAR(2000),
|
||||
`gmt_create` DATETIME(6),
|
||||
`gmt_modified` DATETIME(6),
|
||||
PRIMARY KEY (`branch_id`),
|
||||
KEY `idx_xid` (`xid`)
|
||||
) ENGINE = InnoDB
|
||||
DEFAULT CHARSET = utf8mb4;
|
||||
|
||||
-- the table to store lock data
|
||||
CREATE TABLE IF NOT EXISTS `lock_table`
|
||||
(
|
||||
`row_key` VARCHAR(128) NOT NULL,
|
||||
`xid` VARCHAR(128),
|
||||
`transaction_id` BIGINT,
|
||||
`branch_id` BIGINT NOT NULL,
|
||||
`resource_id` VARCHAR(256),
|
||||
`table_name` VARCHAR(32),
|
||||
`pk` VARCHAR(36),
|
||||
`status` TINYINT NOT NULL DEFAULT '0' COMMENT '0:locked ,1:rollbacking',
|
||||
`gmt_create` DATETIME,
|
||||
`gmt_modified` DATETIME,
|
||||
PRIMARY KEY (`row_key`),
|
||||
KEY `idx_status` (`status`),
|
||||
KEY `idx_branch_id` (`branch_id`),
|
||||
KEY `idx_xid` (`xid`)
|
||||
) ENGINE = InnoDB
|
||||
DEFAULT CHARSET = utf8mb4;
|
||||
|
||||
CREATE TABLE IF NOT EXISTS `distributed_lock`
|
||||
(
|
||||
`lock_key` CHAR(20) NOT NULL,
|
||||
`lock_value` VARCHAR(20) NOT NULL,
|
||||
`expire` BIGINT,
|
||||
primary key (`lock_key`)
|
||||
) ENGINE = InnoDB
|
||||
DEFAULT CHARSET = utf8mb4;
|
||||
|
||||
INSERT INTO `distributed_lock` (lock_key, lock_value, expire) VALUES ('AsyncCommitting', ' ', 0);
|
||||
INSERT INTO `distributed_lock` (lock_key, lock_value, expire) VALUES ('RetryCommitting', ' ', 0);
|
||||
INSERT INTO `distributed_lock` (lock_key, lock_value, expire) VALUES ('RetryRollbacking', ' ', 0);
|
||||
INSERT INTO `distributed_lock` (lock_key, lock_value, expire) VALUES ('TxTimeoutCheck', ' ', 0);
|
||||
@@ -0,0 +1,72 @@
|
||||
-- -------------------------------- The script used when storeMode is 'db' --------------------------------
|
||||
-- the table to store GlobalSession data
|
||||
CREATE TABLE global_table
|
||||
(
|
||||
xid VARCHAR2(128) NOT NULL,
|
||||
transaction_id NUMBER(19),
|
||||
status NUMBER(3) NOT NULL,
|
||||
application_id VARCHAR2(32),
|
||||
transaction_service_group VARCHAR2(32),
|
||||
transaction_name VARCHAR2(128),
|
||||
timeout NUMBER(10),
|
||||
begin_time NUMBER(19),
|
||||
application_data VARCHAR2(2000),
|
||||
gmt_create TIMESTAMP(0),
|
||||
gmt_modified TIMESTAMP(0),
|
||||
PRIMARY KEY (xid)
|
||||
);
|
||||
|
||||
CREATE INDEX idx_status_gmt_modified ON global_table (status, gmt_modified);
|
||||
CREATE INDEX idx_transaction_id ON global_table (transaction_id);
|
||||
|
||||
-- the table to store BranchSession data
|
||||
CREATE TABLE branch_table
|
||||
(
|
||||
branch_id NUMBER(19) NOT NULL,
|
||||
xid VARCHAR2(128) NOT NULL,
|
||||
transaction_id NUMBER(19),
|
||||
resource_group_id VARCHAR2(32),
|
||||
resource_id VARCHAR2(256),
|
||||
branch_type VARCHAR2(8),
|
||||
status NUMBER(3),
|
||||
client_id VARCHAR2(64),
|
||||
application_data VARCHAR2(2000),
|
||||
gmt_create TIMESTAMP(6),
|
||||
gmt_modified TIMESTAMP(6),
|
||||
PRIMARY KEY (branch_id)
|
||||
);
|
||||
|
||||
CREATE INDEX idx_xid ON branch_table (xid);
|
||||
|
||||
-- the table to store lock data
|
||||
CREATE TABLE lock_table
|
||||
(
|
||||
row_key VARCHAR2(128) NOT NULL,
|
||||
xid VARCHAR2(128),
|
||||
transaction_id NUMBER(19),
|
||||
branch_id NUMBER(19) NOT NULL,
|
||||
resource_id VARCHAR2(256),
|
||||
table_name VARCHAR2(32),
|
||||
pk VARCHAR2(36),
|
||||
status NUMBER(3) DEFAULT 0 NOT NULL,
|
||||
gmt_create TIMESTAMP(0),
|
||||
gmt_modified TIMESTAMP(0),
|
||||
PRIMARY KEY (row_key)
|
||||
);
|
||||
|
||||
comment on column lock_table.status is '0:locked ,1:rollbacking';
|
||||
CREATE INDEX idx_branch_id ON lock_table (branch_id);
|
||||
CREATE INDEX idx_lock_table_xid ON lock_table (xid);
|
||||
CREATE INDEX idx_status ON lock_table (status);
|
||||
|
||||
CREATE TABLE distributed_lock (
|
||||
lock_key VARCHAR2(20) NOT NULL,
|
||||
lock_value VARCHAR2(20) NOT NULL,
|
||||
expire DECIMAL(18) NOT NULL,
|
||||
PRIMARY KEY (lock_key)
|
||||
);
|
||||
|
||||
INSERT INTO distributed_lock (lock_key, lock_value, expire) VALUES ('AsyncCommitting', ' ', 0);
|
||||
INSERT INTO distributed_lock (lock_key, lock_value, expire) VALUES ('RetryCommitting', ' ', 0);
|
||||
INSERT INTO distributed_lock (lock_key, lock_value, expire) VALUES ('RetryRollbacking', ' ', 0);
|
||||
INSERT INTO distributed_lock (lock_key, lock_value, expire) VALUES ('TxTimeoutCheck', ' ', 0);
|
||||
@@ -0,0 +1,72 @@
|
||||
-- -------------------------------- The script used when storeMode is 'db' --------------------------------
|
||||
-- the table to store GlobalSession data
|
||||
CREATE TABLE IF NOT EXISTS public.global_table
|
||||
(
|
||||
xid VARCHAR(128) NOT NULL,
|
||||
transaction_id BIGINT,
|
||||
status SMALLINT NOT NULL,
|
||||
application_id VARCHAR(32),
|
||||
transaction_service_group VARCHAR(32),
|
||||
transaction_name VARCHAR(128),
|
||||
timeout INT,
|
||||
begin_time BIGINT,
|
||||
application_data VARCHAR(2000),
|
||||
gmt_create TIMESTAMP(0),
|
||||
gmt_modified TIMESTAMP(0),
|
||||
CONSTRAINT pk_global_table PRIMARY KEY (xid)
|
||||
);
|
||||
|
||||
CREATE INDEX idx_status_gmt_modified ON public.global_table (status, gmt_modified);
|
||||
CREATE INDEX idx_transaction_id ON public.global_table (transaction_id);
|
||||
|
||||
-- the table to store BranchSession data
|
||||
CREATE TABLE IF NOT EXISTS public.branch_table
|
||||
(
|
||||
branch_id BIGINT NOT NULL,
|
||||
xid VARCHAR(128) NOT NULL,
|
||||
transaction_id BIGINT,
|
||||
resource_group_id VARCHAR(32),
|
||||
resource_id VARCHAR(256),
|
||||
branch_type VARCHAR(8),
|
||||
status SMALLINT,
|
||||
client_id VARCHAR(64),
|
||||
application_data VARCHAR(2000),
|
||||
gmt_create TIMESTAMP(6),
|
||||
gmt_modified TIMESTAMP(6),
|
||||
CONSTRAINT pk_branch_table PRIMARY KEY (branch_id)
|
||||
);
|
||||
|
||||
CREATE INDEX idx_xid ON public.branch_table (xid);
|
||||
|
||||
-- the table to store lock data
|
||||
CREATE TABLE IF NOT EXISTS public.lock_table
|
||||
(
|
||||
row_key VARCHAR(128) NOT NULL,
|
||||
xid VARCHAR(128),
|
||||
transaction_id BIGINT,
|
||||
branch_id BIGINT NOT NULL,
|
||||
resource_id VARCHAR(256),
|
||||
table_name VARCHAR(32),
|
||||
pk VARCHAR(36),
|
||||
status SMALLINT NOT NULL DEFAULT 0,
|
||||
gmt_create TIMESTAMP(0),
|
||||
gmt_modified TIMESTAMP(0),
|
||||
CONSTRAINT pk_lock_table PRIMARY KEY (row_key)
|
||||
);
|
||||
|
||||
comment on column public.lock_table.status is '0:locked ,1:rollbacking';
|
||||
CREATE INDEX idx_branch_id ON public.lock_table (branch_id);
|
||||
CREATE INDEX idx_xid ON public.lock_table (xid);
|
||||
CREATE INDEX idx_status ON public.lock_table (status);
|
||||
|
||||
CREATE TABLE distributed_lock (
|
||||
lock_key VARCHAR(20) NOT NULL,
|
||||
lock_value VARCHAR(20) NOT NULL,
|
||||
expire BIGINT NOT NULL,
|
||||
CONSTRAINT pk_distributed_lock_table PRIMARY KEY (lock_key)
|
||||
);
|
||||
|
||||
INSERT INTO distributed_lock (lock_key, lock_value, expire) VALUES ('AsyncCommitting', ' ', 0);
|
||||
INSERT INTO distributed_lock (lock_key, lock_value, expire) VALUES ('RetryCommitting', ' ', 0);
|
||||
INSERT INTO distributed_lock (lock_key, lock_value, expire) VALUES ('RetryRollbacking', ' ', 0);
|
||||
INSERT INTO distributed_lock (lock_key, lock_value, expire) VALUES ('TxTimeoutCheck', ' ', 0);
|
||||
@@ -0,0 +1,80 @@
|
||||
-- -------------------------------- The script used when storeMode is 'db' --------------------------------
|
||||
-- the table to store GlobalSession data
|
||||
CREATE TABLE [global_table]
|
||||
(
|
||||
[xid] nvarchar(128) NOT NULL,
|
||||
[transaction_id] bigint NULL,
|
||||
[status] tinyint NOT NULL,
|
||||
[application_id] nvarchar(32) NULL,
|
||||
[transaction_service_group] nvarchar(32) NULL,
|
||||
[transaction_name] nvarchar(128) NULL,
|
||||
[timeout] int NULL,
|
||||
[begin_time] bigint NULL,
|
||||
[application_data] nvarchar(2000) NULL,
|
||||
[gmt_create] datetime2 NULL,
|
||||
[gmt_modified] datetime2 NULL,
|
||||
PRIMARY KEY CLUSTERED ([xid])
|
||||
WITH (PAD_INDEX = OFF, STATISTICS_NORECOMPUTE = OFF, IGNORE_DUP_KEY = OFF, ALLOW_ROW_LOCKS = ON, ALLOW_PAGE_LOCKS = ON)
|
||||
)
|
||||
GO
|
||||
|
||||
CREATE NONCLUSTERED INDEX [idx_gmt_modified_status]
|
||||
ON [global_table] (
|
||||
[gmt_modified],
|
||||
[status]
|
||||
)
|
||||
GO
|
||||
|
||||
CREATE NONCLUSTERED INDEX [idx_transaction_id]
|
||||
ON [global_table] (
|
||||
[transaction_id]
|
||||
)
|
||||
GO
|
||||
|
||||
-- the table to store BranchSession data
|
||||
CREATE TABLE [branch_table]
|
||||
(
|
||||
[branch_id] bigint NOT NULL,
|
||||
[xid] nvarchar(128) NOT NULL,
|
||||
[transaction_id] bigint NULL,
|
||||
[resource_group_id] nvarchar(32) NULL,
|
||||
[resource_id] nvarchar(256) NULL,
|
||||
[branch_type] varchar(8) NULL,
|
||||
[status] tinyint NULL,
|
||||
[client_id] nvarchar(64) NULL,
|
||||
[application_data] nvarchar(2000) NULL,
|
||||
[gmt_create] datetime2 NULL,
|
||||
[gmt_modified] datetime2 NULL,
|
||||
PRIMARY KEY CLUSTERED ([branch_id])
|
||||
WITH (PAD_INDEX = OFF, STATISTICS_NORECOMPUTE = OFF, IGNORE_DUP_KEY = OFF, ALLOW_ROW_LOCKS = ON, ALLOW_PAGE_LOCKS = ON)
|
||||
)
|
||||
GO
|
||||
|
||||
CREATE NONCLUSTERED INDEX [idx_xid]
|
||||
ON [branch_table] (
|
||||
[xid]
|
||||
)
|
||||
GO
|
||||
|
||||
-- the table to store lock data
|
||||
CREATE TABLE [lock_table]
|
||||
(
|
||||
[row_key] nvarchar(128) NOT NULL,
|
||||
[xid] nvarchar(128) NULL,
|
||||
[transaction_id] bigint NULL,
|
||||
[branch_id] bigint NOT NULL,
|
||||
[resource_id] nvarchar(256) NULL,
|
||||
[table_name] nvarchar(32) NULL,
|
||||
[pk] nvarchar(36) NULL,
|
||||
[gmt_create] datetime2 NULL,
|
||||
[gmt_modified] datetime2 NULL,
|
||||
PRIMARY KEY CLUSTERED ([row_key])
|
||||
WITH (PAD_INDEX = OFF, STATISTICS_NORECOMPUTE = OFF, IGNORE_DUP_KEY = OFF, ALLOW_ROW_LOCKS = ON, ALLOW_PAGE_LOCKS = ON)
|
||||
)
|
||||
GO
|
||||
|
||||
CREATE NONCLUSTERED INDEX [idx_branch_id]
|
||||
ON [lock_table] (
|
||||
[branch_id]
|
||||
)
|
||||
GO
|
||||
Reference in new issue
Block a user