常連

### 前提・実現したいこと

異なるDB間でのデータ移行を行いたいです。


### 該当のソースコード

```vb.net
insert into [コピー先データベース名A].[dbo].テーブル名(列名1,列名2,列名3,…)
select 列名1,列名2,列名3,…
from [コピー元データベース名B].[dbo].テーブル名
```
上記のやりかたでもいいのですが
実現可能であれば
各DBに対してトランザクション（コミット、ロールバック含む）
を行いたいです。

### 詳細

あくまでイメージなのですが

1.コピー先データベース名AのテーブルAに対して必要なデータ（コピーするデータ）をSELECT

2.コピー先データベース名Bのテーブルに対して「1」でSELECTした結果をINSERT

1または2の処理のどこかでエラーが起きた場合は
そのエラーが起きたDBに対してロールバックを行う。

実現可能でしょうか。


もしかしてですが・・・・

```vb.net
insert into [コピー先データベース名A].[dbo].テーブル名(列名1,列名2,列名3,…)
select 列名1,列名2,列名3,…
from [コピー元データベース名B].[dbo].テーブル名
```
の処理に対してトランザクションを行い、
エラーが起きた場合に、コピー先データベース名A・B
の両方に対してロールバックを行えばいいというものなのでしょうか。

よろしくお願い致します。

### 追記（2018/07/11 14:25）
方法として以下のものしか思いつかないのですが
実現できますでしょうか？

1.コピー先データベース名AのテーブルAに対して必要なデータ（コピーするデータ）をSELECTし
　結果をどこかに保存。

2.コピー先データベース名Bのテーブルに対して「1」で保存してあるSELECT結果のデータ（複数レコード）
　をレコード分ループしてINSERT

よろしくお願い致します。

### 補足情報（FW/ツールのバージョンなど）

環境

・sql sv2014
・Win sv 2012r2
・Win7
・vb.net
・vs2015

【SQL】異なるDB間でのデータ移行を行いたい。

VB2008
SQLServer2008

いつもお世話になっております。

今回、お尋ねしたいのは、
「トランザクションのトランザクションタイムアウトが画面遷移の一定時間、タイムアウトせずに耐えられるか」、です。

SqlCommandを使用して更新処理を実行していますが、
仕様上、トランザクション開始は親画面で実行し、
更新処理は親画面、子画面で実行されます。
Commit処理は親画面で一括処理します。
（各画面の表示情報はDBから取得(一時登録を含む)する仕様の為、各画面で登録・更新処理）

SqlCommandでBeginTransactionした場合のトランザクションタイムアウト時間は
いくつになるのでしょうか？また期限があるとしたら変更は可能でしょうか？

もし、トランザクションタイムアウトが不可避であるならば、
回避する良い方法なども頂けたらと思います。

※
SqlCommandのCommandTimeOutは”SQL実行時間”であり、
トランザクションタイムアウトの設定ではない、という認識です。

因みに、TransactionScopeは使用しない予定ですが、
TransactionScopeは10分以上は設定できないと解りました。
（machine.configの設定で延長可？）


以上、宜しくお願いします。

「TransactionScope」の有効性などもご教授頂けると助かります。

--------------------------------------------------------------
■現状報告

まだ設計段階で引き続き調査中ですが、TransactionScopeのタイムアプト設定についていては出てきますが、
SqlCommandでのトランザクションタイムアウトについての記載が見つかりません。

↓以下サイトで「SqlCommandではトランザクションタイムアウトは発生しない」、とあってのですが、その認識で正しいでしょうか？
（トランザクションタイムアウトの設定はできない）
https://social.msdn.microsoft.com/Forums/ja-JP/56e9f087-433f-498b-bf73-5dea5e48cd0b/sql-server-update-?forum=vbgeneralja

SqlCommandのトランザクションのトランザクションタイムアウトについて

現在javaの勉強中なのですが
以下のような流れの処理をボタンを押された際に呼び出されるメソッドに丸ごと詰め込んでいる状態です。

1.トランザクション開始
2.テーブルAからデータ取得
3.なんかいろいろ処理
4.テーブルBにデータ登録
5.トランザクション終了（コミット）

これをDAOを使った作りに書きなおしてみたいと思ったのですが、
その場合トランザクションの管理はどこで行うべきなのでしょうか？

パッと思いついたのは以下の2つです。
①1～5全てをDAOの1つのメソッドに詰め込む。
　トランザクションの管理はDAOのメソッド内で行う

②1,3,5はビジネスロジックにして2,4は個別のメソッドとして定義する。
　トランザクションの管理はビジネスロジックで行いDAOには引数等でトランザクションを渡すようにする。

