feat(sql): add execute() method to SqlEntityManager

Shortcut to `em.driver.execute()`, which as opposed to `em.getConnection().execute()` converts errors to custom exceptions.

packages/knex/src/SqlEntityManager.ts

@@ -1,5 +1,5 @@
-import Knex from 'knex';
-import { AnyEntity, EntityManager, EntityName, EntityRepository, Utils } from '@mikro-orm/core';
+import Knex, { QueryBuilder as KnexQueryBuilder, Raw } from 'knex';
+import { AnyEntity, EntityData, EntityManager, EntityName, EntityRepository, QueryResult, Utils } from '@mikro-orm/core';
 import { AbstractSqlDriver } from './AbstractSqlDriver';
 import { QueryBuilder } from './query';
 import { SqlEntityRepository } from './SqlEntityRepository';
@@ -21,6 +21,10 @@ export class SqlEntityManager<D extends AbstractSqlDriver = AbstractSqlDriver> e
     return this.getConnection(type).getKnex();
   }
 
+  async execute<T extends QueryResult | EntityData<AnyEntity> | EntityData<AnyEntity>[] = EntityData<AnyEntity>[]>(queryOrKnex: string | KnexQueryBuilder | Raw, params: any[] = [], method: 'all' | 'get' | 'run' = 'all'): Promise<T> {
+    return this.getDriver().execute(queryOrKnex, params, method, this.getTransactionContext());
+  }
+
   getRepository<T extends AnyEntity<T>, U extends EntityRepository<T> = SqlEntityRepository<T>>(entityName: EntityName<T>): U {
     return super.getRepository<T, U>(entityName);
   }

tests/EntityManager.mysql.test.ts

@@ -1976,6 +1976,13 @@ describe('EntityManagerMySql', () => {
     await expect(driver.execute('select uuid from author2')).rejects.toThrow(InvalidFieldNameException);
   });
 
+  test('em.execute()', async () => {
+    const res1 = await orm.em.execute('insert into author2 (name, email) values (?, ?)', ['name', 'email']);
+    expect(res1).toMatchObject({ affectedRows: 1, insertId: 1 });
+    const res2 = await orm.em.execute('select 1 as count');
+    expect(res2).toMatchObject([{ count: 1 }]);
+  });
+
   afterAll(async () => orm.close(true));
 
 });