feat(repository): add execute implementation

packages/repository/src/__tests__/unit/repositories/legacy-juggler-bridge.unit.ts

@@ -394,4 +394,25 @@ describe('DefaultCrudRepository', () => {
     const ok = await repo.exists(note1.id);
     expect(ok).to.be.true();
   });
+
+  it('implements Repository.execute()', async () => {
+    // Dummy implementation for execute() in datasource
+    ds.execute = (command, parameters, options) => {
+      return Promise.resolve({command, parameters, options});
+    };
+    const repo = new DefaultCrudRepository(Note, ds);
+    const result = await repo.execute('query', ['arg']);
+    expect(result).to.eql({
+      command: 'query',
+      parameters: ['arg'],
+      options: undefined,
+    });
+  });
+
+  it(`throws error when execute() not implemented by ds connector`, async () => {
+    const repo = new DefaultCrudRepository(Note, ds);
+    await expect(repo.execute('query', [])).to.be.rejectedWith(
+      'execute() must be implemented by the connector',
+    );
+  });
 });

packages/repository/src/repositories/legacy-juggler-bridge.ts

@@ -433,12 +433,10 @@ export class DefaultCrudRepository<T extends Entity, ID>
 
   async execute(
     command: Command,
-    // tslint:disable:no-any
     parameters: NamedParameters | PositionalParameters,
     options?: Options,
   ): Promise<AnyObject> {
-    /* istanbul ignore next */
-    throw new Error('Not implemented');
+    return ensurePromise(this.dataSource.execute(command, parameters, options));
   }
 
   protected toEntity(model: juggler.PersistedModel): T {