diff options
author | afinkbein | 2008-05-20 16:24:55 +0000 |
---|---|---|
committer | afinkbein | 2008-05-20 16:24:55 +0000 |
commit | 3a9ef92451578c3edc2f48345ffe7250615cec58 (patch) | |
tree | 7b4115621c9815606afb258fd15d183a9d17a89a | |
parent | ef47d8bbbaae98d59858aed61bb62f65bb33a3de (diff) | |
download | org.eclipse.osee-3a9ef92451578c3edc2f48345ffe7250615cec58.tar.gz org.eclipse.osee-3a9ef92451578c3edc2f48345ffe7250615cec58.tar.xz org.eclipse.osee-3a9ef92451578c3edc2f48345ffe7250615cec58.zip |
-rw-r--r-- | org.eclipse.osee.framework.ui.skynet/src/org/eclipse/osee/framework/ui/skynet/blam/operation/UpdateCurrentColumn.java | 25 |
1 files changed, 15 insertions, 10 deletions
diff --git a/org.eclipse.osee.framework.ui.skynet/src/org/eclipse/osee/framework/ui/skynet/blam/operation/UpdateCurrentColumn.java b/org.eclipse.osee.framework.ui.skynet/src/org/eclipse/osee/framework/ui/skynet/blam/operation/UpdateCurrentColumn.java index 0e74560af79..836f3175bc1 100644 --- a/org.eclipse.osee.framework.ui.skynet/src/org/eclipse/osee/framework/ui/skynet/blam/operation/UpdateCurrentColumn.java +++ b/org.eclipse.osee.framework.ui.skynet/src/org/eclipse/osee/framework/ui/skynet/blam/operation/UpdateCurrentColumn.java @@ -68,6 +68,7 @@ public class UpdateCurrentColumn extends AbstractBlam { "Updating attributes, artifacts, and relations current_tx column from transaction id [%d].", txNumber)); Connection connection = null; try { + int rowsUpdated; List<UpdateHelper> updates = new ArrayList<UpdateHelper>(); connection = OseeDbConnection.getConnection(); updateBaselinedTransactionsToCurrent(connection, txNumber); @@ -76,12 +77,14 @@ public class UpdateCurrentColumn extends AbstractBlam { getUpdates(connection, updates, 3, SELECT_RELATIONS_TO_UPDATE, txNumber); long time = System.currentTimeMillis(); appendResultLine(String.format("Going to update [%d] items to a 0 tx_current value.", updates.size())); - updateTxCurrentToZero(connection, updates); - appendResultLine(String.format("Took [%d]ms to update.", (System.currentTimeMillis() - time))); + rowsUpdated = updateTxCurrentToZero(connection, updates); + appendResultLine(String.format("Took [%d]ms to update [%d] rows.", (System.currentTimeMillis() - time), + rowsUpdated)); time = System.currentTimeMillis(); appendResultLine(String.format("Going to update [%d] items to a 1 tx_current value.", updates.size())); - updateTxCurrentToOne(connection, updates); - appendResultLine(String.format("Took [%d]ms to update.", (System.currentTimeMillis() - time))); + rowsUpdated = updateTxCurrentToOne(connection, updates); + appendResultLine(String.format("Took [%d]ms to update [%d] rows.", (System.currentTimeMillis() - time), + rowsUpdated)); } finally { if (connection != null) { connection.close(); @@ -120,12 +123,12 @@ public class UpdateCurrentColumn extends AbstractBlam { * @param updates * @throws SQLException */ - private void updateTxCurrentToOne(Connection connection, List<UpdateHelper> updates) throws SQLException { + private int updateTxCurrentToOne(Connection connection, List<UpdateHelper> updates) throws SQLException { List<Object[]> batchArgs = new ArrayList<Object[]>(); for (UpdateHelper data : updates) { batchArgs.add(new Object[] {SQL3DataType.BIGINT, data.gamma_id, SQL3DataType.INTEGER, data.transaction_id}); } - ConnectionHandler.runPreparedUpdate(connection, UPDATE_TXS_CURRENT_TO_1, batchArgs); + return ConnectionHandler.runPreparedUpdate(connection, UPDATE_TXS_CURRENT_TO_1, batchArgs); } /** @@ -133,7 +136,8 @@ public class UpdateCurrentColumn extends AbstractBlam { * @param updates * @throws SQLException */ - private void updateTxCurrentToZero(Connection connection, List<UpdateHelper> updates) throws SQLException { + private int updateTxCurrentToZero(Connection connection, List<UpdateHelper> updates) throws SQLException { + int rowsUpdated = 0; List<Object[]> attrBatchArgs = new ArrayList<Object[]>(); List<Object[]> artBatchArgs = new ArrayList<Object[]>(); List<Object[]> linkBatchArgs = new ArrayList<Object[]>(); @@ -149,9 +153,10 @@ public class UpdateCurrentColumn extends AbstractBlam { SQL3DataType.INTEGER, data.branch_id, SQL3DataType.INTEGER, data.id}); } } - ConnectionHandler.runPreparedUpdate(connection, UPDATE_ATTRIBUTE_CURRENT_TO_0, attrBatchArgs); - ConnectionHandler.runPreparedUpdate(connection, UPDATE_ARTIFACT_CURRENT_TO_0, artBatchArgs); - ConnectionHandler.runPreparedUpdate(connection, UPDATE_RELATION_CURRENT_TO_0, linkBatchArgs); + rowsUpdated += ConnectionHandler.runPreparedUpdate(connection, UPDATE_ATTRIBUTE_CURRENT_TO_0, attrBatchArgs); + rowsUpdated += ConnectionHandler.runPreparedUpdate(connection, UPDATE_ARTIFACT_CURRENT_TO_0, artBatchArgs); + rowsUpdated += ConnectionHandler.runPreparedUpdate(connection, UPDATE_RELATION_CURRENT_TO_0, linkBatchArgs); + return rowsUpdated; } private void getUpdates(Connection connection, List<UpdateHelper> updates, int type, String query, int txNumber) throws SQLException { |