使用MongoDB如何對(duì)Spring進(jìn)行整合

本篇文章給大家分享的是有關(guān)使用MongoDB如何對(duì)Spring進(jìn)行整合，小編覺(jué)得挺實(shí)用的，因此分享給大家學(xué)習(xí)，希望大家閱讀完這篇文章后可以有所收獲，話不多說(shuō)，跟著小編一起來(lái)看看吧。

添加依賴

<dependency>
   <groupId>org.springframework.data</groupId>
   <artifactId>spring-data-mongodb</artifactId>
   <version>1.10.3.RELEASE</version>
</dependency>

其余Spring相關(guān)的忽略

Spring的配置applicationContext-mongo.xml

<?xml version="1.0" encoding="UTF-8"?>
<beans xmlns="http://www.springframework.org/schema/beans"
    xmlns:util="http://www.springframework.org/schema/util"
    xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
    xmlns:context="http://www.springframework.org/schema/context"
    xmlns:mongo="http://www.springframework.org/schema/data/mongo"
    xsi:schemaLocation="
    http://www.springframework.org/schema/util http://www.springframework.org/schema/util/spring-util.xsd
  http://www.springframework.org/schema/beans http://www.springframework.org/schema/beans/spring-beans.xsd
  http://www.springframework.org/schema/context http://www.springframework.org/schema/context/spring-context.xsd
  http://www.springframework.org/schema/data/mongo http://www.springframework.org/schema/data/mongo/spring-mongo.xsd">
  <context:property-placeholder
      ignore-unresolvable="true" location="classpath:/mongodb.properties"/>

  <mongo:mongo-client id="mongoClient" host="${mongo.host}" port="${mongo.port}">
    <!-- credentials="${mongo.user}:${mongo.pwd}@${mongo.defaultDbName}"-->
  </mongo:mongo-client>

  <mongo:db-factory id="mongoDbFactory"
           dbname="${mongo.database}"
           mongo-ref="mongoClient"/>
  <!-- 默認(rèn)Mongodb類型映射 -->
  <bean id="defaultMongoTypeMapper" class="org.springframework.data.mongodb.core.convert.DefaultMongoTypeMapper">
    <constructor-arg name="typeKey">
      <!-- 這里設(shè)置為空,可以把 spring data mongodb 多余保存的_class字段去掉 -->
      <null/>
    </constructor-arg>
  </bean>

  <mongo:repositories base-package="com.critc.mongo"/>
  <!-- 自動(dòng)掃描以下包的有Doucment注解的類 -->
  <mongo:mapping-converter id="mappingConverter" base-package="com.critc.mongo.model"
               type-mapper-ref="defaultMongoTypeMapper">
  </mongo:mapping-converter>

  <!-- Mongodb的模板 -->
  <bean id="mongoTemplate" class="org.springframework.data.mongodb.core.MongoTemplate">
    <constructor-arg name="mongoDbFactory" ref="mongoDbFactory"/>
    <constructor-arg name="mongoConverter" ref="mappingConverter"/>
  </bean>
</beans>

mongo:mongo-client是定義MongoDB的客戶端連接，需要host和port參數(shù)，如果需要賬號(hào)密碼的話，需要增加credentials配置

mongo:db-factory配置連接工廠，指定具體的連接數(shù)據(jù)庫(kù)，本例默認(rèn)為test

defaultMongoTypeMapper默認(rèn)Mongodb類型映射

mongo:mapping-converterMongoDB的實(shí)體映射

mongoTemplate這是最主要的，定義模板類，依賴連接工廠和實(shí)體映射

這里舉一個(gè)article的增刪改查的例子。

相關(guān)實(shí)體Article.java

