web开发 之 Spring + MongoDB

2017-01-14 10:24:28来源:http://www.jianshu.com/p/9a8c4605068c作者:诺之林_人点击

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


目录

安装MongoDB



安装Robomongo



创建SpringMongoDB工程



运行SpringMongoDB工程



添加请求接口



添加Customer-Bean



添加数据库操作



配置数据库



小结



安装MongoDB
brew install mongodb

运行mongodb


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

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


waiting for connections on port 27017

安装Robomongo

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


下载安装后, 创建一个connection



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



spring+mongodb_02.png

-> 接下来要注意的是, 在依赖配置里, 勾选Web和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";
}
}

测试成功结果如下



spring+mongodb_04.png


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



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查看数据库信息



spring+mongodb_07.png

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


Bingo, 数据库配置成功!


小结

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


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


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




最新文章

123

最新摄影

微信扫一扫

第七城市微信公众平台