Class StoredProcedures


  • public class StoredProcedures
    extends java.lang.Object
    Author:
    andrzej
    • 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)  
      • Methods inherited from class java.lang.Object

        clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
    • Constructor Detail

      • StoredProcedures

        public StoredProcedures()
    • 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