@Document(collection = "article_info")
public class Article {
  @Id
  private String id;//id
  @Field("title")
  private String title;//標(biāo)題
  @Field("url")
  private String url;//鏈接
  @Field("author")
  private String author;//作者
  @Field("tags")
  private List<String> tags;//tag 標(biāo)簽
  @Field("visit_count")
  private Long visitCount;//訪問(wèn)次數(shù)
  @Field("add_time")
  private Date addTime;//添加時(shí)間
// get set方法省略

@Document(collection = "article_info")這個(gè)注解和Hibernate的注解Entiry非常相似，就是定義一個(gè)文檔，對(duì)象MongoDB存儲(chǔ)的Collection的名稱是article_info

@Id指該字段是主鍵，不能缺少

@Field("add_time")指該字段映射MongoDB的實(shí)際字段，如果一致可以省略

ArticleRepository實(shí)際訪問(wèn)接口

@Repository("ArticleRepository")
public interface ArticleRepository extends PagingAndSortingRepository<Article, String> {

  //分頁(yè)查詢
  public Page<Article> findAll(Pageable pageable);


  //根據(jù)author查詢
  public List<Article> findByAuthor(String author);

  //根據(jù)作者和標(biāo)題查詢
  public List<Article> findByAuthorAndTitle(String author, String title);

  //忽略參數(shù)大小寫(xiě)
  public List<Article> findByAuthorIgnoreCase(String author);

  //忽略所有參數(shù)大小寫(xiě)
  public List<Article> findByAuthorAndTitleAllIgnoreCase(String author, String title);

  //排序
  public List<Article> findByAuthorOrderByVisitCountDesc(String author);
  public List<Article> findByAuthorOrderByVisitCountAsc(String author);

  //自帶排序條件
  public List<Article> findByAuthor(String author, Sort sort);

}

Spring的data repository封裝了一套增刪改查的方法，就和JPA實(shí)現(xiàn)的一樣，ArticleRepository繼承PagingAndSortingRepository，就集成了常用的增刪改查方法，比如save、findOne、exists、findAll、delete等等，可以采用默認(rèn)實(shí)現(xiàn)方式來(lái)完成常用的增刪改查操作。

測(cè)試上述各個(gè)方法ArticleRepositoryTest.java

@RunWith(SpringJUnit4ClassRunner.class)
@ContextConfiguration(locations = {"classpath*:applicationContext-mongo.xml"})
public class ArticleRepositoryTest {

  @Autowired
  private ArticleRepository articleRepository;

  /**
   * 新增記錄
   */
  @Test
  public void add() {
    //增加一條記錄
    Article article = new Article();
    article.setId("1");
    article.setTitle("MongoTemplate的基本使用");
    article.setAuthor("kcy");
    article.setUrl("http://jianshu.com/");
    article.setTags(Arrays.asList("java", "mongodb", "spring"));
    article.setVisitCount(0L);
    article.setAddTime(new Date());
    articleRepository.save(article);

    //批量添加
    List<Article> articles = new ArrayList<>(10);
    for (int i = 0; i < 10; i++) {
      Article article2 = new Article();
      article2.setId(String.valueOf(i + 1));
      article2.setTitle("MongoTemplate的基本使用");
      article2.setAuthor("kcy");
      article2.setUrl("http://jianshu.com" + i);
      article2.setTags(Arrays.asList("java", "mongodb", "spring"));
      article2.setVisitCount(0L);
      article2.setAddTime(new Date());
      articles.add(article2);
    }
    articleRepository.save(articles);
  }

  /**
   * 修改記錄，修改id為1的訪問(wèn)次數(shù)+1
   */
  @Test
  public void update() {
    Article article = articleRepository.findOne("1");
    article.setVisitCount(article.getVisitCount() + 1);
    articleRepository.save(article);
  }

  /**
   * 批量修改,查看author為kcy的統(tǒng)一修改為kcy2
   */
  @Test
  public void batchUpdate() {
    List<Article> articles = articleRepository.findByAuthor("kcy");
    articles.forEach(article -> {
      article.setAuthor("kcy2");
    });
    articleRepository.save(articles);
  }

  /**
   * 刪除記錄,刪除id為10的
   */
  @Test
  public void delete() {
    Article article = articleRepository.findOne("10");
    articleRepository.delete(article);
  }

  @Test
  public void batchDelete() {
    List<Article> articles = articleRepository.findByAuthor("kcy2");
    articleRepository.delete(articles);
  }

