diff options
author | Ryan D. Brooks | 2013-10-01 05:42:01 +0000 |
---|---|---|
committer | Roberto E. Escobar | 2013-10-12 01:16:38 +0000 |
commit | 8947a09c304cf45ca4beba0af5a15e220f118770 (patch) | |
tree | 09b51281b40db1f54822e7e0ebe0c5b6ca881947 /plugins/org.eclipse.osee.framework.database | |
parent | 591224f3d1942c0f9baffac2f954d66ced185833 (diff) | |
download | org.eclipse.osee-8947a09c304cf45ca4beba0af5a15e220f118770.tar.gz org.eclipse.osee-8947a09c304cf45ca4beba0af5a15e220f118770.tar.xz org.eclipse.osee-8947a09c304cf45ca4beba0af5a15e220f118770.zip |
refactor: Replace in-place constant with MAX_FETCH
Change-Id: I9a8c2dbe7c62f2ea87fff8751de6bc60c6b9647e
Diffstat (limited to 'plugins/org.eclipse.osee.framework.database')
3 files changed, 6 insertions, 3 deletions
diff --git a/plugins/org.eclipse.osee.framework.database/src/org/eclipse/osee/framework/database/core/IOseeStatement.java b/plugins/org.eclipse.osee.framework.database/src/org/eclipse/osee/framework/database/core/IOseeStatement.java index b8fcce897ad..a145de304c0 100644 --- a/plugins/org.eclipse.osee.framework.database/src/org/eclipse/osee/framework/database/core/IOseeStatement.java +++ b/plugins/org.eclipse.osee.framework.database/src/org/eclipse/osee/framework/database/core/IOseeStatement.java @@ -23,6 +23,7 @@ import org.eclipse.osee.framework.core.exception.OseeCoreException; * @author Ryan D. Brooks */ public interface IOseeStatement extends Closeable { + int MAX_FETCH = 10000; void runPreparedQuery(String query, Object... data) throws OseeCoreException; diff --git a/plugins/org.eclipse.osee.framework.database/src/org/eclipse/osee/framework/database/operation/InvalidTxCurrentsAndModTypes.java b/plugins/org.eclipse.osee.framework.database/src/org/eclipse/osee/framework/database/operation/InvalidTxCurrentsAndModTypes.java index 46bd99b0db3..fdf146be1f4 100644 --- a/plugins/org.eclipse.osee.framework.database/src/org/eclipse/osee/framework/database/operation/InvalidTxCurrentsAndModTypes.java +++ b/plugins/org.eclipse.osee.framework.database/src/org/eclipse/osee/framework/database/operation/InvalidTxCurrentsAndModTypes.java @@ -10,6 +10,7 @@ *******************************************************************************/ package org.eclipse.osee.framework.database.operation; +import static org.eclipse.osee.framework.database.core.IOseeStatement.MAX_FETCH; import java.util.ArrayList; import java.util.List; import org.eclipse.core.runtime.IProgressMonitor; @@ -179,7 +180,7 @@ public class InvalidTxCurrentsAndModTypes extends AbstractOperation { IOseeStatement chStmt = getDatabaseService().getStatement(); String sql = String.format(SELECT_ADDRESSES, columnName, tableName, txsTableName, columnName); try { - chStmt.runPreparedQuery(10000, sql); + chStmt.runPreparedQuery(MAX_FETCH, sql); monitor.worked(calculateWork(0.40)); Address previousAddress = null; diff --git a/plugins/org.eclipse.osee.framework.database/src/org/eclipse/osee/framework/database/operation/PurgeTransactionOperation.java b/plugins/org.eclipse.osee.framework.database/src/org/eclipse/osee/framework/database/operation/PurgeTransactionOperation.java index 56e8bc7218f..245db978498 100644 --- a/plugins/org.eclipse.osee.framework.database/src/org/eclipse/osee/framework/database/operation/PurgeTransactionOperation.java +++ b/plugins/org.eclipse.osee.framework.database/src/org/eclipse/osee/framework/database/operation/PurgeTransactionOperation.java @@ -11,6 +11,7 @@ package org.eclipse.osee.framework.database.operation; +import static org.eclipse.osee.framework.database.core.IOseeStatement.MAX_FETCH; import java.util.ArrayList; import java.util.Collection; import java.util.HashMap; @@ -168,7 +169,7 @@ public class PurgeTransactionOperation extends AbstractDbTxOperation { IOseeStatement statement = ConnectionHandler.getStatement(connection); try { - statement.runPreparedQuery(10000, query, joinQuery.getQueryId(), branchId); + statement.runPreparedQuery(MAX_FETCH, query, joinQuery.getQueryId(), branchId); int previousItem = -1; while (statement.next()) { int currentItem = statement.getInt("item_id"); @@ -199,7 +200,7 @@ public class PurgeTransactionOperation extends AbstractDbTxOperation { for (Object[] bindData : bindDataList) { Integer branchId = (Integer) bindData[0]; String query = String.format(SELECT_AFFECTED_ITEMS, itemId, itemTable); - statement.runPreparedQuery(10000, query, bindData); + statement.runPreparedQuery(MAX_FETCH, query, bindData); IdJoinQuery joinId = JoinUtility.createIdJoinQuery(); items.put(branchId, joinId); |