cgl.fthpis.datastore.jdbc
Class JDBCDataStore

java.lang.Object
  cgl.fthpis.datastore.jdbc.JDBCDataStore

All Implemented Interfaces:

FTHPISDataStore

public class JDBCDataStore

extends java.lang.Object

implements FTHPISDataStore

Author:

Mehmet S. Aktas (maktas@indiana.edu)

Constructor Summary

JDBCDataStore()
Create a new JDBCDataStore and aquire a JDBC connection from the connection pool.

Method Summary

void	beginTrans() begin a new transaction
void	commit() commit on all connections.
void	deleteAttribute(java.lang.String attributeKey)
void	deleteContext(java.lang.String contextKey)
void	deletePublisher(java.lang.String publisherID)
void	deleteService(java.lang.String serviceKey)
void	deleteSession(java.lang.String sessionKey)
void	deleteSessionService(java.lang.String serviceKey)
Attribute	fetchAttribute(java.lang.String attributeKey)
Attribute	fetchContext(java.lang.String contextKey)
PublisherInfo	fetchPublisherInfo(java.lang.String publisherID)
BusinessService	fetchService(java.lang.String serviceKey)
SessionEntity	fetchSession(java.lang.String sessionKey)
BusinessService	fetchSessionService(java.lang.String serviceKey)
java.util.Vector	findContext(java.lang.String sessionKey, java.lang.String serviceKey, java.util.Vector nameVector, Lease lease, org.apache.juddi.datatype.request.FindQualifiers findQualifiers)
java.util.Vector	findPublisher(java.lang.String name, org.apache.juddi.datatype.request.FindQualifiers findQualifiers)
java.util.Vector	findService(java.lang.String businessKey, java.util.Vector nameVector, org.apache.juddi.datatype.CategoryBag categoryBag, org.apache.juddi.datatype.TModelBag tModelBag, AttributeBag attributeBag, org.apache.juddi.datatype.request.FindQualifiers findQualifiers)
java.util.Vector	findService(java.lang.String businessKey, java.util.Vector nameVector, org.apache.juddi.datatype.CategoryBag categoryBag, org.apache.juddi.datatype.TModelBag tModelBag, AttributeBag attributeBag, Lease lease, org.apache.juddi.datatype.request.FindQualifiers findQualifiers)
java.util.Vector	findService(java.lang.String businessKey, java.util.Vector nameVector, org.apache.juddi.datatype.CategoryBag categoryBag, org.apache.juddi.datatype.TModelBag tModelBag, org.apache.juddi.datatype.request.FindQualifiers findQualifiers)
java.util.Vector	findServiceAttribute(java.lang.String serviceKey, org.apache.juddi.datatype.CategoryBag categoryBag, Lease lease, org.apache.juddi.datatype.request.FindQualifiers findQualifiers)
java.util.Vector	findSession(java.util.Vector serviceKeyVector, java.util.Vector nameVector, AttributeBag attributeBag, Lease lease, org.apache.juddi.datatype.request.FindQualifiers findQualifiers)
java.util.Vector	findSessionService(java.util.Vector sessionKeyVector, java.util.Vector keyVector, AttributeBag contextBag, org.apache.juddi.datatype.request.FindQualifiers findQualifiers)
java.lang.String	generateToken(Publisher publisher)
AutharizationToken	getAuthToken(java.lang.String token)
Publisher	getAuthTokenPublisher(java.lang.String token)
java.sql.Connection	getConnection()
Publisher	getPublisher(java.lang.String publisherID) verify that the individual or system identified by the 'publisherID' is a valid jUDDI user (aka publisher).
boolean	isAdministrator(java.lang.String publisherID) Will return true if the publisherID parameter specified has been tagged with registry administrator priviledges otherwise returns false.
boolean	isAuthTokenExpired(java.lang.String token)
boolean	isContextPublisher(java.lang.String contextKey, java.lang.String publisherID)
boolean	isEnabled(java.lang.String publisherID) Will return true if the publisherID parameter specified is currently enabled otherwise returns false.
boolean	isServicePublisher(java.lang.String serviceKey, java.lang.String publisherID)
boolean	isSessionAdmin(java.lang.String sessionKey, java.lang.String publisherID)
boolean	isSessionPublisher(java.lang.String sessionKey, java.lang.String publisherID)
boolean	isValidAttributeKey(java.lang.String attributeKey)
boolean	isValidContextKey(java.lang.String contextKey)
boolean	isValidServiceKey(java.lang.String serviceKey)
boolean	isValidSessionKey(java.lang.String sessionKey)
static void	main(java.lang.String[] args)
void	release() Release all JDBC connections used by this JDBCDataStore back into the connection pool.
void	retireAuthToken(java.lang.String token)
void	rollback() rollback on all connections.
void	saveAttribute(Attribute attribute)
void	saveAttributeLease(Lease lease)
void	saveContext(Attribute context)
void	savePublisher(Publisher publisher)
void	saveService(BusinessService service)
void	saveServiceLease(Lease lease)
void	saveSession(SessionEntity session, java.lang.String publisherID)
void	saveSessionService(BusinessService service)
void	storeAuthToken(java.lang.String token, Publisher publisher)
static void	test(java.sql.Connection conn)
void	touchAuthToken(java.lang.String token)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

