fix(core): quote column name for the returning statement when using `…

…convertToJSValueSQL`

Closes #5563

packages/knex/src/query/QueryBuilderHelper.ts

@@ -699,7 +699,8 @@ export class QueryBuilderHelper {
       if (returningProps.length > 0) {
         qb.returning(returningProps.flatMap(prop => {
           if (prop.hasConvertToJSValueSQL) {
-            const sql = prop.customType!.convertToJSValueSQL!(prop.fieldNames[0], this.platform) + ' as ' + this.platform.quoteIdentifier(prop.fieldNames[0]);
+            const aliased = this.platform.quoteIdentifier(prop.fieldNames[0]);
+            const sql = prop.customType!.convertToJSValueSQL!(aliased, this.platform) + ' as ' + this.platform.quoteIdentifier(prop.fieldNames[0]);
             return [this.knex.raw(sql) as any];
           }
           return prop.fieldNames;

tests/features/custom-types/GH5563.test.ts

@@ -0,0 +1,58 @@
+import { Entity, MikroORM, PrimaryKey, Property, Type, BaseEntity } from '@mikro-orm/postgresql';
+
+class IntervalType extends Type<number, number | null | undefined> {
+
+  getColumnType() {
+    return `interval`;
+  }
+
+  override get runtimeType(): string {
+    return 'number';
+  }
+
+  compareAsType(): string {
+    return 'number';
+  }
+
+  convertToJSValueSQL(key: string) {
+    return `(extract (epoch from ${key}::interval) * 1000)::int`;
+  }
+
+  convertToDatabaseValueSQL(key: string) {
+    return `(${key} || 'milliseconds')::interval`;
+  }
+
+}
+
+@Entity()
+export class A extends BaseEntity {
+
+  @PrimaryKey()
+  id!: number;
+
+  @Property({ type: IntervalType })
+  end!: number;
+
+}
+
+
+let orm: MikroORM;
+
+beforeAll(async () => {
+  orm = await MikroORM.init({
+    entities: [A],
+    dbName: '5563',
+  });
+  await orm.schema.refreshDatabase();
+});
+
+afterAll(() => orm.close(true));
+
+test('update customType', async () => {
+  const bk = orm.em.create(A, { end: 10 });
+  await orm.em.flush();
+  orm.em.clear();
+  const entityA = await orm.em.findOneOrFail(A, { id: bk.id });
+  entityA.assign({ end: 500 });
+  await orm.em.flush();
+});