Spring Boot----SpringData

简介

Spring Data 项目的目的是为了简化构建基于Spring 框架应用的数据访问技术，包括非关系数据库、Map-Reduce 框架、云数据服务等等；另外也包含对关系数据库的访问支持。

SpringData特点

SpringData为我们提供使用统一的APl来对数据访问层进行操作；这主要是Spring Data Commons项目来实现的。Spring Data Commons让我们在使用关系型或者非关系型数据访问技术时都基于Spring提供的

统一标准，标准包含了CRUD（创建、获取、更新、删除）、查询、排序和分页的相关操作。

统一的Repository接口

Repository<T，ID extends Serializable>：统一接口

RevisionRepository<T，ID extends Serializable，N extends Number&Comparable<N>>：基于乐观锁机制

CrudRepository<T，ID extends Serializable>：基本CRUD操作

PagingAndSortingRepository<T，ID extends Serializable>：基本CRUD及分页

适用场景

　　适用于单表查询，不适用连表查询（适用mybatis）

springBoot 整合spring data JPA

1、创建项目

spring Data jpa

配置数据源（可以指定druid）

spring:
  datasource:

    driver-class-name: com.mysql.cj.jdbc.Driver
    password: 123456
    url: jdbc:mysql://localhost:3306/javas1?serverTimezone=UTC
    username: root

编写实体类

@Entity                  //告诉jpa这是一个实体类(和数据表映射的类)
@Table(name = "t_user") //指定和那个数据表对应
public class User {
    @Id //主键
    @GeneratedValue(strategy = GenerationType.IDENTITY) //自增主键
    private Integer id;
    @Column(name = "username",length = 32)    //如果数据库中定义的列名是userName,我们就可以使用@Column,@column(name="userName")
    private String username;
}

dao

/*User:对应的实体类,Integer:id字段对应的属性*/
public interface UserDao extends JpaRepository<User,Integer> {

}

编辑基本的配置

spring:
  jpa:
    hibernate:
      #自动创建数据表结构或者更新
      ddl-auto: update
    #控制台显示show语句
    show-sql: true

1、运行（如果数据表不存在，就会自动创建）

测试：curd

    @Autowired
    UserDao userDao;
    @Test
    public void test() {
        Optional<User> byId = userDao.findById(4);
        System.out.println(byId.get());
        //User one = userDao.getOne(4);
    }

spring Data MongoDB

实体类使用@Document注解

@Data
@ToString
@Document(collection = "cms_page")
public class CmsPage {
    //站点ID
    private String siteId;
    //页面ID
    @Id
    private String pageId;
}

dao接口

public interface CmsPageRepository extends MongoRepository<CmsPage,String> {
    //根据页面名称查询
    CmsPage findByPageName(String pageName);
}

• 我们可以点进去MongoRespository，下面是自带操作数据库的方法

    List<T> findAll();

    List<T> findAll(Sort var1);

    <S extends T> S insert(S var1);

    <S extends T> List<S> insert(Iterable<S> var1);

    <S extends T> List<S> findAll(Example<S> var1);

    <S extends T> List<S> findAll(Example<S> var1, Sort var2);

test

@SpringBootTest
@RunWith(SpringRunner.class)
public class CmsPageRepositoryTest {

    @Autowired
    CmsPageRepository cmsPageRepository;

    @Test
    public void test() {
        MongoClientURI connectionString = new MongoClientURI("mongodb://root:123@localhost:27017");
        MongoClient mongoClient = new MongoClient(connectionString);
        MongoDatabase database = mongoClient.getDatabase("xc_cms");
        MongoCollection<Document> collection = database.getCollection("cms_page(1)");
        Document myDoc = collection.find().first();
        String json = myDoc.toJson();
        System.out.println(json);
    }

    @Test
    public void testFindAll() {
        List<CmsPage> all = cmsPageRepository.findAll();
        System.out.println(all);
    }

    //分页查询
    @Test
    public void testFindPage() {
        //分页参数
        int page = 1;//从0开始
        int size = 10;
        Pageable pageable = PageRequest.of(page, size);
        Page<CmsPage> all = cmsPageRepository.findAll(pageable);
        List<CmsPage> content = all.getContent();
        System.out.println(content);
    }

