SpringBoot中怎么对MongoDB 进行增删改查操作

发布时间:2021-06-22 15:36:39 作者:Leah
来源:亿速云 阅读:305

SpringBoot中怎么对MongoDB 进行增删改查操作,针对这个问题,这篇文章详细介绍了相对应的分析和解答,希望可以帮助更多想解决这个问题的小伙伴找到更简单易行的方法。

引入MongoDB

<?xml version="1.0" encoding="UTF-8"?>
<project xmlns="http://maven.apache.org/POM/4.0.0" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
         xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 https://maven.apache.org/xsd/maven-4.0.0.xsd">
    <modelVersion>4.0.0</modelVersion>
    <parent>
        <groupId>org.springframework.boot</groupId>
        <artifactId>spring-boot-starter-parent</artifactId>
        <version>2.3.2.RELEASE</version>
        <relativePath/> <!-- lookup parent from repository -->
    </parent>
    <groupId>com.kailo</groupId>
    <artifactId>kailo-mongodb</artifactId>
    <version>0.0.1-SNAPSHOT</version>
    <name>kailo-mongodb</name>
    <description>MongoDB</description>

    <properties>
        <java.version>1.8</java.version>
    </properties>

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

        <dependency>
            <groupId>org.projectlombok</groupId>
            <artifactId>lombok</artifactId>
            <optional>true</optional>
        </dependency>

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

        <dependency>
            <groupId>org.springframework.boot</groupId>
            <artifactId>spring-boot-starter-test</artifactId>
            <scope>test</scope>
            <exclusions>
                <exclusion>
                    <groupId>org.junit.vintage</groupId>
                    <artifactId>junit-vintage-engine</artifactId>
                </exclusion>
            </exclusions>
        </dependency>

        <!-- https://mvnrepository.com/artifact/org.springframework.boot/spring-boot-starter-data-mongodb -->
        <dependency>
            <groupId>org.springframework.boot</groupId>
            <artifactId>spring-boot-starter-data-mongodb</artifactId>
            <version>2.3.2.RELEASE</version>
        </dependency>

        <dependency>
            <groupId>com.alibaba</groupId>
            <artifactId>fastjson</artifactId>
            <version>1.2.61</version>
        </dependency>

    </dependencies>

    <build>
        <plugins>
            <plugin>
                <groupId>org.springframework.boot</groupId>
                <artifactId>spring-boot-maven-plugin</artifactId>
            </plugin>
        </plugins>
    </build>

</project>

添加配置文件:application.properties

server.port=8080
spring.data.mongodb.uri=mongodb://127.0.0.1:27017/xxx
#spring.data.mongodb.host=127.0.0.1
#spring.data.mongodb.port=27017
#spring.data.mongodb.database=xxx
# 默认没有账号密码
#spring.data.mongodb.username=
#spring.data.mongodb.password=

增删改查代码:ProductController

@Log4j2
@RequestMapping("/product")
@RestController
public class ProductController {

    private final ProductRepository productRepository;

    private final MongoTemplate mongoTemplate;

    @Autowired
    public ProductController(ProductRepository productRepository, MongoTemplate mongoTemplate) {
        this.productRepository = productRepository;
        this.mongoTemplate = mongoTemplate;
    }

    // 增
    @PostMapping("save")
    public ResponseEntity<Result<Product>> save(Product product) {
        if (!StringUtils.isEmpty(product.get_id())) {
            return ResultUtils.error();
        }
        productRepository.save(product);
        return ResultUtils.ok(product);
    }

    // 删 单个删除
    @GetMapping("deleteById")
    public ResponseEntity<Result<String>> deleteById(String id) {
        if (StringUtils.isEmpty(id)) {
            return ResultUtils.error();
        }

        productRepository.deleteById(id);
        return ResultUtils.ok();
    }

    // 删 批量删除
    @DeleteMapping("deleteByIds")
    public ResponseEntity<Result<String>> deleteByIds(@RequestBody String[] ids) {
        if (ids == null) {
            return ResultUtils.error();
        }
        List<String> idList = Arrays.asList(ids);

        Iterable<Product> deleteProducts = productRepository.findAllById((Iterable<String>) idList.iterator());
        productRepository.deleteAll(deleteProducts);

        return ResultUtils.ok();
    }

    // 改 单个
    @PostMapping("update")
    public ResponseEntity<Result<Product>> update(Product product) {
        if (StringUtils.isEmpty(product.get_id())) {
            return ResultUtils.error();
        }
        product = productRepository.save(product);
        return ResultUtils.ok(product, "更新成功");
    }

