springboot Mongodb的集成与使用实例详解

compile('org.springframework.boot:spring-boot-starter-data-mongodb')

testCompile('de.flapdoodle.embed:de.flapdoodle.embed.mongo:2.0.3')

spring:
 data:
  mongodb:
   uri: mongodb://192.168.99.100:27017/Test
   password: guest
   username: guest

/**
 * 地址.
 */
@Data
@NoArgsConstructor
@AllArgsConstructor
public class Address {
 /**
  * 编号.
  */
 @Id
 private String id;
 /**
  * 省.
  */
 private String province;
 /**
  * 市.
  */
 private String city;
 /**
  * 区.
  */
 private String district;
 /**
  * 状态.
  */
 private Status status;
}

/**
 * 对外提供的地址仓储接口，继承所有地址相关的接口.
 */
public interface AddressRepository extends
  AddressExtRepository,
  MongoRepository<Address, String> {
 /**
  * 根据省，拿地址列表.
  *
  * @param province
  * @return
  */
 @Query(fields = "{'province': 0}")
 List<Address> findAddressesByProvince(String province);
 /**
  * 根据省和省，拿地址列表.
  *
  * @param province
  * @param city
  * @return
  */
 @Query()//fields表示包含的字段
 List<Address> findAddressesByProvinceAndCityAndDistrict(String province, String city, String district);
}

/**
 * 特殊规则的仓储实现.
 */
public class AddressExtRepositoryImpl implements AddressExtRepository {
 @Autowired
 MongoTemplate mongoTemplate;
 @Override
 public Address findByProvinceAndCity(String province, String city) {
  Query query = new Query(Criteria.where("province").is(province).and("city").is(city));
  return mongoTemplate.findOne(query, Address.class, "address");
 }
}

@RestController
public class MongoController {
 // 仓储.
 @Autowired
 private AddressRepository repository;
 // 用户业务.
 @Autowired
 private UserService userService;
 /**
  * 得到地址列表.
  *
  * @return
  */
 @RequestMapping("/address/{province}")
 public Address getAddress(@PathVariable("province") String province) {
  System.out.println("1,province=" + province);
  return userService.getAddress(province);
 }
}