**spring-data-jdbc官方文档
-
项目目录结构:
-
导入Maven依赖
<dependency>
<groupId>com.baomidougroupId>
<artifactId>mybatis-plus-generatorartifactId>
<version>3.5.2version>
dependency>
<dependency>
<groupId>com.baomidougroupId>
<artifactId>mybatis-plus-boot-starterartifactId>
<version>3.5.1version>
dependency>
<dependency>
<groupId>org.apache.velocitygroupId>
<artifactId>velocity-engine-coreartifactId>
<version>2.3version>
dependency>
dependencies>
<dependency>
<groupId>org.springframework.datagroupId>
<artifactId>spring-data-jdbcartifactId>
dependency>
<dependency>
<groupId>mysqlgroupId>
<artifactId>mysql-connector-javaartifactId>
dependency>
根据自身选择 是否使用mybatis-plus的代码生成器,如果不使用则无需导入
<dependency>
<groupId>com.baomidougroupId>
<artifactId>mybatis-plus-boot-starterartifactId>
<version>3.5.1version>
dependency>
<dependency>
<groupId>org.apache.velocitygroupId>
<artifactId>velocity-engine-coreartifactId>
<version>2.3version>
dependency>
dependencies>
- yam文件配置
#mp
mybatis-plus:
#这里的路径就是打包出来的 target路径
mapper-locations: classpath*:com/imoc/ecommerce/mapper/xml/*.xml
configuration:
log-impl: org.apache.ibatis.logging.stdout.StdOutImpl
map-underscore-to-camel-case: true
#springdata-jdbc打印输出
logging:
level:
org.springframework.jdbc.core.JdbcTemplate: DEBUG
spring:
datasource:
# 数据源
url: jdbc:mysql://127.0.0.1:3306/数据库名?autoReconnect=true&useUnicode=true&characterEncoding=utf8&useSSL=false&serverTimezone=Asia/Shanghai
username: 数据库连接账号
password: 密码
- mybatis + spring-data-jdbc的整合的配置文件,放在能被spring容器扫描注入的packge下面即可。
@Configuration
@EnableJdbcRepositories
@EnableJdbcAuditing // 开始审计注解
@Import(MyBatisJdbcConfiguration.class)
public class MyBatisConfiguration {}
- 编写实体类
@Getter
@Setter
@Accessors(chain = true)
@TableName("t_ecommerce_address") 、、
@Table("t_ecommerce_address")
public class EcommerceAddress implements Serializable {
private static final long serialVersionUID = 1L;
/**
* 自增主键
*/
@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
使得审记注解有效!!!
/**
* spring-data-jdbc实现DDD中 Repository
*/
@Repository
public interface AddressRepository extends PagingAndSortingRepository<EcommerceAddress,Long> {
/**
** 这里利用了 JPA的规范,通过IDEA自动就可以生成简单的sql
**/
List<EcommerceAddress> findAllByUserId(Long userId);
mapper层的实现我是用mybatis-plus代码生成器完成的。这里用的是spring-boot无需烦人的配置,都已经自动配置好了。
- spring-data-jdbc审计功能
实现BeforeSaveCallback
即可在插入之前进行 *** 作(如加密、解密)
全部的实体回调如下
@Component
public class EcommerceAddressCallbacks implements BeforeSaveCallback<EcommerceAddress> {
@Override
public EcommerceAddress onBeforeSave(EcommerceAddress aggregate, MutableAggregateChange<EcommerceAddress> aggregateChange) {
/** 插入前的一些 *** 作,如数据加密等。。。 **/
return aggregate;
}
}
- 在Service层导入 Repository 和 Mapper 文件即可食用。
@Service
@Slf4j
public class AddressServiceImpl extends ServiceImpl<AddressMapper, EcommerceAddress> implements IAddressService {
@Autowired
AddressRepository addressRepository;
@Override
public TableId createAddressInfo(AddressInfo addressInfo) {
/**
* 获取由拦截器从请求头中token 经过JWT解析出来的 LoginUserInfo对象
*/
LoginUserInfo loginUserInfo = AccessContext.getLoginUserInfo();
// 将传递的参数转换为实体对象
List<EcommerceAddress> ecommerceAddressList =
addressInfo.getAddressItems().stream()
.map(a -> EcommerceAddress.to(loginUserInfo.getId(),a))
.collect(Collectors.toList());
// 保存到数据表并把返回记录的 id给调用方
List<Long> 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())
);
}
}
欢迎分享,转载请注明来源:内存溢出
评论列表(0条)