Ñò
ýÉªWc           @   sV   d  d k  Z  d  d k Z d e  i  f d „  ƒ  YZ d „  Z e d j o e ƒ  n d S(   iÿÿÿÿNt	   Resourcesc           B   sY   e  Z d  „  Z d „  Z d „  Z d „  Z d „  Z d „  Z d „  Z d „  Z	 d „  Z
 RS(	   c         C   s&   t  i  i |  ƒ d |  _ d |  _ d  S(   NsÜ   NAME, RESOURCETYPENAME, CONNECTIONSTRING, MAXCONCURRENTUSERS, ADMINISTRATIVERESOURCESTATUSID, OPERATIONALRESOURCESTATUSID, HEARTBEATCONNECTIONSTRING, HEARTBEATFREQUENCY, ISACTIVE, IGNORETIMEOUT, USER_NAME, FUNCTIONALTYPEs[  SELECT R.NAME, RT.NAME AS RESOURCETYPENAME, R.CONNECTIONSTRING, R.MAXCONCURRENTUSERS, R.ADMINISTRATIVERESOURCESTATUSID, R.OPERATIONALRESOURCESTATUSID, R.HEARTBEATCONNECTIONSTRING, R.HEARTBEATFREQUENCY, R.ISACTIVE, R.IGNORETIMEOUT, R.USER_NAME, R.FUNCTIONALTYPE FROM TTV_RESOURCE R JOIN TTV_RESOURCETYPE RT ON (R.RESOURCETYPEID = RT.RESOURCETYPEID)(   t	   BaseClasst   __init__t   columnst   selectStatement(   t   self(    (    sc   /home/jenkins/workspace/prepack-aio-release-4.2/prepack-aio/src/main/resources/scripts/Resources.pyR      s    	c         C   sO   | d } |  i  i d | ƒ |  i  i ƒ  } t | ƒ o | d d St Sd  S(   Ni    sB   SELECT RESOURCEID FROM TTV_RESOURCE WHERE NAME='%s' AND ISACTIVE=1(   t   cursort   executet   fetchallt   lent   False(   R   t   datat   resourceNamet   rows(    (    sc   /home/jenkins/workspace/prepack-aio-release-4.2/prepack-aio/src/main/resources/scripts/Resources.pyt   checkExistence   s    
c         C   s%   |  i  i d ƒ |  i  i ƒ  d d S(   Ns-   SELECT WFS.TTV_RESOURCE_SEQ.NEXTVAL FROM DUALi    (   R   R   R   (   R   (    (    sc   /home/jenkins/workspace/prepack-aio-release-4.2/prepack-aio/src/main/resources/scripts/Resources.pyt	   getNextId   s    c   
   
   C   s!  yù |  i  | d ƒ } d |  i | | | d g t | d ƒ ƒ } | GH|  i i | ƒ t i ƒ  } | d } | d  j p t | ƒ o |  i ƒ  St	 } x> | D]6 } | i
 | d | i d d ƒ t ƒ p
 t } q¢ q¢ W| o |  i ƒ  S|  i ƒ  SWn! t j
 o }	 |	 GH|  i ƒ  SXd  S(   Ni   s  INSERT INTO TTV_RESOURCE (RESOURCEID, RESOURCETYPEID, NAME, CONNECTIONSTRING, MAXCONCURRENTUSERS, ADMINISTRATIVERESOURCESTATUSID, OPERATIONALRESOURCESTATUSID, HEARTBEATCONNECTIONSTRING, HEARTBEATFREQUENCY, ISACTIVE, IGNORETIMEOUT, USER_NAME, FUNCTIONALTYPE) VALUES %si    i   i   s   \t    (   t   getResourceTypeIdt
   tupleToStrt   listR   R   t   ResourceGroupMembershipt   NoneR	   t   committ   Truet   handlet   replaceR
   t   rollbackt	   Exception(
   R   t   id_R   t   resourceTypeIdt	   statementt   rgmt   resourceGrpst   isAddResourceGrpSuccessfult   resourceGrpt   e(    (    sc   /home/jenkins/workspace/prepack-aio-release-4.2/prepack-aio/src/main/resources/scripts/Resources.pyt   insert   s,    %
 &c         C   s#   | d  j p | d j o d S| S(   NR   t   NULL(   R   (   R   t   val(    (    sc   /home/jenkins/workspace/prepack-aio-release-4.2/prepack-aio/src/main/resources/scripts/Resources.pyt   convert:   s    c   	      C   sc  y;|  i  | d ƒ } d | | d | d | d | d | d |  i | d ƒ | d	 | d
 | d | d f } | GH|  i i | ƒ t i ƒ  } | i | d g ƒ | d } | d  j p t | ƒ o |  i ƒ  St	 } x> | D]6 } | i
 | d | i d d ƒ t ƒ p
 t } qä qä W| o |  i ƒ  S|  i ƒ  SWn! t j
 o } | GH|  i ƒ  SXd  S(   Ni   s-  UPDATE TTV_RESOURCE SET RESOURCETYPEID=%s, CONNECTIONSTRING='%s', MAXCONCURRENTUSERS=%s, ADMINISTRATIVERESOURCESTATUSID='%s', OPERATIONALRESOURCESTATUSID='%s', HEARTBEATCONNECTIONSTRING='%s', HEARTBEATFREQUENCY=%s, IGNORETIMEOUT='%s', USER_NAME='%s', FUNCTIONALTYPE='%s' WHERE NAME='%s' AND ISACTIVE=1i   i   i   i   i   i   i
   i   i   i    i   s   \R   (   R   R'   R   R   R   t   deleteR   R	   R   R   R   R   R
   R   R   (	   R   R   R   R   R   R    R!   R"   R#   (    (    sc   /home/jenkins/workspace/prepack-aio-release-4.2/prepack-aio/src/main/resources/scripts/Resources.pyt   update?   s,    Y
 &c         C   sã   |  i  | ƒ } | t j oÃ y› t i ƒ  } | i | d g ƒ d | } |  i i | ƒ d | } |  i i | ƒ d | } |  i i | ƒ d | } | GH|  i i | ƒ |  i ƒ  Wqß t j
 o } | GH|  i ƒ  SXn d S(   s0    delete the resource:
		data[0]: resourceName
		i    s*   DELETE FROM JBPM_LOG WHERE RESOURCEID='%s's1   DELETE FROM TTV_MESSAGELOG  WHERE RESOURCEID='%s'sS   UPDATE SITES_SITE SET ASSOCIATED_RESOURCE_ID=NULL WHERE ASSOCIATED_RESOURCE_ID='%s's.   DELETE FROM TTV_RESOURCE WHERE RESOURCEID='%s'N(	   R   R
   R   R(   R   R   R   R   R   (   R   R   t
   resourceIdR   R   R#   (    (    sc   /home/jenkins/workspace/prepack-aio-release-4.2/prepack-aio/src/main/resources/scripts/Resources.pyR(   k   s$    



c         C   s5   |  i  i d | i d d ƒ ƒ |  i  i ƒ  d d S(   Ns;   SELECT RESOURCETYPEID FROM TTV_RESOURCETYPE WHERE NAME='%s's   \R   i    (   R   R   R   R   (   R   t   resourceTypeName(    (    sc   /home/jenkins/workspace/prepack-aio-release-4.2/prepack-aio/src/main/resources/scripts/Resources.pyR   „   s     c         C   sí   d } |  i  i | | d ƒ |  i  i ƒ  } d } |  i  i | | d ƒ |  i  i ƒ  } | d  j p t | ƒ o: t | d d d !ƒ t d ƒ g t | d d ƒ } n; t | d d d !ƒ t | d ƒ g t | d d ƒ } | S(   Nsû   SELECT R.NAME, RT.NAME AS RESOURCETYPENAME, R.CONNECTIONSTRING, R.MAXCONCURRENTUSERS, R.HEARTBEATCONNECTIONSTRING, R.HEARTBEATFREQUENCY, R.USER_NAME FROM TTV_RESOURCE R JOIN TTV_RESOURCETYPE RT ON (R.RESOURCETYPEID=RT.RESOURCETYPEID) WHERE R.NAME='%s'i    sÀ   SELECT RG.NAME FROM TTV_RESOURCE R JOIN TTV_RESOURCEGROUPMEMBERSHIP RGM ON (R.RESOURCEID=RGM.RESOURCEID) JOIN TTV_RESOURCEGROUP RG ON (RGM.RESOURCEGROUPID=RG.RESOURCEGROUPID) WHERE R.NAME='%s'i   R   (   R   R   R   R   R	   R   (   R   t   argst   resourceStatementt   resourceRowst   resourceGrpStatementR    t   result(    (    sc   /home/jenkins/workspace/prepack-aio-release-4.2/prepack-aio/src/main/resources/scripts/Resources.pyt   backUpExisting‰   s    ::(   t   __name__t
   __module__R   R   R   R$   R'   R)   R(   R   R1   (    (    (    sc   /home/jenkins/workspace/prepack-aio-release-4.2/prepack-aio/src/main/resources/scripts/Resources.pyR       s   							,		c          C   s;   t  ƒ  }  |  i d d d d d d d d d d d d ƒ d  S(   Nt   MDMS45t   AMIs   http://10.243.90.45:8300/assetsi   i<   i   R   (   R    t   add(   t   r(    (    sc   /home/jenkins/workspace/prepack-aio-release-4.2/prepack-aio/src/main/resources/scripts/Resources.pyt   mainž   s    	t   __main__(   R   R   R    R8   R2   (    (    (    sc   /home/jenkins/workspace/prepack-aio-release-4.2/prepack-aio/src/main/resources/scripts/Resources.pyt   <module>   s
   ™	