将 KnexDriver 测试用例中的主键字段更改为 '_id'，并添加 Schema 同步测试用例以验证表和列的创建与更新

Author: hotlong

packages/driver-knex/test/index.test.ts

@@ -17,16 +17,16 @@ describe('KnexDriver (SQLite Integration)', () => {
         const k = (driver as any).knex;
 
         await k.schema.createTable('users', (t: any) => {
-            t.increments('id');
+            t.string('_id').primary();
             t.string('name');
             t.integer('age');
         });
 
         await k('users').insert([
-            { name: 'Alice', age: 25 },
-            { name: 'Bob', age: 17 },
-            { name: 'Charlie', age: 30 },
-            { name: 'Dave', age: 17 }
+            { _id: '1', name: 'Alice', age: 25 },
+            { _id: '2', name: 'Bob', age: 17 },
+            { _id: '3', name: 'Charlie', age: 30 },
+            { _id: '4', name: 'Dave', age: 17 }
         ]);
     });
 
@@ -71,7 +71,7 @@ describe('KnexDriver (SQLite Integration)', () => {
         const [alice] = await driver.find('users', { filters: [['name', '=', 'Alice']] });
         expect(alice).toBeDefined();
 
-        const fetched = await driver.findOne('users', alice.id);
+        const fetched = await driver.findOne('users', alice._id);
         expect(fetched).toBeDefined();
         expect(fetched.name).toBe('Alice');
     });
@@ -87,17 +87,17 @@ describe('KnexDriver (SQLite Integration)', () => {
 
     it('should update an object', async () => {
         const [bob] = await driver.find('users', { filters: [['name', '=', 'Bob']] });
-        await driver.update('users', bob.id, { age: 18 });
+        await driver.update('users', bob._id, { age: 18 });
 
-        const updated = await driver.findOne('users', bob.id);
+        const updated = await driver.findOne('users', bob._id);
         expect(updated.age).toBe(18);
     });
 
     it('should delete an object', async () => {
         const [charlie] = await driver.find('users', { filters: [['name', '=', 'Charlie']] });
-        await driver.delete('users', charlie.id);
+        await driver.delete('users', charlie._id);
 
-        const deleted = await driver.findOne('users', charlie.id);
+        const deleted = await driver.findOne('users', charlie._id);
         expect(deleted).toBeUndefined();
     });
 

packages/driver-knex/test/schema.test.ts

@@ -0,0 +1,117 @@
+import { KnexDriver } from '../src';
+
+describe('KnexDriver Schema Sync (SQLite)', () => {
+    let driver: KnexDriver;
+    let knexInstance: any;
+
+    beforeEach(async () => {
+        // Init ephemeral in-memory database
+        driver = new KnexDriver({
+            client: 'sqlite3',
+            connection: {
+                filename: ':memory:'
+            },
+            useNullAsDefault: true
+        });
+        knexInstance = (driver as any).knex;
+    });
+
+    afterEach(async () => {
+        await knexInstance.destroy();
+    });
+
+    it('should create table if not exists', async () => {
+        const objects = [{
+            name: 'test_obj',
+            fields: {
+                name: { type: 'string' },
+                age: { type: 'integer' }
+            }
+        }];
+
+        await driver.init(objects);
+
+        const exists = await knexInstance.schema.hasTable('test_obj');
+        expect(exists).toBe(true);
+
+        const columns = await knexInstance('test_obj').columnInfo();
+        expect(columns).toHaveProperty('_id');
+        expect(columns).toHaveProperty('created_at');
+        expect(columns).toHaveProperty('updated_at');
+        expect(columns).toHaveProperty('name');
+        expect(columns).toHaveProperty('age');
+    });
+
+    it('should add new columns if table exists', async () => {
+        // 1. Setup existing table with subset of columns
+        await knexInstance.schema.createTable('test_obj', (t: any) => {
+            t.string('_id').primary();
+            t.string('name');
+        });
+
+        // 2. Insert some data
+        await knexInstance('test_obj').insert({ _id: '1', name: 'Old Data' });
+
+        // 3. Init with new fields
+        const objects = [{
+            name: 'test_obj',
+            fields: {
+                name: { type: 'string' },
+                age: { type: 'integer' }, // New field
+                active: { type: 'boolean' } // New field
+            }
+        }];
+
+        await driver.init(objects);
+
+        // 4. Verify columns
+        const columns = await knexInstance('test_obj').columnInfo();
+        expect(columns).toHaveProperty('age');
+        expect(columns).toHaveProperty('active');
+
+        // 5. Verify data is intact
+        const row = await knexInstance('test_obj').where('_id', '1').first();
+        expect(row.name).toBe('Old Data');
+    });
+
+    it('should not delete existing columns', async () => {
+         // 1. Setup table with extra column
+         await knexInstance.schema.createTable('test_obj', (t: any) => {
+            t.string('_id').primary();
+            t.string('name');
+            t.string('extra_column'); // Should stay
+        });
+
+        // 2. Init with only 'name'
+        const objects = [{
+            name: 'test_obj',
+            fields: {
+                name: { type: 'string' }
+            }
+        }];
+
+        await driver.init(objects);
+
+        const columns = await knexInstance('test_obj').columnInfo();
+        expect(columns).toHaveProperty('name');
+        expect(columns).toHaveProperty('extra_column'); // Preservation check
+    });
+
+    it('should not fail if table creation is repeated', async () => {
+        const objects = [{
+            name: 'test_obj',
+            fields: {
+                name: { type: 'string' }
+            }
+        }];
+
+        // First init
+        await driver.init(objects);
+        
+        // Second init (should be idempotent-ish, or just skip creation)
+        await driver.init(objects);
+
+        const exists = await knexInstance.schema.hasTable('test_obj');
+        expect(exists).toBe(true);
+    });
+});