新增分页插件

pom.xml

@@ -52,6 +52,11 @@
             <artifactId>sharding-jdbc-spring-boot-starter</artifactId>
             <version>${shardingsphere.version}</version>
         </dependency>
+        <dependency>
+            <groupId>io.shardingsphere</groupId>
+            <artifactId>sharding-jdbc-core</artifactId>
+            <version>${shardingsphere.version}</version>
+        </dependency>
 
         <!-- https://mvnrepository.com/artifact/com.alibaba/fastjson -->
         <dependency>
@@ -78,6 +83,11 @@
             <artifactId>lombok</artifactId>
             <scope>provided</scope>
         </dependency>
+        <dependency>
+            <groupId>com.github.pagehelper</groupId>
+            <artifactId>pagehelper-spring-boot-starter</artifactId>
+            <version>1.2.10</version>
+        </dependency>
     </dependencies>
     <repositories>
         <repository>

src/main/java/com/xin/shardingspherejdbcdemo/config/sharding/ShardingDataSourceConfig.java

@@ -0,0 +1,9 @@
+package com.xin.shardingspherejdbcdemo.config.sharding;
+
+import org.springframework.stereotype.Component;
+
+@Component
+public class ShardingDataSourceConfig {
+
+
+}

src/main/java/com/xin/shardingspherejdbcdemo/config/task/RunJob.java

@@ -1,6 +1,6 @@
 package com.xin.shardingspherejdbcdemo.config.task;
 
-import com.xin.shardingspherejdbcdemo.mapper.UserMapper;
+import com.xin.shardingspherejdbcdemo.mapper.DbMapper;
 import lombok.extern.slf4j.Slf4j;
 import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.boot.ApplicationArguments;
