торговый центр интегрирует mongodb для реализации операций с документами

Spring Boot

Резюме

В этой статье торговый центр Mongodb объясняет процесс интеграции для получения истории просмотра продуктов Mongodb, например, добавление, удаление, запрос. Mongodb — это система баз данных для быстрой разработки интернет-приложений и веб-приложений, построенная по ее модели, и стратегия сохранения данных заключается в построении высокой пропускной способности чтения/записи и высокой масштабируемости системы автоматического аварийного восстановления.

Введение в структуру использования проекта

Mongodb

Mongodb — это система баз данных, созданная для быстрой разработки веб-приложений в Интернете.Его модель данных и стратегия сохраняемости предназначены для создания системы с высокой пропускной способностью чтения/записи и высокой масштабируемостью автоматического аварийного восстановления.

Установка и использование MongoDB

  1. Загрузите установочный пакет Mongodb, адрес загрузки:Слишком много всего происходит MongoDB.org/win32/mongo…

  2. Выберите путь установки для установки

展示图片/arch_screen_37.png

展示图片/arch_screen_38.png

  1. Создайте две папки, data\db и data\log в пути установки

展示图片/arch_screen_39.png

  1. Создайте файл конфигурации mongod.cfg в пути установки
systemLog:
    destination: file
    path: D:\developer\env\MongoDB\data\log\mongod.log
storage:
    dbPath: D:\developer\env\MongoDB\data\db
  1. Установите в качестве услуги (привилегии администратора необходимы для запуска команды)
D:\developer\env\MongoDB\bin\mongod.exe --config "D:\developer\env\MongoDB\mongod.cfg" --install

展示图片/arch_screen_40.png

  1. Команды, связанные со службой
启动服务：net start MongoDB
关闭服务：net stop MongoDB
移除服务：D:\developer\env\MongoDB\bin\mongod.exe --remove

  1. Скачайте клиентскую программу:скачать.RO Фильм NGO.org/1.2.1/wind O…

  2. Разархивируйте в указанный каталог, откройте robo3t.exe и подключитесь к localhost:27017.

展示图片/arch_screen_41.png

Spring Data Mongodb

Подобно Spring Data Elasticsearch, Spring Data Mongodb — это способ управления хранилищами данных в стиле Spring Data, который позволяет избежать написания большого количества шаблонного кода.

Общие аннотации

  • @Document: указывает объект домена, сопоставленный с документом MongoDB.
  • @Id: пометить домен как домен ID
  • @Indexed: указывает, что поле является индексным полем Mongodb.

Обработка данных с помощью Spring Data

Наследуйте интерфейс MongoRepository, чтобы получить общие методы обработки данных.

展示图片/arch_screen_42.png

Использование производных может поставить под сомнение

Вы можете запросить, напрямую указав имя метода запроса в интерфейсе, не реализуя его.Ниже приведен пример получения записей просмотра в обратном хронологическом порядке в соответствии с идентификатором участника.

/**
 * 会员商品浏览历史Repository
 * Created by macro on 2018/8/3.
 */
public interface MemberReadHistoryRepository extends MongoRepository<MemberReadHistory,String> {
    /**
     * 根据会员id按时间倒序获取浏览记录
     * @param memberId 会员id
     */
    List<MemberReadHistory> findByMemberIdOrderByCreateTimeDesc(Long memberId);
}

Соответствующее поле подскажет прямо в идее

展示图片/arch_screen_43.png

Используйте аннотацию @Query для запроса с оператором запроса Mongodb JSON.
@Query("{ 'memberId' : ?0 }")
List<MemberReadHistory> findByMemberId(Long memberId);

Интегрируйте MongoDB для реализации операций с документами

Добавьте связанные зависимости в pom.xml

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

Измените файл конфигурации SpringBoot.

Измените файл application.yml и добавьте конфигурацию, связанную с Mongodb, в узел spring:data.

mongodb:
  host: localhost # mongodb的连接地址
  port: 27017 # mongodb的连接端口号
  database: mall-port # mongodb的连接的数据库

Добавить объект документа записи просмотра участника MemberReadHistory

Добавьте аннотацию @Id в поле ID объекта документа и добавьте аннотацию @Indexed в поле, которое необходимо получить.

package com.macro.mall.tiny.nosql.mongodb.document;

import org.springframework.data.annotation.Id;
import org.springframework.data.mongodb.core.index.Indexed;
import org.springframework.data.mongodb.core.mapping.Document;

import java.util.Date;

/**
 * 用户商品浏览历史记录
 * Created by macro on 2018/8/3.
 */
@Document
public class MemberReadHistory {
    @Id
    private String id;
    @Indexed
    private Long memberId;
    private String memberNickname;
    private String memberIcon;
    @Indexed
    private Long productId;
    private String productName;
    private String productPic;
    private String productSubTitle;
    private String productPrice;
    private Date createTime;

    //省略了所有getter和setter方法

}

Добавьте интерфейс MemberReadHistoryRepository для работы с MongoDB.

Унаследуйте интерфейс MongoRepository, чтобы он имел некоторые основные методы манипулирования данными MongoDB и определял производный метод запроса.

package com.macro.mall.tiny.nosql.mongodb.repository;


