Class TagsRepositoryJDBC

java.lang.Object

tigase.extensions.tags.db.TagsRepositoryJDBC

All Implemented Interfaces:

tigase.db.DataSourceAware<tigase.db.DataRepository>, tigase.db.util.RepositoryVersionAware, TagsRepository<tigase.db.DataRepository>

public class TagsRepositoryJDBC
extends Object
implements tigase.db.DataSourceAware<tigase.db.DataRepository>, TagsRepository<tigase.db.DataRepository>, tigase.db.util.RepositoryVersionAware

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
protected static interface	TagsRepositoryJDBC.SQLExecuteFunction<T>
protected static interface	TagsRepositoryJDBC.SQLQueryFunction<T>

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

tigase.db.util.RepositoryVersionAware.SchemaVersion

Constructor Summary

Constructors

Constructor	Description
TagsRepositoryJDBC()

Method Summary

Modifier and Type	Method	Description
void	assignTag(String domain, String tagId, EntityType type, tigase.xmpp.jid.BareJID jid, boolean required)
String	createTag(String domain, TagScope scope, tigase.xmpp.jid.BareJID owner, String name, String description, String color, String icon)
void	deleteTag(String domain, String tagId)
void	dissociateTag(String domain, String tagId, tigase.xmpp.jid.BareJID jid)
protected void	execute(String query, TagsRepositoryJDBC.SQLExecuteFunction function)
protected <T> T	execute(String query, TagsRepositoryJDBC.SQLQueryFunction<T> function)
protected Tag	fromResultSet(ResultSet rs)
Tag	getTag(String domain, String tagId)
EntityType	getTagAssociationType(String domain, String tagId, tigase.xmpp.jid.BareJID jid)
protected void	initPreparedStatements(tigase.db.DataRepository dataSource)
protected void	offerDao(tigase.extensions.tags.db.TagsRepositoryJDBC.HashCode hash)
Stream<Tag>	queryAssociatedTags(String domain, tigase.xmpp.jid.BareJID jid, tigase.xmpp.jid.BareJID requestor)
Stream<tigase.xmpp.jid.BareJID>	queryJidsWithTag(String domain, String tagId, EntityType type, Boolean required)
Stream<Tag>	queryTags(String domain, TagScope scope, tigase.xmpp.jid.BareJID requestor)
void	setDataSource(tigase.db.DataRepository dataSource)
protected tigase.extensions.tags.db.TagsRepositoryJDBC.HashCode	takeDao()
void	updateTag(String domain, String tagId, TagScope scope, tigase.xmpp.jid.BareJID owner, String name, String description, String color, String icon)

Methods inherited from class Object

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

Methods inherited from interface tigase.db.util.RepositoryVersionAware

getVersion, updateSchema

Constructor Details

TagsRepositoryJDBC

public TagsRepositoryJDBC()

Method Details

setDataSource

public void setDataSource(tigase.db.DataRepository dataSource)
                   throws tigase.component.exceptions.RepositoryException

Specified by:

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

Throws:

tigase.component.exceptions.RepositoryException

initPreparedStatements

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

Throws:

SQLException

getTag

public Tag getTag(String domain,
 String tagId)
           throws tigase.component.exceptions.RepositoryException

Specified by:

getTag in interface TagsRepository<tigase.db.DataRepository>

Throws:

tigase.component.exceptions.RepositoryException

createTag

public String createTag(String domain,
 TagScope scope,
 tigase.xmpp.jid.BareJID owner,
 String name,
 String description,
 String color,
 String icon)
                 throws tigase.component.exceptions.RepositoryException

Specified by:

createTag in interface TagsRepository<tigase.db.DataRepository>

Throws:

tigase.component.exceptions.RepositoryException

updateTag

public void updateTag(String domain,
 String tagId,
 TagScope scope,
 tigase.xmpp.jid.BareJID owner,
 String name,
 String description,
 String color,
 String icon)
               throws tigase.component.exceptions.RepositoryException

Specified by:

updateTag in interface TagsRepository<tigase.db.DataRepository>

Throws:

tigase.component.exceptions.RepositoryException

deleteTag

public void deleteTag(String domain,
 String tagId)
               throws tigase.component.exceptions.RepositoryException

Specified by:

deleteTag in interface TagsRepository<tigase.db.DataRepository>

Throws:

tigase.component.exceptions.RepositoryException

assignTag

public void assignTag(String domain,
 String tagId,
 EntityType type,
 tigase.xmpp.jid.BareJID jid,
 boolean required)
               throws tigase.component.exceptions.RepositoryException

Specified by:

assignTag in interface TagsRepository<tigase.db.DataRepository>

Throws:

tigase.component.exceptions.RepositoryException

dissociateTag

public void dissociateTag(String domain,
 String tagId,
 tigase.xmpp.jid.BareJID jid)
                   throws tigase.component.exceptions.RepositoryException

Specified by:

dissociateTag in interface TagsRepository<tigase.db.DataRepository>

Throws:

tigase.component.exceptions.RepositoryException

queryTags

public Stream<Tag> queryTags(String domain,
 TagScope scope,
 tigase.xmpp.jid.BareJID requestor)
                      throws tigase.component.exceptions.RepositoryException

Specified by:

queryTags in interface TagsRepository<tigase.db.DataRepository>

Throws:

tigase.component.exceptions.RepositoryException

queryAssociatedTags

public Stream<Tag> queryAssociatedTags(String domain,
 tigase.xmpp.jid.BareJID jid,
 tigase.xmpp.jid.BareJID requestor)
                                throws tigase.component.exceptions.RepositoryException

Specified by:

queryAssociatedTags in interface TagsRepository<tigase.db.DataRepository>

Throws:

tigase.component.exceptions.RepositoryException

queryJidsWithTag

public Stream<tigase.xmpp.jid.BareJID> queryJidsWithTag(String domain,
 String tagId,
 EntityType type,
 Boolean required)
                                                 throws tigase.component.exceptions.RepositoryException

Specified by:

queryJidsWithTag in interface TagsRepository<tigase.db.DataRepository>

Throws:

tigase.component.exceptions.RepositoryException

getTagAssociationType

public EntityType getTagAssociationType(String domain,
 String tagId,
 tigase.xmpp.jid.BareJID jid)
                                 throws tigase.component.exceptions.RepositoryException

Specified by:

getTagAssociationType in interface TagsRepository<tigase.db.DataRepository>

Throws:

tigase.component.exceptions.RepositoryException

execute

protected void execute(String query,
 TagsRepositoryJDBC.SQLExecuteFunction function)
                throws tigase.component.exceptions.RepositoryException

Throws:

tigase.component.exceptions.RepositoryException

execute

protected <T> T execute(String query,
 TagsRepositoryJDBC.SQLQueryFunction<T> function)
                 throws tigase.component.exceptions.RepositoryException

Throws:

tigase.component.exceptions.RepositoryException

fromResultSet

protected Tag fromResultSet(ResultSet rs)
                     throws SQLException

Throws:

SQLException

takeDao

protected tigase.extensions.tags.db.TagsRepositoryJDBC.HashCode takeDao()

offerDao

protected void offerDao(tigase.extensions.tags.db.TagsRepositoryJDBC.HashCode hash)