しかし、①にした場合DAOにビジネスロジックが入っていしまう上にメソッドの粒度が大きくなりすぎる気がします（呼び出し元が何もしないでDAOのメソッド呼び出すだけなので元々と変わらないですし）。
②の方法にすると何となく解決は出来そうなんですがDAOを使った開発のパターンとして正しいものなのかどうかがわからないです。

フレームワーク等を使えばそれらが上手いことやってくれるらしいので気にしなくていいのかもしれませんが、
別の言語でも同じ問題にぶつかる可能性が高いですし、初学者なのでそれらに頼らずに自分で管理するように書いてみたいと思っています。

よろしくお願いします。

DAOを使う場合にトランザクション管理は何処で行うべきでしょうか？

初めて利用させて頂きます。

【状態】
springで独自にAPIを作成しております。
API実行時に、以下のような形で
トランザクション開始を明示しております。

DefaultTransactionDefinition def = new DefaultTransactionDefinition();
TransactionStatus status = transactionManager.getTransaction(def);

その後、APIで別クラス(以下Bクラス)を呼び出します。
Bクラス側ではテーブルのupdateをしており、
直接JDBCのConnectionを取得して実行しています。

Connection con = DataSorceUtil.getConnection(jdbcTemplate.DateSouce)

Bクラス側でcommitまで完了させ、その後、
API側でロールバックを完了させようとすると、
exceptionが発生してしまう状態です。
なお、APIとBクラスがアクセスするDBはORACLE11gで、同じDB内の別テーブルをそれぞれが更新します(スキーマは同一です)

【フロー図】
API実行
↓
APIでトランザクション開始
↓
APIがBクラス(共通処理的な)呼出
↓
Bクラスでトランザクション開始
↓
Bクラスがコミット実行。Bクラス動作終了。
↓
APIに処理が戻ってきた後、エラー処理でロールバック実行
↓
APIでexception発生

【実現したいこと】
・APIはロールバックを行ってテーブル更新させたくないが、Bクラスはコミットまで完了させたい
(クラス単位で、途中でトランザクション終了させることなく、別々にトランザクション管理をしたい)

【質問】
・複数のトランザクション管理を明示的に行う事は可能なのでしょうか？
・お互いのトランザクション管理が干渉しないようにする為にはどういった実装が理想でしょうか？
・複数のトランザクション管理について、参考になるページなどありましたらご教示頂ければ幸いです。

以上、よろしくお願い致します。

springにおける複数トランザクション管理

### 実現したいこと
- [ ] 登録処理のトランザクションが正しく動作していることを確認するテスト方法が知りたい

※ツールでもコードでもどちらでも良いです

### 前提
FuelPHPで書かれたWebサイトの登録機能を改修しております。
既存仕様では受付番号の採番処理を行う際、登録済みの受付番号の最大値を取得して、+1した値を受付番号として新規登録するという作りになっていました。
この処理に排他制御がなく、同時に複数の登録があった場合に重複した受付番号を登録してしまう不具合が存在しています。
不具合解消の為、受付番号の最大値取得処理～新規登録までをトランザクションで囲う対応を行います。

この改修について、修正前の不具合の再現と、修正後の不具合の解消をテストで確認する必要があります。

### 発生している問題・エラーメッセージ
トランザクションが正しく機能していることを確認するテストの実行方法がわかりません。

### 試したこと
必要なのは同時に複数の登録処理が走ることなので、Postman（PostmanEchoというリクエストを複数回走らせる機能があったので）などのサービスを検討しましたが、レスポンスを待たないで同時にリクエストを実行する、という機能ではなく今回の目的にあっていませんでした。


トランザクション処理を確認する為の同時実行テストの方法

PHPバージョン5.6 
MariaDB 10.0
フレームワーク等は使用しておりません。

下記のようにデータベースA、データベースBがあり
データベースAにINSERTが出来ていれば、データベースB
にもINSERTを行う処理を行っております。

つきましては、データベースAは正常にINSERTが終了したが
データベースBのINSERTが失敗したときに、データベースAに
INSERTされたデータをロールバックもしくは削除したいと考えて
おります。


二つのDBに対するロールバックの方法がございましたら
お教え頂けないでしょうか。

稚拙な質問で申し訳ございませんが、
宜しくお願い致します。

