资讯专栏INFORMATION COLUMN

当MongoDB遇上Spring

Lorry_Lu / 480人阅读

摘要:每个条件必须引用一个属性,并且还可以指定一种比较操作。如果省略比较操作符的话,那么这暗指是一种相等比较操作。

Spring-data对MongoDB进行了很好的支持,接下来就讲解一下关于Spring对MongoDB的配置和一些正常的使用

我下面的工程使用的是Spring的Java配置的方式和Maven构建

具体的工程代码大家可以访问我的Github地址:https://github.com/zoeminghong/springmvc-javaconfig

①MongoDB的必要配置

</>复制代码

  1. package springmvc.rootconfig;
  2. import org.springframework.context.annotation.Bean;
  3. import org.springframework.context.annotation.Configuration;
  4. import org.springframework.data.mongodb.core.MongoClientFactoryBean;
  5. import org.springframework.data.mongodb.core.MongoOperations;
  6. import org.springframework.data.mongodb.core.MongoTemplate;
  7. import org.springframework.data.mongodb.repository.config.EnableMongoRepositories;
  8. import com.mongodb.Mongo;
  9. @Configuration
  10. // 启用MongoDB的Repository功能,会对其Repositories自动扫描
  11. @EnableMongoRepositories(basePackages = "springmvc.orders.db")
  12. public class MongoConfig {
  13. // MongoClient配置
  14. @Bean
  15. public MongoClientFactoryBean mongo() {
  16. MongoClientFactoryBean mongo = new MongoClientFactoryBean();
  17. mongo.setHost("localhost");
  18. //MongoCredential credential=MongoCredential.createCredential(env.getProperty("mongo.username"), "OrdersDB",env.getProperty("mongo.password").toCharArray());
  19. // mongo.setCredentials(new MongoCredential[]{credential});
  20. //还可以对端口进行配置
  21. return mongo;
  22. }
  23. // Mongo Template配置
  24. @Bean
  25. public MongoOperations mongoTemplate(Mongo mongo) {
  26. //OrdersDB就是Mongo的数据库
  27. return new MongoTemplate(mongo, "OrdersDB");
  28. }
  29. }

为了访问数据库的时候,我们可能还需要帐号密码

</>复制代码

  1. MongoCredential credential=MongoCredential.createCredential(env.getProperty("mongo.username"), "OrdersDB",env.getProperty("mongo.password").toCharArray());
  2. mongo.setCredentials(new MongoCredential[]{credential});
②为模型添加注解

</>复制代码

  1. package springmvc.bean;
  2. import java.util.Collection;
  3. import java.util.LinkedHashSet;
  4. import org.springframework.data.annotation.Id;
  5. import org.springframework.data.mongodb.core.mapping.Document;
  6. import org.springframework.data.mongodb.core.mapping.Field;
  7. //这是文档
  8. @Document
  9. public class Order {
  10. //指定ID
  11. @Id
  12. private String id;
  13. //为域重命名
  14. @Field("client")
  15. private String customer;
  16. private String type;
  17. private Collection items=new LinkedHashSet();
  18. public String getId() {
  19. return id;
  20. }
  21. public void setId(String id) {
  22. this.id = id;
  23. }
  24. public String getCustomer() {
  25. return customer;
  26. }
  27. public void setCustomer(String customer) {
  28. this.customer = customer;
  29. }
  30. public String getType() {
  31. return type;
  32. }
  33. public void setType(String type) {
  34. this.type = type;
  35. }
  36. public Collection getItems() {
  37. return items;
  38. }
  39. public void setItems(Collection items) {
  40. this.items = items;
  41. }
  42. }

