添加 ObjectQL 引擎实现，集成内存驱动，更新相关配置和文档

Author: hotlong

examples/objectql/package.json

@@ -0,0 +1,17 @@
+{
+  "name": "@objectstack/objectql",
+  "version": "0.0.1",
+  "description": "ObjectQL Reference Implementation",
+  "main": "dist/index.js",
+  "types": "dist/index.d.ts",
+  "scripts": {
+    "build": "tsc",
+    "dev": "tsc -w"
+  },
+  "dependencies": {
+    "@objectstack/spec": "workspace:*"
+  },
+  "devDependencies": {
+    "typescript": "^5.0.0"
+  }
+}

examples/objectql/src/index.ts

@@ -0,0 +1,71 @@
+import { DriverInterface, DriverOptions, QueryAST } from '@objectstack/spec';
+
+/**
+ * ObjectQL Engine
+ * 
+ * The core orchestration layer that sits between the API/UI and the Data Driver.
+ * It handles:
+ * 1. Request Validation (using Schemas)
+ * 2. Security Enforcement (ACLs, Sharing Rules)
+ * 3. Workflow Triggers
+ * 4. Driver Delegation
+ */
+export class ObjectQL {
+  constructor(private driver: DriverInterface) {
+    console.log(`[ObjectQL] Initialized with driver: ${driver.name} v${driver.version}`);
+  }
+
+  /**
+   * Initialize the engine
+   */
+  async init() {
+    await this.driver.connect();
+    // In a real app, we would sync schemas here
+  }
+
+  async destroy() {
+    await this.driver.disconnect();
+  }
+
+  // ============================================
+  // Data Access Methods
+  // ============================================
+
+  async find(object: string, filters: any = {}, options?: DriverOptions) {
+    console.log(`[ObjectQL] Finding ${object}...`);
+    
+    // Transform simplified filters to QueryAST
+    // This is a simplified "Mock" transform. 
+    // Real implementation would parse complex JSON or FilterBuilders.
+    const ast: QueryAST = {
+       // 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 || []
+    };
+
+    return this.driver.find(object, ast, options);
+  }
+
+  async insert(object: string, data: Record<string, any>, options?: DriverOptions) {
+    console.log(`[ObjectQL] Creating ${object}...`);
+    // 1. Validate Schema
+    // 2. Run "Before Insert" Triggers
+    
+    const result = await this.driver.create(object, data, options);
+    
+    // 3. Run "After Insert" Triggers
+    return result;
+  }
+
+  async update(object: string, id: string, data: Record<string, any>, options?: DriverOptions) {
+    console.log(`[ObjectQL] Updating ${object} ${id}...`);
+    return this.driver.update(object, id, data, options);
+  }
+
+  async delete(object: string, id: string, options?: DriverOptions) {
+    console.log(`[ObjectQL] Deleting ${object} ${id}...`);
+    return this.driver.delete(object, id, options);
+  }
+}

examples/objectql/tsconfig.json

@@ -0,0 +1,13 @@
+{
+  "compilerOptions": {
+    "target": "ES2020",
+    "module": "commonjs",
+    "declaration": true,
+    "outDir": "./dist",
+    "strict": true,
+    "esModuleInterop": true,
+    "skipLibCheck": true,
+    "forceConsistentCasingInFileNames": true
+  },
+  "include": ["src/**/*"]
+}

examples/plugin-driver-memory/src/index.ts

@@ -1,5 +1,7 @@
 import { InMemoryDriver } from './memory-driver';
 
+export { InMemoryDriver }; // Export class for direct usage
+
 // Note: In a real environment, you would import these from @objectstack/spec
 // But distinct PluginDefinition interface might not be strictly defined in schema yet, 
 // usually it mimics the Manifest structure + runtime hooks.

examples/server/package.json

@@ -11,6 +11,8 @@
     "@objectstack/example-crm": "workspace:*",
     "@objectstack/example-todo": "workspace:*",
     "@objectstack/plugin-bi": "workspace:*",
+    "@objectstack/objectql": "workspace:*",
+    "@objectstack/plugin-driver-memory": "workspace:*",
     "hono": "^4.0.0",
     "@hono/node-server": "^1.0.0",
     "zod": "^3.0.0"

examples/server/src/kernel/engine.ts

@@ -1,23 +1,48 @@
 import { ServiceObject } from '@objectstack/spec';
 import { SchemaRegistry } from './registry';
-
-// Simple in-memory storage for demonstration
-const MEMORY_DB: Record<string, any[]> = {};
+import { InMemoryDriver } from '@objectstack/plugin-driver-memory';
+import { ObjectQL } from '@objectstack/objectql';
 
 export class DataEngine {
+  private ql: ObjectQL;
+
+  constructor() {
+    // In a real startup sequence, driver choice involves config loading
+    const driver = new InMemoryDriver();
+    this.ql = new ObjectQL(driver);
+    this.ql.init().catch(console.error);
+    
+    // Seed some data for demo
+    this.seed();
+  }
+
+  async seed() {
+    await this.ql.insert('SystemStatus', { status: 'OK', uptime: 0 });
+  }
 
   async find(objectName: string, query: any) {
     this.ensureSchema(objectName);
-    const records = MEMORY_DB[objectName] || [];
-    // In real world: Implement parsing of `query` (filter, sort, page)
+    
+    // Delegate to ObjectQL
+    const results = await this.ql.find(objectName, { top: 100 });
+    
     return {
-      value: records,
-      count: records.length
+      value: results,
+      count: results.length
     };
   }
 
   async get(objectName: string, id: string) {
     this.ensureSchema(objectName);
+    // Find One not fully implemented in engine wrapper yet, using find as mock
+    const results = await this.ql.find(objectName, { top: 1 });
+    return results[0];
+  }
+
+  async create(objectName: string, data: any) {
+     this.ensureSchema(objectName);
+     return this.ql.insert(objectName, data);
+  }
     const records = MEMORY_DB[objectName] || [];
     const record = records.find(r => r._id === id);
     if (!record) throw new Error(`Record not found: ${id}`);