mongodb-简单增删改查

一、安装和启动mongodb服务

1.下载mongodb 并解压 这里我解压到C:\developer\mongodb

2.进入MONGO_PATH 新建mongo.config文件 文件内容如下:

#放置数据的地址
dbpath=C:\developer\mongodb/data 
#放置运行日志文件的地址
logpath=C:\developer\mongodb/log/log.txt
#注册服务名
serviceName="MongoDB"

3.【管理员权限】运行cmd 进入C:\developer\mongodb\bin目录输入 

mongod --config C:\developer\mongodb\mongo.config --logappend --install

4.之后就可以在任何地方使用cmd命令 net start MongoDB 启动mongodb服务

5.或者不使用注册服务:mongod --dbpath C:\developer\mongodb\data2 --logpath C:\developer\mongodb\log\log2.txt --logappend --bind_ip 127.0.0.1 --port 27017

*注意不要关闭了cmd

6.■■■■■■■■■记得一定要用管理员权限启动■■■■■■■■■

二、CRUD（增删改查）

0.引入mongo-java-driver
<dependency>
<groupId>org.mongodb</groupId>
<artifactId>mongo-java-driver</artifactId>
<version>3.2.2</version>
</dependency>

// 1.连接数据库 需要指定数据库名称，如果指定的数据库不存在，mongo会自动创建数据库。
// 类似于创建并连接Mysql的数据库
@Test
public void conn(){
MongoDatabase mongoDatabase = mongoClient.getDatabase("mycol");
System.out.println("连接数据库成功");
}

// 2.创建集合
// 类似于创建mysql中的表
@Test
public void createCollection(){
// 连接数据库
MongoDatabase mongoDatabase = mongoClient.getDatabase("mycol");
System.out.println("连接数据库成功");

// 创建集合
mongoDatabase.createCollection("user");
System.out.println("集合创建成功");
}

// 3.获取集合  选中要操作的集合
// 类似于mysql中选中要操作的表
@Test 
public void getCollection(){
// 连接数据库
MongoDatabase mongoDatabase = mongoClient.getDatabase("mycol");
System.out.println("连接数据库成功");

// 选中要操作的集合
MongoCollection<Document> collection = mongoDatabase.getCollection("user");
System.out.println("集合 user 选择成功");
}

// 4.插入文档
// 类似于mysql执行数据库录入
// 注:在执行insert方法的时候,如果database中不存在对应的名为"user"的集合,则自动创建这个collection
@Test 
public void insertDocument() {
// 连接数据库
MongoDatabase mongoDatabase = mongoClient.getDatabase("mycol");
System.out.println("连接数据库成功");

// 选中要操作的集合
MongoCollection<Document> collection = mongoDatabase.getCollection("user");
System.out.println("集合 user 选择成功");
// 插入文档
//第一种插入方式:明文单次插入
Document document = new Document();
document.append("id", GeneratorKey.genaraId())
.append("userName", "leo1")
.append("userPass", "12345612")
.append("email", "595324626@qq.com");
collection.insertOne(document);
System.out.println(document);//执行insert过程中 document会自动赋予_id 作为ObjectId
System.out.println("文档插入成功");

}

//修改
@Test
public void updateDocument(){
// 连接数据库
MongoDatabase mongoDatabase = mongoClient.getDatabase("mycol");
System.out.println("连接数据库成功");

// 选中要操作的集合
MongoCollection<Document> collection = mongoDatabase.getCollection("user");
System.out.println("集合 user 选择成功");

collection.updateOne(Filters.ne("userName", "leo1"), new Document("$set", new Document("userName", "leo1211231213")));
// 检索查看结果
FindIterable<Document> findIterable = collection.find();
MongoCursor<Document> mongoCursor = findIterable.iterator();
while (mongoCursor.hasNext()) {
System.out.println(mongoCursor.next());
}
}