JDBCDataStore

public JDBCDataStore()

Create a new JDBCDataStore and aquire a JDBC connection from the connection pool.

Method Detail

release

public void release()

Release all JDBC connections used by this JDBCDataStore back into the connection pool.

Specified by:

release in interface FTHPISDataStore

getConnection

public java.sql.Connection getConnection()

beginTrans

public void beginTrans()
                throws org.apache.juddi.error.RegistryException

begin a new transaction

Specified by:

beginTrans in interface FTHPISDataStore

Throws:

org.apache.juddi.error.RegistryException

commit

public void commit()
            throws org.apache.juddi.error.RegistryException

commit on all connections.

Specified by:

commit in interface FTHPISDataStore

Throws:

org.apache.juddi.error.RegistryException

rollback

public void rollback()
              throws org.apache.juddi.error.RegistryException

rollback on all connections.

Specified by:

rollback in interface FTHPISDataStore

Throws:

org.apache.juddi.error.RegistryException

savePublisher

public void savePublisher(Publisher publisher)
                   throws org.apache.juddi.error.RegistryException

Specified by:

savePublisher in interface FTHPISDataStore

Throws:

org.apache.juddi.error.RegistryException

deletePublisher

public void deletePublisher(java.lang.String publisherID)
                     throws org.apache.juddi.error.RegistryException

Specified by:

deletePublisher in interface FTHPISDataStore

Throws:

org.apache.juddi.error.RegistryException

fetchPublisherInfo

public PublisherInfo fetchPublisherInfo(java.lang.String publisherID)
                                 throws org.apache.juddi.error.RegistryException

Specified by:

fetchPublisherInfo in interface FTHPISDataStore

Throws:

org.apache.juddi.error.RegistryException

findPublisher

public java.util.Vector findPublisher(java.lang.String name,
                                      org.apache.juddi.datatype.request.FindQualifiers findQualifiers)
                               throws org.apache.juddi.error.RegistryException

Specified by:

findPublisher in interface FTHPISDataStore

Throws:

org.apache.juddi.error.RegistryException

getPublisher

public Publisher getPublisher(java.lang.String publisherID)
                       throws org.apache.juddi.error.RegistryException

verify that the individual or system identified by the 'publisherID' is a valid jUDDI user (aka publisher).

Specified by:

getPublisher in interface FTHPISDataStore

Parameters:

publisherID -

Returns:

publisher

Throws:

UDDIException

org.apache.juddi.error.RegistryException

getAuthToken

public AutharizationToken getAuthToken(java.lang.String token)
                                throws org.apache.juddi.error.RegistryException

Specified by:

getAuthToken in interface FTHPISDataStore

Throws:

org.apache.juddi.error.RegistryException

isAdministrator

public boolean isAdministrator(java.lang.String publisherID)
                        throws org.apache.juddi.error.RegistryException

