BaseDao

<dependency>
    <groupId>priv.pfz</groupId>
    <artifactId>basedao-core</artifactId>
    <version>1.0-SNAPSHOT</version>
</dependency>

public interface UserMapper extends SimpleBaseMapper<UserEntity> {
    //手写mapper.xml的方法可与BaseMapper方法共存
   ...
}

    @Resource
    private UserMapper userMapper;

    @Test
    public void test() {
        //simple
        userMapper.insert(new UserEntity());
        userMapper.updateById(new UserEntity());
        userMapper.updateByExample(new UserEntity());
        userMapper.updateByExamples(new ArrayList<>());
        userMapper.selectById(1);
        userMapper.listByIds(new ArrayList<>());
        userMapper.mapByIds(new ArrayList<>());
        userMapper.selectByExample(new UserEntity());
        userMapper.listByExample(new UserEntity());
        userMapper.listByExamples(new ArrayList<>());
        userMapper.countAll();
        userMapper.listAll();
        userMapper.deleteById(1);
        userMapper.deleteByIds(new ArrayList<>());
        userMapper.deleteByExample(new UserEntity());
        userMapper.deleteByExamples(new ArrayList<>());
    }

public class UserEntity {
    /**
     * 数据库自增id
     */
    @NoInsert //insert时无需保存此字段
    private Integer id;

    /**
     * 身份证号
     */
    @UniqueKey //身份证号是唯一键
    private String idCardNo;

    /**
     * 姓名
     */
    private String name;
    
    /**
     * 年龄
     */
    private Integer age;

    /**
     * 住址
     */
    @NoColumn //此字段保存在redis中，数据库并没有此字段
    private String address;
}

public interface UserMapper extends AnnotatedBaseMapper<UserEntity> {
    ...
}

    @Resource
    private UserMapper userMapper;

    @Test
    public void test() {
        //annotated
        userMapper.batchInsert(new ArrayList<>());
        userMapper.updateByUniqueKey(new UserEntity());
    }

@Entity
public class UserEntity {
    ...
}

/**
 * @author BaseDao
 * 2024/1/29 23:26
 */
public class UserQuery extends BaseQuery<UserQuery> {
 
    public final IntColumn<UserQuery> id = new IntColumn<>(this, "id", "id"); 
 
    public final StringColumn<UserQuery> idCardNo = new StringColumn<>(this, "idCardNo", "id_card_no"); 
 
    public final StringColumn<UserQuery> name = new StringColumn<>(this, "name", "name"); 
 
    public final IntColumn<UserQuery> age = new IntColumn<>(this, "age", "age");
}

public interface UserMapper extends DefaultBaseMapper<UserEntity, UserQuery> {
    ...
}

    @Resource
    private UserMapper userMapper;
    
    @Test
    public void test() {
        //default
        userMapper.update(new UserEntity(), new UserQuery());
        userMapper.count(new UserQuery());
        userMapper.list(new UserQuery());
        userMapper.delete(new UserQuery());
        userMapper.pageQuery(new UserQuery());
        
        //query example
        UserQuery query = new UserQuery()
                .idCardNo.eq("123456")
                .name.like("诸葛")
                .age.between(20, 40)
                .id.desc()
                .page(2, 10);
        userMapper.list(query);
    }

    UserQuery query = new UserQuery()
        .idCardNo.eq("123456");

    UserQuery query = new UserQuery()
        .id.desc();

    UserQuery query = new UserQuery()
        .page(2, 10);

@Table(enableLogicDelete = true)
public interface UserMapper extends DefaultBaseMapper<UserEntity, UserQuery> {
    ...
}

@Table(dbName = "db", shardingMode = ShardingMode.SHARDING_DB_TABLE)
public interface UserMapper extends DefaultShardingBaseMapper<UserEntity, UserQuery> {
    ...
}

    /**
     * 身份证号
     */
    @UniqueKey
    @ShardingKey(shardingStrategy = UserShardingStrategy.class)
    private String idCardNo;

/**
 * user表根据idCardNo分库分表的切分策略
 */