    // 查 查单个
    @GetMapping("findById")
    public ResponseEntity<Result<Product>> findById(String id) {
        Product product = productRepository.findById(id).get();
        return ResultUtils.ok(product);
    }

    // 查 查全部列表
    @GetMapping("findAll")
    public ResponseEntity<Result<List<Product>>> findAll() {
        List<Product> products = productRepository.findAll();
        return ResultUtils.ok(products);
    }

    // 查 分页查询
    @GetMapping("findPage")
    public ResponseEntity<Result<Pagination<Product>>> findPage(int page, int size) {
        PageRequest pageRequest = PageRequest.of(page, size, Sort.unsorted());
        Page<Product> productPage = productRepository.findAll(pageRequest);
        log.error(productPage.getClass());
        log.error(productPage.getPageable().getClass());
        return ResultUtils.ok(Pagination.from(productPage));
    }

    // 查 模糊查询
    @GetMapping("findByNameLike")
    public ResponseEntity<Result<List<Product>>> findByNameLike(String name) {
        List<Product> products = null;
        if (StringUtils.isEmpty(name)) {
            products = productRepository.findAll();
        } else {
            products = productRepository.findByNameLike(name);
        }
        return ResultUtils.ok(products);
    }

    @GetMapping("findPageByNameMongoTemplate")
    public ResponseEntity<Result<List<Product>>> findPageByNameMongoTemplate(int page, int size, String name) {

        Query query = new Query();
        query.addCriteria(Criteria.where("name").regex(name));
        List<Product> products = mongoTemplate.find(query, Product.class);

        return ResultUtils.ok(products);
    }

    // 查 根据条件过滤
    @GetMapping("findPageByNameLike")
    public ResponseEntity<Result<Pagination<Product>>> findPageByNameLike(int page, int size, String name) {
        if (StringUtils.isEmpty(name)) {
            return ResultUtils.error();
        }

        PageRequest pageRequest = PageRequest.of(page, size, Sort.unsorted());

        Query query = new Query();
        query.addCriteria(Criteria.where("name").regex(name));
        List<Product> products = mongoTemplate.find(query, Product.class);

        long total = mongoTemplate.count(query, Product.class);

        return ResultUtils.ok(Pagination.build(products, total, pageRequest));
    }
}

相关代码

@Data
@Document(value = "xxx")
public class Product implements Serializable  {

    @Id
    @JSONField(name="_id") // fastjson 会过滤 _
    private String _id;
    @Field
    private String name;
    @Field
    private String user;
    @Field
    private Double ccc;

}
public interface ProductRepository extends MongoRepository<Product, String> {

    List<Product> findByNameLike(String name);
}

分页相关:不用自带的Page,自定义Pagination,解决序列化和反序列化问题

@Data
public class Pagination<T> implements Serializable {

    private long total;
    private List<T> content = new ArrayList();
    private PaginationRequest pageable;

    public Pagination() {
    }

    public long getTotal() {
        return this.total;
    }

    /**
     * 根据Page,转化成 Pagination
     *
     * @param page
     * @param <T>
     * @return
     */
    public static <T> Pagination<T> from(Page<T> page) {
        if (page == null) {
            return new Pagination<>();
        }
        return build(page.getContent(), page.getTotalElements(), page.getPageable());
    }

    /**
     * 根据参数,初始化 Pagination
     *
     * @param content
     * @param totalElements
     * @param pageable
     * @param <T>
     * @return
     */
    public static <T> Pagination<T> build(List<T> content, long totalElements, Pageable pageable) {
        Pagination<T> pageResult = new Pagination<>();
        pageResult.setTotal(totalElements);
        pageResult.setContent(content);
        pageResult.setPageable(PaginationRequest.from(pageable));
        return pageResult;
    }

    public int getTotalPages() {
        return this.getSize() == 0 ? 1 : (int) Math.ceil((double) this.total / (double) this.getSize());
    }

    public long getTotalElements() {
        return this.total;
    }

    public boolean hasNext() {
        return this.getNumber() + 1 < this.getTotalPages();
    }

    public int getNumber() {
        return this.pageable.getPageNumber();
    }

    public int getSize() {
        return this.pageable.getPageSize();
    }

    public int getNumberOfElements() {
        return this.content.size();
    }

