mpackdb

1.7 KB

1. import MPackDB, { PrimaryKeyType } from '../src/MPackDB.js';
2. import { rm } from 'fs/promises';
4. const TEST_DB_PATH = 'db/indexed';
6. console.log('--- Indexed Database Test ---');
8. // Clean up
9. await rm(TEST_DB_PATH, { recursive: true, force: true });
11. // Create database WITH indexes
12. const db = new MPackDB(`${TEST_DB_PATH}/users`, {
13. primaryKey: 'id',
14. primaryKeyType: PrimaryKeyType.NUMBER,
15. indexes: ['id', 'email', '*age'] // id and email are lexical, age is numeric (*)
16. });
18. console.log('\nTest 1: Insert with indexes');
19. await db.insert({ name: 'Alice', email: '[email protected]', age: 30 });
20. await db.insert({ name: 'Bob', email: '[email protected]', age: 25 });
21. await db.insert({ name: 'Charlie', email: '[email protected]', age: 35 });
22. console.log('✓ Inserted 3 records');
24. console.log('\nTest 1.5: Persist indexes to disk');
25. if (db._indexManager) {
26. await db._indexManager.persist();
27. console.log('✓ Indexes persisted');
28. }
30. console.log('\nTest 2: Read all (should use index)');
31. const all = await db.find();
32. console.log('✓ Found', all.length, 'records:', all);
34. console.log('\nTest 3: Find by primary key (should use index)');
35. const alice = await db.find(0);
36. console.log('✓ Found by ID:', alice);
38. console.log('\nTest 4: Delete (should update index)');
39. await db.delete(r => r.age === 25);
40. const remaining = await db.find();
41. console.log('✓ Remaining:', remaining.length, 'records');
43. console.log('\nTest 5: Verify index files created');
44. const { readdirSync } = await import('fs');
45. const files = readdirSync(TEST_DB_PATH);
46. const indexFiles = files.filter(f => f.endsWith('.txt'));
47. console.log('✓ Index files:', indexFiles);
49. if (indexFiles.length !== 3) {
50. throw new Error(`Expected 3 index files, got ${indexFiles.length}`);
51. }
53. console.log('\n✓ All indexed tests passed!');