重构 ObjectQL 引擎以支持多个存储驱动，更新驱动注册和初始化逻辑

Author: hotlong

examples/objectql/src/index.ts

@@ -11,28 +11,70 @@ import { DriverInterface, DriverOptions, QueryAST } from '@objectstack/spec';
  * 4. Driver Delegation
  */
 export class ObjectQL {
-  constructor(private driver: DriverInterface) {
-    console.log(`[ObjectQL] Initialized with driver: ${driver.name} v${driver.version}`);
+  private drivers = new Map<string, DriverInterface>();
+  private defaultDriver: string | null = null;
+
+  constructor() {
+    console.log(`[ObjectQL] Engine Instance Created`);
+  }
+
+  /**
+   * Register a new storage driver
+   */
+  registerDriver(driver: DriverInterface, isDefault: boolean = false) {
+    if (this.drivers.has(driver.name)) {
+      console.warn(`[ObjectQL] Driver ${driver.name} is already registered. Skipping.`);
+      return;
+    }
+
+    this.drivers.set(driver.name, driver);
+    console.log(`[ObjectQL] Registered driver: ${driver.name} v${driver.version}`);
+
+    if (isDefault || this.drivers.size === 1) {
+      this.defaultDriver = driver.name;
+    }
+  }
+
+  /**
+   * Helper to get the target driver
+   */
+  private getDriver(object: string): DriverInterface {
+    // TODO: Look up Object definition to see if it specifies a specific datasource/driver
+    // For now, always return default
+    if (!this.defaultDriver) {
+      throw new Error('[ObjectQL] No drivers registered!');
+    }
+    return this.drivers.get(this.defaultDriver)!;
   }
 
   /**
-   * Initialize the engine
+   * Initialize the engine and all registered drivers
    */
   async init() {
-    await this.driver.connect();
+    console.log('[ObjectQL] Initializing drivers...');
+    for (const [name, driver] of this.drivers) {
+      try {
+        await driver.connect();
+      } catch (e) {
+        console.error(`[ObjectQL] Failed to connect driver ${name}`, e);
+      }
+    }
     // In a real app, we would sync schemas here
   }
 
   async destroy() {
-    await this.driver.disconnect();
+    for (const driver of this.drivers.values()) {
+      await driver.disconnect();
+    }
   }
 
   // ============================================
   // Data Access Methods
   // ============================================
 
   async find(object: string, filters: any = {}, options?: DriverOptions) {
-    console.log(`[ObjectQL] Finding ${object}...`);
+    const driver = this.getDriver(object);
+    console.log(`[ObjectQL] Finding ${object} on ${driver.name}...`);
 
     // Transform simplified filters to QueryAST
     // This is a simplified "Mock" transform. 
@@ -45,27 +87,30 @@ export class ObjectQL {
        sort: filters.sort || []
     };
 
-    return this.driver.find(object, ast, options);
+    return driver.find(object, ast, options);
   }
 
   async insert(object: string, data: Record<string, any>, options?: DriverOptions) {
-    console.log(`[ObjectQL] Creating ${object}...`);
+    const driver = this.getDriver(object);
+    console.log(`[ObjectQL] Creating ${object} on ${driver.name}...`);
     // 1. Validate Schema
     // 2. Run "Before Insert" Triggers
 
-    const result = await this.driver.create(object, data, options);
+    const result = await driver.create(object, data, options);
 
     // 3. Run "After Insert" Triggers
     return result;
   }
 
   async update(object: string, id: string, data: Record<string, any>, options?: DriverOptions) {
+    const driver = this.getDriver(object);
     console.log(`[ObjectQL] Updating ${object} ${id}...`);
-    return this.driver.update(object, id, data, options);
+    return driver.update(object, id, data, options);
   }
 
   async delete(object: string, id: string, options?: DriverOptions) {
+    const driver = this.getDriver(object);
     console.log(`[ObjectQL] Deleting ${object} ${id}...`);
-    return this.driver.delete(object, id, options);
+    return driver.delete(object, id, options);
   }
 }

examples/server/src/kernel/engine.ts

@@ -7,9 +7,15 @@ 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 = new ObjectQL();
+
+    // 1. Initialize Driver (Usually loaded from plugins or config)
+    const memoryDriver = new InMemoryDriver();
+
+    // 2. Register Driver to Engine
+    this.ql.registerDriver(memoryDriver, true); // Set as default
+
+    // 3. Start Engine
     this.ql.init().catch(console.error);
 
     // Seed some data for demo