|
||||||||||
| PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
| SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD | |||||||||
java.lang.Objectorg.griphyn.vdl.dbschema.DatabaseSchema
org.griphyn.common.catalog.transformation.Database
public class Database
| Field Summary | |
|---|---|
private static Database |
mDatabaseTC
|
protected static LogManager |
mLogger
The LogManager object which is used to log all the messages. |
| Fields inherited from class org.griphyn.vdl.dbschema.DatabaseSchema |
|---|
m_dbdriver, m_dbschemaprops |
| Fields inherited from interface org.griphyn.common.catalog.Catalog |
|---|
DB_ALL_PREFIX |
| Constructor Summary | |
|---|---|
private |
Database()
|
| Method Summary | |
|---|---|
private long |
addLogicalTr(String namespace,
String name,
String version)
Adds a logical entry to the logicaltx table |
private long |
addPhysicalTr(String physicalname,
String resourceid,
TCType type,
long archid)
Adds a physical entry to the physicaltxtable |
private boolean |
addProfile(Profile p,
long id,
boolean pfn)
Add a lfn or pfn profile to the TC |
private long |
addSysInfo(SysInfo system)
Adds a system information entry into the TC. |
boolean |
addTCEntry(List tcentry)
Add multiple TCEntries to the Catalog. |
boolean |
addTCEntry(String namespace,
String name,
String version,
String physicalname,
TCType type,
String resourceid,
List lfnprofiles,
List pfnprofiles,
SysInfo system)
Add an single entry into the transformation catalog. |
boolean |
addTCEntry(String namespace,
String name,
String version,
String physicalname,
TCType type,
String resourceid,
List lfnprofiles,
List pfnprofiles,
SysInfo system,
boolean write)
Add an single entry into the transformation catalog. |
boolean |
addTCEntry(TransformationCatalogEntry entry)
Add a single TCEntry to the Catalog. |
boolean |
addTCEntry(TransformationCatalogEntry entry,
boolean write)
Add a single TCEntry to the Catalog. |
boolean |
addTCLfnProfile(String namespace,
String name,
String version,
List profiles)
Add additional profile to a logical transformation . |
boolean |
addTCPfnProfile(String pfn,
TCType type,
String resourceid,
List profiles)
Add additional profile to a physical transformation. |
private long |
checkLfnPfnMap(long lfnid,
long pfnid)
Checks if a lfn,pfn exist in the map. |
private long |
checkProfile(String namespace,
String name,
String value,
long id,
boolean pfn)
Checks if a given profile exists |
void |
close()
Disassociate from the database driver before finishing. |
private static void |
columnLength(String[] s,
int[] count)
Computes the maximum column lenght for pretty printing. |
boolean |
connect(Properties props)
|
private boolean |
deleteProfile(Profile p,
long id,
boolean pfn)
Delete a given lfn or pfn profile |
boolean |
deleteTC()
Deletes the entire transformation catalog. |
boolean |
deleteTCbyLogicalName(String namespace,
String name,
String version,
String resourceid,
TCType type)
Delete all entries in the transformation catalog for a give logical tranformation and/or on a resource and/or of a particular type |
boolean |
deleteTCbyPhysicalName(String physicalname,
String namespace,
String name,
String version,
String resourceid,
TCType type)
Delete all entries in the transformation catalog for pair of logical and physical transformation. |
boolean |
deleteTCbyResourceId(String resourceid)
Delete all entries on a particular resource from the transformation catalog. |
boolean |
deleteTCbySysInfo(SysInfo sysinfo)
Deletes entries from the catalog which have a particular system information. |
boolean |
deleteTCbyType(TCType type,
String resourceid)
Delete a paricular type of transformation, and/or on a particular resource |
boolean |
deleteTCLfnProfile(String namespace,
String name,
String version,
List profiles)
Delete a list of profiles or all the profiles associated with a logical transformation. |
boolean |
deleteTCPfnProfile(String physicalname,
TCType type,
String resourceid,
List profiles)
Delete a list of profiles or all the profiles associated with a pfn on a resource and of a type. |
static TransformationCatalog |
getInstance()
|
private long |
getLogicalId(String namespace,
String name,
String version)
Returns the id associated with the logical transformation. |
private long |
getPhysicalId(String pfn,
TCType type,
String resourceid)
Returns the id of the physical transformation |
private long[] |
getPhysicalIds(String pfn,
TCType type,
String resourceid)
Returns a list of pfnid for a given pfn on any resource, and of any type. |
private long |
getSysInfoId(SysInfo system)
Gets the id for the system information entry. |
List |
getTC()
List all the contents of the TC in a column format. |
List |
getTCEntries(String namespace,
String name,
String version,
List resourceids,
TCType type)
Returns TC entries for a particular logical transformation and/or on a number of resources and/or of a particular type. |
List |
getTCEntries(String namespace,
String name,
String version,
String resourceid,
TCType type)
Returns TC entries for a particular logical transformation and/or on a particular resource and/or of a particular type. |
List |
getTCLfnProfiles(String namespace,
String name,
String version)
Get the list of Profiles associated with a particular logical transformation. |
List |
getTCLogicalNames(String resourceid,
TCType type)
Get the list of LogicalNames available on a particular resource. |
String |
getTCMode()
Returns the TC implementation being used |
List |
getTCPfnProfiles(String pfn,
String resourceid,
TCType type)
Get the list of Profiles associated with a particular physical transformation. |
List |
getTCPhysicalNames(String namespace,
String name,
String version,
String resourceid,
TCType type)
Get the list of PhysicalNames for a particular transformation on a site/sites for a particular type/types; |
List |
getTCResourceIds(String namespace,
String name,
String version,
TCType type)
Get the list of Resource ID's where a particular transformation may reside. |
boolean |
isClosed()
|
| Methods inherited from class org.griphyn.vdl.dbschema.DatabaseSchema |
|---|
cachingMakesSense, finalize, loadSchema, loadSchema, longOrNull, makeNotNull, stringOrNull |
| Methods inherited from class java.lang.Object |
|---|
clone, equals, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
| Field Detail |
|---|
protected static LogManager mLogger
private static Database mDatabaseTC
| Constructor Detail |
|---|
private Database()
throws ClassNotFoundException,
NoSuchMethodException,
InstantiationException,
IllegalAccessException,
InvocationTargetException,
SQLException,
IOException
ClassNotFoundException
NoSuchMethodException
InstantiationException
IllegalAccessException
InvocationTargetException
SQLException
IOException| Method Detail |
|---|
public List getTCEntries(String namespace,
String name,
String version,
String resourceid,
TCType type)
throws Exception
getTCEntries in interface TransformationCatalognamespace - String The namespace of the logical transformation.name - String the name of the logical transformation.version - String The version of the logical transformation.resourceid - String The resourceid where the transformation is
located. If NULL it returns all resources.type - TCType The type of the transformation to search for.
If NULL it returns all types.
ExceptionTCType,
TransformationCatalogEntry
public List getTCEntries(String namespace,
String name,
String version,
List resourceids,
TCType type)
throws Exception
getTCEntries in interface TransformationCatalognamespace - String The namespace of the logical transformation.name - String the name of the logical transformation.version - String The version of the logical transformation.resourceids - List The List resourceid where the transformation is
located. If NULL it returns all resources.type - TCType The type of the transformation to search for.
If NULL it returns all types.
ExceptionTCType,
TransformationCatalogEntry
public List getTC()
throws Exception
getTC in interface TransformationCatalogException
public List getTCResourceIds(String namespace,
String name,
String version,
TCType type)
throws Exception
getTCResourceIds in interface TransformationCatalognamespace - String The namespace of the transformation to search for.name - String The name of the transformation to search for.version - String The version of the transformation to search for.type - TCType The type of the transformation to search for.Exception - NotImplementedException if not implementedTCType
public List getTCPhysicalNames(String namespace,
String name,
String version,
String resourceid,
TCType type)
throws Exception
getTCPhysicalNames in interface TransformationCatalognamespace - String The namespace of the transformation to search for.name - String The name of the transformation to search for.version - String The version of the transformation to search for.resourceid - String The id of the resource on which you want to
search. type - TCType The type of the transformation to search for. Exception - NotImplementedException if not implemented.TCType,
SysInfo
public List getTCLogicalNames(String resourceid,
TCType type)
throws Exception
getTCLogicalNames in interface TransformationCatalogresourceid - String The id of the resource on which you want to searchtype - TCType The type of the transformation to search for. Exception - NotImpementedException if not implemented
public List getTCLfnProfiles(String namespace,
String name,
String version)
throws Exception
getTCLfnProfiles in interface TransformationCatalognamespace - String The namespace of the transformation to search for.name - String The name of the transformation to search for.version - String The version of the transformation to search for.
Exception - NotImplementedException if not implemented.Profile
public List getTCPfnProfiles(String pfn,
String resourceid,
TCType type)
throws Exception
getTCPfnProfiles in interface TransformationCatalogpfn - The physical file name to search the transformation by.resourceid - String The id of the resource on which you want to search.type - TCType The type of the transformation to search for. Exception - NotImplementedException if not implemented.Profile
public boolean addTCEntry(List tcentry)
throws Exception
addTCEntry in interface TransformationCatalogtcentry - List Takes a list of TCEntry objects as input
ExceptionTransformationCatalogEntry
public boolean addTCEntry(TransformationCatalogEntry entry)
throws Exception
addTCEntry in interface TransformationCatalogentry - a single TransformationCatalogEntry
object as input.
ExceptionTransformationCatalogEntry
public boolean addTCEntry(TransformationCatalogEntry entry,
boolean write)
throws Exception
addTCEntry in interface TransformationCatalogentry - a single TransformationCatalogEntry
object as input.write - boolean to commit additions to backend catalog.
ExceptionTransformationCatalogEntry
public boolean addTCEntry(String namespace,
String name,
String version,
String physicalname,
TCType type,
String resourceid,
List lfnprofiles,
List pfnprofiles,
SysInfo system)
throws Exception
addTCEntry in interface TransformationCatalognamespace - String The namespace of the transformation to be
added (Can be null)name - String The name of the transformation to be added.version - String The version of the transformation to be added.
(Can be null)physicalname - String The physical name/location of the transformation
to be added.type - TCType The type of the physical transformation.resourceid - String The resource location id where the
transformation is located.lfnprofiles - List The List of Profile objects associated with
a Logical Transformation. (can be null)pfnprofiles - List The List of Profile objects associated with
a Physical Transformation. (can be null)system - SysInfo The System information associated with a
physical transformation.
ExceptionTransformationCatalogEntry,
SysInfo,
Profile
public boolean addTCEntry(String namespace,
String name,
String version,
String physicalname,
TCType type,
String resourceid,
List lfnprofiles,
List pfnprofiles,
SysInfo system,
boolean write)
throws Exception
namespace - String The namespace of the transformation to be
added (Can be null)name - String The name of the transformation to be added.version - String The version of the transformation to be added.
(Can be null)physicalname - String The physical name/location of the transformation
to be added.type - TCType The type of the physical transformation.resourceid - String The resource location id where the
transformation is located.lfnprofiles - List The List of Profile objects associated with
a Logical Transformation. (can be null)pfnprofiles - List The List of Profile objects associated with
a Physical Transformation. (can be null)system - SysInfo The System information associated with a
physical transformation.write - boolean to commit changes to the backend catalog
ExceptionTransformationCatalogEntry,
SysInfo,
Profile
public boolean addTCLfnProfile(String namespace,
String name,
String version,
List profiles)
throws Exception
addTCLfnProfile in interface TransformationCatalognamespace - String The nsamespace of the transformation to be added. (can be null)name - String The name of the transformation to be added.version - String The version of the transformation to be added. (can be null)profiles - List The List of Profile objects that are to be added to the transformation.
ExceptionProfile
public boolean addTCPfnProfile(String pfn,
TCType type,
String resourceid,
List profiles)
throws Exception
addTCPfnProfile in interface TransformationCatalogpfn - String The physical name of the transformationtype - TCType The type of transformation that the profile is associated with.resourceid - String The resource on which the physical transformation existsprofiles - List The List of Profile objects that are to be added to the transformation.
ExceptionProfile
public boolean deleteTCbyLogicalName(String namespace,
String name,
String version,
String resourceid,
TCType type)
throws Exception
deleteTCbyLogicalName in interface TransformationCatalognamespace - String The namespace of the transformation to be added. (can be null)name - String The name of the transformation to be added.version - String The version of the transformation to be added. ( can be null)resourceid - String The resource id for which the transformation is to be deleted.
If NULL then transformation on all resource are deletedtype - TCType The type of the transformation. If NULL then all types are deleted for the transformation.
ExceptionTCType
public boolean deleteTCbyPhysicalName(String physicalname,
String namespace,
String name,
String version,
String resourceid,
TCType type)
throws Exception
deleteTCbyPhysicalName in interface TransformationCatalogphysicalname - String The physical name of the transformationnamespace - String The namespace assocaited in the logical name of the transformation.name - String The name of the logical transformation.version - String The version number of the logical transformation.resourceid - String The resource on which the transformation is to be deleted.
If NULL then it searches all the resource id.type - TCType The type of transformation. If NULL then it search and deletes entries for all types.
ExceptionTCType
public boolean deleteTCbySysInfo(SysInfo sysinfo)
throws Exception
deleteTCbySysInfo in interface TransformationCatalogsysinfo - SysInfo The System Information by which you want to delete
ExceptionSysInfo
public boolean deleteTCbyType(TCType type,
String resourceid)
throws Exception
deleteTCbyType in interface TransformationCatalogtype - TCType The type of the transformationresourceid - String The resource on which the transformation exists.
If NULL then that type of transformation is deleted from all the resources.
ExceptionTCType
public boolean deleteTCbyResourceId(String resourceid)
throws Exception
deleteTCbyResourceId in interface TransformationCatalogresourceid - String The resource which you want to remove.
Exception
public boolean deleteTC()
throws Exception
deleteTC in interface TransformationCatalogException
public boolean deleteTCPfnProfile(String physicalname,
TCType type,
String resourceid,
List profiles)
throws Exception
deleteTCPfnProfile in interface TransformationCatalogphysicalname - String The physical name of the transformation.type - TCType The type of the transformation.resourceid - String The resource of the transformation.profiles - List The list of profiles to be deleted. If NULL
then all profiles for that pfn+resource+type are deleted.
ExceptionProfile
public boolean deleteTCLfnProfile(String namespace,
String name,
String version,
List profiles)
throws Exception
deleteTCLfnProfile in interface TransformationCatalognamespace - String The namespace of the logical transformation.name - String The name of the logical transformation.version - String The version of the logical transformation.profiles - List The List of profiles to be deleted. If NULL
then all profiles for the logical transformation are deleted.
ExceptionProfilepublic static TransformationCatalog getInstance()
public String getTCMode()
getTCMode in interface TransformationCatalogpublic void close()
DatabaseSchema
close in class DatabaseSchemapublic boolean connect(Properties props)
public boolean isClosed()
private long getLogicalId(String namespace,
String name,
String version)
throws Exception
namespace - Stringname - Stringversion - String
Exception
private long checkLfnPfnMap(long lfnid,
long pfnid)
throws Exception
lfnid - longpfnid - long
Exception
private long checkProfile(String namespace,
String name,
String value,
long id,
boolean pfn)
throws Exception
namespace - Stringname - Stringvalue - Stringid - longpfn - boolean
Exception
private long getSysInfoId(SysInfo system)
throws Exception
system - SysInfo
ExceptionSysInfo
private long addSysInfo(SysInfo system)
throws Exception
system - SysInfo
Exception
private long addLogicalTr(String namespace,
String name,
String version)
throws Exception
namespace - String The namespace of the transformationname - String The name of the transformationversion - String The version of the transformation
Exception
private long addPhysicalTr(String physicalname,
String resourceid,
TCType type,
long archid)
throws Exception
physicalname - String The physical name of the transformationresourceid - String The resource on which the transformation existstype - TCType The type of the transformationarchid - long The architecture id from the sysinfo table for the tr.
Exception
private boolean addProfile(Profile p,
long id,
boolean pfn)
throws Exception
p - Profile The profile to be addedid - long The lfn or pfn id to which the profile is associated.pfn - boolean if true entry is added to the pfn, false to the lfn.
Exception
private boolean deleteProfile(Profile p,
long id,
boolean pfn)
throws Exception
p - Profile The profile to be deletedid - long The lfn or pfnid with which the profile is associatedpfn - boolean If true the pfn profile is deleted, if false lfn profile is deleted
Exception
private long getPhysicalId(String pfn,
TCType type,
String resourceid)
throws Exception
pfn - String the physical transformationtype - TCType The type of the transformationresourceid - String The resource on which the transformation exists.
Exception
private long[] getPhysicalIds(String pfn,
TCType type,
String resourceid)
throws Exception
pfn - String The physical transformation to search for.type - TCType The type to search for. If NULL then all types are searched.resourceid - String The resource to search for. If NULL then all resources are searched.
Exception
private static void columnLength(String[] s,
int[] count)
s - String[]count - int[]
|
||||||||||
| PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
| SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD | |||||||||