web开发 之 Spring + MongoDB

你想知道MongoDB是什么? 请移步官网, 本文不做解释

目录

安装MongoDB

brew install mongodb

运行mongodb

mongod --dbpath=/Users/yuanlin/Workspace/mongodb/

成功运行mongodb后, 最后看到的log应该是这样的

waiting for connections on port 27017

安装Robomongo

Robomongo是一个用于管理mongodb的图形化工具

下载安装后, 创建一个connection

《web开发 之 Spring + MongoDB》 spring+mongodb_01.png

connect mongodb之后, create database -> create collection -> insert document这些都是可以通过图形化操作完成的, 非常简单, 在此就不解释了

如果Robomongo连接失败, 请检查mongod是否正常运行, 以及端口等是否配置正确

创建SpringMongoDB工程

使用IntelliJ Idea创建Spring工程的详细流程可以参考上一篇文章《Spring + IntelliJ Idea》

New Project -> Spring Initializr -> 设置Name为SpringMongoDB, Type为Gradle Project

《web开发 之 Spring + MongoDB》 spring+mongodb_02.png

-> 接下来要注意的是, 在依赖配置里, 勾选Web和MongoDB, 如下图

《web开发 之 Spring + MongoDB》 spring+mongodb_03.png

-> 剩下的操作和上一篇文章《Spring + IntelliJ Idea》类似, 这里略过

由于使用Gradle编译, 而Gradle已经被墙, 所以你懂的

运行SpringMongoDB工程

仍然可以参考上一篇文章《Spring + IntelliJ Idea》

不过这里需要注意的问题是, 成功连接到mongodb之后的log是这样的

[           main] org.mongodb.driver.cluster               : Cluster created with settings equiredClusterType=UNKNOWN, serverSelectionTimeout='30000 ms', maxWaitQueueSize=500}
[localhost:27017] org.mongodb.driver.connection            : Opened connection [}] to localhost:27017
[localhost:27017] org.mongodb.driver.cluster               : Monitor thread successfully connected to server with description ServerDescription{address=localhost:27017, type=STANDALONE, state=CONNECTED, ok=true, version=ServerVersion{versionList=[3, 2, 6]}, minWireVersion=0, maxWireVersion=4, maxDocumentSize=16777216, roundTripTimeNanos=742451}

如果运行工程后出现连接失败的log, 那么请检查mongodb是否成功运行

以及端口是否被修改过, 因为工程现在使用的是默认端口和配置

这里你或许会很好奇, 我还没有写一行代码或做任何配置, 数据库居然都已经连接成功了?

是的, Spring就是这么”傻瓜”!

添加请求接口

我们先添加两个接口, 这两个接口只返回String信息以确认连接成功, 其中Method=GET

package com.example;

import org.springframework.web.bind.annotation.RequestMapping;
import org.springframework.web.bind.annotation.RequestMethod;
import org.springframework.web.bind.annotation.ResponseBody;
import org.springframework.web.bind.annotation.RestController;

@RestController
public class MongoDBController {

    @RequestMapping(value = "insert", method = RequestMethod.GET)
    @ResponseBody
    public String insert() {
        return "insert";
    }

    @RequestMapping(value = "all", method = RequestMethod.GET)
    @ResponseBody
    public String all() {
        return "all";
    }

}

测试成功结果如下

《web开发 之 Spring + MongoDB》 spring+mongodb_04.png
《web开发 之 Spring + MongoDB》 spring+mongodb_05.png

如果你对MongoDBController的代码有疑问, 请参考上一篇文章《Spring + IntelliJ Idea》

添加Customer Bean

为了后面的DB操作, 这里我们先创建一个Customer Bean如下

package com.example;

import org.springframework.data.annotation.Id;

public class Customer {

    @Id
    private String id;

    private String firstName;
    private String lastName;

    public Customer() {}
    
    public Customer(String firstName, String lastName) {
        this.firstName = firstName;
        this.lastName = lastName;
    }

    @Override
    public String toString() {
        return String.format("Customer[id=%s, firstName='%s', lastName='%s']", id, firstName, lastName);
    }

}

代码也是非常简单的, 就不废话了

添加数据库操作

铺垫了半天, 总算是切入正题了!