```php
//===============================================
//データベースA
//===============================================
    try {
require './common/dbconnect.php';
        $pdo->beginTransaction();
             $stmt = $pdo->prepare(" INSERT INTO ******");
            
        $ret = $stmt ->execute();                   
        $pdo->commit();             
    } catch (Exception $ex) {
       $pdo->rollBack();
        exit();
    }
//===============================================
//データベースB
//===============================================
      
      try {
            require './common/dbconnect_new.php';
            $pdo_new->beginTransaction();
      if (!empty($ret)) {
             $stmt_team = $pdo_new->prepare(" INSERT INTO *****);       
        }  
            $stmt_team->execute();
            $pdo_new->commit();                     
        } catch (Exception $ex) {
        $pdo_new->rollBack();                
        exit();
        }
```

複数のDBでのトランザクション　ロールバックについて

DBにデータを登録している時にエラーが発生したらロールバックを行いたいので、@Transactionalを使おうと思うのですが、
本当にロールバックが発生するか確認するためにJunitでこのテストを書きたいです。
以下のqiitaの記事にあるようなテスト対象のメソッド中にDBに登録しているメソッドを２つ呼び出している場合は、１つ目を正常に実行させて、２つ目が呼ばれた時にRuntime exceptionを発生させてロールバックを実現しています。
https://qiita.com/shimi58/items/60ea681c74188c4ea8bc
私が行いたいのは、以下のように100件ずつデータを登録するときのロールバックのテストです。
100件登録させて、101件以降のデータを登録中にロールバックを発生させて、テーブルの内容がテスト実行開始時の状態になっているかを確認したいです。
------------Service class--------------------------
```
@Slf4j
@Service
public class SampleService {
    
    @Autowired
    SampleLogic sampleLogic;
    
    @Transactional
    public CommandType execute() {
        try {
            //get items
            List<ItemEntity> itemEntities = sampleLogic.getItems();
            
            //save item data
            sampleLogic.itemSave(itemEntities);
        } catch (Exception e) {
            log.error("Error Happened!!!", e);
             return CommandType.FAILURE;
        }
        return CommandType.SUCCESS;
    }

}
```
-----logic class----------------------------------------
```
@Component
public class SampleLogic {
    
    @Autowired
    SampleRepository sampleRepository;
    
    
    public List<ItemEntity> getItems() {
        
        List<ItemEntity> itemEntities = new ArrayList<>();
        for(int i = 0; i < 1000; i++) {
            itemEntities.add(new ItemEntity(String.valueOf(i), "itemName"));
        }
        
        return itemEntities;
    }
    
    public void itemSave(List<ItemEntity> itemEntities) {
        
        Iterables.partition(itemEntities, 100).forEach(list -> {
            // save data per 100
            sampleRepository.saveAll(itemEntities);
        });        
    }    

}
```

-----test class----------------------------------------
```
@ExtendWith(SpringExtension.class)
@TestExecutionListeners({DirtiesContextTestExecutionListener.class,
    DependencyInjectionTestExecutionListener.class, 
    TransactionDbUnitTestExecutionListener.class})
@AutoConfigureTestDatabase(replace = AutoConfigureTestDatabase.Replace.NONE)
public class SampleServiceTest {
    
    @InjectMocks
    private SampleService sampleService;
    
    @Test
    @DatabaseSetup("/itemPrep.xml")
    @ExpectedDatabase(value = "/testdata/CustomerServiceTest/init-data", assertionMode=DatabaseAssertionMode.NON_STRICT)
    void whenSaveMethodCalledRollBackHappen() {
        //

        //
        Assertions.assertEquals(CommandType.FAILURE, sampleService.execute());
    }

}
```
以下のようにメソッドの呼び出し回数によって異なる結果を返す方法でできるか試したのですが、List.classをモックするとitemSaveメソッドが実行されず、うまくいきませんでした。。もしどこか間違っていればご指摘お願いします。
https://reasonable-code.com/mockito-consecutive-calls/

```ここに言語を入力
    @Test
    @DatabaseSetup("/itemPrep.xml")
    @ExpectedDatabase(value = "/testdata/CustomerServiceTest/init-data", assertionMode=DatabaseAssertionMode.NON_STRICT)
    void whenSaveMethodCalledRollBackHappen() {
        //
        List<ItemEntity> itemMockList = Mockito.mock(List.class);
        for(int i = 0; i < 100; i++) {
            Mockito.when(itemMockList.get(i))
            .thenReturn(new ItemEntity(String.valueOf(i), "itemName"));
        }
        Mockito.when(itemMockList.get(101)).thenThrow(new RuntimeException());
                
        //make sure execute method returns failure and item table is roll backed
        Assertions.assertEquals(CommandType.FAILURE, sampleService.execute());
    }
```

