首页 / MONGODB / mall整合Mongodb实现文档操作

mall整合Mongodb实现文档操作

内容导读

互联网集市收集整理的这篇技术教程文章主要介绍了mall整合Mongodb实现文档操作，小编现在分享给大家，供广大互联网技能从业者学习和参考。文章包含7953字，纯文字阅读大概需要12分钟。

内容图文

文主要讲解mall整合Mongodb的过程，以实现商品浏览记录在Mongodb中的添加、删除、查询为例。

项目使用框架介绍

Mongodb

Mongodb是为快速开发互联网Web应用而构建的数据库系统，其数据模型和持久化策略就是为了构建高读/写吞吐量和高自动灾备伸缩性的系统。

Mongodb的安装和使用

1.下载Mongodb安装包，下载地址：https://fastdl.mongodb.org/win32/mongodb-win32-x86_64-2008plus-ssl-3.2.21-signed.msi

2.选择安装路径进行安装

mall整合Mongodb实现文档操作 - 文章图片

3.在安装路径下创建data\db和data\log两个文件夹

4.在安装路径下创建mongod.cfg配置文件

systemLog:    destination: file    path: D:\developer\env\MongoDB\data\log\mongod.logstorage:    dbPath: D:\developer\env\MongoDB\data\db

4.安装为服务（运行命令需要用管理员权限）

D:\developer\env\MongoDB\bin\mongod.exe --config "D:\developer\env\MongoDB\mongod.cfg" --install

5.服务相关命令

启动服务：net start MongoDB关闭服务：net stop MongoDB移除服务：D:\developer\env\MongoDB\bin\mongod.exe --remove

6.下载客户端程序：https://download.robomongo.org/1.2.1/windows/robo3t-1.2.1-windows-x86_64-3e50a65.zip

7.解压到指定目录，打开robo3t.exe并连接到localhost:27017

Spring Data Mongodb

和Spring Data Elasticsearch类似，Spring Data Mongodb是Spring提供的一种以Spring Data风格来操作数据存储的方式，它可以避免编写大量的样板代码。

常用注解

@Document:标示映射到Mongodb文档上的领域对象
@Id:标示某个域为ID域
@Indexed:标示某个字段为Mongodb的索引字段

Sping Data方式的数据操作

继承MongoRepository接口可以获得常用的数据操作方法

可以使用衍生查询

在接口中直接指定查询方法名称便可查询，无需进行实现，以下为根据会员id按时间倒序获取浏览记录的例子。

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

在idea中直接会提示对应字段

使用@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文件，在spring:data节点下添加Mongodb相关配置。

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

查询Mongodb中的商品浏览记录

mall整合Mongodb实现文档操作 - 文章图片

内容总结

以上是互联网集市为您收集整理的mall整合Mongodb实现文档操作全部内容，希望文章能够帮你解决mall整合Mongodb实现文档操作所遇到的程序开发问题。如果觉得互联网集市技术教程内容还不错，欢迎将互联网集市网站推荐给程序员好友。

内容备注

版权声明：本文内容由互联网用户自发贡献，该文观点与技术仅代表作者本人。本站仅提供信息存储空间服务，不拥有所有权，不承担相关法律责任。如发现本站有涉嫌侵权/违法违规的内容，请发送邮件至 gblab@vip.qq.com 举报，一经查实，本站将立刻删除。

内容手机端

扫描二维码推送至手机访问。

本文链接：https://qyyshop.com/info/865560.html

来源：【匿名】

【上一篇】Mongodb查询操作【下一篇】在MongoDB上如何进行数据的导入与导出

更多 ►

【mall整合Mongodb实现文档操作】教程文章相关的互联网学习教程文章

Mongodb使用shell实现与javascript的动态交互【图】

关于利用mongodb的shell执行脚本，这点在以前的文章中有点遗漏；现在在此篇博客中做个补充；一、在命令行中传入脚本文件定义一个javasciprt文件，名称为：script1.js，内容如下： print("I am albert shao in the script1.js") 定义另一个javascript文件，名称为script2,内容如下：print("I like to read and study") 在命令窗口运行得到如下结果：备注：脚本文件必须放到mongo的同目录文件下如果希望使用指定的主机和端口的mon...

Springboot集成MongoDB实现CRUD【代码】

