SpringBoot интегрирует MongoDB
SpringBoot интегрирует MongoDB

SpringBoot интегрирует MongoDB

1. Введение

MongoDBЭто документ с открытым исходным кодомданные Библиотека,Использование метода распределенного хранения файлов,даNoSQLданные Библиотекасерединаиз Что-то вроде。Целью его разработки является решение традиционных реляционных проблем при разработке современных приложений.данные Библиотекастолкнулсяизнекоторые проблемы,Такие как гибкость, Масштабируемость и вопросы производительности.

к ВниздаMongoDBНекоторые основные особенности：

  1. Документоориентированное хранилище：MongoDBПримите документно-ориентированную модель хранения,данныекJSONформат хранения,Этот шаблон хорошо сочетается со структурой данных приложения.,Может более естественно сопоставляться со структурой кода.
  2. Гибкий дизайн шаблона：MongoDBНет необходимости заранее определять структуру таблицы,Документы могут содержать разные поля,Можетк Добавляйте динамически по мере необходимости илиудалить Поле,Следовательно, он больше подходит для быстрой итерации и гибкого проектирования модели данных.
  3. высокая производительность：MongoDBиметьвысокая Операции чтения и записи производительности поддерживают эффективные операции запроса и записи при большом объеме данных, а также поддерживают оптимизацию запросов на основе индексов.
  4. Масштабируемость：MongoDBиметьхорошийиз Горизонтальная масштабируемость,Возможности хранения и обработки данных можно расширить за счет добавления дополнительных узлов.,Чтобы справиться с растущим объемом и давлением доступа.
  5. Репликация и отказоустойчивость：MongoDBподдерживатьданныеиз Репликация и Механизм отказоустойчивости позволяет настраивать мастер-подчиненные копировать и сегментировать кластеры для обеспечения доступности и надежности данных.
  6. Богатые функции и инструменты：MongoDBпредоставил Богатые функции и инструменты, включая резервное копирование и восстановление данных, шифрование данных, проверку данных, текстовый поиск и другие функции, а также различные клиентские драйверы и инструменты управления.

в общем,MongoDBда Мощный、Высокая гибкость、Превосходная производительностьизNoSQLданные Библиотека,Подходит для всех типов приложений,Особенно те приложения, которым необходимо обрабатывать большие объемы данных и которые имеют сложную структуру данных.

Эта статья познакомит васSpringBootКомплексное использованиеMongoDB,Про установку его сервисов говорить не буду.

2. Код

1) Конфигурация

Язык кода:javascript
копировать
spring:
  data:
    mongodb:
      host: адрес хоста
      port: порт
      database: данные Библиотека      authentication-database: admin
      auto-index-creation: false

2）MongoRepository

МожеткиспользоватьMongoRepositoryкодировать,Это иMybatisPlusФизическая часть очень похожа

Язык кода:javascript
копировать
package com.banmoon.repository;

import com.banmoon.entity.MemberAccountLogEntity;
import org.springframework.data.mongodb.repository.MongoRepository;
import org.springframework.stereotype.Repository;

@Repository
public interface MemberAccountLogRepository extends MongoRepository<MemberAccountLogEntity, Long> {
}

специфическийизсущностьMemberAccountLogEntity.java

Язык кода:javascript
копировать
package com.banmoon.entity;

import lombok.Data;
import lombok.experimental.FieldNameConstants;
import org.springframework.data.annotation.Id;
import org.springframework.data.mongodb.core.mapping.Document;

import java.math.BigDecimal;

@Data
@FieldNameConstants
@Document(collection = "member_account_log")
public class MemberAccountLogEntity {

    @Id
    private Long id;

    private String memberId;

    private String memberName;

    private BigDecimal totalConsumption;

    private BigDecimal depositMoney;

}

использоватьMemberAccountLogRepository.java

Язык кода:javascript
копировать
package com.banmoon.execute;

import cn.hutool.core.collection.CollUtil;
import cn.hutool.core.util.IdUtil;
import cn.hutool.core.util.RandomUtil;
import com.banmoon.entity.MemberAccountLogEntity;
import com.banmoon.repository.MemberAccountLogRepository;
import lombok.extern.slf4j.Slf4j;
import org.springframework.data.domain.*;
import org.springframework.stereotype.Component;

import javax.annotation.Resource;
import java.math.BigDecimal;
import java.util.ArrayList;
import java.util.List;

/**
 * Проверьте использование mongo, используйте MongoRepository.
 */
@Slf4j
@Component
public class MongoExecute implements Runnable {

    @Resource
    private MemberAccountLogRepository memberAccountLogRepository;

    @Override
    public void run() {
        insertOne();
        insertBatch(50);
        findAll();
        update();
        delete();
    }

