SCViewer/plugins/com.minres.scviewer.databas.../src/com/minres/scviewer/database/sqlite/TxStream.java

213 lines
6.3 KiB
Java
Raw Normal View History

/*******************************************************************************
2015-10-22 00:25:12 +02:00
* Copyright (c) 2015 MINRES Technologies GmbH and others.
* 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:
* MINRES Technologies GmbH - initial API and implementation
*******************************************************************************/
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.List;
import java.util.Map;
2015-01-20 18:50:15 +01:00
import java.util.Map.Entry;
import java.util.NavigableMap;
import java.util.TreeMap;
2020-11-28 10:22:22 +01:00
import com.minres.scviewer.database.EventKind;
2015-01-06 17:14:16 +01:00
import com.minres.scviewer.database.HierNode;
2020-11-28 10:22:22 +01:00
import com.minres.scviewer.database.IEvent;
2015-01-20 18:50:15 +01:00
import com.minres.scviewer.database.ITx;
2015-01-06 17:14:16 +01:00
import com.minres.scviewer.database.ITxGenerator;
import com.minres.scviewer.database.IWaveform;
import com.minres.scviewer.database.IWaveformDb;
import com.minres.scviewer.database.RelationType;
import com.minres.scviewer.database.sqlite.db.IDatabase;
import com.minres.scviewer.database.sqlite.db.SQLiteDatabaseSelectHandler;
import com.minres.scviewer.database.sqlite.tables.ScvGenerator;
import com.minres.scviewer.database.sqlite.tables.ScvStream;
import com.minres.scviewer.database.sqlite.tables.ScvTx;
2020-11-28 10:22:22 +01:00
public class TxStream extends HierNode implements IWaveform {
private IDatabase database;
private String fullName;
2015-01-06 17:14:16 +01:00
private IWaveformDb db;
2015-01-06 17:14:16 +01:00
private ScvStream scvStream;
private TreeMap<Integer, TxGenerator> generators;
2015-01-06 17:14:16 +01:00
private TreeMap<Integer, ITx> transactions;
2015-01-20 18:50:15 +01:00
private Integer maxConcurrency;
2020-11-28 10:22:22 +01:00
private TreeMap<Long, IEvent[]> events;
private List<RelationType> usedRelationsList;
public TxStream(IDatabase database, IWaveformDb waveformDb, ScvStream scvStream) {
super(scvStream.getName());
this.database=database;
fullName=scvStream.getName();
this.scvStream=scvStream;
db=waveformDb;
}
@Override
public IWaveformDb getDb() {
return db;
}
@Override
public String getFullName() {
return fullName;
}
@Override
public Long getId() {
return (long) scvStream.getId();
}
@Override
public String getKind() {
return scvStream.getKind();
}
2015-01-06 17:14:16 +01:00
public List<ITxGenerator> getGenerators() {
if(generators==null){
SQLiteDatabaseSelectHandler<ScvGenerator> handler = new SQLiteDatabaseSelectHandler<ScvGenerator>(
ScvGenerator.class, database, "stream="+scvStream.getId());
generators=new TreeMap<Integer, TxGenerator>();
try {
for(ScvGenerator scvGenerator:handler.selectObjects()){
2015-01-06 17:14:16 +01:00
generators.put(scvGenerator.getId(), new TxGenerator(this, scvGenerator));
}
} catch (SecurityException | IllegalArgumentException | InstantiationException | IllegalAccessException
| InvocationTargetException | SQLException | IntrospectionException e) {
e.printStackTrace();
}
}
2015-01-06 17:14:16 +01:00
return new ArrayList<ITxGenerator>(generators.values());
}
@Override
2015-01-20 18:50:15 +01:00
public int getMaxConcurrency() {
if(maxConcurrency==null){
java.sql.Connection connection=null;
java.sql.Statement statement=null;
java.sql.ResultSet resultSet=null;
try {
connection = database.createConnection();
statement = connection.createStatement();
StringBuilder sb = new StringBuilder();
sb.append("SELECT MAX(concurrencyLevel) as concurrencyLevel FROM ScvTx where stream=");
sb.append(scvStream.getId());
resultSet = statement.executeQuery(sb.toString());
while (resultSet.next()) {
2018-09-26 21:25:02 +02:00
if(maxConcurrency==null) maxConcurrency=0;
2015-01-20 18:50:15 +01:00
Object value = resultSet.getObject("concurrencyLevel");
if(value!=null)
maxConcurrency=(Integer) value;
}
} catch (SQLException e) {
if(maxConcurrency==null) maxConcurrency=0;
} finally {
try{
if(resultSet!=null) resultSet.close();
if(statement!=null) statement.close();
if(connection!=null) connection.close();
} catch (SQLException e) { }
}
maxConcurrency+=1;
}
return maxConcurrency;
}
@Override
2020-11-28 10:22:22 +01:00
public NavigableMap<Long, IEvent[]> getEvents(){
2015-01-20 18:50:15 +01:00
if(events==null){
2020-11-28 10:22:22 +01:00
events=new TreeMap<Long, IEvent[]>();
2015-01-20 18:50:15 +01:00
for(Entry<Integer, ITx> entry:getTransactions().entrySet()){
2020-11-28 10:22:22 +01:00
putEvent(new TxEvent(EventKind.BEGIN, entry.getValue()));
putEvent(new TxEvent(EventKind.END, entry.getValue()));
2015-01-20 18:50:15 +01:00
}
}
return events;
}
private void putEvent(TxEvent ev){
Long time = ev.getTime();
2020-11-28 10:22:22 +01:00
if(events.containsKey(time)) {
IEvent[] oldV = events.get(time);
IEvent[] newV = new IEvent[oldV.length+1];
System.arraycopy(oldV, 0, newV, 0, oldV.length);
newV[oldV.length]=ev;
events.put(time, newV);
} else {
2020-11-28 10:22:22 +01:00
events.put(time, new IEvent[] {ev});
}
}
2015-01-20 18:50:15 +01:00
protected Map<Integer, ITx> getTransactions() {
if(transactions==null){
if(generators==null) getGenerators();
transactions = new TreeMap<Integer, ITx>();
SQLiteDatabaseSelectHandler<ScvTx> handler = new SQLiteDatabaseSelectHandler<ScvTx>(ScvTx.class, database,
"stream="+scvStream.getId());
try {
for(ScvTx scvTx:handler.selectObjects()){
2015-01-20 18:50:15 +01:00
transactions.put(scvTx.getId(), new Tx(database, this, generators.get(scvTx.getGenerator()), scvTx));
}
} catch (SecurityException | IllegalArgumentException | InstantiationException | IllegalAccessException
| InvocationTargetException | SQLException | IntrospectionException e) {
e.printStackTrace();
}
}
2015-01-20 18:50:15 +01:00
return transactions;
}
@Override
2020-11-28 10:22:22 +01:00
public IEvent[] getEventsAtTime(Long time) {
2015-01-20 18:50:15 +01:00
return getEvents().get(time);
}
public void setRelationTypeList(List<RelationType> usedRelationsList){
this.usedRelationsList=usedRelationsList;
}
public RelationType getRelationType(String name) {
RelationType relType=RelationType.create(name);
if(!usedRelationsList.contains(relType)) usedRelationsList.add(relType);
return relType;
}
@Override
public Boolean equals(IWaveform other) {
return(other instanceof TxStream && this.getId().equals(other.getId()));
}
2020-11-28 10:22:22 +01:00
@Override
public IEvent[] getEventsBeforeTime(Long time) {
Entry<Long, IEvent[]> e = events.floorEntry(time);
if(e==null)
return null;
else
return events.floorEntry(time).getValue();
}
@Override
public Class<?> getType() {
return TxEvent.class;
}
}