Mongodb client operation (mongorepository)

Official documents

orm

jpa

MongoRepository

springboot Integrate

1. rely on

 <dependency>
     <groupId>org.springframework.boot</groupId>
     <artifactId>spring-boot-starter-data-mongodb</artifactId>
 </dependency>

2. springboot Scan the annotation

@EnableMongoRepositories(
    basePackages = {"com.jl.ability.*"},
    repositoryImplementationPostfix = "Impl")
repositoryImplementationPostfix  The default is  Impl  suffix , You can specify the suffix of the implementation class of the user-defined warehouse layer interface 
 Such as mongodb Its CustomizedUserRepository Specify the implementation class customizedUserRepositoryImpl

3. Define interfaces, user-defined interfaces and implementation classes

interface CustomizedUserRepository {
  void someCustomMethod(User user);
}
class CustomizedUserRepositoryImpl implements CustomizedUserRepository {
  public void someCustomMethod(User user) {
    // Your custom implementation
  }
}
@Repository
interface UserRepository extends CrudRepository<User, Long>, CustomizedUserRepository {
  // Declare query methods here
}

curd Basic operation

Entity class

@Data
@Document(collection = "balloon_msg")
public class BalloonMsg {
    @Id
    private Long id;
    private String sid;
    private String body;
    private Long from;
    private int sex;
    private Date ctime;
    private String accid;
    private Integer revNum;
    private Integer replyNum;
}

Interface

@Repository
public interface BalloonMsgMapper extends MongoRepository<BalloonMsg, Long>, CustomizedBalloonMsgMapper {

    List<BalloonMsg> findByFromOrderByIdDesc(Long from, Pageable pageable);

    @Query(value="{'$and': [{'from':?0}, {'sid':?1}]}", fields="{'_id': 1}")
    List<BalloonMsg> findIdsByFromAndSid(Long from, String sid);
}
 Be careful ：
MongoRepository<BalloonMsg, Long>
BalloonMsg Mapping entity classes for collections ,Long Primary key id type 

Basic operation

 Support  save,insert,find,delete

Query extensions support native query statements

     similar sql：select id from xxx where `from` = from and sid = sid
    @Query(value="{'$and': [{'from':?0}, {'sid':?1}]}", fields="{'_id': 1}")
    List<BalloonMsg> findIdsByFromAndSid(Long from, String sid);

Support jpa Specification method

     similar sql：select * from balloon_msg where `from` = from order by id desc limit x, x
    List<BalloonMsg> findByFromOrderByIdDesc(Long from, Pageable pageable);

Custom extension

public interface CustomizedBalloonMsgMapper {
    int incRevNumById(long id, int num);

    int incReplyNumById(long id, int num);
}

public class CustomizedBalloonMsgMapperImpl implements CustomizedBalloonMsgMapper {

    @Resource
    private MongoTemplate mongoTemplate;

    @Override
    public int incRevNumById(long id, int num) {
        Query query = Query.query(Criteria.where("_id").is(id));
        Update update = new Update();
        update.inc("revNum");
        UpdateResult res = mongoTemplate.updateFirst(query, update, BalloonMsg.class);
        return (int) res.getModifiedCount();
    }

    @Override
    public int incReplyNumById(long id, int num) {
        Query query = Query.query(Criteria.where("_id").is(id));
        Update update = new Update();
        update.inc("replyNum");
        return (int) mongoTemplate.updateFirst(query, update, BalloonMsg.class).getModifiedCount();
    }
}

At this time BalloonMsgMapper The interface contains basic curd And custom extended method sets

@Repository
public interface BalloonMsgMapper extends MongoRepository<BalloonMsg, Long>, CustomizedBalloonMsgMapper{
...
}

Be careful ：

1. General operation use Spring Data Repositories Its MongoRepository
2. Custom extensions use MongoTemplate, Access through the user-defined extension interface