    /**
     * удалить
     */
    private void delete() {
        List<MemberAccountLogEntity> list = memberAccountLogRepository.findAll();
        if (CollUtil.isNotEmpty(list)) {
            memberAccountLogRepository.deleteById(list.get(0).getId());
        }
    }

    /**
     * возобновлять
     */
    private void update() {
        long id = 1729792683813355522L;
        MemberAccountLogEntity entity = memberAccountLogRepository.findById(id)
                .map(memberAccountLogEntity -> {
                    memberAccountLogEntity.setMemberName("Полумесяц без мороза");
                    memberAccountLogEntity.setDepositMoney(new BigDecimal("1000"));
                    return memberAccountLogRepository.save(memberAccountLogEntity);
                }).orElse(null);
        log.info("Измененная информация, {}", memberAccountLogRepository.findById(id).get());
    }

    /**
     * Искать все
     */
    private void findAll() {
        List<MemberAccountLogEntity> list = memberAccountLogRepository.findAll();
        log.info("Количество всех пользователей mongoDB: {}, сведения: {}", list.size(), list);

        // Добавить условие, совпадение имени
        MemberAccountLogEntity entity = new MemberAccountLogEntity();
        entity.setMemberName("35ns98w1");
        List<MemberAccountLogEntity> list1 = memberAccountLogRepository.findAll(Example.of(entity));
        log.info("Количество всех пользователей mongoDB: {}, сведения: {}", list1.size(), list1);

        // Добавьте условия, назовите нечеткое соответствие, добавьте сортировку
        MemberAccountLogEntity entity1 = new MemberAccountLogEntity();
        entity1.setMemberName("35");
        ExampleMatcher matcher = ExampleMatcher.matching()
                .withMatcher(MemberAccountLogEntity.Fields.memberName, ExampleMatcher.GenericPropertyMatchers.contains());
        Example<MemberAccountLogEntity> example = Example.of(entity1, matcher);
        Sort sort = Sort.by(MemberAccountLogEntity.Fields.depositMoney).descending();
        List<MemberAccountLogEntity> list2 = memberAccountLogRepository.findAll(example, sort);
        log.info("Количество всех пользователей mongoDB: {}, сведения: {}", list2.size(), list2);

        // Пагинация
        Sort sort1 = Sort.by(MemberAccountLogEntity.Fields.totalConsumption).descending();
        PageRequest page = PageRequest.of(0, 10, sort1);
        Page<MemberAccountLogEntity> list3 = memberAccountLogRepository.findAll(page);
        log.info("Количество всех пользователей mongoDB: {}, текущие данные пагинации: {}", list3.getTotalElements(), list3.getContent());

        // общий
        long count = memberAccountLogRepository.count(example);
        log.info("Запросить количество пользователей: {}", count);
    }

    /**
     * Пакетная вставка
     */
    private void insertBatch(int count) {
        List<MemberAccountLogEntity> list = new ArrayList<>();
        for (int i = 0; i < count; i++) {
            MemberAccountLogEntity entity = new MemberAccountLogEntity();
            entity.setId(IdUtil.getSnowflakeNextId());
            entity.setMemberId(i + RandomUtil.randomString(6));
            entity.setMemberName(i + RandomUtil.randomString(6));
            entity.setTotalConsumption(RandomUtil.randomBigDecimal(BigDecimal.ZERO, BigDecimal.TEN));
            entity.setDepositMoney(RandomUtil.randomBigDecimal(BigDecimal.ZERO, BigDecimal.TEN));
            list.add(entity);
        }
        memberAccountLogRepository.insert(list);
    }

    /**
     * Вставить хедз-ап
     */
    private void insertOne() {
        MemberAccountLogEntity entity = new MemberAccountLogEntity();
        entity.setId(IdUtil.getSnowflakeNextId());
        entity.setMemberId(RandomUtil.randomString(6));
        entity.setMemberName(RandomUtil.randomString(6));
        entity.setTotalConsumption(RandomUtil.randomBigDecimal(BigDecimal.ZERO, BigDecimal.TEN));
        entity.setDepositMoney(RandomUtil.randomBigDecimal(BigDecimal.ZERO, BigDecimal.TEN));
        memberAccountLogRepository.insert(entity);
    }
}

3）MongoTemplate

Для какого-то сложногоиз Запрос,Тогда мы будем использоватьMongoTemplate.java

Язык кода:javascript
копировать
package com.banmoon.execute;

import cn.hutool.core.util.IdUtil;
import cn.hutool.core.util.RandomUtil;
import cn.hutool.json.JSONUtil;
import com.banmoon.dto.MangoAggregationDTO;
import com.banmoon.dto.MangoAggregationGroupByDTO;
import com.banmoon.entity.MemberAccountLogEntity;
import lombok.extern.slf4j.Slf4j;
import org.springframework.data.mongodb.core.MongoTemplate;
import org.springframework.data.mongodb.core.aggregation.*;
import org.springframework.data.mongodb.core.query.Criteria;
import org.springframework.data.mongodb.core.query.Query;
import org.springframework.data.mongodb.core.query.Update;
import org.springframework.stereotype.Component;

