<?xml version="1.0" encoding="UTF-8" ?>

 <beans xmlns="http://www.springframework.org/schema/beans"

        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/context http://www.springframework.org/schema/context/spring-context-3.0.xsd

     http://www.springframework.org/schema/beans http://www.springframework.org/schema/beans/spring-beans-3.0.xsd

     http://www.springframework.org/schema/data/mongo http://www.springframework.org/schema/data/mongo/spring-mongo.xsd">

     <!--1.开启注解-->

     <context:annotation-config/>

     <!--2.自动扫描-->

     <context:component-scan base-package="com.mongodb"/>

     <!--3.服务器连接信息-->

     <mongo:mongo host="localhost" port="27017"/>

     <!--4.创建mongoTemplate模板-->

     <bean id="mongoTemplate" class="org.springframework.data.mongodb.core.MongoTemplate">

         <constructor-arg ref="mongo"/>

         <!-- 设置使用的数据库 名-->

         <constructor-arg name="databaseName" value="station"/>

     </bean>

 </beans>

 package com.mongodb.pojo;

 /**

  * @author zt1994 2018/3/12 10:43

  */

 public class Product {

     private String id;

     private String productName;

     private Integer productNum;

     public String getId() {

         return id;

     }

     public void setId(String id) {

         this.id = id;

     }

     public String getProductName() {

         return productName;

     }

     public void setProductName(String productName) {

         this.productName = productName;

     }

     public Integer getProductNum() {

         return productNum;

     }

     public void setProductNum(Integer productNum) {

         this.productNum = productNum;

     }

     @Override

     public String toString() {

         return "Product{" +

                 "id='" + id + '\'' +

                 ", productName='" + productName + '\'' +

                 ", productNum=" + productNum +

                 '}';

     }

 }

 package com.mongodb.dao;

 import com.mongodb.pojo.Product;

 import java.util.List;

 /**

  * @author zt1994 2018/3/12 10:45

  */

 public interface IProductDao {

     /**

      * 添加产品

      * @param product

      */

     void addProduct(Product product);

     /**

      * 删除产品

      * @param id

      */

     void removeProduct(String id);

     /**

      * 保存或修改产品

      * @param product

      */

     void saveOrUpdateProduct(Product product);

     /**

      * 查询单个产品

      * @param id

      * @return

      */

     Product findById(String id);

     /**

      * 查询所有产品

      * @return

      */

     List<Product> findAll();

 }

 package com.mongodb.dao.impl;

 import com.mongodb.dao.IProductDao;

 import com.mongodb.pojo.Product;

 import org.springframework.beans.factory.annotation.Autowired;

 import org.springframework.data.mongodb.core.MongoTemplate;

 import org.springframework.stereotype.Repository;

 import java.util.List;

 /**

  * @author zt1994 2018/3/12 10:46

  */

 @Repository

 public class ProductDaoImpl implements IProductDao {

     @Autowired

     private MongoTemplate mongoTemplate;

     public void addProduct(Product product) {

         //1.如果没有指定集合，则默认添加到和对象名称相同的集合中，没有则创建一个

         //2.也可以指定集合 mongoTemplate.save(product, "product_db");

         mongoTemplate.save(product);

     }

     public void removeProduct(String id) {

         Product product = findById(id);

         mongoTemplate.remove(product);

     }

     public void saveOrUpdateProduct(Product product) {

         mongoTemplate.save(product);

     }

     public Product findById(String id) {

         return mongoTemplate.findById(id, Product.class);

     }

     public List<Product> findAll() {

         return mongoTemplate.findAll(Product.class);

     }

 }

 package com.mongodb.test;

 import com.mongodb.dao.IProductDao;

 import com.mongodb.pojo.Product;

 import org.junit.Test;

 import org.junit.runner.RunWith;

 import org.springframework.beans.factory.annotation.Autowired;

 import org.springframework.test.context.ContextConfiguration;

 import org.springframework.test.context.junit4.SpringJUnit4ClassRunner;

 import java.util.List;

 /**

  * @author zt1994 2018/3/12 10:52

  */

 @RunWith(SpringJUnit4ClassRunner.class)

 @ContextConfiguration("classpath:spring-config.xml")

 public class TestProductDao {

     @Autowired

     private IProductDao productDao;

     /**

      * 测试添加产品

      */

     @Test

     public void testAddProduct(){

         Product product = new Product();

         product.setProductName("测试新增");

         product.setProductNum(3);

         productDao.addProduct(product);

     }

     /**

      * 测试查找所有产品

      */

     @Test

     public void testFindAll(){

         List<Product> productList = productDao.findAll();

         for (Product product : productList) {

             System.out.println(product);

         }

     }

     /**

      * 测试通过id查找产品

      */

     @Test

     public void testFindId(){

         Product product = productDao.findById("5aa5f3d9b735172bc3a617c1");

         System.out.println(product);

     }

     /**

      * 测试更新产品

      */

     @Test

     public void testUpdateProduct(){

         Product product = productDao.findById("5aa5f3d9b735172bc3a617c1");

         System.out.println(product);

         product.setProductName("测试修改");

         product.setProductNum(5);

         this.productDao.saveOrUpdateProduct(product);

         Product product2 = productDao.findById("5aa5f3d9b735172bc3a617c1");

         System.out.println(product2);

     }

 }