1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
130
131
132
133
134
135
136
137
138
139
140
141
142
143
144
145
146
147
148
149
150
151
152
153
154
155
156
157
158
159
160
161
162
163
164
165
166
167
168
169
170
171
172
173
174
175
176
|
/*******************************************************************************
* Copyright (c) 2004, 2007 Boeing.
* All rights reserved. This program and the accompanying materials
* are made available under the terms of the Eclipse Public License v1.0
* which accompanies this distribution, and is available at
* http://www.eclipse.org/legal/epl-v10.html
*
* Contributors:
* Boeing - initial API and implementation
*******************************************************************************/
package org.eclipse.osee.framework.branch.management.purge;
import java.util.ArrayList;
import java.util.List;
import java.util.logging.Level;
import org.eclipse.core.runtime.IProgressMonitor;
import org.eclipse.osee.framework.branch.management.internal.InternalBranchActivator;
import org.eclipse.osee.framework.core.cache.BranchCache;
import org.eclipse.osee.framework.core.enums.TransactionDetailsType;
import org.eclipse.osee.framework.core.exception.OseeArgumentException;
import org.eclipse.osee.framework.core.exception.OseeCoreException;
import org.eclipse.osee.framework.core.exception.OseeDataStoreException;
import org.eclipse.osee.framework.core.model.Branch;
import org.eclipse.osee.framework.core.services.IOseeCachingServiceProvider;
import org.eclipse.osee.framework.database.IOseeDatabaseServiceProvider;
import org.eclipse.osee.framework.database.core.AbstractDbTxOperation;
import org.eclipse.osee.framework.database.core.IOseeStatement;
import org.eclipse.osee.framework.database.core.OseeConnection;
import org.eclipse.osee.framework.logging.OseeLog;
/**
* @author Megumi Telles
* @author Jeff C. Phillips
* @author Robert A. Fisher
* @author Ryan D. Brooks
*/
public class PurgeBranchOperation extends AbstractDbTxOperation {
private static final String COUNT_CHILD_BRANCHES = "select count(1) from osee_branch WHERE parent_branch_id = ?";
private static final String SELECT_DELETABLE_GAMMAS =
"select %s from osee_tx_details txd1, %s txs1 where txd1.branch_id = ? AND txd1.tx_type = %d AND txd1.transaction_id = txs1.transaction_id AND NOT EXISTS (SELECT 1 FROM osee_txs txs2, osee_tx_details txd2 WHERE txs1.%s = txs2.gamma_id AND txd2.transaction_id = txs2.transaction_id AND txd1.branch_id <> txd2.branch_id)AND NOT EXISTS (SELECT 1 FROM osee_txs_archived txs3, osee_tx_details txd3 WHERE txs1.%s = txs3.gamma_id AND txd3.transaction_id = txs3.transaction_id AND txd1.branch_id <> txd3.branch_id)";
public static final String TEST_TXS =
"select count(1) from osee_tx_details txd where txd.branch_id = ? AND txd.tx_type = 1 AND exists (select 1 from osee_txs txs where txd.transaction_id = txs.transaction_id)";
private static final String PURGE_GAMMAS = "delete from %s where gamma_id = ?";
private static final String DELETE_FROM_ARTIFACT =
"delete from osee_artifact art where not exists (select 1 from osee_artifact_version arv where arv.art_id = art.art_id)";
private static final String DELETE_FROM_TX_DETAILS = "delete from osee_tx_details where branch_id = ?";
private static final String DELETE_FROM_BRANCH_TABLE = "delete from osee_branch where branch_id = ?";
public static final String SELECT_ADDRESSING_BY_BRANCH =
"select txd.transaction_id, gamma_id from %s txs, osee_tx_details txd where txs.transaction_id = txd.transaction_id and txd.branch_id = ?";
private final Branch branch;
private final List<Object[]> deleteableGammas = new ArrayList<Object[]>();
private OseeConnection connection;
private IProgressMonitor monitor;
private String sourceTableName;
private final IOseeCachingServiceProvider cachingService;
private final IOseeDatabaseServiceProvider oseeDatabaseProvider;
public PurgeBranchOperation(Branch branch, IOseeCachingServiceProvider cachingService, IOseeDatabaseServiceProvider oseeDatabaseProvider) {
super(oseeDatabaseProvider, String.format("Purge Branch: [(%s)-%s]", branch.getId(), branch.getShortName()), InternalBranchActivator.PLUGIN_ID);
this.branch = branch;
this.sourceTableName = branch.getArchiveState().isArchived() ? "osee_txs_archived" : "osee_txs";
this.cachingService = cachingService;
this.oseeDatabaseProvider = oseeDatabaseProvider;
}
@Override
protected void doTxWork(IProgressMonitor monitor, OseeConnection connection) throws OseeCoreException {
this.connection = connection;
this.monitor = monitor;
int numberOfChildren =
oseeDatabaseProvider.getOseeDatabaseService().runPreparedQueryFetchObject(0, COUNT_CHILD_BRANCHES, branch.getId());
if (numberOfChildren > 0) {
throw new OseeArgumentException("Unable to purge a branch containing children");
}
if (oseeDatabaseProvider.getOseeDatabaseService().runPreparedQueryFetchObject(0, TEST_TXS, branch.getId()) == 1) {
sourceTableName = "osee_txs";
} else {
sourceTableName = "osee_txs_archived";
}
monitor.worked(calculateWork(0.05));
findDeleteableGammas("osee_removed_txs", "rem_gamma_id", 0.10);
findDeleteableGammas(sourceTableName, "gamma_id", 0.10);
purgeGammas("osee_artifact_version", 0.10);
purgeGammas("osee_attribute", 0.10);
purgeGammas("osee_relation_link", 0.10);
purgeFromTable("Artifact", DELETE_FROM_ARTIFACT, 0.10);
purgeAddressing(0.20);
purgeFromTable("Tx Details", DELETE_FROM_TX_DETAILS, 0.09, branch.getId());
purgeFromTable("Branch", DELETE_FROM_BRANCH_TABLE, 0.01, branch.getId());
}
@Override
protected void doFinally(IProgressMonitor monitor) {
super.doFinally(monitor);
if (getStatus().isOK()) {
BranchCache branchCache;
try {
branchCache = cachingService.getOseeCachingService().getBranchCache();
branchCache.decache(branch);
}
catch (OseeCoreException ex) {
OseeLog.log(InternalBranchActivator.class, Level.SEVERE, ex);
}
}
}
private void purgeGammas(String tableName, double percentage) throws OseeDataStoreException {
if (!deleteableGammas.isEmpty()) {
monitor.setTaskName(String.format("Purge from %s", tableName));
checkForCancelledStatus(monitor);
String sql = String.format(PURGE_GAMMAS, tableName);
oseeDatabaseProvider.getOseeDatabaseService().runBatchUpdate(connection, sql, deleteableGammas);
}
monitor.worked(calculateWork(percentage));
}
private void purgeFromTable(String tableName, String sql, double percentage, Object... data) throws OseeDataStoreException {
monitor.setTaskName(String.format("Purge from %s", tableName));
checkForCancelledStatus(monitor);
oseeDatabaseProvider.getOseeDatabaseService().runPreparedUpdate(connection, sql, data);
monitor.worked(calculateWork(percentage));
}
private void findDeleteableGammas(String sourceTableName, String columnName, double percentage) throws OseeDataStoreException {
IOseeStatement chStmt = oseeDatabaseProvider.getOseeDatabaseService().getStatement(connection);
String sql =
String.format(SELECT_DELETABLE_GAMMAS, columnName, sourceTableName,
TransactionDetailsType.NonBaselined.getId(), columnName, columnName);
try {
chStmt.runPreparedQuery(10000, sql, branch.getId());
while (chStmt.next()) {
deleteableGammas.add(new Object[] {chStmt.getLong(columnName)});
}
} finally {
chStmt.close();
monitor.worked(calculateWork(percentage));
}
}
private void purgeAddressing(double percentage) throws OseeDataStoreException {
monitor.setTaskName("Purge txs addressing");
IOseeStatement chStmt = oseeDatabaseProvider.getOseeDatabaseService().getStatement(connection);
List<Object[]> addressing = new ArrayList<Object[]>();
String sql = String.format(SELECT_ADDRESSING_BY_BRANCH, sourceTableName);
try {
chStmt.runPreparedQuery(10000, sql, branch.getId());
while (chStmt.next()) {
addressing.add(new Object[] {chStmt.getInt("transaction_id"), chStmt.getLong("gamma_id")});
}
} finally {
chStmt.close();
}
sql = String.format("delete from %s where transaction_id = ? and gamma_id = ?", sourceTableName);
oseeDatabaseProvider.getOseeDatabaseService().runBatchUpdate(connection, sql, addressing);
monitor.worked(calculateWork(percentage));
}
}
|
