kingecg
/
gomog
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity
gomog/internal/engine
History
程广 2841e31d84 ``` 
feat(database): 添加分页查询功能并完善适配器实现

- 在DatabaseAdapter接口中新增FindPage方法用于分页查询
- 实现PageResult结构体包含文档列表、是否有更多数据和总数
- 在BaseAdapter、DM8Adapter、PostgresAdapter和SQLiteAdapter中实现分页查询
- SQLite适配器现在正确检查集合是否存在和列出集合
- 调整CollectionExists方法返回nil而不是ErrNotImplemented

refactor(engine): 重构内存存储初始化策略

- 修改Initialize方法改为懒加载模式，不再一次性加载所有数据
- 添加Collection结构体的新字段：pageSize、loadedAll、totalCount
- 实现LoadCollectionPage方法支持按页加载数据
- 添加LoadEntireCollection和LazyLoadDocument方法
- 实现DocumentIterator用于文档遍历

feat(engine): 添加流式聚合执行功能

- 新增StreamAggregationOptions配置流式聚合参数
- 实现StreamExecute方法提供流式聚合能力
- 添加缓冲区大小、并发控制等选项

example: 添加流式聚合示例程序

- 创建stream_aggregate_example.go演示流式聚合用法
- 包含完整的测试数据创建和聚合管道执行流程
- 展示如何处理批量结果和错误通道

chore(config): 更新服务器TCP端口配置

- 将TCP监听地址从:27017更改为:28017
```
 		2026-03-18 15:36:58 +08:00
..
aggregate.go ``` 2026-03-18 15:36:58 +08:00
aggregate_batch2_test.go feat(engine): 实现 MongoDB 高级查询和更新功能 2026-03-13 21:12:26 +08:00
aggregate_batch3.go feat(engine): 实现MongoDB聚合管道第三批功能 2026-03-14 07:39:37 +08:00
aggregate_batch3_test.go feat(engine): 实现MongoDB聚合管道第三批功能 2026-03-14 07:39:37 +08:00
aggregate_batch5.go feat(engine): 实现聚合管道剩余阶段和增强存储功能 2026-03-14 12:20:41 +08:00
aggregate_batch5_test.go feat(engine): 实现聚合管道剩余阶段和增强存储功能 2026-03-14 12:20:41 +08:00
aggregate_helpers.go refactor(engine): 将辅助函数提取到独立文件并更新引用 2026-03-14 18:48:36 +08:00
aggregate_test.go refactor(engine): 移除聚合引擎中的测试辅助方法 2026-03-13 20:24:50 +08:00
benchmark_test.go feat(engine): 实现聚合管道剩余阶段和增强存储功能 2026-03-14 12:20:41 +08:00
bitwise_ops.go feat(engine): 添加类型转换和位运算操作符支持 2026-03-14 11:35:08 +08:00
bitwise_ops_test.go feat(engine): 添加类型转换和位运算操作符支持 2026-03-14 11:35:08 +08:00
concurrency_test.go feat(engine): 实现聚合管道剩余阶段和增强存储功能 2026-03-14 12:20:41 +08:00
crud.go fix(engine): 修复聚合引擎和查询引擎中的类型转换问题 2026-03-14 08:29:29 +08:00
crud_batch2_test.go feat(engine): 实现 MongoDB 高级查询和更新功能 2026-03-13 21:12:26 +08:00
crud_handler.go feat(engine): 实现数据库持久化功能并添加调试日志 2026-03-14 21:56:59 +08:00
date_ops.go feat(engine): 实现MongoDB聚合管道第三批功能 2026-03-14 07:39:37 +08:00
fuzz_test.go feat(engine): 实现聚合管道剩余阶段和增强存储功能 2026-03-14 12:20:41 +08:00
helpers.go refactor(engine): 将辅助函数提取到独立文件并更新引用 2026-03-14 18:48:36 +08:00
integration_batch2_test.go fix(tests): 修复测试代码中的编译错误和访问权限问题 2026-03-13 21:29:57 +08:00
memory_store.go ``` 2026-03-18 15:36:58 +08:00
memory_store_batch2_test.go feat(engine): 添加聚合引擎比较操作符支持并优化查询功能 2026-03-13 21:48:44 +08:00
operators.go refactor(engine): 将辅助函数提取到独立文件并更新引用 2026-03-14 18:48:36 +08:00
projection.go fix(engine): 修复聚合引擎和查询引擎中的类型转换问题 2026-03-14 08:29:29 +08:00
projection_test.go fix(engine): 修复聚合引擎和查询引擎中的类型转换问题 2026-03-14 08:29:29 +08:00
query.go fix(engine): 修复聚合引擎和查询引擎中的类型转换问题 2026-03-14 08:29:29 +08:00
query_batch2_test.go fix(engine): 修复聚合引擎和查询引擎中的类型转换问题 2026-03-14 08:29:29 +08:00
query_test.go fix(engine): 修复聚合引擎和查询引擎中的类型转换问题 2026-03-14 08:29:29 +08:00
stream_aggregate.go ``` 2026-03-18 15:36:58 +08:00
type_conversion.go refactor(engine): 将辅助函数提取到独立文件并更新引用 2026-03-14 18:48:36 +08:00
type_conversion_test.go feat(engine): 添加类型转换和位运算操作符支持 2026-03-14 11:35:08 +08:00