SpringBoot整合MongoDB的实现代码

<!--mongodb-->
<dependency>
    <groupid>org.springframework.boot</groupid>
    <artifactid>spring-boot-starter-data-mongodb</artifactid>
</dependency>

spring:
  data:
    mongodb:
      host: 127.0.0.1
      port: 27017
      database: blog

package com.springcloud.blog.admin.mongo.entity;

import com.springcloud.blog.admin.common.base.basedto;
import org.springframework.data.mongodb.core.mapping.document;
import org.springframework.data.mongodb.core.mapping.field;

/**
 * 联系我-数据模型
 */
@document(collection = "contact_me")
public class contactme extends basedto {

    @field
    private string name;

    @field
    private string email;

    @field
    private string content;


    public string getname() {
        return name;
    }

    public void setname(string name) {
        this.name = name;
    }

    public string getemail() {
        return email;
    }

    public void setemail(string email) {
        this.email = email;
    }

    public string getcontent() {
        return content;
    }

    public void setcontent(string content) {
        this.content = content;
    }
}

package com.springcloud.blog.admin.mongo.dao;

import com.springcloud.blog.admin.mongo.entity.contactme;
import org.springframework.data.mongodb.repository.mongorepository;

/**
 * 联系我-持久层
 */
public interface contactmerepository extends mongorepository<contactme, string> {
}

package com.springcloud.blog.admin.mongo.controller;

import com.alibaba.fastjson.jsonobject;
import com.springcloud.blog.admin.common.dict.responsedict;
import com.springcloud.blog.admin.mongo.dao.contactmerepository;
import com.springcloud.blog.admin.mongo.entity.contactme;
import org.springframework.beans.factory.annotation.autowired;
import org.springframework.web.bind.annotation.postmapping;
import org.springframework.web.bind.annotation.requestbody;
import org.springframework.web.bind.annotation.requestmapping;
import org.springframework.web.bind.annotation.restcontroller;

import java.util.list;

/**
 * 联系我(mongo example)
 */
@restcontroller
@requestmapping("/contactme")
public class contactmecontroller {


    @autowired
    private contactmerepository contactmerepository;

    @postmapping("/save")
    public jsonobject save(@requestbody contactme contactme) {
        jsonobject jsonobject = new jsonobject();
        contactmerepository.save(contactme);
        jsonobject.put(responsedict.response_code_key, responsedict.response_success_code);
        jsonobject.put(responsedict.response_msg_key, responsedict.response_success_msg);
        return jsonobject;
    }


    @postmapping("/delete")
    public jsonobject delete(@requestbody contactme contactme) {
        jsonobject jsonobject = new jsonobject();
        contactmerepository.delete(contactme);
        jsonobject.put(responsedict.response_code_key, responsedict.response_success_code);
        jsonobject.put(responsedict.response_msg_key, responsedict.response_success_msg);
        return jsonobject;
    }


    @postmapping("/update")
    public jsonobject update(@requestbody contactme contactme) {
        jsonobject jsonobject = new jsonobject();
        contactmerepository.save(contactme);
        jsonobject.put(responsedict.response_code_key, responsedict.response_success_code);
        jsonobject.put(responsedict.response_msg_key, responsedict.response_success_msg);
        return jsonobject;
    }

    @postmapping("/getall")
    public jsonobject getall() {
        jsonobject jsonobject = new jsonobject();
        list<contactme> list = contactmerepository.findall();
        jsonobject.put(responsedict.response_code_key, responsedict.response_success_code);
        jsonobject.put(responsedict.response_msg_key, responsedict.response_success_msg);
        jsonobject.put(responsedict.response_data_key, list);
        return jsonobject;
    }
}