@@ -13,18 +13,16 @@ public class RunJob implements ApplicationRunner {
 
 
     @Autowired
-    private UserMapper userMapper;
+    private DbMapper dbMapper;
+
+
 
     @Override
     public void run(ApplicationArguments args) {
         log.info("执行数据同步开始!");
-//        mongoTemplate.dropCollection(User.class);
-//        UserExample example = new UserExample();
-//        List<User> users = userMapper.selectByExample(example);
-//        if(!StringUtils.isEmpty(users)){
-//            log.info("插入数据{}", users);
-//            mongoTemplate.insertAll(users);
-//            log.info("插入数据完毕");
+//        int i = dbMapper.selectUserTable("2021");
+//        if(i==0){
+//            dbMapper.creatUserTable("2021");
 //        }
 
     }

src/main/java/com/xin/shardingspherejdbcdemo/config/task/TimeJob.java

@@ -1,4 +1,9 @@
 package com.xin.shardingspherejdbcdemo.config.task;
 
 public class TimeJob {
+
+    public static void main(String[] args) {
+        Long i = 1L % 3;
+        System.out.println(i);
+    }
 }

src/main/java/com/xin/shardingspherejdbcdemo/controller/UserController.java

@@ -23,7 +23,6 @@ public class UserController {
     public AjaxVo saveUser(@RequestBody User user) {
         return AjaxVo.success(userService.save(user));
     }
-
     @PutMapping
     public AjaxVo update(@RequestBody User user) {
         return AjaxVo.success(userService.update(user));
@@ -39,17 +38,6 @@ public class UserController {
         return AjaxVo.success(userService.info(id));
     }
 
-    @PostMapping("/insertlist")
-    public AjaxVo insertlist() {
-        List<User> userList = Lists.newArrayList();
-        SnowFlake snowFlake = new SnowFlake(2, 3);
-        for (int i = 0; i < 100000; i++) {
-            userList.add(new User(snowFlake.nextId(), "用户", 18 + i));
-        }
-        userService.saveList(userList);
-        return AjaxVo.success();
-    }
-
     @GetMapping("/list")
     public AjaxVo listUser(int pageNum, int pageSize, String name, Integer age) {
         PageVo data = userService.list(pageNum, pageSize, name, age);

src/main/java/com/xin/shardingspherejdbcdemo/entity/User.java

@@ -1,7 +1,12 @@
 package com.xin.shardingspherejdbcdemo.entity;
 
 import com.baomidou.mybatisplus.annotation.TableName;
+import com.fasterxml.jackson.annotation.JsonFormat;
+import lombok.Data;
 
+import java.util.Date;
+
+@Data
 @TableName("user")
 public class User {
     /** */
@@ -13,33 +18,9 @@ public class User {
     /** */
     private Integer age;
 
-    public User(Long id, String name, Integer age) {
-        this.id = id;
-        this.name = name;
-        this.age = age;
-    }
-
-    public Long getId() {
-        return id;
-    }
-
-    public void setId(Long id) {
-        this.id = id;
-    }
-
-    public String getName() {
-        return name;
-    }
-
-    public void setName(String name) {
-        this.name = name == null ? null : name.trim();
-    }
+    private Integer year;
 
-    public Integer getAge() {
-        return age;
-    }
+    @JsonFormat(shape = JsonFormat.Shape.STRING, pattern = "yyyy-MM-dd HH:mm:ss")
+    private Date createTime;
 
-    public void setAge(Integer age) {
-        this.age = age;
-    }
 }

src/main/java/com/xin/shardingspherejdbcdemo/mapper/DbMapper.java

@@ -0,0 +1,12 @@
+package com.xin.shardingspherejdbcdemo.mapper;
+
+import org.apache.ibatis.annotations.Mapper;
+import org.apache.ibatis.annotations.Param;
+
+@Mapper
+public interface DbMapper {
+
+    void creatUserTable(@Param("year") String year);
+
+    int selectUserTable(@Param("year") String year);
+}

src/main/java/com/xin/shardingspherejdbcdemo/mapper/UserMapper.java

@@ -11,35 +11,4 @@ import java.util.List;
 @Mapper
 public interface UserMapper extends BaseMapper<User> {
 
-    int countByExample(UserExample example);
-
-    int deleteByExample(UserExample example);
-
-    int deleteByPrimaryKey(Long id);
-
-    int insert(User record);
-
-    int insertSelective(User record);
-
-    List<User> selectByExample(UserExample example);
-
-    User selectByPrimaryKey(Long id);
-
-    int updateByExampleSelective(@Param("record") User record, @Param("example") UserExample example);
-
-    int updateByExample(@Param("record") User record, @Param("example") UserExample example);
-
-    int updateByPrimaryKeySelective(User record);
-
-    int updateByPrimaryKey(User record);
-
-
-
-
-
-
-    List<User> selectAll(List<Long> list);
-
-
-    void insertAll(List<User> list);
 }

src/main/java/com/xin/shardingspherejdbcdemo/service/UserService.java

@@ -22,7 +22,6 @@ public interface UserService {
      */
     User save(User user);
 
-    String saveList(List<User> list);
 
     User info(Long id);
 

src/main/java/com/xin/shardingspherejdbcdemo/service/impl/UserServiceImpl.java

@@ -1,16 +1,19 @@
 package com.xin.shardingspherejdbcdemo.service.impl;
 
 
+import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;
+import com.github.pagehelper.PageHelper;
 import com.xin.shardingspherejdbcdemo.config.util.SnowFlake;
 import com.xin.shardingspherejdbcdemo.entity.User;
-import com.xin.shardingspherejdbcdemo.entity.UserExample;
 import com.xin.shardingspherejdbcdemo.entity.vo.PageVo;
 import com.xin.shardingspherejdbcdemo.mapper.UserMapper;
 import com.xin.shardingspherejdbcdemo.service.UserService;
+import com.xin.shardingspherejdbcdemo.utils.DateUtils;
 import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.stereotype.Service;
 import org.springframework.transaction.annotation.Transactional;
 
+import java.util.Date;
 import java.util.List;
 
 
@@ -22,34 +25,17 @@ public class UserServiceImpl implements UserService {
 
     @Override
     public PageVo list(int pageNum, int pageSize, String name, Integer age) {
-        UserExample example = new UserExample();
-        int count = userMapper.countByExample(example);
-        List<User> list = userMapper.selectByExample(example);
+        QueryWrapper queryWrapper = new QueryWrapper();
+        queryWrapper.like("name", name);
+        int count = userMapper.selectCount(queryWrapper);
+        queryWrapper.orderByDesc("age");
+        PageHelper.startPage(pageNum, pageSize);
+        List<User> list = userMapper.selectList(queryWrapper);
         return PageVo.data(list, count);
     }
 
-    private void getUser(List<User> users, List<Long> list) {
-        int listCount = list.size();
-        int pageSize = 1000;//一页数量
-        int pageNumer = listCount % pageSize == 0 ? listCount / pageSize : listCount / pageSize + 1;
-        for (int i = 0; i < pageNumer; i++) {
-            int start = i * pageSize;
-            int end = start + pageSize;
-            //防止索引越界
-            if (i == (pageNumer - 1)) {
-                end = list.size();
-            }
-            //实现分页
-            List<Long> ids = list.subList(start, end);
-            users.addAll(userMapper.selectAll(ids));
-            //写业务逻辑传参pageList参数
-            System.out.println("分页list长度:" + ids.size());
-        }
-    }
-
 
     @Override
-    @Transactional
     public User save(User user) {
         SnowFlake snowFlake = new SnowFlake(2, 3);
         user.setId(snowFlake.nextId());
@@ -57,48 +43,23 @@ public class UserServiceImpl implements UserService {
         return user;
     }
 
-    @Override
-    @Transactional
-    public String saveList(List<User> list) {
-
-        int listCount = list.size();
-        int pageSize = 10000;//一页数量
-        int pageNumer = listCount % pageSize == 0 ? listCount / pageSize : listCount / pageSize + 1;
-        for (int i = 0; i < pageNumer; i++) {
-            int start = i * pageSize;
-            int end = start + pageSize;
-            //防止索引越界
-            if (i == (pageNumer - 1)) {
-                end = list.size();
-            }
-            //实现分页
-            List<User> users = list.subList(start, end);
-            userMapper.insertAll(users);
-            //写业务逻辑传参pageList参数
-            System.out.println("分页list长度:" + users.size());
-        }
-        return "保存成功";
-    }
 
     @Override
     public User info(Long id) {
-        return userMapper.selectByPrimaryKey(id);
+        return userMapper.selectById(id);
     }
 
     @Override
     @Transactional
     public User update(User user) {
-        User userRe = userMapper.selectByPrimaryKey(user.getId());
-        UserExample example = new UserExample();
-        example.createCriteria().andIdEqualTo(userRe.getId()).andAgeEqualTo(userRe.getAge());
-        int i = userMapper.updateByExampleSelective(user, example);
+        userMapper.updateById(user);
         return user;
     }
 
     @Override
     @Transactional
     public Long delete(Long id) {
-        userMapper.deleteByPrimaryKey(id);
+        userMapper.deleteById(id);
         return id;
     }
 

src/main/java/com/xin/shardingspherejdbcdemo/utils/DateUtils.java

@@ -0,0 +1,120 @@
+package com.xin.shardingspherejdbcdemo.utils;
+
+import java.lang.management.ManagementFactory;
+import java.text.SimpleDateFormat;
+import java.util.Calendar;
+import java.util.Date;
+
+/**
+ * 时间工具类
+ *
+ * @author gybank
+ */
+public class DateUtils  {
+    public static String YYYY = "yyyy";
+
+    public static String YYYY_MM = "yyyy-MM";
+
+    public static String YYYY_MM_DD = "yyyy-MM-dd";
+
+    public static String YYYYMMDDHHMMSS = "yyyyMMddHHmmss";
+
+    public static String YYYY_MM_DD_HH_MM_SS = "yyyy-MM-dd HH:mm:ss";
+
+    private static String[] parsePatterns = {
+            "yyyy-MM-dd", "yyyy-MM-dd HH:mm:ss", "yyyy-MM-dd HH:mm", "yyyy-MM",
+            "yyyy/MM/dd", "yyyy/MM/dd HH:mm:ss", "yyyy/MM/dd HH:mm", "yyyy/MM",
+            "yyyy.MM.dd", "yyyy.MM.dd HH:mm:ss", "yyyy.MM.dd HH:mm", "yyyy.MM"};
+
+    /**
+     * 获取当前Date型日期
+     *
+     * @return Date() 当前日期
+     */
+    public static Date getNowDate() {
+        return new Date();
+    }
+
+    /**
+     * 获取服务器启动时间
+     */
+    public static Date getServerStartDate() {
+        long time = ManagementFactory.getRuntimeMXBean().getStartTime();
+        return new Date(time);
+    }
+
+    /**
+     * 计算两个时间差
+     */
+    public static String getDatePoor(Date endDate, Date nowDate) {
+        long nd = 1000 * 24 * 60 * 60;
+        long nh = 1000 * 60 * 60;
+        long nm = 1000 * 60;
+        // long ns = 1000;
+        // 获得两个时间的毫秒时间差异
+        long diff = endDate.getTime() - nowDate.getTime();
+        // 计算差多少天
+        long day = diff / nd;
+        // 计算差多少小时
+        long hour = diff % nd / nh;
+        // 计算差多少分钟
+        long min = diff % nd % nh / nm;
+        // 计算差多少秒//输出结果
+        // long sec = diff % nd % nh % nm / ns;
+        return day + "天" + hour + "小时" + min + "分钟";
+    }
+
+    /**
+     * 前一天日期
+     *
+     * @param date
+     * @return
+     */
+    public static String getNextDay(Date date) {
+        Calendar calendar = Calendar.getInstance();
+        calendar.setTime(date);
+        calendar.add(Calendar.DAY_OF_MONTH, -1);
+        date = calendar.getTime();
+        return new SimpleDateFormat(YYYY_MM_DD).format(date);
+    }
+
+    /**
+     * 前一天日期
+     *
+     * @param date
+     * @return
+     */
+    public static int getYear(Date date) {
+        Calendar calendar = Calendar.getInstance();
+        calendar.setTime(date);
+        return calendar.getWeekYear();
+    }
+
+    /**
+     * 几小时后的时间
+     *
+     * @param date
+     * @return
+     */
+    public static String getAddHourDate(Date date, int hour) {
+        Calendar calendar = Calendar.getInstance();
+        calendar.setTime(date);
+        calendar.add(Calendar.HOUR_OF_DAY, hour);
+        date = calendar.getTime();
+        return new SimpleDateFormat(YYYY_MM_DD_HH_MM_SS).format(date);
+    }
+
+    /**
+     * 几分钟后的时间
+     *
+     * @param date
+     * @return
+     */
+    public static String getAddMinuteDate(Date date, int minute) {
+        Calendar calendar = Calendar.getInstance();
+        calendar.setTime(date);
+        calendar.add(Calendar.MINUTE, minute);
+        date = calendar.getTime();
+        return new SimpleDateFormat(YYYY_MM_DD_HH_MM_SS).format(date);
+    }
+}

src/main/resources/application.yml

@@ -1,13 +1,65 @@
 server:
   port: 8087
+pagehelper:
+  helper-dialect: mysql
+
+dbinfo:
+  dbname: study
+  url: jdbc:mysql://192.168.29.131:3306/${dbinfo.dbname}
+  username: root
+  password: 123456
 spring:
+  main:
+    allow-bean-definition-overriding: true
+  datasource:
+    name: mysql_test
+    type: com.alibaba.druid.pool.DruidDataSource
+    #druid�詨��滨蔭
+    druid:
+      #�烐綉蝏蠘恣�行⏛��ilters
+      filters: stat
+      driver-class-name: com.mysql.jdbc.Driver
+      #�箸𧋦撅墧��
+      url: ${dbinfo.url}?useUnicode=true&characterEncoding=UTF-8&allowMultiQueries=true&useSSL=false
+      username: ${dbinfo.username}
+      password: ${dbinfo.password}
+      #�滨蔭�嘥��硋之撠�/��撠�/��憭�
+      initial-size: 1
+      min-idle: 1
+      max-active: 20
+      #�瑕�餈墧𦻖蝑匧�頞�𧒄�園𡢿
+      max-wait: 60000
+      #�湧�憭帋�餈𥡝�銝�甈⊥�瘚页�璉�瘚钅�閬���剔�蝛粹𤦭餈墧𦻖
+      time-between-eviction-runs-millis: 60000
+      #銝�銝芾��亙銁瘙牐葉��撠讐�摮条��園𡢿
+      min-evictable-idle-time-millis: 300000
+      validation-query: SELECT 'x'
+      test-while-idle: true
+      test-on-borrow: false
+      test-on-return: false
+      #�枏�PSCache嚗�僎���瘥譍葵餈墧𦻖銝𢰸SCache��之撠譌��racle霈曆蛹true嚗龧ysql霈曆蛹false���摨枏�銵刻�憭𡁏綫�鞱挽蝵桐蛹false
+      pool-prepared-statements: false
+      max-pool-prepared-statement-per-connection-size: 20
   shardingsphere:
     datasource:
+      #�唳旿摨枏���
       names: master0
-      # 杅擂埭 翋踱
       master0:
         type: com.alibaba.druid.pool.DruidDataSource
         driver-class-name: com.mysql.cj.jdbc.Driver
-        url: jdbc:mysql://192.168.29.131:3306/study?useUnicode=true&characterEncoding=UTF-8&serverTimezone=Asia/Shanghai
-        username: root
-        password: 123456
+        url: ${dbinfo.url}?useUnicode=true&characterEncoding=UTF-8&serverTimezone=Asia/Shanghai&allowMultiQueries=true
+        username: ${dbinfo.username}
+        password: ${dbinfo.password}
+    sharding:
+      tables:
+        #�餉�銵典�
+        user:
+          actual-data-nodes: master0.user$->{0..2}
+          table-strategy:
+            inline:
+              sharding-column: id
+              algorithm-expression: user$->{id%3}
+    #�枏㫲sql
+    props:
+      sql:
+        show: true

src/main/resources/mapper/DbMapper.xml

@@ -0,0 +1,25 @@
+<?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.xin.shardingspherejdbcdemo.mapper.DbMapper">
+
+
+    <select id="creatUserTable">
+        CREATE TABLE `user${year}` (
+          `id` bigint(18) NOT NULL AUTO_INCREMENT,
+          `name` varchar(10) DEFAULT NULL,
+          `age` int(11) DEFAULT NULL,
+          PRIMARY KEY (`id`)
+        ) ENGINE=InnoDB AUTO_INCREMENT=126 DEFAULT CHARSET=utf8mb4;
+    </select>
+
+    <select id="selectUserTable" resultType="java.lang.Integer">
+        SELECT
+            COUNT( 1 )
+        FROM
+            information_schema.TABLES
+        WHERE
+            table_name = 'user${year}';
+
+    </select>
+
+</mapper>

src/main/resources/mapper/UserMapper.xml

@@ -1,210 +1,9 @@
 <?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.xin.shardingspherejdbcdemo.mapper.UserMapper" >
-    <resultMap id="BaseResultMap" type="com.xin.shardingspherejdbcdemo.entity.User" >
-        <id column="id" property="id" jdbcType="BIGINT" />
-        <result column="name" property="name" jdbcType="VARCHAR" />
-        <result column="age" property="age" jdbcType="INTEGER" />
-    </resultMap>
-    <sql id="Example_Where_Clause" >
-        <where >
-            <foreach collection="oredCriteria" item="criteria" separator="or" >
-                <if test="criteria.valid" >
-                    <trim prefix="(" suffix=")" prefixOverrides="and" >
-                        <foreach collection="criteria.criteria" item="criterion" >
-                            <choose >
-                                <when test="criterion.noValue" >
-                                    and ${criterion.condition}
-                                </when>
-                                <when test="criterion.singleValue" >
-                                    and ${criterion.condition} #{criterion.value}
-                                </when>
-                                <when test="criterion.betweenValue" >
-                                    and ${criterion.condition} #{criterion.value} and #{criterion.secondValue}
-                                </when>
-                                <when test="criterion.listValue" >
-                                    and ${criterion.condition}
-                                    <foreach collection="criterion.value" item="listItem" open="(" close=")" separator="," >
-                                        #{listItem}
-                                    </foreach>
-                                </when>
-                            </choose>
-                        </foreach>
-                    </trim>
-                </if>
-            </foreach>
-        </where>
-    </sql>
-    <sql id="Update_By_Example_Where_Clause" >
-        <where >
-            <foreach collection="example.oredCriteria" item="criteria" separator="or" >
-                <if test="criteria.valid" >
-                    <trim prefix="(" suffix=")" prefixOverrides="and" >
-                        <foreach collection="criteria.criteria" item="criterion" >
-                            <choose >
-                                <when test="criterion.noValue" >
-                                    and ${criterion.condition}
-                                </when>
-                                <when test="criterion.singleValue" >
-                                    and ${criterion.condition} #{criterion.value}
-                                </when>
-                                <when test="criterion.betweenValue" >
-                                    and ${criterion.condition} #{criterion.value} and #{criterion.secondValue}
-                                </when>
-                                <when test="criterion.listValue" >
-                                    and ${criterion.condition}
-                                    <foreach collection="criterion.value" item="listItem" open="(" close=")" separator="," >
-                                        #{listItem}
-                                    </foreach>
-                                </when>
-                            </choose>
-                        </foreach>
-                    </trim>
-                </if>
-            </foreach>
-        </where>
-    </sql>
-    <sql id="Base_Column_List" >
-    id, name, age
-  </sql>
-    <select id="selectByExample" resultMap="BaseResultMap" parameterType="com.xin.shardingspherejdbcdemo.entity.UserExample" >
-        select
-        <if test="distinct" >
-            distinct
-        </if>
-        <include refid="Base_Column_List" />
-        from user0
-        <if test="_parameter != null" >
-            <include refid="Example_Where_Clause" />
-        </if>
-        <if test="orderByClause != null" >
-            order by ${orderByClause}
-        </if>
-    </select>
-    <select id="selectByPrimaryKey" resultMap="BaseResultMap" parameterType="java.lang.Long" >
-        select
-        <include refid="Base_Column_List" />
-        from user
-        where id = #{id,jdbcType=BIGINT}
-    </select>
-    <delete id="deleteByPrimaryKey" parameterType="java.lang.Long" >
-    delete from user
-    where id = #{id,jdbcType=BIGINT}
-  </delete>
-    <delete id="deleteByExample" parameterType="com.xin.shardingspherejdbcdemo.entity.UserExample" >
-        delete from user
-        <if test="_parameter != null" >
-            <include refid="Example_Where_Clause" />
-        </if>
-    </delete>
-    <insert id="insert" parameterType="com.xin.shardingspherejdbcdemo.entity.User" >
-    insert into user (id, name, age)
-    values (#{id,jdbcType=BIGINT}, #{name,jdbcType=VARCHAR}, #{age,jdbcType=INTEGER})
-  </insert>
-    <insert id="insertSelective" parameterType="com.xin.shardingspherejdbcdemo.entity.User" >
-        insert into user
-        <trim prefix="(" suffix=")" suffixOverrides="," >
-            <if test="id != null" >
-                id,
-            </if>
-            <if test="name != null" >
-                name,
-            </if>
-            <if test="age != null" >
-                age,
-            </if>
-        </trim>
-        <trim prefix="values (" suffix=")" suffixOverrides="," >
-            <if test="id != null" >
-                #{id,jdbcType=BIGINT},
-            </if>
-            <if test="name != null" >
-                #{name,jdbcType=VARCHAR},
-            </if>
-            <if test="age != null" >
-                #{age,jdbcType=INTEGER},
-            </if>
-        </trim>
-    </insert>
-    <select id="countByExample" parameterType="com.xin.shardingspherejdbcdemo.entity.UserExample" resultType="java.lang.Integer" >
-        select count(*) from user
-        <if test="_parameter != null" >
-            <include refid="Example_Where_Clause" />
-        </if>
-    </select>
-    <update id="updateByExampleSelective" parameterType="map" >
-        update user
-        <set >
-            <if test="record.id != null" >
-                id = #{record.id,jdbcType=BIGINT},
-            </if>
-            <if test="record.name != null" >
-                name = #{record.name,jdbcType=VARCHAR},
-            </if>
-            <if test="record.age != null" >
-                age = #{record.age,jdbcType=INTEGER},
-            </if>
-        </set>
-        <if test="_parameter != null" >
-            <include refid="Update_By_Example_Where_Clause" />
-        </if>
-    </update>
-    <update id="updateByExample" parameterType="map" >
-        update user
-        set id = #{record.id,jdbcType=BIGINT},
-        name = #{record.name,jdbcType=VARCHAR},
-        age = #{record.age,jdbcType=INTEGER}
-        <if test="_parameter != null" >
-            <include refid="Update_By_Example_Where_Clause" />
-        </if>
-    </update>
-    <update id="updateByPrimaryKeySelective" parameterType="com.xin.shardingspherejdbcdemo.entity.User" >
-        update user
-        <set >
-            <if test="name != null" >
-                name = #{name,jdbcType=VARCHAR},
-            </if>
-            <if test="age != null" >
-                age = #{age,jdbcType=INTEGER},
-            </if>
-        </set>
-        where id = #{id,jdbcType=BIGINT}
-    </update>
-    <update id="updateByPrimaryKey" parameterType="com.xin.shardingspherejdbcdemo.entity.User" >
-    update user
-    set name = #{name,jdbcType=VARCHAR},
-      age = #{age,jdbcType=INTEGER}
-    where id = #{id,jdbcType=BIGINT}
-  </update>
 
-    <sql id="selectAll_Base_Column_List">
-        select
-        `id`, `name`, `age`
-        from user
-    </sql>
 
-    <select id="selectAll" resultMap="BaseResultMap">
-        <include refid="selectAll_Base_Column_List"/>
-        where id in
-        <foreach collection="list" item="id" open="(" close=")" separator=",">
-            #{id}
-        </foreach>
-    </select>
-    <insert id="insertAll">
-        insert into user
-        <trim prefix="(" suffix=")" suffixOverrides=",">
-            id,
-            name,
-            age,
-        </trim>
-        values
-        <foreach collection="list" item="item" separator=",">
-            (
-            #{item.id,jdbcType=BIGINT},
-            #{item.name,jdbcType=VARCHAR},
-            #{item.age,jdbcType=INTEGER}
-            )
-        </foreach>
 
-    </insert>
+
+
 </mapper>