Spring+Mongo混合自定义CRUD功能

谁践踏了优雅 2022-06-15 21:13 175阅读 0赞

配置请参考上一篇移至[Spring注解配置Mongo][Spring_Mongo]，Mongo的DAO接口方法定义分为3种：自定义（查询）操作、指定（查询）操作、混合自定义功能操作

1、自定义方法的方法名及是根据CRUD操作及查询参数、查询数据库字段名设置的

例：(1)根据顾客名参数（对应字段customer）查询order集合方法名-----findByCustomer(String name)/getByCustomer(String name)/readByCustomer(String name)

(2)根据顾客名模糊查询:findByCustomerLike(String n)

(3)、根据类型字段type和顾客名模糊查询：findByCustomerLikeAndTypeLike(String name,String type)

查询方法名以find、read、get为前缀均可，条件查询时需加上By，参数顺序与方法名字段名顺序一一对应，如3的参数name对应字段customer,type对应Type,这是Spring-Data的一个特性，Repository方法由一个动词、一个可选的主题、关键词By及一个断言所组成

其它CRUD操作同理，如根据客户名删除：deleteByCustomer(String name);

2、指定操作

指定操作方法名不受限制，但需在@Query补充完整操作

例：(1)根据类型查询：

@Query(value="\{ 'type',?0\}")

List<Order> customSelect(String type);  //?0对应第一个参数位

那要是模糊查询呢？Mongo的数据都为json格式，所以模糊查询时的参数肯定不是%param%的格式，而是正则表达式形式，即/???/形式，JDK1.8中有一个Pattern类可以为我们创建正则表达式，创建时调用该类的compile静态方法进行创建，所以此时我们传参就不再是字符串，而是正则表达式，如：

(2)根据类型模糊查询：

@Query(value="\{ 'type',?0\}")

List<Order> customSelect(Pattern pattern);

（3）根据类型删除

@Query(value = "\{'type':?0\}",delete = true)  
 int customDelete(String type);

@Query中还含有exists根据条件判断数据是否存在，count进行数据统计

3、混合自定义功能

自定义的方法混合到自动生成的Repository中时，还需要涉及到创建一个中间接口来声明自定义的方法。

在上一篇中，OrderRepository只继承了MongoRepository接口，若想添加自定义方法，则需再继承一个自定义的接口，同时也要再编写一个实现类实现该自定义接口。如我想定义额外的Order操作方法，于是新建了一个OrderDAO接口，并使OrderRepository接口继承OrderDAO接口，再新建一个实现类OrderRepositoryImpl实现OrderDAO接口，实现类的命名须已pojo类名+Repository+Impl命名，后缀impl可修改，只需在配置类中的@EnableMongoRespositories中添加repositoryImplementationPostfix='xxx'即可设置后缀。

代码附录（POJO类与上篇相同）：

OrderDAO.java:

package per.nosql.dao;
    
    import per.nosql.pojo.Order;
    
    import java.util.List;
    
    /** * Created by Wilson on 2017/5/5. */ public interface OrderDAO {
        List<Order> findByParam();
    }

OrderRespositoryImpl.java:

package per.nosql.dao.impl;
    
    import org.springframework.beans.factory.annotation.Autowired;
    import org.springframework.data.mongodb.core.MongoOperations;
    import org.springframework.data.mongodb.core.query.Criteria;
    import org.springframework.data.mongodb.core.query.Query;
    import per.nosql.dao.OrderDAO;
    import per.nosql.pojo.Order;
    
    import java.util.List;
    
    /** * Created by Wilson on 2017/5/5. */ public class OrderRepositoryImpl implements OrderDAO {
        @Autowired
        private MongoOperations operations; //MongoTemplate的父接口
    
        @Override
        public List<Order> findByParam() {
            Criteria criteria = Criteria.where("type").is("1").and("customer").regex("tom");
            return operations.find(Query.query(criteria), Order.class);
        }
    }

OrderRepository.java:

package per.nosql.dao;
    
    import org.springframework.data.mongodb.repository.MongoRepository;
    import org.springframework.data.mongodb.repository.Query;
    import per.nosql.pojo.Order;
    
    import java.util.List;
    import java.util.regex.Pattern;
    
    /** * Created by Wilson on 2017/5/5. */ public interface OrderRepository extends MongoRepository<Order, String>, OrderDAO {
        /*自定义查询方法*/
        @Query("{'type' : '1'},{'customer': ?1}")
        List<Order> findByTypeAndName(String type, String name);
    
        List<Order> readByType(String type);
    
        List<Order> getByCustomerLikeAndType(String name,String type);
    
        int countByCustomerLike(String name);
    
        List<Order> findByTypeAndCustomer(String type, String customer);
    
        int deleteByCustomer(String customer);
    
        @Query(value = "{'type':?0}")
        List<Order> customSelect(Pattern pattern);
    
        @Query(value = "{'type':?0}",delete = true)
        int customDelete(String type);
    }