    public boolean hasPrevious() {
        return this.getNumber() > 0;
    }

    public boolean isFirst() {
        return !this.hasPrevious();
    }

    public boolean isLast() {
        return !this.hasNext();
    }

    public PaginationRequest nextPageable() {
        return this.hasNext() ? this.pageable.next() :  null;
    }

    public PaginationRequest previousPageable() {
        return this.hasPrevious() ? this.pageable.previousOrFirst() : null;
    }

    public boolean hasContent() {
        return !this.content.isEmpty();
    }

    public List<T> getContent() {
        return Collections.unmodifiableList(this.content);
    }

    public Iterator<T> iterator() {
        return this.content.iterator();
    }
}
@Data
public class PaginationRequest implements Serializable {

    private int page;
    private int size;

    public PaginationRequest() {}

    public PaginationRequest(int page, int size) {
        this.page = page;
        this.size = size;
    }

    public static PaginationRequest from(Pageable pageable) {
        Sort sort = pageable.getSort();
        return new PaginationRequest(pageable.getPageNumber(), pageable.getPageSize() );
    }

    public PaginationRequest next() {
        return new PaginationRequest(this.getPageNumber() + 1, this.getPageSize());
    }

    public PaginationRequest previous() {
        return this.getPageNumber() == 0 ? this : new PaginationRequest(this.getPageNumber() - 1, this.getPageSize());
    }

    public PaginationRequest first() {
        return new PaginationRequest(0, this.getPageSize());
    }

    public int getPageSize() {
        return this.size;
    }

    public int getPageNumber() {
        return this.page;
    }

    public long getOffset() {
        return (long)this.page * (long)this.size;
    }

    public boolean hasPrevious() {
        return this.page > 0;
    }

    public PaginationRequest previousOrFirst() {
        return this.hasPrevious() ? this.previous() : this.first();
    }
}
@Data
public class Result<T> implements Serializable {
    private int code;
    private String message;
    private T data;
    private long timestamp = Date.from(Instant.now()).getTime();
}
@Data
public class ResultUtils implements Serializable {

    public static final int SUCCESS = 200;
    public static final int NOT_FOUND = 404;
    public static final int ERROR = 500;

    public static final String OPT_SUCCESS_LANG = "操作成功";
    public static final String OPT_ERROR_LANG = "操作失败";

    public static <T> ResponseEntity<Result<T>> ok() {
        return ok(OPT_SUCCESS_LANG);
    }

    public static <T> ResponseEntity<Result<T>> ok(String message) {
        return ok(null, message);
    }

    public static <T> ResponseEntity<Result<T>> ok(T data) {
        return ok(data, null);
    }

    public static <T> ResponseEntity<Result<T>> ok(T data, String message) {
        Result<T> result = new Result<>();
        result.setCode(SUCCESS);
        result.setMessage(message);
        result.setData(data);
        return ResponseEntity.ok(result);
    }


    public static <T> ResponseEntity<Result<T>> error() {
        return ok(OPT_ERROR_LANG);
    }

    public static <T> ResponseEntity<Result<T>> error(String message) {
        return ok(null, message);
    }

    public static <T> ResponseEntity<Result<T>> error(T data) {
        return ok(data, null);
    }

    public static <T> ResponseEntity<Result<T>> error(T data, String message) {
        Result<T> result = new Result<>();
        result.setCode(ERROR);
        result.setMessage(message);
        result.setData(data);
        return ResponseEntity.ok(result);
    }
}

关于SpringBoot中怎么对MongoDB 进行增删改查操作问题的解答就分享到这里了,希望以上内容可以对大家有一定的帮助,如果你还有很多疑惑没有解开,可以关注亿速云行业资讯频道了解更多相关知识。

推荐阅读:
  1. express+mongoose如何实现对mongodb增删改查
  2. 使用Node.js怎么对MongoDB进行增删改查操作

免责声明:本站发布的内容(图片、视频和文字)以原创、转载和分享为主,文章观点不代表本网站立场,如果涉及侵权请联系站长邮箱:is@yisu.com进行举报,并提供相关证据,一经查实,将立刻删除涉嫌侵权内容。

spring boot mongodb

上一篇:ubuntu系统笔记本触摸板不能单击的解决方法

下一篇:ubuntu15.04如何卸载软件

相关阅读

您好,登录后才能下订单哦!

密码登录
登录注册
其他方式登录
点击 登录注册 即表示同意《亿速云用户服务条款》