note/1.java/SpringBoot/12.Spring boot整合mongodb.md

依赖

<dependency>
    <groupId>org.springframework.boot</groupId>
    <artifactId>spring-boot-starter-data-mongodb</artifactId>
</dependency>

配置文件

# mongodb数据源配置
spring.data.mongodb.uri=mongodb://localhost:27017/open5gs

代码

• 实体类

  @Setter
  @Getter
  public class Profiles {
  
  	@Id
  	private String id;
  	private String title;
  	private List<Pdn> pdn;
  	private Link ambr;
  	private Security security;
  
  }
  

• Repository类

  

  

  @Repository
  public interface ProfilesRepository extends MongoRepository<Profiles, String> {
  
  	Profiles findByTitle(String title);
  
  	@Query(value = "{'_id':{'$ne':null}}", fields = "{'title':1,'_id':0}")
  	List<Profiles> title();
  
  }
  

• Repository的使用

  @Service
  public class ProfileService {
  	@Autowired
  	private ProfilesRepository profileRepository;
  
  	public Page<Profiles> find(Profiles exp, BasePageParam pageParam) {
        Integer page = pageParam.getPage();
        if (page == null || page < 1) {
            page = 1;
        }
        Integer size = pageParam.getSize();
        if (size == null || size == 0) {
            size = 20;
        }
        PageRequest pageable = PageRequest.of(page - 1, size, Direction.DESC, "_id");
        ExampleMatcher matcher = ExampleMatcher.matching().withIgnorePaths("_class").withMatcher("title", GenericPropertyMatcher.of(StringMatcher.CONTAINING));
        Example<Profiles> example = Example.of(exp, matcher);
        return profileRepository.findAll(example, pageable);
  	}
  
  	public Profiles findByTitle(String title) {
        return profileRepository.findByTitle(title);
  	}
  
  	public List<Profiles> findTitles() {
        return profileRepository.title();
  	}
  
  	public void save(Profiles profiles) throws SprtException {
        Profiles old = profileRepository.findByTitle(profiles.getTitle());
        if (old != null) {
            throw new SprtException("已存在相同名称的模板");
        }
        profileRepository.save(profiles);
  	}
  
  	public void update(Profiles profiles) throws SprtException {
        profileRepository.save(profiles);
  	}
  
  	public void delete(Profiles profiles) {
        profileRepository.deleteById(profiles.getId());
  	}
  
  }