feat: 更新内存驱动，添加流式查找和合并功能，优化查询参数

Author: hotlong

packages/driver-memory/src/memory-driver.ts

@@ -26,13 +26,15 @@ export class InMemoryDriver implements DriverInterface {
     queryFilters: false,         // TODO: Not implemented - basic find() doesn't handle filters
     queryAggregations: false,    // TODO: Not implemented - count() only returns total
     querySorting: false,         // TODO: Not implemented - find() doesn't handle sorting
-    queryPagination: true,       // Basic pagination via 'top' is implemented
+    queryPagination: true,       // Basic pagination via 'limit' is implemented
     queryWindowFunctions: false, // TODO: Not implemented
     querySubqueries: false,      // TODO: Not implemented
     joins: false,                // TODO: Not implemented
 
     // Advanced Features
     fullTextSearch: false,       // TODO: Not implemented
+    vectorSearch: false,         // TODO: Not implemented
+    geoSpatial: false,           // TODO: Not implemented
     jsonFields: true,            // Native JS object support
     arrayFields: true,           // Native JS array support
   };
@@ -79,15 +81,22 @@ export class InMemoryDriver implements DriverInterface {
     let results = [...table];
 
     // Simple limiting for demonstration
-    if (query.top) {
-      results = results.slice(0, query.top);
+    if (query.limit) {
+      results = results.slice(0, query.limit);
     }
 
     return results;
   }
 
+  async *findStream(object: string, query: QueryInput, options?: DriverOptions) {
+    const results = await this.find(object, query, options);
+    for (const record of results) {
+      yield record;
+    }
+  }
+
   async findOne(object: string, query: QueryInput, options?: DriverOptions) {
-    const results = await this.find(object, { ...query, top: 1 }, options);
+    const results = await this.find(object, { ...query, limit: 1 }, options);
     return results[0] || null;
   }
 
@@ -124,6 +133,23 @@ export class InMemoryDriver implements DriverInterface {
     return updatedRecord;
   }
 
+  async upsert(object: string, data: Record<string, any>, conflictKeys?: string[], options?: DriverOptions) {
+    const table = this.getTable(object);
+    let existingRecord: any = null;
+
+    if (data.id) {
+        existingRecord = table.find(r => r.id === data.id);
+    } else if (conflictKeys && conflictKeys.length > 0) {
+        existingRecord = table.find(r => conflictKeys.every(key => r[key] === data[key]));
+    }
+
+    if (existingRecord) {
+        return this.update(object, existingRecord.id, data, options);
+    } else {
+        return this.create(object, data, options);
+    }
+  }
+
   async delete(object: string, id: string | number, options?: DriverOptions) {
     const table = this.getTable(object);
     const index = table.findIndex(r => r.id == id);

packages/objectql/src/index.ts

@@ -1,5 +1,6 @@
 import { QueryAST } from '@objectstack/spec/data';
-import { DriverInterface, DriverOptions, ObjectStackManifest } from '@objectstack/spec/system';
+import { ObjectStackManifest } from '@objectstack/spec/system';
+import { DriverInterface, DriverOptions } from '@objectstack/spec/driver';
 import { SchemaRegistry } from './registry';
 
 // Export Registry for consumers
@@ -158,9 +159,9 @@ export class ObjectQL {
        object, // Add missing required field
        // Pass through if it looks like AST, otherwise empty
        // In this demo, we assume the caller passes a simplified object or raw AST
-       filters: filters.filters || undefined,
-       top: filters.top || 100,
-       sort: filters.sort || []
+       where: filters.filters || filters.where || undefined,
+       limit: filters.limit || filters.top || 100,
+       orderBy: filters.orderBy || filters.sort || []
     };
 
     return driver.find(object, ast, options);

packages/spec/package.json

@@ -9,14 +9,14 @@
       "types": "./dist/index.d.ts",
       "default": "./dist/index.js"
     },
+    "./driver": {
+        "types": "./dist/driver/index.d.ts",
+        "default": "./dist/driver/index.js"
+    },
     "./data": {
       "types": "./dist/data/index.d.ts",
       "default": "./dist/data/index.js"
     },
-    "./ui": {
-      "types": "./dist/ui/index.d.ts",
-      "default": "./dist/ui/index.js"
-    },
     "./system": {
       "types": "./dist/system/index.d.ts",
       "default": "./dist/system/index.js"
@@ -25,9 +25,17 @@
       "types": "./dist/ai/index.d.ts",
       "default": "./dist/ai/index.js"
     },
+    "./automation": {
+      "types": "./dist/automation/index.d.ts",
+      "default": "./dist/automation/index.js"
+    },
     "./api": {
       "types": "./dist/api/index.d.ts",
       "default": "./dist/api/index.js"
+    },
+    "./ui": {
+      "types": "./dist/ui/index.d.ts",
+      "default": "./dist/ui/index.js"
     }
   },
   "files": [