特别提示：本人博客部分有参考网络其他博客，但均是本人亲手编写过并验证通过。如发现博客有错误，请及时提出以免误导其他人，谢谢！欢迎转载，但记得标明文章出处：http://www.cnblogs.com/mao2080/1、添加依赖1<dependency>2<groupId>org.springframework.boot</groupId>3<artifactId>spring-boot-starter-web</artifactId>4</dependency>5<dependency>6<groupId>org.springframework.boot</groupId>7<artifactId>spring-boot-st...

MongoDB 实现currentOp定时捕获【代码】

问题描述：当分析生产环境发生的性能问题时，常常因为没有实时的依据而无从下手。那么笔者通过捕获db.currentOp()到文件，并作为定时任务，可供后续分析。解决方法：步骤一：Shell脚本记录db.currentOp()1. 创建文件夹mkdir currentOp2.创建currentOp.sh#!/bin/sh MONGO=/usr/bin/mongo DATE=$(date +%Y%m%d%H%M) CURRENTOPFILE=/home/xucy/currentOp/$DATE $MONGO admin -uxucy –pPassw0rd --eval "rs.slaveOk();printjson(db....

图解 MongoDB 地理位置索引的实现原理【代码】

地理位置索引支持是MongoDB的一大亮点，这也是全球最流行的LBS服务foursquare 选择MongoDB的原因之一。我们知道，通常的数据库索引结构是B+ Tree，如何将地理位置转化为可建立B+Tree的形式，下文将为你描述。首先假设我们将需要索引的整个地图分成16×16的方格，如下图（左下角为坐标0,0 右上角为坐标16,16）：单纯的［x，y］的数据是无法建立索引的，所以MongoDB在建立索引的时候，会根据相应字段的坐标计算一个可以用来做索引的ha...

57-4 数据库分片概念及mongodb sharding的实现

04数据库分片的概念及mongodb sharding的实现配置环境：node1:192.168.1.121CentOS release 6.7node2:192.168.1.122CentOS release 6.7node3:192.168.1.123CentOS release 6.7[root@node1 ~]# vim /etc/hosts添加192.168.1.121 node1192.168.1.122 node2192.168.1.123 node3[root@node1 ~]# scp /etc/hosts node2:/etc[root@node1 ~]# scp /etc/hosts node3:/etc[root@node1 ~]# service mongod stop[root@node1 ~]# vim /et...

关于 MongoDB 与 SQL Server 通过本身自带工具实现数据快速迁移及注意事项的探究【图】

背景介绍随着业务的发展、需求的变化，促使我们追求使用不同类型的数据库，充分发挥其各自特性。如果决定采用新类型的数据库，就需要将既有的数据迁移到新的数据库中。在这类需求中，将SQL Server中的数据导入到MongoDB 中显得尤为突出。面对这种需求，大家优先想到的就是百度查找第三方工具，可惜截止目前，还没有一款公认比较满意的数据迁移工具。百度不到，大家可能就要回头自己开发了。如此，更是花费不少人力物力和宝贵的精力...

php实现Mongodb自定义方式生成自增ID的方法【代码】

本文实例讲述了php实现Mongodb自定义方式生成自增ID的方法。分享给大家供大家参考。具体分析如下：复制代码代码如下://首先创建一个自动增长id集合 ids >db.ids.save({name:"user", id:0}); //可以查看一下是否成功 > db.ids.find(); { "_id" : ObjectId("4c637dbd900f00000000686c"), "name" : "user", "id" : 0 } //然后每次添加新用户之前自增一下 ids集合获得id >userid = db.ids.findAndModify({update:{$inc:{‘id‘:1}}, ...

mongodb 实现关系型数据库中查询某一列的效果

最近在tornado\mongodb\ansiblemongodb中有个find()方法很牛逼,可以将集合中所有的表都传出来,一开始我这么写class Module_actionHandler(tornado.web.RequestHandler):def get(self, *args, **kwargs):coll = self.application.db.waitfishhosts = coll.find({}, {'hostname':1,"_id":0})modulenames = ['ping', 'setup', 'copy']self.render("module_action.html",hosts = hosts,modulenames = modulenames,) 然后在模板中: <sel...

实现多线程爬取数据并保存到mongodb【代码】

多线程爬取二手房网页并将数据保存到mongodb的代码：import pymongo import threading import timefrom lxml import etree import requests from queue import Queueindex_url=‘https://m.lianjia.com/gz/ershoufang/pg{}/‘ detail_url=‘https://m.lianjia.com{}‘# 设置爬取主页的页数 INDEX_PAGE_NUM=200# 定义一个类# 0定义主页url队列、主页html队列、详情页url队列、html队列、内容队列 # 1获取首页url并解析详情页url # 2...