</>复制代码

  1. package springmvc.bean;
  2. public class Item {
  3. private Long id;
  4. private Order order;
  5. private String product;
  6. private double price;
  7. private int quantity;
  8. public Long getId() {
  9. return id;
  10. }
  11. public void setId(Long id) {
  12. this.id = id;
  13. }
  14. public Order getOrder() {
  15. return order;
  16. }
  17. public void setOrder(Order order) {
  18. this.order = order;
  19. }
  20. public String getProduct() {
  21. return product;
  22. }
  23. public void setProduct(String product) {
  24. this.product = product;
  25. }
  26. public double getPrice() {
  27. return price;
  28. }
  29. public void setPrice(double price) {
  30. this.price = price;
  31. }
  32. public int getQuantity() {
  33. return quantity;
  34. }
  35. public void setQuantity(int quantity) {
  36. this.quantity = quantity;
  37. }
  38. }
注解 描述
@Document 标示映射到mongoDB文档上的领域对象
@ID 标示某个为ID域
@DbRef 标示某个域要引用其他的文档,这个文档有可能位于另外一个数据库中
@Field 为文档域指定自定义的元数据
@Version 标示某个属性用作版本域

</>复制代码

  1. 若不使用@Field注解,域名就与Java属性相同

  2. 上面之所以ItemJava类为什么没有@Document注解,是因为我们不会多带带想Item持久化为文档

③使用MongoTemplate访问MongoDB

</>复制代码

  1. package springmvc.web;
  2. import java.util.List;
  3. import org.springframework.beans.factory.annotation.Autowired;
  4. import org.springframework.data.mongodb.core.MongoOperations;
  5. import org.springframework.stereotype.Controller;
  6. import org.springframework.web.bind.annotation.RequestMapping;
  7. import org.springframework.web.bind.annotation.RequestMethod;
  8. import springmvc.bean.Order;
  9. import springmvc.orders.db.OrderRepository;
  10. @Controller
  11. public class HomeController {
  12. @Autowired
  13. MongoOperations mongo;
  14. @RequestMapping(value = { "/", "index" }, method = RequestMethod.GET)
  15. public String index() {
  16. long orderCount=mongo.getCollection("order").count();
  17. System.out.println(orderCount);
  18. // Order order = new Order();
  19. // order.setId("1");
  20. // order.setCustomer("gg");
  21. // order.setType("2");
  22. //第二个参数是文档存储的名称
  23. // mongo.save(order,"order");
  24. // String orderId="1";
  25. // Order order=mongo.findById(orderId, Order.class);
  26. // System.out.println(order.getCustomer());
  27. return "index";
  28. }
  29. }

</>复制代码

  1. 在这里我们将MongoTemplate注入到一个类型为MongoOperations的属性中。MongoOperations是MongoTemplate所实现的接口,MongoOperations中存在很多文档操作方法

  2. MongoOperations其实已经能满足很多需求了

如果还没有满足你的需求,接下来我就介绍一下,如何编写MongoDB Repository

编写MongoDB Repository

</>复制代码

  1. package springmvc.orders.db;
  2. import java.util.List;
  3. import org.springframework.data.mongodb.repository.MongoRepository;
  4. import springmvc.bean.Order;
  5. public interface OrderRepository extends MongoRepository {
  6. List findByCustomer(String c);
  7. List findByCustomerLike(String c);
  8. List findByCustomerAndType(String c, String t);
  9. List findByCustomerLikeAndType(String c, String t);
  10. }

</>复制代码

  1. 看到这里,大家有没有发现package的地址就是我们刚才@EnableMongoRepositories(basePackages = "springmvc.orders.db")的配置

  2. MongoRepository接口有两个参数,第一个是带有@Document注解的对象类型,也就是该Repository要处理的类型。第二个参数是带有@Id注解的属性类型

OrderRepository继承了MongoRepository中很多自带的方法