测试类MongoTest.java:

package per.nosql.test;
    
    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 per.nosql.config.MongoConfig;
    import per.nosql.dao.OrderRepository;
    import per.nosql.pojo.Order;
    
    import java.util.List;
    import java.util.regex.Pattern;
    
    /** * Created by Wilson on 2017/5/5. */ @RunWith(SpringJUnit4ClassRunner.class)
    @ContextConfiguration(classes = MongoConfig.class)
    public class MongoTest {
        @Autowired
        OrderRepository orderRepository;
    
        @Test
        public void addOrder() {
            orderRepository.save(new Order(null, "Wilson", "22", null
                    /*Arrays.asList( new Item(null, null, "面条", 13, 5))*/));
            findAllOrders();
        }
    
        @Test
        public void findByType() {
            System.out.println("----------------------------------------findByType-------------------------------------------");
            listToString(orderRepository.readByType("2"));
        }
    
        @Test
        public void findByTypeAndName() {
            findAllOrders();
            System.out.println("------------------------------------findByTypeAndName----------------------------------------------");
            listToString(orderRepository.findByTypeAndName("2", "Wilson"));
        }
    
        @Test
        public void getByCustomerLikeAndType() {
            findAllOrders();
            System.out.println("------------------------------------getByCustomerLikeAndType----------------------------------------------");
            listToString(orderRepository.getByCustomerLikeAndType("ls", "2"));
        }
    
        @Test
        public void countAll() {
            System.out.println("------------------------------------count----------------------------------------------");
            System.out.println("db记录数：" + orderRepository.count());
        }
    
        @Test
        public void countByNameLike() {
            findAllOrders();
            System.out.println("------------------------------------countByNameLike----------------------------------------------");
            System.out.println("name like num:" + orderRepository.countByCustomerLike("il"));
        }
    
        @Test
        public void findAllOrders() {
            System.out.println("------------------------------------findAll----------------------------------------------");
            listToString(orderRepository.findAll());
        }
    
        @Test
        public void findByParam() {
            findAllOrders();
            System.out.println("------------------------------------findByParam----------------------------------------------");
            listToString(orderRepository.findByParam());
        }
    
        @Test
        public void findByTypeAndCustomer() {
            findAllOrders();
            System.out.println("------------------------------------findByTypeAndCustomer----------------------------------------------");
            listToString(orderRepository.findByTypeAndCustomer("2", "il"));
        }
    
        @Test
        public void deleteById() {
            orderRepository.delete("590c4f39b81fcf661ee40e13");
            findAllOrders();
        }
    
        @Test
        public void deleteByCustomer() {
            findAllOrders();
            System.out.println("删除数目：" + orderRepository.deleteByCustomer("Wilson"));
            findAllOrders();
        }
    
        @Test
        public void customSelect() {
            findAllOrders();
            System.out.println("------------------------------------customSelect----------------------------------------------");
            listToString(orderRepository.customSelect(Pattern.compile("2")));
        }
    
        @Test
        public void customDelete() {
            findAllOrders();
            System.out.println("------------------------------------customDelete----------------------------------------------");
            System.out.println("自定义删除数：" + orderRepository.customDelete("22"));
            findAllOrders();
        }
    
        private void listToString(List<Order> orderList) {
            StringBuffer buffer = new StringBuffer();
            orderList.forEach(each -> buffer.append(each).append("\n"));
            System.out.println(buffer.toString());
        }
    
    }

自定义查询方法getByCustomerLikeAndType(String name,String type)测试结果：

![Center][]

混合自定义功能方法findByParam()测试结果：![Center 1][]

指定操作删除方法customDelete(String type)测试结果：

![Center 2][]

[Spring_Mongo]: http://blog.csdn.net/z28126308/article/details/71216143
[Center]: /images/20220616/f33589ea91aa462d9bd21574cf99e7e1.png
[Center 1]: /images/20220616/cd2b40535d2f477ababebf1e08c8f6b3.png
[Center 2]: /images/20220616/9ce40f74010c4ed8aa6b533ae1c1d114.png