import javax.annotation.Resource;
import java.math.BigDecimal;
import java.util.List;

@Slf4j
@Component
public class MongoTemplateExecute implements Runnable{

    @Resource
    private MongoTemplate mongoTemplate;

    public static final String COLLECTION_NAME = "member_account_log";

    @Override
    public void run() {
        simpleCurd();
        aggregation();
    }

    /**
     * Операция агрегирования
     */
    private void aggregation() {
//        count();
        groupBy();
    }

    private void groupBy() {
        // Создайте условия соответствия запроса:
        MatchOperation matchOperation = Aggregation.match(Criteria.where(MemberAccountLogEntity.Fields.memberName).ne(null));
        // Построение сгруппированного совокупного анализа
        GroupOperation groupOperation = Aggregation.group(MemberAccountLogEntity.Fields.memberId)
                                                .first(MemberAccountLogEntity.Fields.memberName).as(MangoAggregationGroupByDTO.Fields.memberName)
                                                .count().as(MangoAggregationGroupByDTO.Fields.count)
                                                .max(MemberAccountLogEntity.Fields.depositMoney).as(MangoAggregationGroupByDTO.Fields.max)
                                                .min(MemberAccountLogEntity.Fields.depositMoney).as(MangoAggregationGroupByDTO.Fields.min)
                                                .avg(MemberAccountLogEntity.Fields.depositMoney).as(MangoAggregationGroupByDTO.Fields.avg)
                                                .sum(MemberAccountLogEntity.Fields.totalConsumption).as(MangoAggregationGroupByDTO.Fields.sum);
        // Интеграция для создания агрегатных объектов
        TypedAggregation<MangoAggregationGroupByDTO> aggregation = Aggregation.newAggregation(MangoAggregationGroupByDTO.class, matchOperation, groupOperation);
        // Запрос
        AggregationResults<MangoAggregationGroupByDTO> resultList = mongoTemplate.aggregate(aggregation, MangoAggregationGroupByDTO.class);
        // Получите результаты
        List<MangoAggregationGroupByDTO> list = resultList.getMappedResults();
        list.forEach(dto -> log.info("{}", JSONUtil.toJsonStr(dto)));
    }

    private void count() {
        // Создайте условия соответствия запроса:
        MatchOperation matchOperation = Aggregation.match(Criteria.where(MemberAccountLogEntity.Fields.totalConsumption).gt(new BigDecimal("1")));
        // Операция подсчета сборки, получение с именем "count"
        CountOperation countOperation = Aggregation.count().as(MangoAggregationDTO.Fields.count);
        // Интеграция для создания агрегатных объектов
        Aggregation aggregation = Aggregation.newAggregation(matchOperation, countOperation);
        // Запросты
        AggregationResults<MangoAggregationDTO> resultList = mongoTemplate.aggregate(aggregation, COLLECTION_NAME, MangoAggregationDTO.class);
        // Получите результаты
        List<MangoAggregationDTO> aggregationList = resultList.getMappedResults();
        log.info("подсчитать количество результатов: {}", aggregationList.get(0).getCount());
    }

    private void simpleCurd() {
        // Искать все
        List<MemberAccountLogEntity> allList = mongoTemplate.findAll(MemberAccountLogEntity.class);
        log.info("Количество всех участников: {}", allList.size());

        // Новый
        MemberAccountLogEntity entity = new MemberAccountLogEntity();
        entity.setId(IdUtil.getSnowflakeNextId());
        entity.setMemberName(RandomUtil.randomString(6));
        entity.setMemberId(RandomUtil.randomString(6));
        entity.setTotalConsumption(new BigDecimal("100"));
        entity.setDepositMoney(RandomUtil.randomBigDecimal(BigDecimal.ZERO, BigDecimal.TEN));
        mongoTemplate.save(entity, COLLECTION_NAME);

        // Исправлять
        Query query = new Query(Criteria.where(MemberAccountLogEntity.Fields.totalConsumption).gte(new BigDecimal("100")));
        Update update = new Update();
        update.set(MemberAccountLogEntity.Fields.depositMoney, new BigDecimal("99"));
        mongoTemplate.updateFirst(query, update, MemberAccountLogEntity.class);

        // Запрос
        Query query1 = new Query(Criteria.where(MemberAccountLogEntity.Fields.totalConsumption).gte(new BigDecimal("100")));
        List<MemberAccountLogEntity> list = mongoTemplate.find(query1, MemberAccountLogEntity.class);
        log.info("Люди с балансом более 100: {}", list);

        // Пагинация Запрос
        Query query2 = new Query(Criteria.where(MemberAccountLogEntity.Fields.totalConsumption).gte(new BigDecimal("100")));
        long count = mongoTemplate.count(query2, COLLECTION_NAME);
        int pageSize = 10;
        int pageIndex = 3;
        query2.skip((pageIndex - 1) * pageSize).limit(pageSize);
        List<MemberAccountLogEntity> list1 = mongoTemplate.find(query2, MemberAccountLogEntity.class, COLLECTION_NAME);
        log.info("Пагинация Запрособщий：{},Текущая страница：{}", count, list1);

        // удалить
        Query query3 = new Query();
        mongoTemplate.remove(query3, MemberAccountLogEntity.class);
    }

}

