🚨 Test: 增加测试类

Author: fanxb

spring-boot/sjdemo/logs/xa_tx.lck

@@ -29,6 +29,12 @@
             <version>2.0.0</version>
         </dependency>
 
+        <!--看不到getter/setter因为这个,请注意-->
+        <dependency>
+            <groupId>org.projectlombok</groupId>
+            <artifactId>lombok</artifactId>
+        </dependency>
+
         <!--这里有个大坑，版本过高使用xa事务会报错未指定数据库，参见:https://github.com/apache/incubator-shardingsphere/issues/1842-->
         <dependency>
             <groupId>mysql</groupId>
@@ -40,18 +46,11 @@
             <artifactId>sharding-jdbc-spring-boot-starter</artifactId>
             <version>3.1.0</version>
         </dependency>
-        <!--druid versoin-->
         <dependency>
             <groupId>com.alibaba</groupId>
             <artifactId>druid</artifactId>
             <version>1.1.14</version>
         </dependency>
-        <dependency>
-            <groupId>org.projectlombok</groupId>
-            <artifactId>lombok</artifactId>
-        </dependency>
-
-        <!-- https://mvnrepository.com/artifact/com.alibaba/fastjson -->
         <dependency>
             <groupId>com.alibaba</groupId>
             <artifactId>fastjson</artifactId>

spring-boot/sjdemo/pom.xml

@@ -42,6 +42,6 @@ public interface OrderDao {
      * @author fanxb
      * @date 2019/3/25 14:24
      */
-    List<Order> getOrderByUserId(int id);
+    List<Order> getOrderByUserId(long id);
 
 }

spring-boot/sjdemo/src/main/java/com/fanxb/sjdemo/dao/OrderDao.java

@@ -31,4 +31,15 @@ public interface OrderItemDao {
      */
     List<OrderItem> getByOrderId(int id);
 
+    /**
+     * Description: 根据订单金额连表查询
+     *
+     * @author fanxb
+     * @date 2019/3/26 16:55
+     * @param price
+     * @return java.util.List<com.fanxb.sjdemo.entity.OrderItem>
+     */
+    List<OrderItem> getOrderItemByPrice(int price);
+
+
 }

spring-boot/sjdemo/src/main/java/com/fanxb/sjdemo/dao/OrderItemDao.java

@@ -0,0 +1,37 @@
+package com.fanxb.sjdemo.dao;
+
+import com.fanxb.sjdemo.entity.Dictionary;
+import com.fanxb.sjdemo.entity.OtherTable;
+
+import java.util.List;
+
+/**
+ * 类功能简述：
+ * 类功能详述：
+ *
+ * @author fanxb
+ * @date 2019/3/22 16:25
+ */
+public interface OtherTableDao {
+
+    /**
+     * Description:
+     *
+     * @author fanxb
+     * @date 2019/3/26 10:16
+     * @param dictionary dictionary
+     * @return long
+     */
+    long addOne(OtherTable table);
+
+    /**
+     * Description:
+     *
+     * @author fanxb
+     * @date 2019/3/26 16:31
+     * @return java.util.List<com.fanxb.sjdemo.entity.OtherTable>
+     */
+    List<OtherTable> getAll();
+
+
+}

spring-boot/sjdemo/src/main/java/com/fanxb/sjdemo/dao/OtherTableDao.java