public class UserShardingStrategy implements ShardingStrategy<String> {
    @Override
    public ShardingInfo getShardingInfo(String idCardNo) {
        String dbSuffix = ...;
        String tableSuffix = ...;
        return new ShardingInfo(dbSuffix, tableSuffix);
    }
}

    UserEntity userEntity = new UserEntity();
    userEntity.setName("yyjx");
    userEntity.setAge(99);
    
    //手工指定02库05表
    ShardingInfo shardingInfo = ShardingInfo.dbTable("02", "05");
    
    userMapper.insert(userEntity, shardingInfo);
    //INSERT INTO db_02.`user_05` (`name`, `age`) VALUES (?, ?);

    //包含切分键idCardNo，根据123456自动计算出分库分表
    UserEntity userEntity = new UserEntity();
    userEntity.setName("yyjx");
    userEntity.setAge(99);
    userEntity.setIdCardNo("123456");
        
    //shardingInfo可不设置值
    ShardingInfo shardingInfo = ShardingInfo.empty();
    
    userMapper.insert(userEntity, shardingInfo);
    //INSERT INTO db_02.`user_05` (`name`, `age`, `id_card_no`) VALUES (?, ?, ?);

    UserEntity userEntity = new UserEntity();
    userEntity.setName("yyjx");
    userEntity.setAge(99);
    userEntity.setIdCardNo("123456");
        
    ShardingInfo shardingInfo = ShardingInfo.empty();
    
    userMapper.insert(userEntity, shardingInfo);
    //INSERT INTO db_02.`user_05` (`name`, `age`, `id_card_no`) VALUES (?, ?, ?);
    
    //调用方法后从shardingInfo中获取实际的分库分表信息
    System.out.println(shardingInfo);
    //ShardingInfo(dbSuffix=02, tableSuffix=05)

@Table(shardingMode = ShardingMode.THIRD_SHARDING_COMPONENT)
public interface UserMapper extends DefaultShardingBaseMapper<UserEntity, UserQuery> {
    ...
}

    UserEntity userEntity = new UserEntity();
    userEntity.setName("yyjx");
    userEntity.setAge(99);
    userEntity.setIdCardNo("123456");
        
    //shardingInfo中传入第三方所需的分库分表信息，此信息段追加到SQL末尾
    ShardingInfo shardingInfo = ShardingInfo.third("/@sdb=02;ts=05@/");
    
    userMapper.insert(userEntity, shardingInfo);
    //INSERT INTO `user` (`name`, `age`, `id_card_no`) VALUES (?, ?, ?) /@sdb=02;ts=05@/ 

public static void main(String[] args) {
   Generator.newInstance()
           .entitySuffix("Entity")
           .entityPath("basedao-lab/src/main/java/priv/pfz/basedao/lab/dao/entity/")
           .entityPackage("priv.pfz.basedao.lab.dao.entity")
           .dbName("world")
           .tableNames("tb_goods_00", "tb_trade_info_00")
           .tableNamePrefix("tb_")
           .tableNameSuffix("_00")
           .dbUrl("jdbc:mysql://localhost:3306/")
           .dbUser("root")
           .dbPassword("123456")
           .generate();
}

CREATE TABLE `tb_goods_00` (
    `id` int NOT NULL COMMENT '自增id',
    `goods_code` varchar(30) NOT NULL COMMENT '商品编码',
    `name` varchar(30) DEFAULT NULL COMMENT '商品名称',
    `price` int DEFAULT NULL COMMENT '价格',
    `delete_flag` int NOT NULL COMMENT '删除标识',
    `create_time` datetime NOT NULL DEFAULT CURRENT_TIMESTAMP COMMENT '创建时间',
    `update_time` datetime NOT NULL DEFAULT CURRENT_TIMESTAMP ON UPDATE CURRENT_TIMESTAMP COMMENT '更新时间'
) ENGINE=InnoDB DEFAULT CHARSET=utf8mb4 COLLATE=utf8mb4_0900_ai_ci

package priv.pfz.basedao.lab.dao.entity;

import lombok.Data;
import priv.pfz.basedao.annotations.Entity;
import java.util.Date;

/**
 * @author BaseDao
 * 2024/2/6 0:27
 */
@Data
@Entity
public class GoodsEntity  {

   /**
    * 自增id
    */
   private Long id;

   /**
    * 商品编码
    */
   private String goodsCode;

   /**
    * 商品名称
    */
   private String name;

   /**
    * 价格
    */
   private Long price;

   /**
    * 删除标识
    */
   private Long deleteFlag;

   /**
    * 创建时间
    */
   private Date createTime;

   /**
    * 更新时间
    */
   private Date updateTime;
}