MongoDB

最近进行MongoDB开发，虽然需求比较简单，但是涉及较多的细节使用。加之不够熟悉 就使用了各种方法达到目标。

1.简介

MongoDB是一个基于分布式文件存储的数据库，一个介于关系数据库和非关系数据库之间的产品，是非关系数据库当中功能最丰富，最像关系数据库的。

MongoDB 将数据存储为一个文档，数据结构由键值(key=>value)对组成。MongoDB 文档类似于 JSON 对象。字段值可以包含其他文档，数组及文档数组。支持比较丰富和复杂的数据类型。

MongoDB已经在多个站点部署，其主要场景如下：

1）网站实时数据处理。它非常适合实时的插入、更新与查询，并具备网站实时数据存储所需的复制及高度伸缩性。

2）缓存。由于性能很高，它适合作为信息基础设施的缓存层。在系统重启之后，由它搭建的持久化缓存层可以避免下层的数据源过载。

3）高伸缩性的场景。非常适合由数十或数百台服务器组成的数据库，它的路线图中已经包含对MapReduce引擎的内置支持。

不适用的场景如下：

1）要求高度事务性的系统。

2）传统的商业智能应用。

3）复杂的跨文档（表）级联查询。

2.使用

连接和认证——方式一（ MongoClient ）

使用mongoclient的方式。MongoClient是线程安全的，可以在多程程环境中共享同一个MongoClient。通常来说，一个应用程序中，只需要生成一个全局的MongoClient实例，然后在程序的其他地方使用这个实例即可。

直接连接：

MongoClient mongoClient = new MongoClient("localhost", 27017); // 获取链接
MongoDatabase database = mongoClient.getDatabase("mydb"); // 获取数据库

认证与连接：

MongoClientOptions.Builder builder = MongoClientOptions.builder(); //可以通过builder做各种详细配置 MongoClientOptions myOptions = builder.build();

ArrayList<ServerAddress> serverAddressList = new ArrayList();

ServerAddress record = new ServerAddress("localhost", 27017); //IP、端口

serverAddressList.add(record); //用户名、默认库名、密码

MongoCredential credential = MongoCredential.createCredential("账号", "默认库名", "密码".toCharArray());

MongoClient mongoClient = new MongoClient(serverAddressList, credential, myOptions);

连接和认证——方式二（ MongoClientURI）

直接使用MongoClientURI完成MongoDB的认证，它代表了一个URI对象。MongoClientURI的构造函数接受一个String类型的字符串，这个字符串的格式如下：

