Package tigase.pubsub.repository.derby
Class StoredProcedures
- java.lang.Object
-
- tigase.pubsub.repository.derby.StoredProcedures
-
public class StoredProcedures extends java.lang.Object
- Author:
- andrzej
-
-
Constructor Summary
Constructors Constructor Description StoredProcedures()
-
Method Summary
All Methods Static Methods Concrete Methods Modifier and Type Method Description protected static java.lang.Long
getIdOfJid(java.sql.Connection conn, java.lang.String jid)
protected static java.lang.String
sha1OfLower(java.lang.String data)
static void
tigPubSubCountNodes(java.lang.String serviceJid, java.sql.ResultSet[] data)
static void
tigPubSubCreateNode(java.lang.String serviceJid, java.lang.String nodeName, java.lang.Integer nodeType, java.lang.String nodeCreator, java.lang.String nodeConf, java.lang.Long collectionId, java.sql.Timestamp ts, java.lang.String domain, java.lang.Integer autocreateService, java.sql.ResultSet[] data)
static void
tigPubSubCreateService(java.lang.String serviceJid, java.lang.String domain, java.lang.Integer isPublic, java.sql.ResultSet[] data)
static void
tigPubSubDeleteAllNodes(java.lang.String serviceJid, java.sql.ResultSet[] data)
static void
tigPubSubDeleteItem(java.lang.Long nodeId, java.lang.String itemId, java.sql.ResultSet[] data)
static void
tigPubSubDeleteNodeSubscription(java.lang.Long nodeId, java.lang.String jid, java.sql.ResultSet[] data)
static java.lang.Long
tigPubSubEnsureJid(java.lang.String jid)
static java.lang.Long
tigPubSubEnsureJid(java.sql.Connection conn, java.lang.String jid)
static java.lang.Long
tigPubSubEnsureServiceJid(java.lang.String serviceJid, java.lang.String domain, java.lang.Integer autocreateService)
static void
tigPubSubFixItem(java.lang.Long nodeId, java.lang.String itemId, java.sql.Timestamp creationDate, java.sql.Timestamp updateDate)
static void
tigPubSubFixNode(java.lang.Long nodeId, java.sql.Timestamp creationDate)
static void
tigPubSubGetAllNodes(java.lang.String serviceJid, java.sql.ResultSet[] data)
static void
tigPubSubGetChildNodes(java.lang.String serviceJid, java.lang.String collection, java.sql.ResultSet[] data)
static void
tigPubSubGetItem(java.lang.Long nodeId, java.lang.String itemId, java.sql.ResultSet[] data)
static void
tigPubSubGetNodeAffiliations(java.lang.Long nodeId, java.sql.ResultSet[] data)
static void
tigPubSubGetNodeConfiguration(java.lang.Long nodeId, java.sql.ResultSet[] data)
static void
tigPubSubGetNodeId(java.lang.String serviceJid, java.lang.String nodeName, java.sql.ResultSet[] data)
static void
tigPubSubGetNodeItemIds(java.lang.Long nodeId, java.lang.Integer order, java.sql.ResultSet[] data)
static void
tigPubSubGetNodeItemIdsSince(java.lang.Long nodeId, java.lang.Integer order, java.sql.Timestamp since, java.sql.ResultSet[] data)
static void
tigPubSubGetNodeItemsMeta(java.lang.Long nodeId, java.sql.ResultSet[] data)
static void
tigPubSubGetNodeMeta(java.lang.String serviceJid, java.lang.String nodeName, java.sql.ResultSet[] data)
static void
tigPubSubGetNodeSubscriptions(java.lang.Long nodeId, java.sql.ResultSet[] data)
static void
tigPubSubGetRootNodes(java.lang.String serviceJid, java.sql.ResultSet[] data)
static void
tigPubSubGetServices(java.lang.String domain, java.lang.Integer isPublic, java.sql.ResultSet[] data)
static void
tigPubSubGetUserAffiliations(java.lang.String serviceJid, java.lang.String jid, java.sql.ResultSet[] data)
static void
tigPubSubGetUserSubscriptions(java.lang.String serviceJid, java.lang.String jid, java.sql.ResultSet[] data)
static void
tigPubSubMamAddItem(java.lang.Long nodeId, java.lang.String uuid, java.sql.Timestamp ts, java.lang.String itemData, java.lang.String itemId, java.sql.ResultSet[] data)
static void
tigPubSubMamQueryItemPosition(java.lang.Long nodeId, java.sql.Timestamp since, java.sql.Timestamp to, java.lang.String uuid, java.sql.ResultSet[] data)
static void
tigPubSubMamQueryItems(java.lang.Long nodeId, java.sql.Timestamp since, java.sql.Timestamp to, java.lang.Integer limit, java.lang.Integer offset, java.sql.ResultSet[] data)
static void
tigPubSubMamQueryItemsCount(java.lang.Long nodeId, java.sql.Timestamp since, java.sql.Timestamp to, java.sql.ResultSet[] data)
static void
tigPubSubQueryItemPosition(java.lang.String nodesIds, java.sql.Timestamp since, java.sql.Timestamp to, java.lang.Integer order, java.lang.Long nodeId, java.lang.String itemId, java.sql.ResultSet[] data)
static void
tigPubSubQueryItems(java.lang.String nodesIds, java.sql.Timestamp since, java.sql.Timestamp to, java.lang.Integer order, java.lang.Integer limit, java.lang.Integer offset, java.sql.ResultSet[] data)
static void
tigPubSubQueryItemsCount(java.lang.String nodesIds, java.sql.Timestamp since, java.sql.Timestamp to, java.lang.Integer order, java.sql.ResultSet[] data)
static void
tigPubSubRemoveNode(java.lang.Long nodeId, java.sql.ResultSet[] data)
static void
tigPubSubRemoveService(java.lang.String serviceJid, java.sql.ResultSet[] data)
static void
tigPubSubSetNodeAffiliation(java.lang.Long nodeId, java.lang.String jid, java.lang.String affil, java.sql.ResultSet[] data)
static void
tigPubSubSetNodeConfiguration(java.lang.Long nodeId, java.lang.String conf, java.lang.Long collectionId, java.sql.ResultSet[] data)
static void
tigPubSubSetNodeSubscription(java.lang.Long nodeId, java.lang.String jid, java.lang.String subscr, java.lang.String subscrId, java.sql.ResultSet[] data)
static void
tigPubSubWriteItem(java.lang.Long nodeId, java.lang.String itemId, java.lang.String publisher, java.lang.String itemData, java.sql.Timestamp ts, java.lang.String uuid, java.sql.ResultSet[] data)
-
-
-
Method Detail
-
getIdOfJid
protected static java.lang.Long getIdOfJid(java.sql.Connection conn, java.lang.String jid) throws java.sql.SQLException
- Throws:
java.sql.SQLException
-
sha1OfLower
protected static java.lang.String sha1OfLower(java.lang.String data) throws java.sql.SQLException
- Throws:
java.sql.SQLException
-
tigPubSubCreateNode
public static void tigPubSubCreateNode(java.lang.String serviceJid, java.lang.String nodeName, java.lang.Integer nodeType, java.lang.String nodeCreator, java.lang.String nodeConf, java.lang.Long collectionId, java.sql.Timestamp ts, java.lang.String domain, java.lang.Integer autocreateService, java.sql.ResultSet[] data) throws java.sql.SQLException
- Throws:
java.sql.SQLException
-
tigPubSubDeleteAllNodes
public static void tigPubSubDeleteAllNodes(java.lang.String serviceJid, java.sql.ResultSet[] data) throws java.sql.SQLException
- Throws:
java.sql.SQLException
-
tigPubSubDeleteItem
public static void tigPubSubDeleteItem(java.lang.Long nodeId, java.lang.String itemId, java.sql.ResultSet[] data) throws java.sql.SQLException
- Throws:
java.sql.SQLException
-
tigPubSubDeleteNodeSubscription
public static void tigPubSubDeleteNodeSubscription(java.lang.Long nodeId, java.lang.String jid, java.sql.ResultSet[] data) throws java.sql.SQLException
- Throws:
java.sql.SQLException
-
tigPubSubEnsureJid
public static java.lang.Long tigPubSubEnsureJid(java.lang.String jid) throws java.sql.SQLException
- Throws:
java.sql.SQLException
-
tigPubSubEnsureJid
public static java.lang.Long tigPubSubEnsureJid(java.sql.Connection conn, java.lang.String jid) throws java.sql.SQLException
- Throws:
java.sql.SQLException
-
tigPubSubEnsureServiceJid
public static java.lang.Long tigPubSubEnsureServiceJid(java.lang.String serviceJid, java.lang.String domain, java.lang.Integer autocreateService) throws java.sql.SQLException
- Throws:
java.sql.SQLException
-
tigPubSubFixItem
public static void tigPubSubFixItem(java.lang.Long nodeId, java.lang.String itemId, java.sql.Timestamp creationDate, java.sql.Timestamp updateDate) throws java.sql.SQLException
- Throws:
java.sql.SQLException
-
tigPubSubFixNode
public static void tigPubSubFixNode(java.lang.Long nodeId, java.sql.Timestamp creationDate) throws java.sql.SQLException
- Throws:
java.sql.SQLException
-
tigPubSubGetAllNodes
public static void tigPubSubGetAllNodes(java.lang.String serviceJid, java.sql.ResultSet[] data) throws java.sql.SQLException
- Throws:
java.sql.SQLException
-
tigPubSubGetChildNodes
public static void tigPubSubGetChildNodes(java.lang.String serviceJid, java.lang.String collection, java.sql.ResultSet[] data) throws java.sql.SQLException
- Throws:
java.sql.SQLException
-
tigPubSubGetItem
public static void tigPubSubGetItem(java.lang.Long nodeId, java.lang.String itemId, java.sql.ResultSet[] data) throws java.sql.SQLException
- Throws:
java.sql.SQLException
-
tigPubSubGetNodeAffiliations
public static void tigPubSubGetNodeAffiliations(java.lang.Long nodeId, java.sql.ResultSet[] data) throws java.sql.SQLException
- Throws:
java.sql.SQLException
-
tigPubSubGetNodeConfiguration
public static void tigPubSubGetNodeConfiguration(java.lang.Long nodeId, java.sql.ResultSet[] data) throws java.sql.SQLException
- Throws:
java.sql.SQLException
-
tigPubSubGetNodeId
public static void tigPubSubGetNodeId(java.lang.String serviceJid, java.lang.String nodeName, java.sql.ResultSet[] data) throws java.sql.SQLException
- Throws:
java.sql.SQLException
-
tigPubSubGetNodeItemIds
public static void tigPubSubGetNodeItemIds(java.lang.Long nodeId, java.lang.Integer order, java.sql.ResultSet[] data) throws java.sql.SQLException
- Throws:
java.sql.SQLException
-
tigPubSubGetNodeItemIdsSince
public static void tigPubSubGetNodeItemIdsSince(java.lang.Long nodeId, java.lang.Integer order, java.sql.Timestamp since, java.sql.ResultSet[] data) throws java.sql.SQLException
- Throws:
java.sql.SQLException
-
tigPubSubGetNodeItemsMeta
public static void tigPubSubGetNodeItemsMeta(java.lang.Long nodeId, java.sql.ResultSet[] data) throws java.sql.SQLException
- Throws:
java.sql.SQLException
-
tigPubSubGetNodeMeta
public static void tigPubSubGetNodeMeta(java.lang.String serviceJid, java.lang.String nodeName, java.sql.ResultSet[] data) throws java.sql.SQLException
- Throws:
java.sql.SQLException
-
tigPubSubGetNodeSubscriptions
public static void tigPubSubGetNodeSubscriptions(java.lang.Long nodeId, java.sql.ResultSet[] data) throws java.sql.SQLException
- Throws:
java.sql.SQLException
-
tigPubSubGetRootNodes
public static void tigPubSubGetRootNodes(java.lang.String serviceJid, java.sql.ResultSet[] data) throws java.sql.SQLException
- Throws:
java.sql.SQLException
-
tigPubSubGetUserAffiliations
public static void tigPubSubGetUserAffiliations(java.lang.String serviceJid, java.lang.String jid, java.sql.ResultSet[] data) throws java.sql.SQLException
- Throws:
java.sql.SQLException
-
tigPubSubGetUserSubscriptions
public static void tigPubSubGetUserSubscriptions(java.lang.String serviceJid, java.lang.String jid, java.sql.ResultSet[] data) throws java.sql.SQLException
- Throws:
java.sql.SQLException
-
tigPubSubMamAddItem
public static void tigPubSubMamAddItem(java.lang.Long nodeId, java.lang.String uuid, java.sql.Timestamp ts, java.lang.String itemData, java.lang.String itemId, java.sql.ResultSet[] data) throws java.sql.SQLException
- Throws:
java.sql.SQLException
-
tigPubSubMamQueryItemPosition
public static void tigPubSubMamQueryItemPosition(java.lang.Long nodeId, java.sql.Timestamp since, java.sql.Timestamp to, java.lang.String uuid, java.sql.ResultSet[] data) throws java.sql.SQLException
- Throws:
java.sql.SQLException
-
tigPubSubMamQueryItems
public static void tigPubSubMamQueryItems(java.lang.Long nodeId, java.sql.Timestamp since, java.sql.Timestamp to, java.lang.Integer limit, java.lang.Integer offset, java.sql.ResultSet[] data) throws java.sql.SQLException
- Throws:
java.sql.SQLException
-
tigPubSubMamQueryItemsCount
public static void tigPubSubMamQueryItemsCount(java.lang.Long nodeId, java.sql.Timestamp since, java.sql.Timestamp to, java.sql.ResultSet[] data) throws java.sql.SQLException
- Throws:
java.sql.SQLException
-
tigPubSubQueryItemPosition
public static void tigPubSubQueryItemPosition(java.lang.String nodesIds, java.sql.Timestamp since, java.sql.Timestamp to, java.lang.Integer order, java.lang.Long nodeId, java.lang.String itemId, java.sql.ResultSet[] data) throws java.sql.SQLException
- Throws:
java.sql.SQLException
-
tigPubSubQueryItems
public static void tigPubSubQueryItems(java.lang.String nodesIds, java.sql.Timestamp since, java.sql.Timestamp to, java.lang.Integer order, java.lang.Integer limit, java.lang.Integer offset, java.sql.ResultSet[] data) throws java.sql.SQLException
- Throws:
java.sql.SQLException
-
tigPubSubQueryItemsCount
public static void tigPubSubQueryItemsCount(java.lang.String nodesIds, java.sql.Timestamp since, java.sql.Timestamp to, java.lang.Integer order, java.sql.ResultSet[] data) throws java.sql.SQLException
- Throws:
java.sql.SQLException
-
tigPubSubRemoveNode
public static void tigPubSubRemoveNode(java.lang.Long nodeId, java.sql.ResultSet[] data) throws java.sql.SQLException
- Throws:
java.sql.SQLException
-
tigPubSubRemoveService
public static void tigPubSubRemoveService(java.lang.String serviceJid, java.sql.ResultSet[] data) throws java.sql.SQLException
- Throws:
java.sql.SQLException
-
tigPubSubSetNodeAffiliation
public static void tigPubSubSetNodeAffiliation(java.lang.Long nodeId, java.lang.String jid, java.lang.String affil, java.sql.ResultSet[] data) throws java.sql.SQLException
- Throws:
java.sql.SQLException
-
tigPubSubSetNodeConfiguration
public static void tigPubSubSetNodeConfiguration(java.lang.Long nodeId, java.lang.String conf, java.lang.Long collectionId, java.sql.ResultSet[] data) throws java.sql.SQLException
- Throws:
java.sql.SQLException
-
tigPubSubSetNodeSubscription
public static void tigPubSubSetNodeSubscription(java.lang.Long nodeId, java.lang.String jid, java.lang.String subscr, java.lang.String subscrId, java.sql.ResultSet[] data) throws java.sql.SQLException
- Throws:
java.sql.SQLException
-
tigPubSubWriteItem
public static void tigPubSubWriteItem(java.lang.Long nodeId, java.lang.String itemId, java.lang.String publisher, java.lang.String itemData, java.sql.Timestamp ts, java.lang.String uuid, java.sql.ResultSet[] data) throws java.sql.SQLException
- Throws:
java.sql.SQLException
-
tigPubSubCountNodes
public static void tigPubSubCountNodes(java.lang.String serviceJid, java.sql.ResultSet[] data) throws java.sql.SQLException
- Throws:
java.sql.SQLException
-
tigPubSubGetServices
public static void tigPubSubGetServices(java.lang.String domain, java.lang.Integer isPublic, java.sql.ResultSet[] data) throws java.sql.SQLException
- Throws:
java.sql.SQLException
-
tigPubSubCreateService
public static void tigPubSubCreateService(java.lang.String serviceJid, java.lang.String domain, java.lang.Integer isPublic, java.sql.ResultSet[] data) throws java.sql.SQLException
- Throws:
java.sql.SQLException
-
-