Will return true if the publisherID parameter specified has been tagged with registry administrator priviledges otherwise returns false. An Unknown user exception is thrown if the publisherID specified is null, blank or does not exist (can't be found in the PUBLISHER table).

Specified by:

isAdministrator in interface FTHPISDataStore

Parameters:

publisherID -

Returns:

Returns true if publisherID parameter specified has jUDDI administrator priv's otherwise returns false.

Throws:

org.apache.juddi.error.RegistryException

isEnabled

public boolean isEnabled(java.lang.String publisherID)
                  throws org.apache.juddi.error.RegistryException

Will return true if the publisherID parameter specified is currently enabled otherwise returns false. An UnknownUserException is thrown if the publisherID specified is null, blank or does not exist (can't be found in the PUBLISHER table).

Parameters:

publisherID -

Returns:

Returns true if publisherID parameter specified has jUDDI administrator priv's otherwise returns false.

Throws:

org.apache.juddi.error.RegistryException

generateToken

public java.lang.String generateToken(Publisher publisher)
                               throws org.apache.juddi.error.RegistryException

Specified by:

generateToken in interface FTHPISDataStore

Parameters:

publisher -

Returns:

String

Throws:

UDDIException

org.apache.juddi.error.RegistryException

storeAuthToken

public void storeAuthToken(java.lang.String token,
                           Publisher publisher)
                    throws org.apache.juddi.error.RegistryException

Specified by:

storeAuthToken in interface FTHPISDataStore

Throws:

org.apache.juddi.error.RegistryException

retireAuthToken

public void retireAuthToken(java.lang.String token)
                     throws org.apache.juddi.error.RegistryException

Specified by:

retireAuthToken in interface FTHPISDataStore

Throws:

org.apache.juddi.error.RegistryException

getAuthTokenPublisher

public Publisher getAuthTokenPublisher(java.lang.String token)
                                throws org.apache.juddi.error.RegistryException

Specified by:

getAuthTokenPublisher in interface FTHPISDataStore

Throws:

org.apache.juddi.error.RegistryException

isAuthTokenExpired

public boolean isAuthTokenExpired(java.lang.String token)
                           throws org.apache.juddi.error.RegistryException

Specified by:

isAuthTokenExpired in interface FTHPISDataStore

Throws:

org.apache.juddi.error.RegistryException

touchAuthToken

public void touchAuthToken(java.lang.String token)
                    throws org.apache.juddi.error.RegistryException

Specified by:

touchAuthToken in interface FTHPISDataStore

Throws:

org.apache.juddi.error.RegistryException

saveService

public void saveService(BusinessService service)
                 throws org.apache.juddi.error.RegistryException

Specified by:

saveService in interface FTHPISDataStore

Throws:

org.apache.juddi.error.RegistryException

fetchAttribute

public Attribute fetchAttribute(java.lang.String attributeKey)
                         throws org.apache.juddi.error.RegistryException

Specified by:

fetchAttribute in interface FTHPISDataStore

Throws:

org.apache.juddi.error.RegistryException

deleteAttribute

public void deleteAttribute(java.lang.String attributeKey)
                     throws org.apache.juddi.error.RegistryException

Specified by:

deleteAttribute in interface FTHPISDataStore

Throws:

org.apache.juddi.error.RegistryException

fetchService

public BusinessService fetchService(java.lang.String serviceKey)
                             throws org.apache.juddi.error.RegistryException

Specified by:

fetchService in interface FTHPISDataStore

Throws:

org.apache.juddi.error.RegistryException

deleteService

public void deleteService(java.lang.String serviceKey)
                   throws org.apache.juddi.error.RegistryException

Specified by:

deleteService in interface FTHPISDataStore

Throws:

org.apache.juddi.error.RegistryException

isValidAttributeKey

public boolean isValidAttributeKey(java.lang.String attributeKey)
                            throws org.apache.juddi.error.RegistryException

Specified by:

isValidAttributeKey in interface FTHPISDataStore

Throws:

org.apache.juddi.error.RegistryException

isValidServiceKey

public boolean isValidServiceKey(java.lang.String serviceKey)
                          throws org.apache.juddi.error.RegistryException

Specified by:

isValidServiceKey in interface FTHPISDataStore

Throws:

org.apache.juddi.error.RegistryException

isServicePublisher

public boolean isServicePublisher(java.lang.String serviceKey,
                                  java.lang.String publisherID)
                           throws org.apache.juddi.error.RegistryException

Specified by:

isServicePublisher in interface FTHPISDataStore

Throws:

org.apache.juddi.error.RegistryException

saveAttribute

public void saveAttribute(Attribute attribute)
                   throws org.apache.juddi.error.RegistryException

Specified by:

saveAttribute in interface FTHPISDataStore

Throws:

org.apache.juddi.error.RegistryException

saveAttributeLease

public void saveAttributeLease(Lease lease)
                        throws org.apache.juddi.error.RegistryException

Throws:

org.apache.juddi.error.RegistryException

saveServiceLease

public void saveServiceLease(Lease lease)
                      throws org.apache.juddi.error.RegistryException

Throws:

org.apache.juddi.error.RegistryException

findService

public java.util.Vector findService(java.lang.String businessKey,
                                    java.util.Vector nameVector,
                                    org.apache.juddi.datatype.CategoryBag categoryBag,
                                    org.apache.juddi.datatype.TModelBag tModelBag,
                                    org.apache.juddi.datatype.request.FindQualifiers findQualifiers)
                             throws org.apache.juddi.error.RegistryException

Specified by:

findService in interface FTHPISDataStore

Throws:

org.apache.juddi.error.RegistryException

findService

public java.util.Vector findService(java.lang.String businessKey,
                                    java.util.Vector nameVector,
                                    org.apache.juddi.datatype.CategoryBag categoryBag,
                                    org.apache.juddi.datatype.TModelBag tModelBag,
                                    AttributeBag attributeBag,
                                    org.apache.juddi.datatype.request.FindQualifiers findQualifiers)
                             throws org.apache.juddi.error.RegistryException

Specified by:

findService in interface FTHPISDataStore

Throws:

org.apache.juddi.error.RegistryException

findService

public java.util.Vector findService(java.lang.String businessKey,
                                    java.util.Vector nameVector,
                                    org.apache.juddi.datatype.CategoryBag categoryBag,
                                    org.apache.juddi.datatype.TModelBag tModelBag,
                                    AttributeBag attributeBag,
                                    Lease lease,
                                    org.apache.juddi.datatype.request.FindQualifiers findQualifiers)
                             throws org.apache.juddi.error.RegistryException

Specified by:

findService in interface FTHPISDataStore

Throws:

org.apache.juddi.error.RegistryException

findServiceAttribute

public java.util.Vector findServiceAttribute(java.lang.String serviceKey,
                                             org.apache.juddi.datatype.CategoryBag categoryBag,
                                             Lease lease,
                                             org.apache.juddi.datatype.request.FindQualifiers findQualifiers)
                                      throws org.apache.juddi.error.RegistryException

Specified by:

findServiceAttribute in interface FTHPISDataStore

Throws:

org.apache.juddi.error.RegistryException

findSessionService

public java.util.Vector findSessionService(java.util.Vector sessionKeyVector,
                                           java.util.Vector keyVector,
                                           AttributeBag contextBag,
                                           org.apache.juddi.datatype.request.FindQualifiers findQualifiers)
                                    throws org.apache.juddi.error.RegistryException

Specified by:

findSessionService in interface FTHPISDataStore

Throws:

org.apache.juddi.error.RegistryException

saveSessionService

public void saveSessionService(BusinessService service)
                        throws org.apache.juddi.error.RegistryException

Specified by:

saveSessionService in interface FTHPISDataStore

Throws:

org.apache.juddi.error.RegistryException

findSession

public java.util.Vector findSession(java.util.Vector serviceKeyVector,
                                    java.util.Vector nameVector,
                                    AttributeBag attributeBag,
                                    Lease lease,
                                    org.apache.juddi.datatype.request.FindQualifiers findQualifiers)
                             throws org.apache.juddi.error.RegistryException

Specified by:

findSession in interface FTHPISDataStore

Throws:

org.apache.juddi.error.RegistryException

deleteSession

public void deleteSession(java.lang.String sessionKey)
                   throws org.apache.juddi.error.RegistryException

Specified by:

deleteSession in interface FTHPISDataStore

Throws:

org.apache.juddi.error.RegistryException

deleteSessionService

public void deleteSessionService(java.lang.String serviceKey)
                          throws org.apache.juddi.error.RegistryException

Specified by:

deleteSessionService in interface FTHPISDataStore

Throws:

org.apache.juddi.error.RegistryException

fetchContext

public Attribute fetchContext(java.lang.String contextKey)
                       throws org.apache.juddi.error.RegistryException

Specified by:

fetchContext in interface FTHPISDataStore

Throws:

org.apache.juddi.error.RegistryException

fetchSession

public SessionEntity fetchSession(java.lang.String sessionKey)
                           throws org.apache.juddi.error.RegistryException

Specified by:

fetchSession in interface FTHPISDataStore

Throws:

org.apache.juddi.error.RegistryException

deleteContext

public void deleteContext(java.lang.String contextKey)
                   throws org.apache.juddi.error.RegistryException

Specified by:

deleteContext in interface FTHPISDataStore

Throws:

org.apache.juddi.error.RegistryException

fetchSessionService

public BusinessService fetchSessionService(java.lang.String serviceKey)
                                    throws org.apache.juddi.error.RegistryException

Specified by:

fetchSessionService in interface FTHPISDataStore

Throws:

org.apache.juddi.error.RegistryException

findContext

public java.util.Vector findContext(java.lang.String sessionKey,
                                    java.lang.String serviceKey,
                                    java.util.Vector nameVector,
                                    Lease lease,
                                    org.apache.juddi.datatype.request.FindQualifiers findQualifiers)
                             throws org.apache.juddi.error.RegistryException

Specified by:

findContext in interface FTHPISDataStore

Throws:

org.apache.juddi.error.RegistryException

isSessionAdmin

public boolean isSessionAdmin(java.lang.String sessionKey,
                              java.lang.String publisherID)
                       throws org.apache.juddi.error.RegistryException

Specified by:

isSessionAdmin in interface FTHPISDataStore

Throws:

org.apache.juddi.error.RegistryException

isSessionPublisher

public boolean isSessionPublisher(java.lang.String sessionKey,
                                  java.lang.String publisherID)
                           throws org.apache.juddi.error.RegistryException

Specified by:

isSessionPublisher in interface FTHPISDataStore

Throws:

org.apache.juddi.error.RegistryException

isContextPublisher

public boolean isContextPublisher(java.lang.String contextKey,
                                  java.lang.String publisherID)
                           throws org.apache.juddi.error.RegistryException

Specified by:

isContextPublisher in interface FTHPISDataStore

Throws:

org.apache.juddi.error.RegistryException

isValidSessionKey

public boolean isValidSessionKey(java.lang.String sessionKey)
                          throws org.apache.juddi.error.RegistryException

Specified by:

isValidSessionKey in interface FTHPISDataStore

Throws:

org.apache.juddi.error.RegistryException

isValidContextKey

public boolean isValidContextKey(java.lang.String contextKey)
                          throws org.apache.juddi.error.RegistryException

Specified by:

isValidContextKey in interface FTHPISDataStore

Throws:

org.apache.juddi.error.RegistryException

saveContext

public void saveContext(Attribute context)
                 throws org.apache.juddi.error.RegistryException

Specified by:

saveContext in interface FTHPISDataStore

Throws:

org.apache.juddi.error.RegistryException

saveSession

public void saveSession(SessionEntity session,
                        java.lang.String publisherID)
                 throws org.apache.juddi.error.RegistryException

Specified by:

saveSession in interface FTHPISDataStore

Throws:

org.apache.juddi.error.RegistryException

main

public static void main(java.lang.String[] args)
                 throws java.lang.Exception

Throws:

java.lang.Exception

test

public static void test(java.sql.Connection conn)
                 throws java.lang.Exception

Throws:

java.lang.Exception