通常情况下, 这时候我们就要开始编写保存, 读取数据到数据库的代码了

不过MongoDB为我们提供了一种更便捷的方式去实现数据库操作: MongoRepository

我们只要定义类继承自该接口, 无需实现里面的方法

这么强大, 这么方便, 是不是迫不及待想要瞧瞧代码了?

package com.example;

import java.util.List;

import org.springframework.data.mongodb.repository.MongoRepository;

public interface CustomerRepository extends MongoRepository<Customer, String> {

    Customer save(Customer customer);
    List<Customer> findAll();

}

代码还是非常简单, 以致于没有解释的必要了

这种只定义接口, 由框架根据定义的接口规则自动生成其实现的原理就叫做: Dynamic Proxy

关于Dynamic Proxy的更多介绍, 请参考设计模式 之 Proxy

当今Android平台开发中, 最火热的网络库Retrofit也是同样的原理

可能你和我一样, 仍然”耿耿于怀”: 操作数据库的实现这么容易就搞定了?!

不信, 我们就来测试下吧, 在请求接口中添加保存和读取数据库的代码如下

@RestController
public class MongoDBController {

    @Autowired
    private CustomerRepository repository;

    @RequestMapping(value = "insert", method = RequestMethod.GET)
    @ResponseBody
    public String insert() {
        repository.save(new Customer("xiao", "ming"));
        return "insert";
    }

    @RequestMapping(value = "all", method = RequestMethod.GET)
    @ResponseBody
    public String all() {
        for (Customer customer : repository.findAll()) {
            System.out.println(customer);
        }
        return "all";
    }

}

这时候不要忘记重新运行SpringMongoDB工程, 已使最新的修改生效!

接下来在浏览器中访问”/insert”接口, 没什么变化?

别急, 这时候Robomongo就派上用处了

打开Robomongo中的Test Database查看数据, 发现多了一条新的Customer

《web开发 之 Spring + MongoDB》 spring+mongodb_06.png

这时候再在浏览器中访问”/all”接口, 发现这时候idea的log中打印信息如下

Customer[id=57b1d2dff81e0217b788d70d, firstName='xiao', lastName='ming']

这说明findAll也是可以正常工作的

一切都是如此的简单, 顺滑, 大家再也不用担心服务器开发了

配置数据库

这次的讨论到这里本来是可以告一段落的, 但是有个问题大家或许会很关心

上述所有的配置都是基于默认的, 我们能不能自定义数据库的配置呢?

答案当然是yes

下面我们就来看看如何配置mongodb端口, 并自定义数据库名称

首先, 需要重新运行mongodb, 并且配置数据库的端口

mongod --dbpath=/Users/yuanlin/Workspace/mongodb --port 9090

接着, 在代码中根据mongodb运行时的端口号做相应的配置

package com.example;

import com.mongodb.Mongo;
import org.springframework.context.annotation.Configuration;
import org.springframework.data.mongodb.config.AbstractMongoConfiguration;

@Configuration
public class MongoDBConfig extends AbstractMongoConfiguration {

    @Override
    public Mongo mongo() throws Exception {
        return new Mongo("localhost", 9090);
    }

    @Override
    protected String getDatabaseName() {
        return "SpringMongoDB";
    }

}

同样, 我们只需要继承AbstractMongoConfiguration即可快速是实现mongodb的配置

注意这里的database name被设置成了”SpringMongoDB”

老规矩, 重新运行SpringMongoDB工程, 以使修改生效

再次访问”/insert”接口成功后, 打开Robomongo查看数据库信息

《web开发 之 Spring + MongoDB》 spring+mongodb_07.png

Robomongo connection同样需要修改端口号从默认值为9090

Bingo, 数据库配置成功!

小结

以上就是一个iOS&Android终端开发工程师对Spring的进一步了解了

解决了Spring和DB的问题, 下一步打算探讨下Spring和Web开发中常用的第三方库, 敬请期待!

更多文章, 请支持我的个人博客

    原文作者:诺之林
    原文地址: https://www.jianshu.com/p/9a8c4605068c
    本文转自网络文章,转载此文章仅为分享知识,如有侵权,请联系博主进行删除。
点赞