Spring BootのTransactionのテスト方法について

###前提・実現したいこと
mybatis-springを利用して複数DBへの更新処理を試みています。
現在、トランザクションを意識せずにinsert,update等のSQLは処理出来ています。

###発生している問題・エラーメッセージ
トランザクション制御をかけるため、@Transactionalを使用して実装したのですが
どうやらトランザクションが想定通りに動作していません。

特定のメソッドに@Transactionalを付与しているので、そのメソッドで例外が発生した場合、
ロールバックされる想定でしたが、例外発生するまでの更新処理はコミットされています。


###該当のソースコード
applicationContext.xml
```
 <tx:annotation-driven />

  
  <bean id="propertyConfigurer" class="org.springframework.beans.factory.config.PropertyPlaceholderConfigurer">
    <property name="locations">
      <list>
        <value>classpath:dbsetting.properties</value>
      </list>
    </property>
  </bean>

  
  <bean id="oracleDataSource" class="org.apache.commons.dbcp2.BasicDataSource"
    p:driverClassName="${oracle.jdbc.driver}"
    p:url="${oracle.jdbc.url}"
    p:username="${oracle.jdbc.username}"
    p:password="${oracle.jdbc.password}"
    p:defaultAutoCommit="false" />

 
 <bean id="oracleTransactionManager" class="org.springframework.jdbc.datasource.DataSourceTransactionManager"
    p:dataSource-ref="oracleDataSource"
    p:rollbackOnCommitFailure="true" />

 
 
 <bean id="oracleSqlSessionFactory" class="org.mybatis.spring.SqlSessionFactoryBean"
    p:dataSource-ref="oracleDataSource">
    <property name="configuration">
      <bean class="org.apache.ibatis.session.Configuration"
        p:localCacheScope="STATEMENT"
        p:mapUnderscoreToCamelCase="true"
        p:lazyLoadingEnabled="true"
        p:aggressiveLazyLoading="false"
        p:defaultFetchSize="1000"
        p:defaultExecutorType="REUSE" />
    </property>
    <property name="mapperLocations" value="classpath*:dao/oracle/*.xml" />
  </bean>

    <bean class="org.mybatis.spring.mapper.MapperScannerConfigurer">
        <property name="basePackage" value="xxx.dao.oracle" />
        <property name="sqlSessionFactoryBeanName" value="oracleSqlSessionFactory" />
    </bean>

  
  <bean id="postgresDataSource" class="org.apache.commons.dbcp2.BasicDataSource"
    p:driverClassName="${postgres.jdbc.driver}"
    p:url="${postgres.jdbc.url}"
    p:username="${postgres.jdbc.username}"
    p:password="${postgres.jdbc.password}"
    p:defaultAutoCommit="false" />

 
 <bean id="postgresTransactionManager" class="org.springframework.jdbc.datasource.DataSourceTransactionManager"
    p:dataSource-ref="postgresDataSource"
    p:rollbackOnCommitFailure="true" />

 
 
 <bean id="postgresSqlSessionFactory" class="org.mybatis.spring.SqlSessionFactoryBean"
    p:dataSource-ref="postgresDataSource">
    <property name="configuration">
      <bean class="org.apache.ibatis.session.Configuration"
        p:localCacheScope="STATEMENT"
        p:mapUnderscoreToCamelCase="true"
        p:lazyLoadingEnabled="true"
        p:aggressiveLazyLoading="false"
        p:defaultFetchSize="1000"
        p:defaultExecutorType="REUSE" />
    </property>
    <property name="mapperLocations" value="classpath*:dao/postgres/*.xml" />
  </bean>

    <bean class="org.mybatis.spring.mapper.MapperScannerConfigurer">
        <property name="basePackage" value="xxx.dao.postgres" />
        <property name="sqlSessionFactoryBeanName" value="postgresSqlSessionFactory" />
    </bean>
```

SampleImpl.java
```JAVA
@Component
public class SampleImpl implements Sample{

    @Autowired
    SampleModel model;

    @Override
    @Transactional(value="postgresTransactionManager")
    public void insert(Entity entity) {

        model.insert(entity);
        model.insert(entity); //一意制約エラーを起こす
    }
}

```

SampleModelImpl.java
```JAVA
@Component
public class SampleModelImpl implements SampleModel {

    @Autowired
    private UserMapper mapper;

    @Override
    public void insert(Entity entity) {
        mapper.insert(entity);
    }
}

```

###最後に
@Transactionalの使い方がよくないのでしょうか？
誤っている点などがありましたら、ご指摘ください。
どうぞよろしくお願い致します。