简介
MongoDB 是一个基于分布式文件存储的数据库。为 WEB 应用提供可扩展的高性能数据存储解决方案。
MongoDB 是一个介于关系数据库和非关系数据库之间的产品，是非关系数据库当中功能最丰富，最像关系数据库的。
MongoDB 属于NoSQL，而且是NoSQL数据库中文档存储方式的代表之一。Redis是NoSQL键值对的存储方式，HBase则是NoSQL列存储方式。
环境搭建
下载
MongoDB是一个服务，当然它也像Redis一样提供了相应的客户端。首先我们来下载它。MongoDB的官网是：http://www.mongodb.org/
可以到官网去下载，也可以直接下载zip版本:http://dl.mongodb.org/dl/win32/x86_64
我这里下载zip版本。
安装
1.随便找一个目录解压下载的zip
我这里解压到了 F:\software\install\mongodb\mongodb3.4
2.默认解压后，目录中没有data文件夹，我们创建一个data文件夹
3.然后在data文件夹中创建log、db两个子文件夹
4.最后在log中创建MongoDB.log文件
F:\software\install\mongodb\mongodb3.4\data
F:\software\install\mongodb\mongodb3.4\data\db
F:\software\install\mongodb\mongodb3.4\data\log
F:\software\install\mongodb\mongodb3.4\data\log\MongoDB.log
5.命令行安装
F:\software\install\mongodb\mongodb3.4\bin>mongod -dbpath "F:\software\install\mongodb\mongodb3.4\data\db"
安装完成之后打开http://127.0.0.1:27017/
看到
image.png
说明安装成功，并启动了MongoDB服务，监听了27017端口
image.png
测试
接下来我们可以运行bin目录下的 mongo.exe,启动MongoDB客户端连接服务并测试。
> db.foo.insert({ab:123}) //在默认数据库的foo表中插入一个文档对象{ab:123}
WriteResult({ "nInserted" : 1 })
> db.foo.find() //查找出foo表中所有数据
{ "_id" : ObjectId("5b1ceb2980af338114561451"), "ab" : 123 }
> db.foo.update({},{$unset:{"ab":""}},false,true) //删除刚刚插入的数据
WriteResult({ "nMatched" : 1, "nUpserted" : 0, "nModified" : 1 })
> db.foo.find()
{ "_id" : ObjectId("5b1ceb2980af338114561451") }
>
OK！至此，MongoDB安装成功。接下来我们配置一下数据库的用户名和密码。
创建数据库，并设置用户名和密码
>db //db 命令 --查看当前使用的数据库
test
> use mydb //使用 mydb 数据库（没有则自动创建）
switched to db mydb
> db.createUser({user:"yu",pwd:"yu123%abc",roles:[{role:"readWrite",db:"mydb"}]})
Successfully added user: {
"user" : "yu",
"roles" : [
{
"role" : "readWrite",
"db" : "mydb"
}
]
}
>
db.createUser()//创建当前数据库的用户
{
user:"yu", //用户名
pwd:"yu123%abc",//密码
roles:[
{
role: "readWrite", db: "mydb"//数据库读写权限
}
]
}
基本命令增删改查
1.增加(插入)
> db.student.insert({name:"zhangsan",age:22})
> db.student.insert({name:"李四",age:21})
2.查找
//查找所有
> db.student.find()
{ "_id" : ObjectId("5b1d01e880af338114561452"), "name" : "zhangsan", "age" : 22 }
{ "_id" : ObjectId("5b1d047e80af338114561453"), "name" : "李四", "age" : 21 }
//查找by对象ID
> db.student.find({"_id":ObjectId("5b1d01e880af338114561452")})
{ "_id" : ObjectId("5b1d01e880af338114561452"), "name" : "zhangsan", "age" : 22 }
3.更新
> db.student.update({"_id" : ObjectId("5b1d01e880af338114561452")},{"age":23,"name":"zhangsan"})
3.删除
> db.student.deleteOne({"_id":ObjectId("5b1d01e880af338114561452")})
{ "acknowledged" : true, "deletedCount" : 1 }
> db.student.find()
{ "_id" : ObjectId("5b1d047e80af338114561453"), "name" : "李四", "age" : 21 }
SpringBoot集成MongoDB
1.maven引入
<!--mongodb-->
<dependency>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-starter-data-mongodb</artifactId>
</dependency>
2.application.properties配置
#mongodb(uri中有%则用%25编码)配置连接服务的地址、用户名、密码
spring.data.mongodb.uri=mongodb://yu:yu123%25abc@127.0.0.1:27017/mydb
logging.level.org.springframework.data.mongodb=debug
3.新建Student实体类（文档类）
import java.util.Date;
import java.util.List;
public class Student {
private String id;
private String name;
private int age;
private List<String> friend;
private Date createDate;
private Date updateDate;
private int version=0;
//......省略setter、getter
}
4.新建MongoDBTestController(控制器类操作MongoDB增删改查)
import com.fasterxml.jackson.core.JsonProcessingException;
import com.mongodb.WriteResult;
import com.yu.scloud.baseframe.frame.model.Student;
import com.yu.scloud.baseframe.frame.utils.Util;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.data.mongodb.core.MongoTemplate;
import org.springframework.data.mongodb.core.query.Criteria;
import org.springframework.data.mongodb.core.query.Update;
import org.springframework.stereotype.Controller;
import org.springframework.web.bind.annotation.GetMapping;
import org.springframework.web.bind.annotation.PathVariable;
import org.springframework.web.bind.annotation.ResponseBody;
import java.util.Date;
import static org.springframework.data.mongodb.core.query.Criteria.where;
import static org.springframework.data.mongodb.core.query.Query.query;
@Controller
public class MongoDBTestController {
@Autowired
MongoTemplate mongoTemplate;
//插入Student对象
@GetMapping("/addstudent")
@ResponseBody
public String insertStudent(Student student)
{
student.setUpdateDate(new Date());
student.setVersion(1);
mongoTemplate.insert(student);
return "MongoDB插入成功";
}
//查询By name
@GetMapping("/getstudent/{name}")
@ResponseBody
public String getStudent(@PathVariable String name)
{
Criteria criteria=where("name").in(name);
List<Student> students=mongoTemplate.find(query(criteria),Student.class);
try {
return students.size()>0?"MongoDB查找成功:"+ Util.toJackson(students.get(0)):"未找到";
} catch (JsonProcessingException e) {
e.printStackTrace();
}
return "查询异常";
}
//更新By name
@GetMapping("/updatestudent/{name}")
@ResponseBody
public String updateStudent(@PathVariable String name)
{
Criteria criteria=where("name").in(name);
Update update=new Update();
update.inc("version",1);//设置更新自段自增
WriteResult result=mongoTemplate.updateFirst(query(criteria),update,Student.class);
return result.getN()>0?"MongoDB更新成功":"没有更新";
}
//删除By name
@GetMapping("/delstudent/{name}")
@ResponseBody
public String deleteStudent(@PathVariable String name)
{
Criteria criteria=where("name").in(name);
WriteResult result=mongoTemplate.remove(query(criteria),Student.class);
return result.getN()>0?"MongoDB删除成功":"没有删除";
}
}
访问以上控制器的增删改查接口，查看MongoDB返回的结果。这样我们就完成了SpringBoot集成MongoDB，并且使用MongoTemplate完成基本的操作。
配置MongoDB日志
logging.level.org.springframework.data.mongodb=debug
在 application.properties中配置日志级别，可以在控制台输出相应级别的日志。
网友评论