众所周知,MongoDB 是最早热门非关系数据库的之一,使用也比较普遍,一般会用做离线数据分析来使用,放到内网的居多。

MongoDB 简介

MongoDB(来自于英文单词“Humongous”,中文含义为“庞大”)是可以应用于各种规模的企业、各个行业以及各类应用程序的开源数据库。基于分布式文件存储的数据库。由C++语言编写。旨在为 WEB 应用提供可扩展的高性能数据存储解决方案。MongoDB 是一个高性能,开源,无模式的文档型数据库,是当前 NoSql 数据库中比较热门的一种。

MongoDB 是一个介于关系数据库和非关系数据库之间的产品,是非关系数据库当中功能最丰富,最像关系数据库的。他支持的数据结构非常松散,是类似 json 的 bjson 格式,因此可以存储比较复杂的数据类型。MongoDB 最大的特点是他支持的查询语言非常强大,其语法有点类似于面向对象的查询语言,几乎可以实现类似关系数据库单表查询的绝大部分功能,而且还支持对数据建立索引。

传统的关系数据库一般由数据库(database)、表(table)、记录(record)三个层次概念组成,MongoDB 是由数据库(database)、集合(collection)、文档对象(document)三个层次组成。MongoDB 对于关系型数据库里的表,但是集合中没有列、行和关系概念,这体现了模式自由的特点。

MongoDB 中的一条记录就是一个文档,是一个数据结构,由字段和值对组成。MongoDB 文档与 JSON 对象类似。字段的值有可能包括其它文档、数组以及文档数组。MongoDB 支持 OS X、Linux 及 Windows 等操作系统,并提供了 Python,PHP,Ruby,Java及 C++ 语言的驱动程序,社区中也提供了对 Erlang 及 .NET 等平台的驱动程序。

MongoDB 的适合对大量或者无固定格式的数据进行存储,比如:日志、缓存等。对事物支持较弱,不适用复杂的多文档(多表)的级联查询。

引用pow包:

<!-- 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.1.5.RELEASE</version> </dependency>

引用pom还是建议大家去官方Maven仓库下引用。地址https://mvnrepository.com,版本最新,安全有保障。

application.yml 配置中添加如下:

spring.data.mongodb.uri=mongodb://name:pass@localhost:27017/test
#多个 IP 集群:
spring.data.mongodb.uri=mongodb://user:pwd@ip1:port1,ip2:port2/database

配置MongoDB:

@Configuration
public class MongoConfig {

    @Bean
    public MappingMongoConverter mappingMongoConverter(MongoDbFactory factory, MongoMappingContext context, BeanFactory beanFactory) {
        DbRefResolver dbRefResolver = new DefaultDbRefResolver(factory);
        MappingMongoConverter mappingConverter = new MappingMongoConverter(dbRefResolver, context);
        try {
            mappingConverter.setCustomConversions(beanFactory.getBean(CustomConversions.class));
        } catch (NoSuchBeanDefinitionException ignore) {
        }

        // Don't save _class to mongo
        mappingConverter.setTypeMapper(new DefaultMongoTypeMapper(null));

        return mappingConverter;
    }
}

以下是员工订单派送、员工信息以及地理坐标的实体:

@Data
@Accessors(chain = true)
public class UserLocationEntity implements Serializable {
    private static final long serialVersionUID = -3258839839160856613L;

    private LocData loc;
    @ApiModelProperty(value = "服务时间 时间戳")
    private long startTime;
    @ApiModelProperty(value = "员工id")
    private int employeeId;
    @ApiModelProperty(value = "订单号  初始化地址默认订单号 为 “0”")
    private String billNo;
    @ApiModelProperty(value = "日期  时间戳")
    private long day;
    @ApiModelProperty(value = "手机")
    private String phone;
    @ApiModelProperty(value = "所属门店")
    private int storeId;
    @ApiModelProperty(value = "是否可谓队长")
    private boolean leader;
    @ApiModelProperty(value = "员工编号")
    private String no;
    @ApiModelProperty(value = "真实姓名")
    private String realName;
    @ApiModelProperty(value = "中文地址")
    private String addr;
    @ApiModelProperty(value = "是否自动派单的   false  标示否   true 标示 是")
    private boolean auto;
}

在这里,我们通过注入 mongoTemplate 对象,实现MongoDB 的增删该查:

MongoDB增删改查demo:

@Service
@Slf4j
public class OrderServiceImpl implements IBaseService, OrderService {
    @Autowired
    private MongoTemplate mongoTemplate;

    /**
     * 创建对象
     *
     * @param userLoc
     */
    @Override
    public void saveUserLoc(UserLocationEntity userLoc) {
        mongoTemplate.save(userLoc);
    }

    /**
     * 根据员工ID查询对象
     *
     * @param empId
     * @return
     */
    @Override
    public UserLocationEntity findUserById(Integer empId) {
        Query query = new Query(Criteria.where("employeeId").is(empId));
        UserLocationEntity userLoc = mongoTemplate.findOne(query, UserLocationEntity.class);
        return userLoc;
    }

    /**
     * 更新对象
     *
     * @param userLoc
     * @return
     */
    @Override
    public long updateUserLoc(UserLocationEntity userLoc) {
        Query query = new Query(Criteria.where("employeeId").is(userLoc.getEmployeeId()));
        Update update = new Update().set("addr", userLoc.getAddr()).set("startTime", System.currentTimeMillis());
        //更新查询返回结果集的第一条
        UpdateResult result = mongoTemplate.updateFirst(query, update, UserLocationEntity.class);
        //更新查询返回结果集的所有
        // mongoTemplate.updateMulti(query,update,UserEntity.class);
        return result.getMatchedCount();
    }

    /**
     * 删除对象
     *
     * @param empId
     */
    @Override
    public void deleteUserById(int empId) {
        Query query = new Query(Criteria.where("employeeId").is(empId));
        mongoTemplate.remove(query, UserLocationEntity.class);
    }
}

编写测试类,运行saveUserLoc方法,随便存储一些数据,在 NoSQLBooster for MongoDB 看到已经存储成功: