Add the UnsupportedTransactionManager class to simplify our library

Author: nakamura-to

deployment/src/test/java/org/seasar/doma/quarkus/deployment/InjectConfigTest.java

@@ -2,7 +2,6 @@
 
 import static org.junit.jupiter.api.Assertions.assertEquals;
 import static org.junit.jupiter.api.Assertions.assertNotNull;
-import static org.junit.jupiter.api.Assertions.assertNull;
 
 import io.quarkus.test.QuarkusUnitTest;
 import javax.inject.Inject;
@@ -50,7 +49,7 @@ public void test() {
     assertNotNull(config.getMapKeyNaming());
     assertNotNull(config.getCommenter());
     assertNotNull(config.getEntityListenerProvider());
-    assertNull(config.getTransactionManager());
+    assertNotNull(config.getTransactionManager());
     assertEquals("<default>", config.getDataSourceName());
     assertEquals(0, config.getBatchSize());
     assertEquals(0, config.getFetchSize());

runtime/src/main/java/org/seasar/doma/quarkus/runtime/DbConfig.java

@@ -80,7 +80,7 @@ public DbConfig(
     this.mapKeyNaming = Objects.requireNonNull(mapKeyNaming);
     this.commenter = Objects.requireNonNull(commenter);
     this.entityListenerProvider = Objects.requireNonNull(entityListenerProvider);
-    this.transactionManager = transactionManager;
+    this.transactionManager = Objects.requireNonNull(transactionManager);
     this.dataSourceName = Objects.requireNonNull(dataSourceName);
     this.batchSize = batchSize;
     this.fetchSize = fetchSize;

runtime/src/main/java/org/seasar/doma/quarkus/runtime/DomaProducer.java

@@ -3,7 +3,6 @@
 import io.quarkus.arc.DefaultBean;
 import java.util.Objects;
 import javax.enterprise.context.ApplicationScoped;
-import javax.enterprise.inject.Instance;
 import javax.inject.Singleton;
 import javax.sql.DataSource;
 import org.seasar.doma.jdbc.ClassHelper;
@@ -169,6 +168,12 @@ SqlLogType exceptionSqlLogType() {
     return Objects.requireNonNull(exceptionSqlLogType);
   }
 
+  @ApplicationScoped
+  @DefaultBean
+  TransactionManager transactionManager() {
+    return new UnsupportedTransactionManager();
+  }
+
   @ApplicationScoped
   @DefaultBean
   DbConfig dbConfig(
@@ -187,7 +192,7 @@ DbConfig dbConfig(
       MapKeyNaming mapKeyNaming,
       Commenter commenter,
       EntityListenerProvider entityListenerProvider,
-      Instance<TransactionManager> transactionManager) {
+      TransactionManager transactionManager) {
     return new DbConfig(
         dataSource,
         dialect,
@@ -204,7 +209,7 @@ DbConfig dbConfig(
         mapKeyNaming,
         commenter,
         entityListenerProvider,
-        transactionManager.isResolvable() ? transactionManager.get() : null,
+        transactionManager,
         dataSourceName,
         batchSize,
         fetchSize,

runtime/src/main/java/org/seasar/doma/quarkus/runtime/UnsupportedTransactionManager.java

@@ -0,0 +1,106 @@
+package org.seasar.doma.quarkus.runtime;
+
+import java.util.function.Supplier;
+import org.seasar.doma.jdbc.tx.TransactionIsolationLevel;
+import org.seasar.doma.jdbc.tx.TransactionManager;
+
+public class UnsupportedTransactionManager implements TransactionManager {
+
+  @Override
+  public void required(Runnable block) {
+    throw useNarayanaJta();
+  }
+
+  @Override
+  public void required(TransactionIsolationLevel isolationLevel, Runnable block) {
+    throw useNarayanaJta();
+  }
+
+  @Override
+  public <RESULT> RESULT required(Supplier<RESULT> supplier) {
+    throw useNarayanaJta();
+  }
+
+  @Override
+  public <RESULT> RESULT required(
+      TransactionIsolationLevel isolationLevel, Supplier<RESULT> supplier) {
+    throw useNarayanaJta();
+  }
+
+  @Override
+  public void requiresNew(Runnable block) {
+    throw useNarayanaJta();
+  }
+
+  @Override
+  public void requiresNew(TransactionIsolationLevel isolationLevel, Runnable block) {
+    throw useNarayanaJta();
+  }
+
+  @Override
+  public <RESULT> RESULT requiresNew(Supplier<RESULT> supplier) {
+    throw useNarayanaJta();
+  }
+
+  @Override
+  public <RESULT> RESULT requiresNew(
+      TransactionIsolationLevel isolationLevel, Supplier<RESULT> supplier) {
+    throw useNarayanaJta();
+  }
+
+  @Override
+  public void notSupported(Runnable block) {
+    throw useNarayanaJta();
+  }
+
+  @Override
+  public void notSupported(TransactionIsolationLevel isolationLevel, Runnable block) {
+    throw useNarayanaJta();
+  }
+
+  @Override
+  public <RESULT> RESULT notSupported(Supplier<RESULT> supplier) {
+    throw useNarayanaJta();
+  }
+
+  @Override
+  public <RESULT> RESULT notSupported(
+      TransactionIsolationLevel isolationLevel, Supplier<RESULT> supplier) {
+    throw useNarayanaJta();
+  }
+
+  @Override
+  public void setRollbackOnly() {
+    throw useNarayanaJta();
+  }
+
+  @Override
+  public boolean isRollbackOnly() {
+    throw useNarayanaJta();
+  }
+
+  @Override
+  public void setSavepoint(String savepointName) {
+    throw new UnsupportedOperationException();
+  }
+
+  @Override
+  public boolean hasSavepoint(String savepointName) {
+    throw new UnsupportedOperationException();
+  }
+
+  @Override
+  public void releaseSavepoint(String savepointName) {
+    throw new UnsupportedOperationException();
+  }
+
+  @Override
+  public void rollback(String savepointName) {
+    throw new UnsupportedOperationException();
+  }
+
+  private UnsupportedOperationException useNarayanaJta() {
+    return new UnsupportedOperationException(
+        "Use quarkus-narayana-jta directly. See https://quarkus.io/guides/transaction");
+  }
+}