@@ -6,7 +6,7 @@
 @Data
 public class OrderItem {
 
-//    private long userId;
+    private long userId;
     private long orderItemId;
     private long orderId;
     private String name;

spring-boot/sjdemo/src/main/java/com/fanxb/sjdemo/entity/OrderItem.java

@@ -0,0 +1,16 @@
+package com.fanxb.sjdemo.entity;
+
+import lombok.Data;
+
+/**
+ * 类功能简述：
+ * 类功能详述：
+ *
+ * @author fanxb
+ * @date 2019/3/26 16:27
+ */
+@Data
+public class OtherTable {
+    private Long id;
+    private String name;
+}

spring-boot/sjdemo/src/main/java/com/fanxb/sjdemo/entity/OtherTable.java

@@ -11,7 +11,6 @@
 import org.springframework.stereotype.Service;
 import org.springframework.transaction.annotation.Transactional;
 
-import java.util.logging.ConsoleHandler;
 
 /**
  * 类功能简述：
@@ -41,7 +40,7 @@ public User getOne(long id) {
      * 测试跨库事务
      */
     @ShardingTransactionType(TransactionType.XA)
-    @Transactional
+    @Transactional(rollbackFor = Exception.class)
     public void testTransactional() {
         User user1 = new User(123, "988", 12);
         logger.info("user1已经插入");

spring-boot/sjdemo/src/main/java/com/fanxb/sjdemo/service/UserService.java

@@ -1,7 +1,8 @@
 sharding:
   jdbc:
     datasource:
-      names: ds0,ds1
+      # 配置数据源
+      names: ds0,ds1,ds2
       ds0:
         type: com.alibaba.druid.pool.DruidDataSource
         driver-class-name: com.mysql.jdbc.Driver
@@ -14,28 +15,30 @@ sharding:
         url: jdbc:mysql://10.82.27.177:3306/ds1
         username: root
         password: 123456
-#      ds2:
-#        type: com.alibaba.druid.pool.DruidDataSource
-#        driver-class-name: com.mysql.jdbc.Driver
-#        url: jdbc:mysql://10.82.27.177:3306/ds2
-#        username: root
-#        password: 123456
+      ds2:
+        type: com.alibaba.druid.pool.DruidDataSource
+        driver-class-name: com.mysql.jdbc.Driver
+        url: jdbc:mysql://10.82.27.177:3306/ds2
+        username: root
+        password: 123456
     config:
       sharding:
-        # 默认数据源，可以将不分库分表的数据表放在这里(此处的表需与已经分库分表的表完全没有关联，不会产生联表查询操作，因为跨库连表查询是没办法实现的),3.1.0版本dql查询存在bug，不使用默认库
-#        default-data-source-name: ds2
-        # 默认分库策略
+        # 默认数据源，可以将不分库分表的数据表放在这里(此处的表需与已经分库分表的表完全没有关联，不会产生联表查询操作，因为跨库连表查询是没办法实现的)
+        # 3.1.0版本中dql查询存在bug，不使用默认库.会在下个版本中修复
+        default-data-source-name: ds2
+        # 默认分库策略,根据userId对2取余确定库
         default-database-strategy:
           inline:
             sharding-column: userId
             algorithm-expression: ds$->{userId % 2}
         # 配置表策略
         tables:
-          # 公共表(比如字典表,角色表，权限表等),不分库或者分表,数据将发送到所有库中,方便联表查询
+          # 公共表(比如字典表,角色表，权限表等),不分库分表,数据将发送到所有库中,方便联表查询
           dictionary:
+            # 配置主键，以便sharding-jdbc生成主键
             key-generator-column-name: dictionaryId
             actual-data-nodes: ds$->{0..1}.dictionary
-          # user 前面已经根据uId分库，因此user表不进行分表
+          # user 已经根据userId分库，因此user表不进行分表
           user:
             key-generator-column-name: userId
             actual-data-nodes: ds$->{0..1}.user
@@ -44,14 +47,18 @@ sharding:
             actual-data-nodes: ds$->{0..1}.order$->{0..1}
             table-strategy:
               inline:
+                # 设置分片键，相同分片键的连表查询不会出现笛卡儿积
                 sharding-column: orderId
+                # 设置分表规则,根据订单id对2取余分两个表
                 algorithm-expression: order$->{orderId%2}
           order_item:
             key-generator-column-name: orderItemId
             actual-data-nodes: ds$->{0..1}.order_item$->{0..1}
             table-strategy:
               inline:
                 sharding-column: orderId
+                # 设置分表规则,根据订单id对2取余分两个表
                 algorithm-expression: order_item$->{orderId%2}
+      # 打印sql解析过程
       props:
         sql.show: true

spring-boot/sjdemo/src/main/resources/application-sharding.yml

@@ -3,11 +3,15 @@
 <mapper namespace="com.fanxb.sjdemo.dao.OrderItemDao">
 
     <insert id="addOne" parameterType="orderItem" useGeneratedKeys="true" keyProperty="orderItemId">
-        insert into order_item(orderId,name,price) values(#{orderId},#{name},#{price})
+        insert into order_item(userId,orderId,name,price) values(#{userId},#{orderId},#{name},#{price})
     </insert>
 
     <select id="getByOrderId" resultType="orderItem">
         select * from order_item where orderId=#{id}
     </select>
 
+    <select id="getOrderItemByPrice" resultType="orderItem">
+        select a.* from order_item a inner join order b on a.orderId = b.orderId where b.totalPrice=#{price}
+    </select>
+
 </mapper>

spring-boot/sjdemo/src/main/resources/mapper/OrderItemMapper.xml

@@ -0,0 +1,14 @@
+<?xml version="1.0" encoding="UTF-8" ?>
+<!DOCTYPE mapper PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN" "http://mybatis.org/dtd/mybatis-3-mapper.dtd">
+<mapper namespace="com.fanxb.sjdemo.dao.OtherTableDao">
+
+    <insert id="addOne" useGeneratedKeys="true" keyProperty="id" parameterType="otherTable">
+        insert into other_table(name) values(#{name})
+    </insert>
+
+    <select id="getAll" resultType="otherTable">
+        select * from other_table
+    </select>
+
+
+</mapper>