  /**
   * 查詢所有
   *
   * @author 孔垂云
   */
  @Test
  public void findAll() {
    Iterable<Article> articles = articleRepository.findAll();
    articles.forEach(article -> {
      System.out.println(article.toString());
    });
  }

  /**
   * 根據(jù)author查詢
   *
   * @author 孔垂云
   */
  @Test
  public void findByAuthor() {
    List<Article> articles = articleRepository.findByAuthor("kcy");
    articles.forEach(article -> {
      System.out.println(article.toString());
    });
  }

  /**
   * 按照author和title查詢
   *
   * @author 孔垂云
   */
  @Test
  public void findByAuthorAndTitle() {
    List<Article> articles = articleRepository.findByAuthorAndTitle("kcy", "MongoTemplate的基本使用");
    articles.forEach(article -> {
      System.out.println(article.toString());
    });
  }

  /**
   * 根據(jù)作者查詢，忽略大小寫(xiě)
   *
   * @author 孔垂云
   */
  @Test
  public void findByAuthorIgnoreCase() {
    List<Article> articles = articleRepository.findByAuthorIgnoreCase("JASON");
    articles.forEach(article -> {
      System.out.println(article.getId());
    });
  }

  /**
   * 忽略所有參數(shù)的大小寫(xiě)
   *
   * @author 孔垂云
   */
  @Test
  public void findByAuthorAndTitleAllIgnoreCase() {
    List<Article> articles = articleRepository.findByAuthorAndTitleAllIgnoreCase("KCY", "MONGOTEMPLATE的基本使用");
    articles.forEach(article -> {
      System.out.println(article.toString());
    });
  }

  /**
   * 根據(jù)author查詢，并且以訪問(wèn)次數(shù)降序排序顯示
   *
   * @author 孔垂云
   */
  @Test
  public void findByAuthorOrderByVisitCountDesc() {
    List<Article> articles = articleRepository.findByAuthorOrderByVisitCountDesc("kcy");
    articles.forEach(article -> {
      System.out.println(article.toString());
    });
  }


  /**
   * 根據(jù)作者查詢，并且以訪問(wèn)次數(shù)升序排序顯示
   *
   * @author 孔垂云
   */
  @Test
  public void findByAuthorOrderByVisitCountAsc() {
    List<Article> articles = articleRepository.findByAuthorOrderByVisitCountAsc("kcy");
    articles.forEach(article -> {
      System.out.println(article.toString());
    });
  }

  /**
   * 自帶排序條件
   *
   * @author 孔垂云
   */
  @Test
  public void findByAuthorBySort() {
    List<Article> articles = articleRepository.findByAuthor("kcy", new Sort(Direction.ASC, "VisitCount"));
    articles.forEach(article -> {
      System.out.println(article.toString());
    });
  }

  /**
   * 分頁(yè)查詢所有，并且排序
   */
  @Test
  public void findByPage() {
    int page = 1;
    int size = 2;
    Pageable pageable = new PageRequest(page, size, new Sort(Direction.ASC, "VisitCount"));
    Page<Article> pageInfo = articleRepository.findAll(pageable);
    //總數(shù)量
    System.out.println(pageInfo.getTotalElements());
    //總頁(yè)數(shù)
    System.out.println(pageInfo.getTotalPages());
    for (Article article : pageInfo.getContent()) {
      System.out.println(article.toString());
    }
  }
}

上面一段代碼較長(zhǎng)，基本上MongoDB常用的各種例子都講清楚了，比如增加、批量增加、修改、刪除、按id查找、按標(biāo)題查詢、分頁(yè)等等。

以上就是使用MongoDB如何對(duì)Spring進(jìn)行整合，小編相信有部分知識(shí)點(diǎn)可能是我們?nèi)粘９ぷ鲿?huì)見(jiàn)到或用到的。希望你能通過(guò)這篇文章學(xué)到更多知識(shí)。更多詳情敬請(qǐng)關(guān)注億速云行業(yè)資訊頻道。