168 lines
4.6 KiB
Markdown
168 lines
4.6 KiB
Markdown
# MongoDB联查测试项目
|
||
|
||
一个简单的MongoDB多表联查测试项目，演示如何使用Spring Boot + MongoDB进行复杂的聚合查询。
|
||
|
||
## 功能特性
|
||
|
||
- **5表联查**：购物记录、用户、地址、产品、分类的复杂关联查询
|
||
- **动态条件**：支持多种查询条件的动态组合
|
||
- **分页查询**：使用MongoDB Facet操作实现高效分页
|
||
- **灵活排序**：支持多字段排序
|
||
|
||
## 技术栈
|
||
|
||
- Spring Boot 2.7.18
|
||
- Spring Data MongoDB
|
||
- Java 21
|
||
- Lombok
|
||
|
||
## 快速开始
|
||
|
||
### 1. 启动MongoDB
|
||
```bash
|
||
# 使用Docker
|
||
docker run -d -p 27017:27017 --name mongodb mongo:latest
|
||
|
||
# 或启动本地MongoDB
|
||
mongod --dbpath /path/to/your/db
|
||
```
|
||
|
||
### 2. 运行项目
|
||
```bash
|
||
mvn spring-boot:run
|
||
```
|
||
|
||
### 3. 测试接口
|
||
```bash
|
||
# 基本查询
|
||
curl "http://localhost:8080/test/search?phase=双十一&user=alice&page=0&size=10"
|
||
|
||
# 价格范围查询
|
||
curl "http://localhost:8080/test/search?minPrice=100&maxPrice=1000&page=0&size=10"
|
||
|
||
# 城市筛选
|
||
curl "http://localhost:8080/test/search?city=北京&category=电子产品&page=0&size=10"
|
||
```
|
||
|
||
## 数据模型
|
||
|
||
### 核心集合
|
||
- **shopping_record**: 购物记录（主表）
|
||
- **users**: 用户信息
|
||
- **address**: 地址信息
|
||
- **product**: 产品信息
|
||
- **categories**: 分类信息
|
||
- **shopping_phase**: 购物阶段
|
||
|
||
### 关联关系
|
||
```
|
||
shopping_record
|
||
├── userId -> users._id
|
||
├── productId -> product._id
|
||
├── shoppingPhaseId -> shopping_phase._id
|
||
└── users.addressId -> address._id
|
||
└── product.categoryId -> categories._id
|
||
```
|
||
|
||
## API接口
|
||
|
||
### 搜索购物记录
|
||
`GET /test/search`
|
||
|
||
**参数**:
|
||
- `phase`: 购物阶段名称
|
||
- `user`: 用户名模糊匹配
|
||
- `city`: 城市名称
|
||
- `category`: 分类名称
|
||
- `minPrice`: 最低价格
|
||
- `maxPrice`: 最高价格
|
||
- `page`: 页码（从0开始）
|
||
- `size`: 每页大小
|
||
- `sortField`: 排序字段
|
||
- `ascending`: 是否升序
|
||
|
||
**响应**:
|
||
```json
|
||
{
|
||
"success": true,
|
||
"data": [
|
||
{
|
||
"username": "alice",
|
||
"email": "alice@example.com",
|
||
"productName": "iPhone 15",
|
||
"price": 7999.00,
|
||
"categoryName": "电子产品"
|
||
}
|
||
],
|
||
"pagination": {
|
||
"page": 0,
|
||
"size": 10,
|
||
"total": 1,
|
||
"totalPages": 1,
|
||
"hasNext": false,
|
||
"hasPrevious": false
|
||
}
|
||
}
|
||
```
|
||
|
||
## 核心实现
|
||
|
||
### 聚合查询构建器
|
||
使用自定义的`MongoAggregationBuilder`构建复杂的聚合管道：
|
||
|
||
<augment_code_snippet path="src/main/java/org/example/mongosimple/service/ShoppingAggregationService.java" mode="EXCERPT">
|
||
````java
|
||
PageResult<ShoppingResult> result = MongoAggregationBuilder.fromWithCompatibility(mongoTemplate, "shopping_record")
|
||
// 关联所有需要的表
|
||
.lookupAndUnwind("shopping_phase", "shoppingPhaseId", "_id", "phase")
|
||
.lookupAndUnwind("users", "userId", "_id", "user")
|
||
.lookupAndUnwind("address", "user.addressId", "_id", "address")
|
||
.lookupAndUnwind("product", "productId", "_id", "product")
|
||
.lookupAndUnwind("categories", "product.categoryId", "_id", "category")
|
||
|
||
// 动态条件构建
|
||
.matchDynamic(criteria -> criteria
|
||
.whenNotEmpty(params.getPhaseName(), "phase.name")
|
||
.whenNotEmptyLike(params.getUsernamePattern(), "user.username")
|
||
.whenNotEmpty(params.getCity(), "address.city")
|
||
.whenRange(params.getMinPrice(), params.getMaxPrice(), "product.price")
|
||
)
|
||
|
||
// 投影和分页
|
||
.project(project -> project
|
||
.and("user.username").as("username")
|
||
.and("product.name").as("productName")
|
||
.and("product.price").as("price")
|
||
)
|
||
.sort(params.getSortField(), params.isAscending())
|
||
.executeWithPagination(ShoppingResult.class, params.getPage(), params.getSize());
|
||
````
|
||
</augment_code_snippet>
|
||
|
||
## 项目结构
|
||
|
||
```
|
||
src/main/java/org/example/mongosimple/
|
||
├── controller/ # REST控制器
|
||
├── service/ # 业务逻辑层
|
||
├── mongoObject/ # MongoDB文档实体
|
||
├── entity/ # 查询结果实体
|
||
└── prepareEntity/ # 查询构建工具类
|
||
```
|
||
|
||
## 开发说明
|
||
|
||
这是一个专注于MongoDB联查功能的测试项目，去除了复杂的缓存、监控、导出等功能，专注于核心的聚合查询实现。
|
||
|
||
适合用于：
|
||
- 学习MongoDB聚合查询
|
||
- 测试复杂的多表关联查询
|
||
- 验证查询性能和结果准确性
|
||
|
||
|
||
| 查询条件 | 是否命中复合索引 |
|
||
| -------------------------------------- | -------- |
|
||
| `{ user_id: ? }` | ✅（最左前缀） |
|
||
| `{ user_id: ?, shopping_phase_id: ? }` | ✅（完整索引） |
|
||
| `{ shopping_phase_id: ? }` | ❌（缺少最左） |
|