add sqlId() api to SqlEntity interfaces. (#324)

future-architect · Jul 30, 2024 · bf52679 · bf52679
1 parent 09baff3
commit bf52679
Show file tree

Hide file tree

Showing 6 changed files with 171 additions and 0 deletions.
diff --git a/src/main/java/jp/co/future/uroborosql/SqlEntityDeleteImpl.java b/src/main/java/jp/co/future/uroborosql/SqlEntityDeleteImpl.java
@@ -45,6 +45,38 @@ final class SqlEntityDeleteImpl<E> extends AbstractExtractionCondition<SqlEntity
 		this.entityType = entityType;
 	}
 
+	/**
+	 * {@inheritDoc}
+	 *
+	 * @see jp.co.future.uroborosql.fluent.SqlEntityDelete#sqlId(java.lang.String)
+	 */
+	@Override
+	public SqlEntityDelete<E> sqlId(final String sqlId) {
+		context().setSqlId(sqlId);
+		return this;
+	}
+
+	/**
+	 * {@inheritDoc}
+	 *
+	 * @see jp.co.future.uroborosql.fluent.SqlEntityDelete#retry(int)
+	 */
+	@Override
+	public SqlEntityDelete<E> retry(final int count) {
+		return retry(count, 0);
+	}
+
+	/**
+	 * {@inheritDoc}
+	 *
+	 * @see jp.co.future.uroborosql.fluent.SqlEntityDelete#retry(int, int)
+	 */
+	@Override
+	public SqlEntityDelete<E> retry(final int count, final int waitTime) {
+		context().setMaxRetryCount(count).setRetryWaitTime(waitTime);
+		return this;
+	}
+
 	@Override
 	public int count() {
 		try {

diff --git a/src/main/java/jp/co/future/uroborosql/SqlEntityQueryImpl.java b/src/main/java/jp/co/future/uroborosql/SqlEntityQueryImpl.java
@@ -80,6 +80,38 @@ final class SqlEntityQueryImpl<E> extends AbstractExtractionCondition<SqlEntityQ
 		this.excludeColumns = new ArrayList<>();
 	}
 
+	/**
+	 * {@inheritDoc}
+	 *
+	 * @see jp.co.future.uroborosql.fluent.SqlEntityQuery#sqlId(java.lang.String)
+	 */
+	@Override
+	public SqlEntityQuery<E> sqlId(final String sqlId) {
+		context().setSqlId(sqlId);
+		return this;
+	}
+
+	/**
+	 * {@inheritDoc}
+	 *
+	 * @see jp.co.future.uroborosql.fluent.SqlEntityQuery#retry(int)
+	 */
+	@Override
+	public SqlEntityQuery<E> retry(final int count) {
+		return retry(count, 0);
+	}
+
+	/**
+	 * {@inheritDoc}
+	 *
+	 * @see jp.co.future.uroborosql.fluent.SqlEntityQuery#retry(int, int)
+	 */
+	@Override
+	public SqlEntityQuery<E> retry(final int count, final int waitTime) {
+		context().setMaxRetryCount(count).setRetryWaitTime(waitTime);
+		return this;
+	}
+
 	/**
 	 * {@inheritDoc}
 	 *

diff --git a/src/main/java/jp/co/future/uroborosql/SqlEntityUpdateImpl.java b/src/main/java/jp/co/future/uroborosql/SqlEntityUpdateImpl.java
@@ -48,6 +48,38 @@ final class SqlEntityUpdateImpl<E> extends AbstractExtractionCondition<SqlEntity
 		this.entityType = entityType;
 	}
 
+	/**
+	 * {@inheritDoc}
+	 *
+	 * @see jp.co.future.uroborosql.fluent.SqlEntityUpdate#sqlId(java.lang.String)
+	 */
+	@Override
+	public SqlEntityUpdate<E> sqlId(final String sqlId) {
+		context().setSqlId(sqlId);
+		return this;
+	}
+
+	/**
+	 * {@inheritDoc}
+	 *
+	 * @see jp.co.future.uroborosql.fluent.SqlEntityUpdate#retry(int)
+	 */
+	@Override
+	public SqlEntityUpdate<E> retry(final int count) {
+		return retry(count, 0);
+	}
+
+	/**
+	 * {@inheritDoc}
+	 *
+	 * @see jp.co.future.uroborosql.fluent.SqlEntityUpdate#retry(int, int)
+	 */
+	@Override
+	public SqlEntityUpdate<E> retry(final int count, final int waitTime) {
+		context().setMaxRetryCount(count).setRetryWaitTime(waitTime);
+		return this;
+	}
+
 	/**
 	 * {@inheritDoc}
 	 *

diff --git a/src/main/java/jp/co/future/uroborosql/fluent/SqlEntityDelete.java b/src/main/java/jp/co/future/uroborosql/fluent/SqlEntityDelete.java
@@ -13,6 +13,31 @@
  * @author ota
  */
 public interface SqlEntityDelete<E> extends ExtractionCondition<SqlEntityDelete<E>> {
+	/**
+	 * 発行するSQLに付与するSQL_IDを設定する
+	 *
+	 * @param sqlId SQL_ID文字列
+	 * @return SqlEntityDelete
+	 */
+	SqlEntityDelete<E> sqlId(String sqlId);
+
+	/**
+	 * リトライ回数を設定する。 リトライ待機時間は0msが設定される
+	 *
+	 * @param count リトライ回数
+	 * @return SqlEntityDelete
+	 */
+	SqlEntityDelete<E> retry(int count);
+
+	/**
+	 * リトライ回数を設定する
+	 *
+	 * @param count リトライ回数
+	 * @param waitTime リトライ待機時間（ms）
+	 * @return SqlEntityDelete
+	 */
+	SqlEntityDelete<E> retry(int count, int waitTime);
+
 	/**
 	 * 削除結果の取得（終端処理）
 	 *

diff --git a/src/main/java/jp/co/future/uroborosql/fluent/SqlEntityQuery.java b/src/main/java/jp/co/future/uroborosql/fluent/SqlEntityQuery.java
@@ -52,6 +52,31 @@ public String toString() {
 		}
 	}
 
+	/**
+	 * 発行するSQLに付与するSQL_IDを設定する
+	 *
+	 * @param sqlId SQL_ID文字列
+	 * @return SqlEntityQuery
+	 */
+	SqlEntityQuery<E> sqlId(String sqlId);
+
+	/**
+	 * リトライ回数を設定する。 リトライ待機時間は0msが設定される
+	 *
+	 * @param count リトライ回数
+	 * @return SqlEntityQuery
+	 */
+	SqlEntityQuery<E> retry(int count);
+
+	/**
+	 * リトライ回数を設定する
+	 *
+	 * @param count リトライ回数
+	 * @param waitTime リトライ待機時間（ms）
+	 * @return SqlEntityQuery
+	 */
+	SqlEntityQuery<E> retry(int count, int waitTime);
+
 	/**
 	 * 検索結果の取得（終端処理）
 	 *

diff --git a/src/main/java/jp/co/future/uroborosql/fluent/SqlEntityUpdate.java b/src/main/java/jp/co/future/uroborosql/fluent/SqlEntityUpdate.java
@@ -16,6 +16,31 @@
  * @author H.Sugimoto
  */
 public interface SqlEntityUpdate<E> extends ExtractionCondition<SqlEntityUpdate<E>> {
+	/**
+	 * 発行するSQLに付与するSQL_IDを設定する
+	 *
+	 * @param sqlId SQL_ID文字列
+	 * @return SqlEntityUpdate
+	 */
+	SqlEntityUpdate<E> sqlId(String sqlId);
+
+	/**
+	 * リトライ回数を設定する。 リトライ待機時間は0msが設定される
+	 *
+	 * @param count リトライ回数
+	 * @return SqlEntityUpdate
+	 */
+	SqlEntityUpdate<E> retry(int count);
+
+	/**
+	 * リトライ回数を設定する
+	 *
+	 * @param count リトライ回数
+	 * @param waitTime リトライ待機時間（ms）
+	 * @return SqlEntityUpdate
+	 */
+	SqlEntityUpdate<E> retry(int count, int waitTime);
+
 	/**
 	 * 更新結果の取得（終端処理）
 	 *