**spring-data-jdbc官方文档
-
项目目录结构:
-
导入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
- 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接口的时间类。
坑: 要在
- Repository层的实现 Application.class 或者 MyBatisConfiguration.class 上添加注解@EnableJdbcAuditing 使得审记注解有效!!!
@Repository public interface AddressRepository extends PagingAndSortingRepository{ List findAllByUserId(Long userId);
mapper层的实现我是用mybatis-plus代码生成器完成的。这里用的是spring-boot无需烦人的配置,都已经自动配置好了。
- spring-data-jdbc审计功能
实现 BeforeSaveCallback即可在插入之前进行操作(如加密、解密)
全部的实体回调如下
@Component public class EcommerceAddressCallbacks implements BeforeSaveCallback{ @Override public EcommerceAddress onBeforeSave(EcommerceAddress aggregate, MutableAggregateChange aggregateChange) { return aggregate; } }
- 在Service层导入 Repository 和 Mapper 文件即可食用。
@Service @Slf4j public class AddressServiceImpl extends ServiceImplimplements 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()) ); } }



