tigase.workgroupqueues.data.jdbc

Class JDBCWorkgroupQueuesRepository

java.lang.Object

tigase.workgroupqueues.data.jdbc.JDBCWorkgroupQueuesRepository

All Implemented Interfaces:

tigase.db.DataSourceAware<tigase.db.DataRepository>, tigase.db.Repository, tigase.db.util.RepositoryVersionAware, Store

public class JDBCWorkgroupQueuesRepository
extends Object
implements Store, tigase.db.util.RepositoryVersionAware

Nested Class Summary

Nested classes/interfaces inherited from interface tigase.db.Repository

tigase.db.Repository.Meta, tigase.db.Repository.SchemaId

Nested classes/interfaces inherited from interface tigase.db.util.RepositoryVersionAware

tigase.db.util.RepositoryVersionAware.SchemaVersion

Field Summary

Fields

Modifier and Type	Field and Description
static String	ADD_QUEUEY_KEY
protected tigase.db.DataRepository	dataRepository
static String	DELETE_QUEUEY_KEY
static String	GET_QUEUES_KEY
static String	GET_QUEUEY_KEY
protected Logger	log
static String	UPDATE_QUEUEY_KEY

Constructor Summary

Constructors

Constructor and Description
JDBCWorkgroupQueuesRepository()

Method Summary

Modifier and Type	Method and Description
void	addWorkgroupQueue(WorkgroupQueueEntity queue) Add queue entity to storage.
void	deleteWorkgroupQueue(tigase.xmpp.jid.BareJID queueJid)
WorkgroupQueueEntity	getWorkgroupQueue(tigase.xmpp.jid.BareJID queueJID) Loads queue entity from storage.
Collection<WorkgroupQueueEntity>	getWorkgroupQueues() Returns collection of known queues.
protected void	initPreparedStatements(tigase.db.DataRepository dataRepository)
void	initRepository(String resource_uri, Map<String,String> params)
void	setDataSource(tigase.db.DataRepository dataRepository)
void	updateWorkgroupQueue(WorkgroupQueueEntity queue)

Methods inherited from class java.lang.Object

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

Methods inherited from interface tigase.db.util.RepositoryVersionAware

getVersion, updateSchema

Field Detail

ADD_QUEUEY_KEY

public static final String ADD_QUEUEY_KEY

See Also:

Constant Field Values

GET_QUEUEY_KEY

public static final String GET_QUEUEY_KEY

See Also:

Constant Field Values

DELETE_QUEUEY_KEY

public static final String DELETE_QUEUEY_KEY

See Also:

Constant Field Values

UPDATE_QUEUEY_KEY

public static final String UPDATE_QUEUEY_KEY

See Also:

Constant Field Values

GET_QUEUES_KEY

public static final String GET_QUEUES_KEY

See Also:

Constant Field Values

log

protected final Logger log

dataRepository

protected tigase.db.DataRepository dataRepository

Constructor Detail

JDBCWorkgroupQueuesRepository

public JDBCWorkgroupQueuesRepository()

Method Detail

deleteWorkgroupQueue

public void deleteWorkgroupQueue(tigase.xmpp.jid.BareJID queueJid)

Specified by:

deleteWorkgroupQueue in interface Store

addWorkgroupQueue

public void addWorkgroupQueue(WorkgroupQueueEntity queue)

Description copied from interface: Store

Add queue entity to storage.

Specified by:

addWorkgroupQueue in interface Store

Parameters:

queue - queue to add.

getWorkgroupQueue

public WorkgroupQueueEntity getWorkgroupQueue(tigase.xmpp.jid.BareJID queueJID)

Description copied from interface: Store

Loads queue entity from storage.

Specified by:

getWorkgroupQueue in interface Store

Parameters:

queueJID - JID of queue.

Returns:

queue instance of null if queue doesn't exists.

getWorkgroupQueues

public Collection<WorkgroupQueueEntity> getWorkgroupQueues()

Description copied from interface: Store

Returns collection of known queues.

Specified by:

getWorkgroupQueues in interface Store

Returns:

collection of queues.

initRepository

public void initRepository(String resource_uri,
                           Map<String,String> params)
                    throws tigase.db.DBInitException

Specified by:

initRepository in interface tigase.db.Repository

Throws:

tigase.db.DBInitException

setDataSource

public void setDataSource(tigase.db.DataRepository dataRepository)

Specified by:

setDataSource in interface tigase.db.DataSourceAware<tigase.db.DataRepository>

updateWorkgroupQueue

public void updateWorkgroupQueue(WorkgroupQueueEntity queue)

initPreparedStatements

protected void initPreparedStatements(tigase.db.DataRepository dataRepository)
                               throws SQLException

Throws:

SQLException