方法 描述
long count() 返回指定Repository类型的文档数量
void delete(Iterable) 删除与指定对象关联的所有文档
void delete(T) 删除与指定对象关联的文档
void delete(ID) 根据ID删除某一个文档
void deleteAll(); 删除指定Repository类型的所有文档
boolean exists(Object) 如果存在与指定对象相关联的文档,则返回true
boolean exists(ID) 如果存在与指定对象相关联的文档,则返回true
ListfindAll() 返回指定Repository类型的所有文档
ListfindAll(Iterable) 返回指定文档ID对应的所有文档
ListfindAll(Pageable) 为指定Repository类型,返回分页且排序的文档列表
ListfindAll(Sort) 为指定Repository类型,返回排序后的所有文档列表
T findOne(ID) 为指定的ID返回单个文档
Save(terable) 保存指定Iterable中的所有文档
save() 为给定的对象保存一条文档

上面的我们定义的四个方法都是我们自定义的方法,其方法名存在很多意义,不能随便定义

</>复制代码

  1. List findByCustomer(String c);

find为查询动词,还可以是read、get、count等

Customer为断言,判断其行为

在断言中,会有一个或多个限制结果的条件。每个条件必须引用一个属性,并且还可以指定一种比较操作。如果省略比较操作符的话,那么这暗指是一种相等比较操作。不过,我们也可以选择其他的比较操作

类型
IsAfter、After、IsGreaterThan、GreaterThan
IsGreaterThanEqual、GreaterThanEqual
IsBefore、Before、IsLessThan、LessThan
IsLessThanEqual、LessThanEqual
IsBetween、Between
IsNull、Null
IsNotNull、NotNull
IsIn、In
IsNotIn、NotIn
IsStartingWith、StartingWith、StartsWith
IsEndingWith、EndingWith、EndsWith
IsContaining、Containing、Contains
IsLike、Like
IsNotLike、NotLike
IsTure、True
IsFalse、False
Is、Equals
IsNot、Not

other

类型
IgnoringCase、IgnoresCase、OrderBy、And、Or
指定查询

</>复制代码

  1. @Query("{"customer":"Chuck Wagon","type":?0}")
  2. List findChucksOrders(String t);

</>复制代码

  1. @Query中给定的JSON将会与所有的Order文档进行匹配,并返回匹配的文档,这里的type属性映射成“?0”,这表明type属性应该与查询方法的第0个参数相等,如果有多个参数,则"?1".....

混合自定义的功能

</>复制代码

  1. package springmvc.orders.db;
  2. import java.util.List;
  3. import springmvc.bean.Order;
  4. public interface OrderOperations {
  5. List findOrdersByType(String t);
  6. }

</>复制代码

  1. package springmvc.orders.db;
  2. import java.util.List;
  3. import org.springframework.beans.factory.annotation.Autowired;
  4. import org.springframework.data.mongodb.core.MongoOperations;
  5. import org.springframework.data.mongodb.core.query.Criteria;
  6. import org.springframework.data.mongodb.core.query.Query;
  7. import springmvc.bean.Order;
  8. public class OrderRepositoryImpl implements OrderOperations {
  9. @Autowired
  10. private MongoOperations mongo;
  11. //将混合实现注入MongoOperations
  12. @Override
  13. public List findOrdersByType(String t) {
  14. String type =t.equals("Net")?"2":t;
  15. Criteria where=Criteria.where("type").is(type);
  16. Query query=Query.query(where);
  17. return mongo.find(query, Order.class);
  18. }
  19. }

</>复制代码

  1. package springmvc.orders.db;
  2. import java.util.List;
  3. import org.springframework.data.mongodb.repository.MongoRepository;
  4. import org.springframework.data.mongodb.repository.Query;
  5. import springmvc.bean.Order;
  6. //继承OrderOperations接口
  7. public interface OrderRepository extends MongoRepository,OrderOperations {
  8. List findByCustomer(String c);
  9. List findByCustomerLike(String c);
  10. List findByCustomerAndType(String c, String t);
  11. List findByCustomerLikeAndType(String c, String t);
  12. @Query("{"customer":"Chuck Wagon","type":?0}")
  13. List findChucksOrders(String t);
  14. }

