Error when running HQL queries spanning multiple tables in Hibernate Reactive

extensions/hibernate-reactive/runtime/src/main/java/io/quarkus/hibernate/reactive/runtime/boot/FastBootReactiveEntityManagerFactoryBuilder.java

@@ -6,6 +6,7 @@
 import org.hibernate.boot.internal.SessionFactoryOptionsBuilder;
 import org.hibernate.boot.registry.StandardServiceRegistry;
 import org.hibernate.boot.spi.SessionFactoryOptions;
+import org.hibernate.reactive.bulk.impl.ReactiveBulkIdStrategy;
 import org.hibernate.reactive.session.impl.ReactiveSessionFactoryImpl;
 
 import io.quarkus.hibernate.orm.runtime.PersistenceUnitUtil;
@@ -26,6 +27,7 @@ public FastBootReactiveEntityManagerFactoryBuilder(PrevalidatedQuarkusMetadata m
     public EntityManagerFactory build() {
         final SessionFactoryOptionsBuilder optionsBuilder = metadata.buildSessionFactoryOptionsBuilder();
         optionsBuilder.enableCollectionInDefaultFetchGroup(true);
+        optionsBuilder.applyMultiTableBulkIdStrategy(new ReactiveBulkIdStrategy(metadata));
         populate(PersistenceUnitUtil.DEFAULT_PERSISTENCE_UNIT_NAME, optionsBuilder, standardServiceRegistry,
                 multiTenancyStrategy);
         SessionFactoryOptions options = optionsBuilder.buildOptions();

integration-tests/hibernate-reactive-postgresql/src/main/java/io/quarkus/it/hibernate/reactive/postgresql/HibernateReactiveTestEndpointJoinedSubclass.java

@@ -0,0 +1,123 @@
+package io.quarkus.it.hibernate.reactive.postgresql;
+
+import java.util.Objects;
+
+import javax.inject.Inject;
+import javax.persistence.DiscriminatorValue;
+import javax.persistence.Entity;
+import javax.persistence.Id;
+import javax.persistence.Inheritance;
+import javax.persistence.InheritanceType;
+import javax.persistence.Table;
+import javax.ws.rs.DELETE;
+import javax.ws.rs.POST;
+import javax.ws.rs.Path;
+import javax.ws.rs.PathParam;
+
+import org.hibernate.reactive.mutiny.Mutiny;
+
+import io.smallrye.mutiny.Uni;
+
+/**
+ * We want to check that the right {@link org.hibernate.hql.spi.id.MultiTableBulkIdStrategy}
+ * is set when using Hibernate Reactive.
+ *
+ * @see io.quarkus.hibernate.reactive.runtime.boot.FastBootReactiveEntityManagerFactoryBuilder
+ * @see org.hibernate.reactive.bulk.impl.ReactiveBulkIdStrategy
+ */
+@Path("/hr-joinedsubclass")
+public class HibernateReactiveTestEndpointJoinedSubclass {
+
+    @Inject
+    Mutiny.Session session;
+
+    @DELETE
+    @Path("/deleteBook/{bookId}")
+    public Uni<Book> deleteBook(@PathParam("bookId") Integer bookId) {
+        return session.withTransaction(tx -> session
+                .createQuery("delete BookJS where id=:id")
+                .setParameter("id", bookId)
+                .executeUpdate())
+                .chain(() -> session.find(SpellBook.class, bookId));
+    }
+
+    @POST
+    @Path("/prepareDb")
+    public Uni<Void> prepareDb() {
+        final SpellBook spells = new SpellBook(6, "Necronomicon", true);
+
+        return session.persist(spells)
+                .chain(session::flush);
+    }
+
+    @Entity(name = "SpellBookJS")
+    @Table(name = "SpellBookJS")
+    @DiscriminatorValue("S")
+    public static class SpellBook extends Book {
+
+        private boolean forbidden;
+
+        public SpellBook(Integer id, String title, boolean forbidden) {
+            super(id, title);
+            this.forbidden = forbidden;
+        }
+
+        SpellBook() {
+        }
+
+        public boolean getForbidden() {
+            return forbidden;
+        }
+    }
+
+    @Entity(name = "BookJS")
+    @Table(name = "BookJS")
+    @Inheritance(strategy = InheritanceType.JOINED)
+    public static class Book {
+
+        @Id
+        private Integer id;
+        private String title;
+
+        public Book() {
+        }
+
+        public Book(Integer id, String title) {
+            this.id = id;
+            this.title = title;
+        }
+
+        public Integer getId() {
+            return id;
+        }
+
+        public void setId(Integer id) {
+            this.id = id;
+        }
+
+        public String getTitle() {
+            return title;
+        }
+
+        public void setTitle(String title) {
+            this.title = title;
+        }
+
+        @Override
+        public boolean equals(Object o) {
+            if (this == o) {
+                return true;
+            }
+            if (o == null || getClass() != o.getClass()) {
+                return false;
+            }
+            Book book = (Book) o;
+            return Objects.equals(title, book.title);
+        }
+
+        @Override
+        public int hashCode() {
+            return Objects.hash(title);
+        }
+    }
+}

integration-tests/hibernate-reactive-postgresql/src/test/java/io/quarkus/it/hibernate/reactive/postgresql/HibernateReactiveJoinedSubclassInGraalIT.java

@@ -0,0 +1,7 @@
+package io.quarkus.it.hibernate.reactive.postgresql;
+
+import io.quarkus.test.junit.NativeImageTest;
+
+@NativeImageTest
+public class HibernateReactiveJoinedSubclassInGraalIT extends HibernateReactiveJoinedSubclassTest {
+}

integration-tests/hibernate-reactive-postgresql/src/test/java/io/quarkus/it/hibernate/reactive/postgresql/HibernateReactiveJoinedSubclassTest.java

@@ -0,0 +1,28 @@
+package io.quarkus.it.hibernate.reactive.postgresql;
+
+import static org.hamcrest.Matchers.emptyOrNullString;
+
+import org.junit.jupiter.api.Test;
+
+import io.quarkus.test.common.http.TestHTTPEndpoint;
+import io.quarkus.test.junit.QuarkusTest;
+import io.restassured.RestAssured;
+
+@QuarkusTest
+@TestHTTPEndpoint(HibernateReactiveTestEndpointJoinedSubclass.class)
+public class HibernateReactiveJoinedSubclassTest {
+
+    @Test
+    public void deleteBookQuery() {
+        RestAssured.when()
+                .post("/prepareDb")
+                .then()
+                .statusCode(204);
+
+        RestAssured.when()
+                .delete("/deleteBook/6")
+                .then()
+                .statusCode(204)
+                .body(emptyOrNullString());
+    }
+}