Spring Data若干组件集成搭建与示例代码

官网 https://spring.io/projects/spring-data

来看一张全景图:

---

---

本文涉及框架版本说明：

文章涉及代码已上传到 GITEE https://gitee.com/aqu415/demo/tree/master/spring-data

spring-data-elasticsearch

• pom(父pom可以到gitee获取)

    
        spring-data
        com.uu
        1.0.0
        ../pom.xml
    
    4.0.0

    spring-data-es-demo

    
        8
        8
    

    
        
        
            org.springframework.boot
            spring-boot-starter-data-elasticsearch
        
    

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27

• 配置文件

spring:
  elasticsearch:
    rest:
      uris: http://192.168.126.105:9200
1
2
3
4

• 实体类：

package com.xx.entity;

import lombok.AllArgsConstructor;
import lombok.Builder;
import lombok.Data;
import lombok.NoArgsConstructor;
import org.springframework.data.annotation.Id;
import org.springframework.data.elasticsearch.annotations.Document;
import org.springframework.data.elasticsearch.annotations.Field;
import org.springframework.data.elasticsearch.annotations.FieldType;

@Data
@Document(indexName = "info")
@Builder
@AllArgsConstructor
@NoArgsConstructor
public class Info implements java.io.Serializable {

    @Id
    @Field(type = FieldType.Long, store = true)
    private long id;

    @Field(type = FieldType.Text, store = true, analyzer = "ik_smart")
    private String title;

    @Field(type = FieldType.Text, store = true, analyzer = "ik_smart")
    private String content;
}

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29

• 仓库操作类

package com.xx.repository;

import com.xx.entity.Info;
import org.springframework.data.elasticsearch.repository.ElasticsearchRepository;
import org.springframework.stereotype.Repository;

@Repository
public interface InfoRepository extends ElasticsearchRepository {
}

1
2
3
4
5
6
7
8
9
10

• 启动类

package com.xx;

import org.springframework.boot.SpringApplication;
import org.springframework.boot.autoconfigure.SpringBootApplication;

@SpringBootApplication
public class ESApplication {

    public static void main(String[] args) {
        SpringApplication.run(ESApplication.class, args);
    }
}

1
2
3
4
5
6
7
8
9
10
11
12
13

• 测试类

package com.xx;


import com.xx.entity.Info;
import com.xx.repository.InfoRepository;
import org.junit.Test;
import org.junit.runner.RunWith;
import org.springframework.boot.test.context.SpringBootTest;
import org.springframework.test.context.junit4.SpringRunner;

import javax.annotation.Resource;
import java.util.Arrays;
import java.util.UUID;

@RunWith(SpringRunner.class)
@SpringBootTest(classes = ESApplication.class)
public class ESTest {

    @Resource
    private InfoRepository infoRepository;


    @Test
    public void batchSaveTest() {
        Info info = Info.builder().id(System.currentTimeMillis()).content(UUID.randomUUID().toString()).title(UUID.randomUUID().toString()).build();
        Iterable infos = infoRepository.saveAll(Arrays.asList(info));
        System.out.println(infos);
    }

    @Test
    public void indexTest() {
        Iterable all = this.infoRepository.findAll();
        System.out.println(all);
    }
}

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36

• 测试结果
  写入
  

查询

spring-data-mongodb

• pom(父pom可以到gitee获取)

    
        spring-data
        com.uu
        1.0.0
        ../pom.xml
    
    4.0.0

    spring-data-mongodb-demo

    
        8
        8
    

    
        
            org.springframework.boot
            spring-boot-starter-data-mongodb
        
    


1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27

• 配置文件

spring:
  application:
    name: mongo
  data:
    mongodb:
      uri: mongodb://127.0.0.1:27017/test
1
2
3
4
5
6

• 实体类：

package com.xx.entity;

import lombok.Builder;
import lombok.Data;
import lombok.ToString;
import org.springframework.data.mongodb.core.index.Indexed;
import org.springframework.data.mongodb.core.mapping.Document;

@Document(collection = "test")
@Data
@ToString
@Builder
public class People implements java.io.Serializable {

    @Indexed
    private String name;

    @Indexed
    private int age;
}

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21

• 仓库操作类

package com.xx.service;

import com.xx.entity.People;
import org.springframework.data.mongodb.core.MongoTemplate;
import org.springframework.stereotype.Service;

import javax.annotation.Resource;
import java.util.List;

@Service
public class PeopleServie {

    @Resource
    private MongoTemplate mongoTemplate;

    public List getAll() {
        return mongoTemplate.findAll(People.class);
    }

    public void batchSave(People people){
        mongoTemplate.save(people);
    }
}

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24

• 启动类

package com.xx;

import org.springframework.boot.SpringApplication;
import org.springframework.boot.autoconfigure.SpringBootApplication;

@SpringBootApplication
public class MongoApp {

    public static void main(String[] args) {
        SpringApplication.run(MongoApp.class);
    }
}

1
2
3
4
5
6
7
8
9
10
11
12
13

• 测试类

package java.com.xx;//package com.xx.test;
//
import com.xx.MongoApp;
import com.xx.entity.People;
import com.xx.service.PeopleServie;
import lombok.extern.slf4j.Slf4j;
import org.junit.Test;
import org.junit.runner.RunWith;
import org.springframework.boot.test.context.SpringBootTest;
import org.springframework.test.context.junit4.SpringRunner;

import javax.annotation.Resource;

@RunWith(SpringRunner.class)
@SpringBootTest(classes = MongoApp.class)
@Slf4j
public class MongoTest {

    @Resource
    private PeopleServie peopleServie;

    @Test
    public void getAllTest() {
        log.info("" + peopleServie.getAll());
    }

    @Test
    public void batchSaveTest() {
        for (int i = 0; i < 10000; i++) {
            this.peopleServie.batchSave(People.builder().name(String.valueOf(i)).age(i).build());
        }
        log.info("save over");
    }
}

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35

文章涉及代码已上传到 GITEE https://gitee.com/aqu415/demo/tree/master/spring-data