Ñò ýɪWc@sœddklZddkZddkZddklZdd d„ƒYZdefd„ƒYZdefd „ƒYZd „Ze d jo eƒndS( iÿÿÿÿ(tDecimalN(tCMSVersionDeploymentPolicytMeFieldDefinitioncBskeZd„Zd„Zd„Zd„Zd„Zd„Zd„Zd„Z d„Z d „Z d „Z RS( cCs+tiƒiƒ|_|iiƒ|_dS(N(RtgetPrepackDepolymentPolicytgetDatabaseConnectiont connectiontcursor(tself((sk/home/jenkins/workspace/prepack-aio-release-4.2/prepack-aio/src/main/resources/scripts/MeFieldDefinition.pyt__init__ scCsdS(N((Rtdata((sk/home/jenkins/workspace/prepack-aio-release-4.2/prepack-aio/src/main/resources/scripts/MeFieldDefinition.pytgetIdscCs1d}|ii|ƒ|iiƒ}|ddS(Ns4select WFS.ME_FIELD_DEFINITION_SEQ.nextval from duali(Rtexecutetfetchall(Rt statementtrows((sk/home/jenkins/workspace/prepack-aio-release-4.2/prepack-aio/src/main/resources/scripts/MeFieldDefinition.pyt getNextIdscCs1d}|ii|ƒ|iiƒ}|ddS(Ns'SELECT MAX(ID) FROM ME_FIELD_DEFINITIONi(RR R (RR R((sk/home/jenkins/workspace/prepack-aio-release-4.2/prepack-aio/src/main/resources/scripts/MeFieldDefinition.pytgetNextIdViaMaxValuesc CsL|d}|d}|d}|d}|d}|iƒ}|i|ƒ}|tjp |djotSyBd|i||||||gƒ} | GH|ii| ƒ|SWn—tj o‹} |iiƒdGH|i ƒd}yBd|i||||||gƒ} | GH|ii| ƒ|SWqHtj o} | GHtSXnXdS( s3 data[0]: fieldName data[1]: ME profile Name iiiiisXINSERT INTO ME_FIELD_DEFINITION (ID,PROFILE_ID, NAME, MAPPING, DATATYPE, PATH) VALUES %ssInsert failed, retry...N( RtgetMeProfileIdtFalset tupleToStrRR t ExceptionRtrollbackR( RR t fieldNamet meProfileNametmappingtdatatypetpathtidt meProfileIdR te((sk/home/jenkins/workspace/prepack-aio-release-4.2/prepack-aio/src/main/resources/scripts/MeFieldDefinition.pytinsert s4      % %c Cs£|d}|d}|d}|d}|d}|i|ƒ}|tjotSy/d||||f}|GH|ii|ƒWntj o} | GHnXdS(s3 data[0]: fieldName data[1]: ME profile Name iiiiisTUPDATE ME_FIELD_DEFINITION SET MAPPING='%s', DATATYPE='%s', PATH='%s' WHERE ID = %d N(R RRR R( RR RRRRRtfieldIdR R((sk/home/jenkins/workspace/prepack-aio-release-4.2/prepack-aio/src/main/resources/scripts/MeFieldDefinition.pytupdateBs      cCs5|tjodSd|}|GH|ii|ƒdS(Ns-DELETE FROM ME_FIELD_DEFINITION WHERE ID = %d(RRR (RRR ((sk/home/jenkins/workspace/prepack-aio-release-4.2/prepack-aio/src/main/resources/scripts/MeFieldDefinition.pytdeleteYs   cCs#d|}|GH|ii|ƒdS(Ns5DELETE FROM ME_FIELD_DEFINITION WHERE PROFILE_ID = %d(RR (Rt profileIdR ((sk/home/jenkins/workspace/prepack-aio-release-4.2/prepack-aio/src/main/resources/scripts/MeFieldDefinition.pytdeleteByProfilebs cGstiƒi|ƒS(N(t MeSubsProfiletcheckExistence(RR ((sk/home/jenkins/workspace/prepack-aio-release-4.2/prepack-aio/src/main/resources/scripts/MeFieldDefinition.pyRgscCsGd|}|ii|ƒ|iiƒ}t|ƒo |dSdSdS(NsKSELECT NAME, MAPPING, DATATYPE, PATH FROM ME_FIELD_DEFINITION WHERE ID = %di((RR R tlen(RRR R((sk/home/jenkins/workspace/prepack-aio-release-4.2/prepack-aio/src/main/resources/scripts/MeFieldDefinition.pyt getFieldsjs    cCsÍg}xœ|D]”}t|tƒo|it|ƒƒq t|ƒttƒƒjo|it|ƒƒq t|tƒo|it|ƒƒq |i|ƒq Wtt|ƒƒi ddƒi ddƒS(NtNonetNULLs\\s\( t isinstancet basestringtappendtstrttypetlongtintRttupletreplace(Rtvaluestarrtv((sk/home/jenkins/workspace/prepack-aio-release-4.2/prepack-aio/src/main/resources/scripts/MeFieldDefinition.pyRss( t__name__t __module__RR RRRR R!R#RR'R(((sk/home/jenkins/workspace/prepack-aio-release-4.2/prepack-aio/src/main/resources/scripts/MeFieldDefinition.pyRs    "    tMeCriteriaFieldDefinitioncBseZd„Zd„ZRS(cCsti|ƒdS(N(RR(R((sk/home/jenkins/workspace/prepack-aio-release-4.2/prepack-aio/src/main/resources/scripts/MeFieldDefinition.pyRƒscCs†|d}|d}|i|ƒ}|tjotSd||f}|ii|ƒ|iiƒ}t|ƒo |ddStSdS(s3 data[0]: fieldName data[1]: ME profile Name iisselect FD.ID from ME_IDENTIFIER_CRITERIA CR join ME_FIELD_DEFINITION FD on (FD.ID = CR.KEY_FIELD_ID)where FD.NAME = '%s' and CR.PROFILE_ID = %dN(RRRR R R&(RR RRRR R((sk/home/jenkins/workspace/prepack-aio-release-4.2/prepack-aio/src/main/resources/scripts/MeFieldDefinition.pyR †s      (R6R7RR (((sk/home/jenkins/workspace/prepack-aio-release-4.2/prepack-aio/src/main/resources/scripts/MeFieldDefinition.pyR8s tMeEnhanceFieldDefinitioncBseZd„Zd„ZRS(cCsti|ƒdS(N(RR(R((sk/home/jenkins/workspace/prepack-aio-release-4.2/prepack-aio/src/main/resources/scripts/MeFieldDefinition.pyRŸscCs†|d}|d}|i|ƒ}|tjotSd||f}|ii|ƒ|iiƒ}t|ƒo |ddStSdS(s3 data[0]: fieldName data[1]: ME profile Name iis†select FD.ID from ME_ENHANCED_FIELD EF join ME_FIELD_DEFINITION FD on (FD.ID = EF.FIELD_ID)where FD.NAME = '%s' and EF.PROFILE_ID = %dN(RRRR R R&(RR RRRR R((sk/home/jenkins/workspace/prepack-aio-release-4.2/prepack-aio/src/main/resources/scripts/MeFieldDefinition.pyR ¢s      (R6R7RR (((sk/home/jenkins/workspace/prepack-aio-release-4.2/prepack-aio/src/main/resources/scripts/MeFieldDefinition.pyR9s cCs tƒ}dS(N(R8(tfieldDefinition((sk/home/jenkins/workspace/prepack-aio-release-4.2/prepack-aio/src/main/resources/scripts/MeFieldDefinition.pytmain¸st__main__(( tdecimalRt BaseClassR$RRR8R9R;R6(((sk/home/jenkins/workspace/prepack-aio-release-4.2/prepack-aio/src/main/resources/scripts/MeFieldDefinition.pyts  y