pom.xml

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

配置文件

#username和password在mongodb開啟了驗證后需要填寫，否則只要ip:port/db即可
sprint.data.mongodb.uri:=mongodb://username:pwd@ip:port/db

實體類

@Document(collection = "T_conversation")
public class Conversation {

    @Id
    private String id;
    private String fromId;
    private String toId;
    private String type;
    private Integer timestamp;

    public String getId() {
        return id;
    }

    public void setId(String id) {
        this.id = id;
    }

    public String getFromId() {
        return fromId;
    }

    public void setFromId(String fromId) {
        this.fromId = fromId;
    }

    public String getToId() {
        return toId;
    }

    public void setToId(String toId) {
        this.toId = toId;
    }

    public String getType() {
        return type;
    }

    public void setType(String type) {
        this.type = type;
    }

    public Integer getTimestamp() {
        return timestamp;
    }

    public void setTimestamp(Integer timestamp) {
        this.timestamp = timestamp;
    }

    public Conversation() {

    }

    @Override
    public String toString() {
        return "Conversation{" +
                "id='" + id + '\'' +
                ", fromId='" + fromId + '\'' +
                ", toId='" + toId + '\'' +
                ", type='" + type + '\'' +
                ", timestamp=" + timestamp +
                '}';
    }
}

@Document（collection = "xxx"）
實體類將會映射到數(shù)據(jù)庫中名為xxx的collection中
此注解可不寫，不寫的話會在數(shù)據(jù)庫中創(chuàng)建以類名小寫為名的collection
@Id
標注在屬性上沾鳄，映射到collection的_id屬性上mongodb自己維護此字段惧蛹，生成

"_id" : ObjectId("598137f6d243573250a370ee")

這樣的字段

DAO層

public interface ConversationRepository  extends MongoRepository<Conversation,String>{
}

只需要寫一個空的interface繼承MongoRepostitory就可以實現(xiàn)簡單的增刪改查
<xxx,yyy>xxx代表要操作的實體類右冻，yyy代表實體類的主鍵類型

簡單的增刪改查操作

  ConversationRepository  conversationRepository  = new ConversationRepository ();
  conversationRepository.xxxx()

復雜查詢

查詢T_conversation中fromId,toId等于傳入的值并且timestamp在begin和end之間的conversation

@Autowired
ConversationRepository conversationRepository;

@Autowired
private MongoTemplate mongoTemplate;

@GetMapping("conversation")
public String getConversationByFromIdAndToIdAndTimeInBeginAndEnd(Integer begin,Integer end,String fromId,String toId){
        BasicDBObject timestampGt = new BasicDBObject("timestamp",new BasicDBObject("$gt", begin));
        BasicDBObject timestampLt = new BasicDBObject("timestamp", new BasicDBObject("$lt", end));
        BasicDBObject fromIdObject = new BasicDBObject("fromId", fromId);
        BasicDBObject toIdObject = new BasicDBObject("toId", toId);
        BasicDBList andList = new BasicDBList();
        andList.add(timestampGt);
        andList.add(timestampLt);
        andList.add(fromIdObject);
        andList.add(toIdObject);
        BasicDBObject queryCondition = new BasicDBObject("$and",andList);
        List<Conversation> conversations = mongoTemplate.find(new BasicQuery(queryCondition), Conversation.class);
        StringBuffer result = new StringBuffer("");
        Gson gson = new Gson();
        String s = gson.toJson(conversations);
        return s;
}