| java.lang.Object
 org.griphyn.vdl.dbschema.DatabaseSchema
org.griphyn.vdl.dbschema.InvocationSchema
| InvocationSchema | | public class InvocationSchema extends DatabaseSchema implements PTC(Code) | | This class provides basic functionalities to interact with the
backend database for invocation records, such as insertion, deletion,
and search.
author:
Jens-S. Vöckler
author:
Yong Zhao
version:
$Revision: 148 $ |
| Constructor Summary | |
| public | InvocationSchema(String dbDriverName)
Default constructor for the provenance tracking. |
| Method Summary | |
| public long | getInvocationID(java.util.Date start, InetAddress host, int pid)
Checks the existence of an invocation record in the database.
The information is based on the (start,host,pid) tuple, although
with private networks, cases may arise that have this tuple
identical, yet are different.
Parameters:
start - is the start time of the grid launcher
Parameters:
host - is the address of the host it ran upon
Parameters:
pid - is the process id of the grid launcher itself. | | public long | saveArchitecture(Architecture arch)
Determines the id of an existing identical architecture, or creates
a new entry. | | public boolean | saveInvocation(InvocationRecord ivr)
Inserts an invocation record into the database.
Parameters:
ivr - is the invocation record to store. | | protected void | saveJob(long iid, Job job)
Helper function to insert a chunk of the invocation record. | | protected void | saveLFN(long iid, StatCall s)
Helper function to insert a LFN PFN mapping stat call into the
stat information records. | | protected long | saveStat(StatCall s)
Helper function to insert a chunk of the invocation record. | | protected long | saveUsage(Usage u)
Helper function to insert a chunk of the invocation record. | | protected java.sql.Timestamp | toStamp(java.util.Date date)
Converts a regular datum into an SQL timestamp. |
| getInvocationID | | public long getInvocationID(java.util.Date start, InetAddress host, int pid) throws SQLException(Code) | | Checks the existence of an invocation record in the database.
The information is based on the (start,host,pid) tuple, although
with private networks, cases may arise that have this tuple
identical, yet are different.
Parameters:
start - is the start time of the grid launcher
Parameters:
host - is the address of the host it ran upon
Parameters:
pid - is the process id of the grid launcher itself. the id of the existing record, or -1 |
| saveArchitecture | | public long saveArchitecture(Architecture arch) throws SQLException(Code) | | Determines the id of an existing identical architecture, or creates
a new entry.
Parameters:
arch - is the architecture description the id of the architecture, either new or existing. |
| saveInvocation | | public boolean saveInvocation(InvocationRecord ivr) throws SQLException(Code) | | Inserts an invocation record into the database.
Parameters:
ivr - is the invocation record to store. true, if insertion was successful, false otherwise. |
| saveJob | | protected void saveJob(long iid, Job job) throws SQLException(Code) | | Helper function to insert a chunk of the invocation record. This piece
deals with the jobs themselves
Parameters:
iid - is the invocation record id to which this job belongs.
Parameters:
job - is the job to insert.
exception:
SQLException - if something goes awry during insertion. |
| saveLFN | | protected void saveLFN(long iid, StatCall s) throws SQLException(Code) | | Helper function to insert a LFN PFN mapping stat call into the
stat information records.
Parameters:
iid - is the invocation record id to which this job belongs.
Parameters:
s - is an instance of a stat call from the initial or final list
exception:
SQLException - if something goes awry during insertion. |
| saveStat | | protected long saveStat(StatCall s) throws SQLException(Code) | | Helper function to insert a chunk of the invocation record. This piece
deals with the stat and fstat information.
Parameters:
s - is the stat record to insert into the database the sequence number under which it was inserted.
exception:
SQLException - if something goes awry during insertion. |
| saveUsage | | protected long saveUsage(Usage u) throws SQLException(Code) | | Helper function to insert a chunk of the invocation record. This piece
deals with the rusage information.
Parameters:
u - is the usage record to insert into the database the sequence number under which it was inserted.
exception:
SQLException - if something goes awry during insertion. |
| toStamp | | protected java.sql.Timestamp toStamp(java.util.Date date)(Code) | | Converts a regular datum into an SQL timestamp.
Parameters:
date - is a regular Java date a SQL timestamp obtained from the Date. |
| Methods inherited from org.griphyn.vdl.dbschema.DatabaseSchema | public boolean cachingMakesSense()(Code)(Java Doc)
public void close() throws SQLException(Code)(Java Doc)
protected void finalize() throws Throwable(Code)(Java Doc)
public static DatabaseSchema loadSchema(String dbSchemaName, String propertyPrefix, Object[] arguments) throws ClassNotFoundException, IOException, NoSuchMethodException, InstantiationException, IllegalAccessException, InvocationTargetException(Code)(Java Doc)
public static DatabaseSchema loadSchema(String propertyPrefix) throws ClassNotFoundException, IOException, NoSuchMethodException, InstantiationException, IllegalAccessException, InvocationTargetException(Code)(Java Doc)
protected void longOrNull(PreparedStatement ps, int pos, long l) throws SQLException(Code)(Java Doc)
protected String makeNotNull(String s)(Code)(Java Doc)
protected void stringOrNull(PreparedStatement ps, int pos, String s) throws SQLException(Code)(Java Doc)
|
|
|