【修改】test UID

loit-shardingsphere-seata-main/src/main/java/com/loit/shardingsphere/seata/controller/DemoController.java

@@ -28,7 +28,7 @@ public class DemoController {
 
     @GetMapping("purchase")
     public void purchase() {
-        for (long i = 1; i < 20; i++) {
+        for (long i = 1; i < 2; i++) {
             businessService.purchase(i);
         }
         log.info("success");

loit-shardingsphere-seata-main/src/main/java/com/loit/shardingsphere/seata/modules/entity/Order.java

-
-
-package com.loit.shardingsphere.seata.modules.entity;
-
-import java.io.Serializable;
-
-public class Order implements Serializable {
-
-    private static final long serialVersionUID = 661434701950670670L;
-
-    private long orderId;
-
-    private int userId;
-
-    private String status;
-
-    public long getOrderId() {
-        return orderId;
-    }
-
-    public void setOrderId(final long orderId) {
-        this.orderId = orderId;
-    }
-
-    public int getUserId() {
-        return userId;
-    }
-
-    public void setUserId(final int userId) {
-        this.userId = userId;
-    }
-
-    public String getStatus() {
-        return status;
-    }
-
-    public void setStatus(final String status) {
-        this.status = status;
-    }
-
-    @Override
-    public String toString() {
-        return String.format("order_id: %s, user_id: %s, status: %s", orderId, userId, status);
-    }
-}

loit-shardingsphere-seata-main/src/main/java/com/loit/shardingsphere/seata/modules/entity/OrderEntity.java

@@ -2,13 +2,12 @@
 package com.loit.shardingsphere.seata.modules.entity;
 
 
-import com.baomidou.mybatisplus.annotation.IdType;
 import com.baomidou.mybatisplus.annotation.TableId;
 import com.baomidou.mybatisplus.annotation.TableName;
 
 @TableName("t_order")
 public final class OrderEntity {
-    @TableId(value = "id", type = IdType.ID_WORKER_STR)
+    @TableId(value = "id")
     private String id;
     @TableId(value = "order_id")
     private long orderId;

loit-shardingsphere-seata-main/src/main/java/com/loit/shardingsphere/seata/modules/entity/OrderItemEntity.java

@@ -2,13 +2,12 @@
 package com.loit.shardingsphere.seata.modules.entity;
 
 
-import com.baomidou.mybatisplus.annotation.IdType;
 import com.baomidou.mybatisplus.annotation.TableId;
 import com.baomidou.mybatisplus.annotation.TableName;
 
 @TableName("t_order_item")
 public final class OrderItemEntity {
-    @TableId(value = "id", type = IdType.ID_WORKER_STR)
+    @TableId(value = "id")
     private String id;
     @TableId(value = "order_item_id")
     private long orderItemId;

loit-shardingsphere-seata-main/src/main/java/com/loit/shardingsphere/seata/modules/service/impl/BusinessServiceImpl.java

@@ -4,6 +4,7 @@ import com.loit.shardingsphere.seata.modules.entity.OrderEntity;
 import com.loit.shardingsphere.seata.modules.service.IBusinessService;
 import com.loit.shardingsphere.seata.modules.service.IOrderService;
 import io.seata.spring.annotation.GlobalTransactional;
+import lombok.extern.slf4j.Slf4j;
 import org.apache.shardingsphere.transaction.annotation.ShardingTransactionType;
 import org.apache.shardingsphere.transaction.core.TransactionType;
 import org.apache.shardingsphere.transaction.core.TransactionTypeHolder;
@@ -11,6 +12,7 @@ import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.stereotype.Service;
 
 @Service
+@Slf4j
 public class BusinessServiceImpl implements IBusinessService {
 
     @Autowired
@@ -29,6 +31,7 @@ public class BusinessServiceImpl implements IBusinessService {
         orderEntity.setStatus("seata");
         orderEntity.setUserId(userId.intValue());
         orderService.insertOrder(orderEntity);
+        log.info(orderEntity.getId());
         //throw new RuntimeException("回滚测试");
     }