import com.macro.mall.tiny.nosql.mongodb.document.MemberReadHistory;
import org.springframework.data.mongodb.repository.MongoRepository;

import java.util.List;

/**
 * 会员商品浏览历史Repository
 * Created by macro on 2018/8/3.
 */
public interface MemberReadHistoryRepository extends MongoRepository<MemberReadHistory,String> {
    /**
     * 根据会员id按时间倒序获取浏览记录
     * @param memberId 会员id
     */
    List<MemberReadHistory> findByMemberIdOrderByCreateTimeDesc(Long memberId);
}

Добавить интерфейс MemberReadHistoryService

package com.macro.mall.tiny.service;


import com.macro.mall.tiny.nosql.mongodb.document.MemberReadHistory;

import java.util.List;

/**
 * 会员浏览记录管理Service
 * Created by macro on 2018/8/3.
 */
public interface MemberReadHistoryService {
    /**
     * 生成浏览记录
     */
    int create(MemberReadHistory memberReadHistory);

    /**
     * 批量删除浏览记录
     */
    int delete(List<String> ids);

    /**
     * 获取用户浏览历史记录
     */
    List<MemberReadHistory> list(Long memberId);
}

Добавьте класс реализации интерфейса MemberReadHistoryService MemberReadHistoryServiceImpl.

package com.macro.mall.tiny.service.impl;

import com.macro.mall.tiny.nosql.mongodb.document.MemberReadHistory;
import com.macro.mall.tiny.nosql.mongodb.repository.MemberReadHistoryRepository;
import com.macro.mall.tiny.service.MemberReadHistoryService;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Service;

import java.util.ArrayList;
import java.util.Date;
import java.util.List;

/**
 * 会员浏览记录管理Service实现类
 * Created by macro on 2018/8/3.
 */
@Service
public class MemberReadHistoryServiceImpl implements MemberReadHistoryService {
    @Autowired
    private MemberReadHistoryRepository memberReadHistoryRepository;
    @Override
    public int create(MemberReadHistory memberReadHistory) {
        memberReadHistory.setId(null);
        memberReadHistory.setCreateTime(new Date());
        memberReadHistoryRepository.save(memberReadHistory);
        return 1;
    }

    @Override
    public int delete(List<String> ids) {
        List<MemberReadHistory> deleteList = new ArrayList<>();
        for(String id:ids){
            MemberReadHistory memberReadHistory = new MemberReadHistory();
            memberReadHistory.setId(id);
            deleteList.add(memberReadHistory);
        }
        memberReadHistoryRepository.deleteAll(deleteList);
        return ids.size();
    }

    @Override
    public List<MemberReadHistory> list(Long memberId) {
        return memberReadHistoryRepository.findByMemberIdOrderByCreateTimeDesc(memberId);
    }
}

Добавить интерфейс определения MemberReadHistoryController

package com.macro.mall.tiny.controller;

import com.macro.mall.tiny.common.api.CommonResult;
import com.macro.mall.tiny.nosql.mongodb.document.MemberReadHistory;
import com.macro.mall.tiny.service.MemberReadHistoryService;
import io.swagger.annotations.Api;
import io.swagger.annotations.ApiOperation;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Controller;
import org.springframework.web.bind.annotation.*;

import java.util.List;

/**
 * 会员商品浏览记录管理Controller
 * Created by macro on 2018/8/3.
 */
@Controller
@Api(tags = "MemberReadHistoryController", description = "会员商品浏览记录管理")
@RequestMapping("/member/readHistory")
public class MemberReadHistoryController {
    @Autowired
    private MemberReadHistoryService memberReadHistoryService;

    @ApiOperation("创建浏览记录")
    @RequestMapping(value = "/create", method = RequestMethod.POST)
    @ResponseBody
    public CommonResult create(@RequestBody MemberReadHistory memberReadHistory) {
        int count = memberReadHistoryService.create(memberReadHistory);
        if (count > 0) {
            return CommonResult.success(count);
        } else {
            return CommonResult.failed();
        }
    }

    @ApiOperation("删除浏览记录")
    @RequestMapping(value = "/delete", method = RequestMethod.POST)
    @ResponseBody
    public CommonResult delete(@RequestParam("ids") List<String> ids) {
        int count = memberReadHistoryService.delete(ids);
        if (count > 0) {
            return CommonResult.success(count);
        } else {
            return CommonResult.failed();
        }
    }

    @ApiOperation("展示浏览记录")
    @RequestMapping(value = "/list", method = RequestMethod.GET)
    @ResponseBody
    public CommonResult<List<MemberReadHistory>> list(Long memberId) {
        List<MemberReadHistory> memberReadHistoryList = memberReadHistoryService.list(memberId);
        return CommonResult.success(memberReadHistoryList);
    }
}

Проведите тестирование интерфейса

Добавить записи просмотра продуктов в MongoDB

展示图片/arch_screen_44.png
展示图片/arch_screen_45.png

Запросить записи просмотра продуктов в MongoDB

展示图片/arch_screen_46.png
展示图片/arch_screen_47.png

Адрес исходного кода проекта

GitHub.com/macro-positive/…

публика

Полный набор обучающих руководств для проекта торгового центра сериализуется.Обратите внимание на публичный аккаунтПолучите это прямо сейчас.

公众号图片

Категории