String sURI = String.format(
“mongodb://%s:%s@%s:%d/%s”, ”用户名“, ”密码“, ”localhost“, 27017, ”数据库");
MongoClientURI uri = new MongoClientURI(sURI);

MongoClient mongoClient = new MongoClient(uri);

DB db = mongoClient.getDB(“数据库");

MongoClientOptions.Builder mongoBuilder = new MongoClientOptions.Builder(); mongoBuilder.maxWaitTime(1000603);

mongoBuilder.connectTimeout(6010003); //与数据库建立连接的timeout设置为1分钟 mongoBuilder.minConnectionsPerHost(1);

MongoClientURI mongoClientURI = new MongoClientURI(“mongodb://root:root@localhost:27017/数据库",mongoBuilder);

SimpleMongoDbFactory mongoDbFactory = new SimpleMongoDbFactory(mongoClientURI); MongoTemplate mongoTemplate = new MongoTemplate(mongoDbFactory);

连接和认证——方式三（ MongoTemplate）

public MongoClient mongoClient() {

MongoCredential credential = MongoCredential.createCredential(“用户”, "数据库", “password”);
return MongoClients.create(
MongoClientSettings.builder()
.applyToClusterSettings(builder ->
builder.applyConnectionString(new ConnectionString(serverList)))
.credential(credential)
.applicationName("应用")
.readConcern(ReadConcern.MAJORITY)
.readPreference(ReadPreference.primaryPreferred())
.writeConcern(WriteConcern.MAJORITY)
.applyToConnectionPoolSettings(builder -> {
builder
.maxWaitTime(1, TimeUnit.SECONDS)
.maxSize(10);
})
.applyToSocketSettings(builder -> builder
.connectTimeout(5, TimeUnit.SECONDS)
.readTimeout(5, TimeUnit.SECONDS))
.build());
}

public MongoTemplate mongoTemplate() {
return new MongoTemplate(mongoClient(), "数据库");
}

CRUD——方式一

基于注解的方式：

1.实体上使用 @Document(collection = ”UserDO")
2.继承MongoRepository，简单的增删改查无需实现，可直接使用

@Repository
public interface UserExtRepository extends MongoRepository<UserDO, String> {
List<UserDO> findById(String id);
}

xxRepository.insert(UserDO);

xxRepository. findBy(”11”);

Repositry接口
基础的 Repository提供了最基本的数据访问功能，其几个子接口则扩展了一些功能。它们的继承关系如下：

Repository：仅仅是一个标识，表明任何继承它的均为仓库接口类

CrudRepository：继承Repository，实现了一组CRUD相关的方法

PagingAndSortingRepository：继承CrudRepository，实现了一组分页排序相关的方法

JpaRepository：继承PagingAndSortingRepository，实现一组JPA规范相关的方法

自定义的XxxxRepository需要继承 JpaRepository，这样的XxxxRepository接口就具备了通用的数据访问控制层的能力。

JpaSpecificationExecutor：不属于Repository体系，实现一组JPACriteria查询相关的方法

CRUD——方式二

增：

MongoCollection<Document> collection = mongo.getDb(“database”).getCollection(“CollectionName”);
Document document = Document.parse(JSONObject.toJSONString(userDO));
collection.insertOne(document);

collection.insertMany(document);

删：

MongoCollection<Document> collection = mongo.getDb(database).getCollection(“collection”);
BasicDBObject queryObject = new BasicDBObject(”id“,”1111“);
collection.deleteOne(queryObject);

collection.deleteMany(queryObject);

改：

MongoCollection<Document> collection = mongo.getDb(“database”).getCollection(“collection”);
BasicDBObject queryObject = new BasicDBObject(“id”,“1111”);
BasicDBObject updateNewOneSql = new BasicDBObject(“$set”, new BasicDBObject(“name”, “tom”));
collection.updateOne(queryObject, updateNewOneSql);

collection. updateMany();

collection. findOneAndUpdate();

查：

MongoCollection<Document> collection = mongo.getDb(database).getCollection(“collection”);
BasicDBObject queryObject = new BasicDBObject(”id“,”1111“);
FindIterable<Document> documents = collection.find(queryObject);

other：

collection.aggregate();//聚合索引

collection.countDocuments();//统计

collection.createIndex(); collection. dropIndex(); //增加删除索引

collection.createIndexs(); collection. dropIndexs(); //批量增加删除索引

collection.replaceOne();//替换文档

collection.distinct();//返回具有指定字段不同值的文档（去除指定字段的重复数据）

collection.bulkWrite();//批量写入

collection.dataSize();//返回集合大小

collection.drop(); //删除集合

聚合查询：

BasicDBObject query= new BasicDBObject();

BasicDBObject[] array = { new BasicDBObject("time", new BasicDBObject("lte","2018-12-25"))};

query.append("$and", array);

BasicDBObject match = new BasicDBObject("$match", query); // match(相当于 WHERE 或者 HAVING )

BasicDBObject group = new BasicDBObject("subject") //group（相当于 GROUP BY）

.append("count", new BasicDBObject("$sum", 1)));

BasicDBObject sort = new BasicDBObject("$sort", new BasicDBObject("count", -1));//1:正序，-1倒序

BasicDBObject limit = new BasicDBObject("$limit", pageSize); //limt(只要前多少条数据，分页时使用)

BasicDBObject skip = new BasicDBObject("$skip", xx); //skip(跳过前面多少条数据，分页时使用)

List<DBObject> queryList = new ArrayList<>(); //queryList集合里的顺序不能乱，否则会报错。

queryList .add(match);

queryList .add(group);

queryList .add(sort);

queryList .add(skip);

queryList .add(limit);

AggregateIterable<Document> iterable = mongoClient.mongoClient.getDatabase(dbName).getCollection(gatherName).aggregate(queryList );

CRUD——分页查询

方式一：使用limit和skip进行分页find().skip((pageNum-1)*pageSize).sort().limit(pageSize)

方式二：通过原生的方法实现条件查询、分页和排序

方式三：通过实现Pageable接口等方式做自定义实现

find(索引).projection(查询字段).sort().limit()

image.png