Support fror @Inject StatelessSession

Why:

 * Sometimes you just want to do raw data access

This change addreses the need by:

 * Add StatelessSession as a possible injection.

extensions/hibernate-orm/deployment/src/main/java/io/quarkus/hibernate/orm/deployment/HibernateOrmProcessor.java

@@ -95,6 +95,7 @@
 import io.quarkus.hibernate.orm.deployment.integration.HibernateOrmIntegrationRuntimeConfiguredBuildItem;
 import io.quarkus.hibernate.orm.runtime.DefaultEntityManagerFactoryProducer;
 import io.quarkus.hibernate.orm.runtime.DefaultEntityManagerProducer;
+import io.quarkus.hibernate.orm.runtime.DefaultStatelessSessionProducer;
 import io.quarkus.hibernate.orm.runtime.HibernateOrmRecorder;
 import io.quarkus.hibernate.orm.runtime.JPAConfig;
 import io.quarkus.hibernate.orm.runtime.JPAResourceReferenceProvider;
@@ -421,6 +422,7 @@ void registerBeans(BuildProducer<AdditionalBeanBuildItem> additionalBeans, Combi
             if (isUserDefinedProducerMissing(combinedIndex.getIndex(), PERSISTENCE_CONTEXT)) {
                 additionalBeans.produce(new AdditionalBeanBuildItem(DefaultEntityManagerProducer.class));
             }
+            additionalBeans.produce(new AdditionalBeanBuildItem(DefaultStatelessSessionProducer.class));
         }
     }
 

extensions/hibernate-orm/deployment/src/test/java/io/quarkus/hibernate/orm/StatelessSessionTest.java

@@ -0,0 +1,49 @@
+package io.quarkus.hibernate.orm;
+
+import static org.junit.jupiter.api.Assertions.assertNotNull;
+
+import java.util.List;
+
+import javax.inject.Inject;
+import javax.persistence.EntityManager;
+import javax.persistence.TransactionRequiredException;
+
+import org.hibernate.StatelessSession;
+import org.jboss.shrinkwrap.api.ShrinkWrap;
+import org.jboss.shrinkwrap.api.spec.JavaArchive;
+import org.junit.jupiter.api.Assertions;
+import org.junit.jupiter.api.Test;
+import org.junit.jupiter.api.extension.RegisterExtension;
+
+import io.quarkus.arc.Arc;
+import io.quarkus.hibernate.orm.enhancer.Address;
+import io.quarkus.test.QuarkusUnitTest;
+
+/**
+ * @author Max Rydahl Andersen <manderse@redhat.com>
+ */
+public class StatelessSessionTest {
+
+    @RegisterExtension
+    static QuarkusUnitTest runner = new QuarkusUnitTest()
+            .setArchiveProducer(() -> ShrinkWrap.create(JavaArchive.class)
+                    .addClass(Address.class)
+                    .addAsResource("application.properties"));
+
+    @Inject
+    StatelessSession statelessSession;
+
+    @Test
+    public void testStatelessSession() {
+        Arc.container().requestContext().activate();
+        try {
+            List list = statelessSession.createNativeQuery("SELECT VALUE FROM INFORMATION_SCHEMA.SETTINGS")
+                    .addScalar("VALUE")
+                    .list();
+            assertNotNull(list);
+        } finally {
+            Arc.container().requestContext().terminate();
+        }
+    }
+
+}

extensions/hibernate-orm/runtime/src/main/java/io/quarkus/hibernate/orm/runtime/DefaultStatelessSessionProducer.java

@@ -0,0 +1,16 @@
+package io.quarkus.hibernate.orm.runtime;
+
+import javax.enterprise.inject.Produces;
+import javax.inject.Singleton;
+import javax.persistence.PersistenceContext;
+
+import org.hibernate.StatelessSession;
+
+public class DefaultStatelessSessionProducer {
+
+    @Produces
+    @PersistenceContext
+    @Singleton
+    StatelessSession statelessSession;
+
+}

extensions/hibernate-orm/runtime/src/main/java/io/quarkus/hibernate/orm/runtime/JPAResourceReferenceProvider.java

@@ -9,6 +9,8 @@
 import javax.persistence.PersistenceContext;
 import javax.persistence.PersistenceUnit;
 
+import org.hibernate.StatelessSession;
+
 import io.quarkus.arc.Arc;
 import io.quarkus.arc.InstanceHandle;
 import io.quarkus.arc.ResourceReferenceProvider;
@@ -26,6 +28,37 @@ public InstanceHandle<Object> get(Type type, Set<Annotation> annotations) {
                 return () -> jpaConfig.getEntityManagerFactory(pu.unitName());
             }
         } else if (EntityManager.class.equals(type)) {
+            PersistenceContext pc = getAnnotation(annotations, PersistenceContext.class);
+            if (pc != null) {
+                if (jpaConfig.isJtaEnabled()) {
+                    TransactionEntityManagers transactionEntityManagers = Arc.container()
+                            .instance(TransactionEntityManagers.class).get();
+                    ForwardingEntityManager entityManager = new ForwardingEntityManager() {
+
+                        @Override
+                        protected EntityManager delegate() {
+                            return transactionEntityManagers.getEntityManager(pc.unitName());
+                        }
+                    };
+                    return () -> entityManager;
+                } else {
+                    EntityManagerFactory entityManagerFactory = jpaConfig.getEntityManagerFactory(pc.unitName());
+                    EntityManager entityManager = entityManagerFactory.createEntityManager();
+                    return new InstanceHandle<Object>() {
+
+                        @Override
+                        public Object get() {
+                            return entityManager;
+                        }
+
+                        @Override
+                        public void destroy() {
+                            entityManager.close();
+                        }
+                    };
+                }
+            } 
+        } else if (StatelessSession.class.equals(type)) {
             PersistenceContext pc = getAnnotation(annotations, PersistenceContext.class);
             if (pc != null) {
                 if (jpaConfig.isJtaEnabled()) {
@@ -56,8 +89,8 @@ public void destroy() {
                     };
                 }
             }
-        }
 
+    }
         return null;
     }