3. Наконец

представилMongoRepository.java、MongoTemplate.javaДва способа написания。

Конкретное использование может быть не очень полным. Если позже появятся новые, я добавлю их позже.

Я Бан Юэ, и мы с вами вместе будем поддерживать друг друга! ! !

boy illustration
Неразрушающее увеличение изображений одним щелчком мыши, чтобы сделать их более четкими артефактами искусственного интеллекта, включая руководства по установке и использованию.
boy illustration
Копикодер: этот инструмент отлично работает с Cursor, Bolt и V0! Предоставьте более качественные подсказки для разработки интерфейса (создание навигационного веб-сайта с использованием искусственного интеллекта).
boy illustration
Новый бесплатный RooCline превосходит Cline v3.1? ! Быстрее, умнее и лучше вилка Cline! (Независимое программирование AI, порог 0)
boy illustration
Разработав более 10 проектов с помощью Cursor, я собрал 10 примеров и 60 подсказок.
boy illustration
Я потратил 72 часа на изучение курсорных агентов, и вот неоспоримые факты, которыми я должен поделиться!
boy illustration
Идеальная интеграция Cursor и DeepSeek API
boy illustration
DeepSeek V3 снижает затраты на обучение больших моделей
boy illustration
Артефакт, увеличивающий количество очков: на основе улучшения характеристик препятствия малым целям Yolov8 (SEAM, MultiSEAM).
boy illustration
DeepSeek V3 раскручивался уже три дня. Сегодня я попробовал самопровозглашенную модель «ChatGPT».
boy illustration
Open Devin — инженер-программист искусственного интеллекта с открытым исходным кодом, который меньше программирует и больше создает.
boy illustration
Эксклюзивное оригинальное улучшение YOLOv8: собственная разработка SPPF | SPPF сочетается с воспринимаемой большой сверткой ядра UniRepLK, а свертка с большим ядром + без расширения улучшает восприимчивое поле
boy illustration
Популярное и подробное объяснение DeepSeek-V3: от его появления до преимуществ и сравнения с GPT-4o.
boy illustration
9 основных словесных инструкций по доработке академических работ с помощью ChatGPT, эффективных и практичных, которые стоит собрать
boy illustration
Вызовите deepseek в vscode для реализации программирования с помощью искусственного интеллекта.
boy illustration
Познакомьтесь с принципами сверточных нейронных сетей (CNN) в одной статье (суперподробно)
boy illustration
50,3 тыс. звезд! Immich: автономное решение для резервного копирования фотографий и видео, которое экономит деньги и избавляет от беспокойства.
boy illustration
Cloud Native｜Практика: установка Dashbaord для K8s, графика неплохая
boy illustration
Краткий обзор статьи — использование синтетических данных при обучении больших моделей и оптимизации производительности
boy illustration
MiniPerplx: новая поисковая система искусственного интеллекта с открытым исходным кодом, спонсируемая xAI и Vercel.
boy illustration
Конструкция сервиса Synology Drive сочетает проникновение в интрасеть и синхронизацию папок заметок Obsidian в облаке.
boy illustration
Центр конфигурации————Накос
boy illustration
Начинаем с нуля при разработке в облаке Copilot: начать разработку с минимальным использованием кода стало проще
boy illustration
[Серия Docker] Docker создает мультиплатформенные образы: практика архитектуры Arm64
boy illustration
Обновление новых возможностей coze | Я использовал coze для создания апплета помощника по исправлению домашних заданий по математике
boy illustration
Советы по развертыванию Nginx: практическое создание статических веб-сайтов на облачных серверах
boy illustration
Feiniu fnos использует Docker для развертывания личного блокнота Notepad
boy illustration
Сверточная нейронная сеть VGG реализует классификацию изображений Cifar10 — практический опыт Pytorch
boy illustration
Начало работы с EdgeonePages — новым недорогим решением для хостинга веб-сайтов
boy illustration
[Зона легкого облачного игрового сервера] Управление игровыми архивами
boy illustration
Развертывание SpringCloud-проекта на базе Docker и Docker-Compose
©