栏目分类:
子分类:
返回
名师互学网用户登录
快速导航关闭
当前搜索
当前分类
子分类
实用工具
热门搜索
名师互学网 > IT > 软件开发 > 后端开发 > Java

Spring-Data-JDBC + Mybatis-plus 实现DDD仓储层,实现1+1 >= 2

Java 更新时间: 发布时间: IT归档 最新发布 模块sitemap 名妆网 法律咨询 聚返吧 英语巴士网 伯小乐 网商动力

Spring-Data-JDBC + Mybatis-plus 实现DDD仓储层,实现1+1 >= 2

Spring-Data-JDBC整合 Mybatis-plus

**spring-data-jdbc官方文档

  1. 项目目录结构:

  2. 导入Maven依赖

  
        
            com.baomidou
            mybatis-plus-generator
            3.5.2
        

        
        
            com.baomidou
            mybatis-plus-boot-starter
            3.5.1
        


        
        
            org.apache.velocity
            velocity-engine-core
            2.3
        
    

        

        
            org.springframework.data
            spring-data-jdbc
        

        
        
            mysql
            mysql-connector-java
        

根据自身选择 是否使用mybatis-plus的代码生成器,如果不使用则无需导入

 
        
            com.baomidou
            mybatis-plus-boot-starter
            3.5.1
        
        
        
            org.apache.velocity
            velocity-engine-core
            2.3
        
    
  1. yam文件配置
#mp
mybatis-plus:
  #这里的路径就是打包出来的 target路径
  mapper-locations: classpath*:com/imoc/ecommerce/mapper/xml
    @TableId(value = "id", type = IdType.AUTO)
    @Id // 这个是spring-data-jdbc的注解
    private Long id;

    
    @TableField("address_detail")
    @Column("address_detail")
    private String addressDetail;

    
    @TableField(value = "create_time",fill = FieldFill.INSERT)
    @Column("create_time")
    @CreatedDate // 创建时候自动 填充为 当前时间
    private LocalDate createTime;

    
    @TableField(value = "update_time",fill = FieldFill.INSERT)
    @Column("update_time")
    @LastModifiedDate // 更新时候自动 填充为 当前时间
    private LocalDate updateTime;```

} 

其中 @TableField(value = "update_time",fill = FieldFill.INSERT) 这是mybatis-plus的注解,使用fill = FieldFill.INSERT 按照官网文档的操作就会在插入时候自动更新时间。

而spring-data-jdbc 用到 官方文档的 :审计篇章来实现
其中 创建时间 @CreatedDate 和 更新时间用@LastModifiedDate 实现,但是注意:

坑: 上面两个注解支持的数据格式为: 实现了 TemporalAccessor接口的时间类。
坑: 要在

  1. Repository层的实现 Application.class 或者 MyBatisConfiguration.class 上添加注解@EnableJdbcAuditing 使得审记注解有效!!!

@Repository
public interface AddressRepository extends PagingAndSortingRepository {
	
    List findAllByUserId(Long userId);



mapper层的实现我是用mybatis-plus代码生成器完成的。这里用的是spring-boot无需烦人的配置,都已经自动配置好了。

  1. spring-data-jdbc审计功能
    实现 BeforeSaveCallback 即可在插入之前进行操作(如加密、解密)
    全部的实体回调如下

@Component
public class EcommerceAddressCallbacks implements BeforeSaveCallback {

    @Override
    public EcommerceAddress onBeforeSave(EcommerceAddress aggregate, MutableAggregateChange aggregateChange) {
        
        return aggregate;
    }
}



  1. 在Service层导入 Repository 和 Mapper 文件即可食用。
@Service
@Slf4j
public class AddressServiceImpl extends ServiceImpl implements IAddressService {
    @Autowired
    AddressRepository addressRepository;
	

    @Override
    public TableId createAddressInfo(AddressInfo addressInfo) {
        
        LoginUserInfo loginUserInfo = AccessContext.getLoginUserInfo();

        // 将传递的参数转换为实体对象
        List ecommerceAddressList =
                addressInfo.getAddressItems().stream()
                        .map(a -> EcommerceAddress.to(loginUserInfo.getId(),a))
                        .collect(Collectors.toList());

        // 保存到数据表并把返回记录的 id给调用方
        List ids = StreamSupport.stream(
                addressRepository.saveAll(ecommerceAddressList).spliterator(),false)
                .map(EcommerceAddress::getId).collect(Collectors.toList());
        log.info("create address info: [{}] [{}] ",loginUserInfo.getId(),JSON.toJSONString(ids));

        // 返回
        return new TableId(
                ids.stream().map(TableId.Id::new).collect(Collectors.toList())
        );
    }
}    
转载请注明:文章转载自 www.mshxw.com
本文地址:https://www.mshxw.com/it/838272.html
我们一直用心在做
关于我们 文章归档 网站地图 联系我们

版权所有 (c)2021-2022 MSHXW.COM

ICP备案号:晋ICP备2021003244-6号