DBアクセスに失敗した場合、5回までリトライしたい

Question

SpringBootを使用しています。
DBアクセスに失敗した場合、リトライ処理を入れたいのですがどうもうまくいきません。
Connectionにはsql2Oを使用しています。

実装したい詳細な内容

DB接続時にsql2OExceptionの例外が返ってきた場合、5秒間待機してから5回までリトライする
リトライ回数が5回になったら終了する。

	public void dbacceser() {
		try(Connection con = sql2o.open()){
			List <ProgressDataCollect> prodata = result.executeAndFetch(ProgressDataCollect.class);

			int countarray[] = new int[3];

			/** 1レコードずつ処理開始 **/
			for (int i = 0; i < prodata.size(); i++) {
		}
		catch (Sql2oException e) {
			this.logger.warn(e.getMessage());
             /**リトライ処理を入れたい */
		}

詳しい方、アドバイスお願いします。

Answer 1

SpringBootをご利用でしたら、https://github.com/spring-projects/spring-retry を導入するのが一番簡単です
※Spring-RetryはAOPの機能を使うので、spring-boot-starter-aopも必要です。

import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.retry.annotation.Backoff;
import org.springframework.retry.annotation.Recover;
import org.springframework.retry.annotation.Retryable;
import org.springframework.stereotype.Repository;
import org.springframework.transaction.annotation.Transactional;
import org.sql2o.Connection;
import org.sql2o.Sql2o;

import lombok.extern.log4j.Log4j2;

@Repository
@Retryable
public class SampleRepository {

	@Autowired
	Sql2o sql2o;

	@Retryable(maxAttempts = 5, backoff=@Backoff(delay=5000), value = Exception.class)
	@Transactional(readOnly = true)
	public int findCount() {
		String sql = "SELECT count(*) FROM sample1oo";

		try (Connection con = sql2o.open()) {
			return con.createQuery(sql).executeScalar(Integer.class);
		}
	}
	@Recover
	public int recover() {
		log.warn("-- failure");
		return -1;
	}
}

import javax.sql.DataSource;

import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;
import org.springframework.jdbc.datasource.DataSourceTransactionManager;
import org.springframework.retry.annotation.EnableRetry;
import org.springframework.transaction.PlatformTransactionManager;
import org.springframework.transaction.annotation.EnableTransactionManagement;
import org.springframework.transaction.annotation.TransactionManagementConfigurer;
import org.sql2o.Sql2o;

@Configuration
@EnableTransactionManagement
@EnableRetry
public class Sql2oConfig implements TransactionManagementConfigurer {

	@Autowired
	DataSource dataSource;

	@Bean
	public Sql2o sql2o() {
		return new Sql2o(dataSource);
	}

	@Override
	public PlatformTransactionManager annotationDrivenTransactionManager() {
		return new DataSourceTransactionManager(dataSource);
	}
}

Answer 2

そのDBアクセスに係る処理を一つのメソッドにまとめてしまいます。
アクセスに成功したらTrue、失敗したらFalseを返すようにしておきます

次に、for文あたりで５回ループ処理を書いて、その関数を実行させ、返り値がTrueなら成功として終了、すべてFalseなら失敗として終了するような関数を組みましょう