169 lines
5.7 KiB
Java
169 lines
5.7 KiB
Java
package com.minres.scviewer.database.sqlite;
|
|
|
|
import java.beans.IntrospectionException;
|
|
import java.lang.reflect.InvocationTargetException;
|
|
import java.sql.SQLException;
|
|
import java.util.ArrayList;
|
|
import java.util.Collection;
|
|
import java.util.List;
|
|
|
|
import com.minres.scviewer.database.AssociationType;
|
|
import com.minres.scviewer.database.ITx;
|
|
import com.minres.scviewer.database.ITxAttribute;
|
|
import com.minres.scviewer.database.ITxEvent;
|
|
import com.minres.scviewer.database.ITxGenerator;
|
|
import com.minres.scviewer.database.ITxRelation;
|
|
import com.minres.scviewer.database.ITxStream;
|
|
import com.minres.scviewer.database.sqlite.db.IDatabase;
|
|
import com.minres.scviewer.database.sqlite.db.SQLiteDatabaseSelectHandler;
|
|
import com.minres.scviewer.database.sqlite.tables.ScvTx;
|
|
import com.minres.scviewer.database.sqlite.tables.ScvTxAttribute;
|
|
import com.minres.scviewer.database.sqlite.tables.ScvTxEvent;
|
|
import com.minres.scviewer.database.sqlite.tables.ScvTxRelation;
|
|
|
|
public class Tx implements ITx {
|
|
|
|
private IDatabase database;
|
|
private TxStream trStream;
|
|
private TxGenerator trGenerator;
|
|
private ScvTx scvTx;
|
|
private List<ITxAttribute> attributes;
|
|
private Long begin, end;
|
|
private List<ITxRelation> incoming, outgoing;
|
|
|
|
public Tx(IDatabase database, TxStream trStream, TxGenerator trGenerator, ScvTx scvTx) {
|
|
this.database=database;
|
|
this.trStream=trStream;
|
|
this.trGenerator=trGenerator;
|
|
this.scvTx=scvTx;
|
|
}
|
|
|
|
@Override
|
|
public Long getId() {
|
|
return (long) scvTx.getId();
|
|
}
|
|
|
|
@Override
|
|
public ITxStream<ITxEvent> getStream() {
|
|
return trStream;
|
|
}
|
|
|
|
@Override
|
|
public ITxGenerator getGenerator() {
|
|
return trGenerator;
|
|
}
|
|
|
|
@Override
|
|
public int getConcurrencyIndex() {
|
|
return scvTx.getConcurrencyLevel();
|
|
}
|
|
|
|
@Override
|
|
public Long getBeginTime() {
|
|
if(begin==null){
|
|
SQLiteDatabaseSelectHandler<ScvTxEvent> handler = new SQLiteDatabaseSelectHandler<ScvTxEvent>(ScvTxEvent.class,
|
|
database, "tx="+scvTx.getId()+" AND type="+ AssociationType.BEGIN.ordinal());
|
|
try {
|
|
for(ScvTxEvent scvEvent:handler.selectObjects()){
|
|
begin= scvEvent.getTime()*(Long)database.getData("TIMERESOLUTION");
|
|
}
|
|
} catch (SecurityException | IllegalArgumentException | InstantiationException | IllegalAccessException
|
|
| InvocationTargetException | SQLException | IntrospectionException e) {
|
|
}
|
|
}
|
|
return begin;
|
|
}
|
|
|
|
@Override
|
|
public Long getEndTime() {
|
|
if(end==null){
|
|
SQLiteDatabaseSelectHandler<ScvTxEvent> handler = new SQLiteDatabaseSelectHandler<ScvTxEvent>(ScvTxEvent.class,
|
|
database, "tx="+scvTx.getId()+" AND type="+ AssociationType.END.ordinal());
|
|
try {
|
|
for(ScvTxEvent scvEvent:handler.selectObjects()){
|
|
end = scvEvent.getTime()*(Long)database.getData("TIMERESOLUTION");
|
|
}
|
|
} catch (SecurityException | IllegalArgumentException | InstantiationException | IllegalAccessException
|
|
| InvocationTargetException | SQLException | IntrospectionException e) {
|
|
}
|
|
}
|
|
return end;
|
|
}
|
|
|
|
@Override
|
|
public List<ITxAttribute> getAttributes() {
|
|
if(attributes==null){
|
|
SQLiteDatabaseSelectHandler<ScvTxAttribute> handler = new SQLiteDatabaseSelectHandler<ScvTxAttribute>(
|
|
ScvTxAttribute.class, database, "tx="+scvTx.getId());
|
|
try {
|
|
attributes = new ArrayList<ITxAttribute>();
|
|
for(ScvTxAttribute scvAttribute:handler.selectObjects()){
|
|
attributes.add(new TxAttribute(this, scvAttribute));
|
|
|
|
}
|
|
} catch (SecurityException | IllegalArgumentException | InstantiationException | IllegalAccessException
|
|
| InvocationTargetException | SQLException | IntrospectionException e) {
|
|
}
|
|
}
|
|
return attributes;
|
|
}
|
|
|
|
@Override
|
|
public Collection<ITxRelation> getIncomingRelations() {
|
|
if(incoming==null){
|
|
SQLiteDatabaseSelectHandler<ScvTxRelation> handler = new SQLiteDatabaseSelectHandler<ScvTxRelation>(
|
|
ScvTxRelation.class, database, "sink="+scvTx.getId());
|
|
try {
|
|
incoming = new ArrayList<ITxRelation>();
|
|
for(ScvTxRelation scvRelation:handler.selectObjects()){
|
|
incoming.add(createRelation(scvRelation, false));
|
|
}
|
|
} catch (SecurityException | IllegalArgumentException | InstantiationException | IllegalAccessException
|
|
| InvocationTargetException | SQLException | IntrospectionException e) {
|
|
}
|
|
}
|
|
return incoming;
|
|
}
|
|
|
|
@Override
|
|
public Collection<ITxRelation> getOutgoingRelations() {
|
|
if(outgoing==null){
|
|
SQLiteDatabaseSelectHandler<ScvTxRelation> handler = new SQLiteDatabaseSelectHandler<ScvTxRelation>(
|
|
ScvTxRelation.class, database, "src="+scvTx.getId());
|
|
try {
|
|
outgoing = new ArrayList<ITxRelation>();
|
|
for(ScvTxRelation scvRelation:handler.selectObjects()){
|
|
outgoing.add(createRelation(scvRelation, true));
|
|
}
|
|
} catch (SecurityException | IllegalArgumentException | InstantiationException | IllegalAccessException
|
|
| InvocationTargetException | SQLException | IntrospectionException e) {
|
|
}
|
|
}
|
|
return outgoing;
|
|
}
|
|
|
|
private ITxRelation createRelation(ScvTxRelation rel, boolean outgoing) {
|
|
long otherId = outgoing?rel.getSink():rel.getSrc();
|
|
/*FIXME:
|
|
try {
|
|
List<ScvTx> scvTx=new SQLiteDatabaseSelectHandler<ScvTx>(ScvTx.class, database, "id="+otherId).selectObjects();
|
|
assert(scvTx.size()==1);
|
|
ITxStream stream = trStream.getDb().getStreamById(scvTx.get(0).getStream());
|
|
Tx that=(Tx) stream.getTransactionById(otherId);
|
|
if(outgoing)
|
|
return new TxRelation(trStream.getDb().getRelationType(rel.getName()), this, that);
|
|
else
|
|
return new TxRelation(trStream.getDb().getRelationType(rel.getName()), that, this);
|
|
} catch (SecurityException | IllegalArgumentException | InstantiationException | IllegalAccessException
|
|
| InvocationTargetException | SQLException | IntrospectionException e) {
|
|
}*/
|
|
return null;
|
|
}
|
|
|
|
@Override
|
|
public int compareTo(ITx o) {
|
|
return this.getBeginTime().compareTo(o.getBeginTime());
|
|
}
|
|
|
|
}
|