    //修改
    @Test
    public void testUpdate() {
        //查询对象
        //Optional对象是jdk1.8出来的,目的是保障程序尽量能避免空指针的问题存在,和我们手动判断cmsPage!=null作用是一样的.(标准化)
        Optional<CmsPage> optional = cmsPageRepository.findById("5b4b1d8bf73c6623b03f8cec");
        if (optional.isPresent()) {
            CmsPage cmsPage = optional.get();
            //设置要修改值
            cmsPage.setPageAliase("test01");
            //...
            //修改
            CmsPage save = cmsPageRepository.save(cmsPage);
            System.out.println(save);
        }
    }

    //根据页面名称查询
    @Test
    public void testfindByPageName() {
        CmsPage cmsPage = cmsPageRepository.findByPageName("index_category.html");
        System.out.println(cmsPage);
    }
}

自定义Dao方法

　　同Spring Data JPA一样Spring Data mongodb也提供自定义方法的规则，如下：
　　按照fndByXXX，findByXXXAndYYY、countByXXXAndYYY等规则定义方法，实现查询操作。

interface CmsPageRepository extends MongoRepository<CmsPage,String> {
    //根据页面名称查询
    CmsPage findByPageName(String pageName);

    //根据页面名称和类型查询
    CmsPage findByPageNameAndPageType(String pageName, String pageType);

    //根据站点和页面类型查询记录数
    int countBySiteIdAndPageType(String siteId, String pageType);

    //根据站点和页面类型分页查询（Pageable是自带类）
    Page<CmsPage> findBySiteIdAndPageType(String siteId, String pageType, Pageable pageable);
}

自定义条件查询测试

    //自定义条件查询测试
    @Test
    public void testFindAllByExample() {
        //分页参数
        int page = 0;//从0开始
        int size = 10;
        Pageable pageable = PageRequest.of(page,size);

        //条件值对象
        CmsPage cmsPage= new CmsPage();
        //要查询5a751fab6abb5044e0d19ea1站点的页面
//        cmsPage.setSiteId("5b30b052f58b4411fc6cb1cf");
        //设置模板id条件
//        cmsPage.setTemplateId("5ad9a24d68db5239b8fef199");
        //设置页面别名(默认是精确查询,我们在条件匹配器中定义了该字段设置为模糊查询了)
        cmsPage.setPageAliase("轮播");
        //条件匹配器（设置页面别名）
//        ExampleMatcher exampleMatcher = ExampleMatcher.matching();
//        exampleMatcher = exampleMatcher.withMatcher("pageAliase", ExampleMatcher.GenericPropertyMatchers.contains()); //模糊匹配
        ExampleMatcher exampleMatcher = ExampleMatcher.matching()
                .withMatcher("pageAliase", ExampleMatcher.GenericPropertyMatchers.contains());
        //ExampleMatcher.GenericPropertyMatchers.contains() 包含关键字
//        ExampleMatcher.GenericPropertyMatchers.startsWith()//前缀匹配
        //定义Example
        Example<CmsPage> example = Example.of(cmsPage,exampleMatcher);
        Page<CmsPage> all = cmsPageRepository.findAll(example, pageable);
        List<CmsPage> content = all.getContent();
        System.out.println(content);
    }

JPA自定义Sql语句

public interface XcTaskRepository extends JpaRepository<XcTask,String> {
    //查询某个时间之间的前n条任务
    Page<XcTask> findByUpdateTimeBefore(Pageable pageable, Date updateTime);

    //更新updateTime
    @Modifying
    @Query("update XcTask t set t.updateTime = :updateTime where t.id = :id") //XcTask 是类名，updateTime是类里面的字段名
    public int updateTaskTime(@Param(value = "id") String id,@Param(value = "updateTime") Date updateTime);

    
    @Modifying
    @Query("update XcTask t set t.version = :version+1 where t.id = :id and t.version = :version")
    public int updateTaskVersion(@Param(value = "id") String id,@Param(value = "version") int version);
}

参考手册

https://docs.spring.io/spring-data/data-jpa/docs/current/reference/html/#reference