Spring-data-mongodb初步使用

前几天调研了一下spring-data的使用。此处作一下使用的简单介绍：
在使用关系型数据库的传统Java web开发中，咱们一般使用以下层级结构：

Dao层主要完成OR-Mapping的功能，进行数据的存储。可是在咱们使用Mongo数据库以后，本来的层级就可能变成了以下：

由于咱们从mongo的数据为json格式，可使用fastjson与POJO进行相互转换。
这样层级设计，开发就能够能很快地完成，可是形成一些问题：

1. 业务逻辑代码和数据库操做代码耦合在一块儿，较为难以分离
2. 加大了单元测试的难度
3. 结构层次不清晰

如下是理由：

1. 上面1和3形成的缘由都是由于函数体变长，业务代码和数据库代码杂糅在一块儿形成的，出错时，须要对整个函数进行复验，确保函数的编写的正确性。编写UT时也会形成须要覆盖的路径（语句）增多，难度所以增长。
2. 结构层次不清晰，在分为Service和Dao层的状况下，逻辑层级更为清晰，业务层主作业务，Dao层主作数据库的CURD。

因此咱们可使用spring-data-mongo来完成dao层的编写。
如下代码都是测试经过的，主要注意几个点：

1. 代码只须要定义成这样既可，通常的查询均可以使用这些自动生成的代码来进行完成
2. 若是须要添加自定义的方法，在这边我使用的是JDK8的default关键字，直接将实现添加在了接口里面，实测可用
3. 启动时spring会操做字节码自动生成实现类，因此启动可能较慢，而且一旦有bug调试起来很麻烦（基本没法调试）。

接口定义示例：

public interface UserRepository extends MongoRepository<User, String> {
    //////////////////////Query/////////////////////
    // Do not recommend using @Query annotation like this
    @Query("{ 'firstname' : ?0, 'password': ?1 }")
    public User findByUsernameAndPassword(String username, String password);

    // find age larger than
    // there are others:
    public List<User> findByAgeGreaterThan(Integer age);
    public List<User> findByAgeLessThan(Integer age);
    public List<User> findByAgeBetween(Integer from, Integer to);
    public List<User> findBySexNot(String sex);
    public List<User> findBySexLike(String sex);
    public List<User> findBySexNotLike(String sex);
    public List<User> findByUsernameNull();
    public List<User> findByUsernameNotNull();

    // find by username
    public User findByUsername(String username);

    // find distinct users by username
    public List<User> findDistinctUserByUsername(String username);
    public List<User> findUserDistinctByUsername(String username);

    // find users by username and age
    public List<User> findByUsernameAndAge(String username, Integer age);

    // find users by username or age
    public List<User> findByUsernameOrAge(String username, Integer age);

    // find users by sex with ignoring cases
    public List<User> findBySexIgnoreCase(String sex, Pageable pageable);

    // find users by sex with order firstname ascending
    public List<User> findBySexOrderByUsernameAsc(String sex);

    // find users by sex with the order sort specfied
    public List<User> findBySex(String sex, Sort sort);

    // find users bys sex with pageable
    public List<User> findBySex(String sex, Pageable pageable);

    // find the first ten results by user sex
    public Slice<User> findTop10BySex(String sex, Sort sort);
    public Slice<User> findFirst10BySex(String sex, Sort sort);

    // other query like Stream Query and Async Query could be
    // found here http://docs.spring.io/spring-data/mongodb/docs/current/reference/html/#repositories.query-methods

    // define the method by ourself
    default User findByUsernameAndPasswordByOwn(String username, String password) {
        MongoOperations ops = DbUtil.getDbUtil().getMongoTemplate();
        User user = ops.findOne(query(where("username").is(username))
                .addCriteria(where("password").is(password)), User.class);
        return user;
    }

    default GroupByResults<User> findUserGroupBySex() {
        GroupByResults<User> results = DbUtil.getDbUtil().getMongoTemplate()
                .group("user", GroupBy.key("sex").initialDocument("{ count: 0 }")
                                .reduceFunction("function(doc, prev) { prev.count += 1 }"),
                User.class);
        return results;
    }

    //////////////////////Delete/////////////////////
    public void deleteByUsername(String username);
    public void removeByUsernameAndAge(String username, Integer age);

    /////////////////////update////////////////////////
    // normally, we use sper.update(), if the method can't meet your demand,
    // you can write the method yourself
    default void updateMultiByUsername(String username, Integer age) {
        MongoOperations ops = DbUtil.getDbUtil().getMongoTemplate();
        // update all the documents whose username atteribute is username
        // and the class need to be User
        ops.updateMulti(query(where("username").is(username)),
                Update.update("age", age), User.class);
    }

    //////////////////save///////////////
    // just use default save(). forget about the others.
}

使用例子：

@RestController
public class UserController {
    @Autowired
    UserRepository userRepository;

    @RequestMapping("/")
    public String sayHello(String name) {
        return "Hello, " + name;
    }

    @RequestMapping(value="/user", method = RequestMethod.POST)
    public String add(@RequestParam String companyId, @RequestBody User user) {
        user = userRepository.save(user);
        return user.getId();
    }

    @RequestMapping(value = "/user/username", method = RequestMethod.GET)
    public User getUserByUserName(@RequestParam String companyId, @RequestParam String username,
                                  @RequestParam String password) {
        User user;

        user = userRepository.findByUsernameAndPassword(username, password);
        return user;
    }

    @RequestMapping(value="/user/group/sex", method = RequestMethod.GET)
    public GroupByResults<User> groupUserBySex() {
        return userRepository.findUserGroupBySex();
    }
}