</>复制代码

  1. package springmvc.web;
  2. import java.util.List;
  3. import org.springframework.beans.factory.annotation.Autowired;
  4. import org.springframework.data.mongodb.core.MongoOperations;
  5. import org.springframework.stereotype.Controller;
  6. import org.springframework.web.bind.annotation.RequestMapping;
  7. import org.springframework.web.bind.annotation.RequestMethod;
  8. import springmvc.bean.Order;
  9. import springmvc.orders.db.OrderRepository;
  10. @Controller
  11. public class HomeController {
  12. @Autowired
  13. MongoOperations mongo;
  14. @Autowired
  15. OrderRepository orderRepository;
  16. @RequestMapping(value = { "/", "index" }, method = RequestMethod.GET)
  17. public String index() {
  18. List list=orderRepository.findOrdersByType("2");
  19. System.out.println(list.size());
  20. return "index";
  21. }
  22. }

</>复制代码

  1. 以上这些关联起来的关键点是OrderRepositoryImpl,这个名字前半部分与OrderRepository相同,只是添加了一个“Impl”后缀。如果想更改该后缀,可以在MongoConfig类中更改为自己理想的后缀

</>复制代码

  1. @EnableMongoRepositories(basePackages = "springmvc.orders.db",repositoryImplementationPostfix="Stuff")

更多内容可以关注微信公众号,或者访问AppZone网站

文章版权归作者所有,未经允许请勿转载,若此文章存在违规行为,您可以联系管理员删除。

转载请注明本文地址:https://www.ucloud.cn/yun/64888.html

相关文章

  • MongoDB遇上Spring

    摘要:每个条件必须引用一个属性,并且还可以指定一种比较操作。如果省略比较操作符的话,那么这暗指是一种相等比较操作。 Spring-data对MongoDB进行了很好的支持,接下来就讲解一下关于Spring对MongoDB的配置和一些正常的使用 我下面的工程使用的是Spring的Java配置的方式和Maven构建 具体的工程代码大家可以访问我的Github地址:https://github.c...

    fai1017 评论0 收藏0
  • 用户管理系统遇上python和mongodb后……

    摘要:安装基本是一路下一步,需要注意的地方小胖网上找了几张图来说明。这里可以自定选择需要安装的东西小胖选择完全安装,随便你们选择安装路径但是需要注意不要选择一个叫的东西,否则可能要很长时间都一直在执行安装,是一个图形界面管理工具。 Overview: 环境 前言 效果图 mongdb安装 代码涉及知识点 关于windows的cmd下执行python文件显示中文乱码的问题 总结 0.环境 ...

    keithyau 评论0 收藏0
  • 后端好书阅读与推荐(续二)

    摘要:后端好书阅读与推荐系列文章后端好书阅读与推荐后端好书阅读与推荐续后端好书阅读与推荐续二几个月又过去了,又读了几本书,同时为了深切体会到某些书里面的要点还专门做了一个小项目,这里就把读书与小项目过程中的一些心得体会记录一下。 后端好书阅读与推荐系列文章:后端好书阅读与推荐后端好书阅读与推荐(续)后端好书阅读与推荐(续二) 几个月又过去了,又读了几本书,同时为了深切体会到某些书里面的要点还...

    Jioby 评论0 收藏0
  • 后端好书阅读与推荐(续二)

    摘要:后端好书阅读与推荐系列文章后端好书阅读与推荐后端好书阅读与推荐续后端好书阅读与推荐续二几个月又过去了,又读了几本书,同时为了深切体会到某些书里面的要点还专门做了一个小项目,这里就把读书与小项目过程中的一些心得体会记录一下。 后端好书阅读与推荐系列文章:后端好书阅读与推荐后端好书阅读与推荐(续)后端好书阅读与推荐(续二) 几个月又过去了,又读了几本书,同时为了深切体会到某些书里面的要点还...

    CompileYouth 评论0 收藏0

发表评论

0条评论

最新活动
阅读需要支付1元查看
<