使用mongodb作为Quartz.Net下的JobStore实现底层的持久化机制【代码】【图】

我们都知道默认的Quartz底层采用的是RAMJobStore，所有的Job,Trigger,Calendar都是用Dictionary,SortSet等等这样的数据结构进行储存，相对来说性能肯定快的没法说，但是面对灾难重启的时候还是很拿不出手的，而且都是全内存的，也没法实现多机器搭建Quartz集群，这一点还是很讨厌，虽然官方已经提供了一些关系性持久化存储方案，但面对如今这么火的nosql，不进行官方支持还是有点可惜，不过基于Quartz本身的插拔式设计，一切都不是...

MongoDB分片存储的集群架构实现【代码】

MongoDB分片存储的集群架构实现如果需要存储大量数据，或者系统的读写吞吐量很大的时候，单个server就很难满足需求了。这个时候我们可以使用MongoDB的分片机制来解决这些问题。分片的基本概念分片（sharding）是一种水平扩展（horizontal scaling）的方式，把一个大的数据集分散到多个片服务器上，所有的片服务器将组成一个逻辑上的数据库来存储这个大的数据集。分片对用户（应用层）是透明的，用户不会知道数据很被存放到哪个片...

python实现将excel数据添加到mongodb【代码】

利用pymongo包进行数据库的连接使用xlrd包读取excel数据，由于二者数据结构的不同，要将excel格式数据转换为json格式数据由于编码问题会出现“TypeError: ‘str‘ object does not support item assignment”要利用json.loads方法对数据进行解码#coding=utf-8import xlrd import sys import json import pymongo from pymongo import MongoClient#连接数据库 client=MongoClient(‘localhost‘,27017) db=client.scrapy account=db...

python实现连接mongodb的方法【代码】

本文实例讲述了python实现连接mongodb的方法。分享给大家供大家参考。具体分析如下：通过pymongo可以很容易的链接到mongodb，下面的代码链接到本地mongodb，数据库为mydb，并检索出mycollection中的所有数据输出，简单的几行代码已经做了很多事情 from pymongo import Connection connection = Connection(‘localhost‘, 27017) db = connection.mydb collection = db.mycollection for doc in collection.find():doc希望本文所述...

Mysql or Mongodb LBS快速实现方案

http://www.wubiao.info/470前两篇文章：查找附近的xxx 球面距离以及Geohash方案探讨（http://www.wubiao.info/372）微信、陌陌架构方案分析（http://www.wubiao.info/401）探讨了，LBS查找附近的XXX；其中包括了，Mysql自定义存储函数方案，以及通过GeoHash、redis自建索引方案。===============================================================今天分享两种，利用GeoHash封装成内置数据库函数的简易方案；A:Mysql 内置函数方...

express+vue+mongodb+session 实现注册登录【代码】【图】

上个月写了一篇文章是 express+mongodb+vue 实现增删改查. 只是简单的实现了增删改查功能，那么今天是在那个基础之上做了扩展，首先实现的功能有如下：1. 支持注册，登录功能，用户可以注册完成后，进行登录，登录完成后会进入到列表增删改查页面。2. 支持session会话，也就是说设置了多长时间登录过期，如果用户没有登录，直接进查询列表页面，会重定向到登录页面去，如果用户登录了后，把浏览器关掉，直接输入列表查询页面，会直...

首页 / MONGODB / mall整合Mongodb实现文档操作

mall整合Mongodb实现文档操作

内容导读

内容图文

项目使用框架介绍

Mongodb

Mongodb的安装和使用

Spring Data Mongodb

常用注解

Sping Data方式的数据操作

继承MongoRepository接口可以获得常用的数据操作方法

可以使用衍生查询

使用@Query注解可以用Mongodb的JSON查询语句进行查询

整合Mongodb实现文档操作

在pom.xml中添加相关依赖

修改SpringBoot配置文件

添加会员浏览记录文档对象MemberReadHistory

添加MemberReadHistoryRepository接口用于操作Mongodb

添加MemberReadHistoryService接口

添加MemberReadHistoryService接口实现类MemberReadHistoryServiceImpl

添加MemberReadHistoryController定义接口

进行接口测试

添加商品浏览记录到Mongodb

查询Mongodb中的商品浏览记录

内容总结

内容备注

内容手机端

【mall整合Mongodb实现文档操作】教程文章相关的互联网学习教程文章

MONGODB - 相关标签

文档 - 相关标签

MONGODB - 技术教程分类

MONGODB - 最新教程

MONGODB - 最热教程