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
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开发中常用的第三方库, 敬请期待!
更多文章, 请支持我的个人博客
