Ñò ýɪWc@sndZddkZddkZddkZdefd„ƒYZd„ZedjodZeeƒndS(s* Created on Jan 4, 2013 @author: ebracox iÿÿÿÿNtRemoteDatabaseConnectioncBsJeZdZd„Zd„Zed„Zd„Zd„Ze d„Z RS(s classdocs cCsód}d}d}d}tiƒ|_|iiƒ|iitiƒƒdGH|ii||||ƒ|iiƒ|_|ii dƒ|i ƒ|i dƒ|i dƒ|i d ƒ|i d ƒ|i d ƒ|i d ƒ|i d ƒdS(s Constructor tcmstcms1234tdbserveris*** Connecting...gð?tsutroot1234s su - oracles!source /home/oracle/.bash_profiles$ORACLE_HOME/bin/sqlplus /nologsconnect / as sysdbasset feedback onN( tparamikot SSHClienttclienttload_system_host_keystset_missing_host_key_policyt AutoAddPolicytconnectt invoke_shelltchannelt settimeouttflushtsend(tselftusernametpasswordthosttport((sr/home/jenkins/workspace/prepack-aio-release-4.2/prepack-aio/src/main/resources/scripts/RemoteDatabaseConnection.pyt__init__s&        cCs|idƒdS(Nscommit;(R(R((sr/home/jenkins/workspace/prepack-aio-release-4.2/prepack-aio/src/main/resources/scripts/RemoteDatabaseConnection.pytcommit0scCs8|i|ƒt|ƒiƒdjo|iƒndS(Nttrue(RtstrtlowerR(RtqueryR((sr/home/jenkins/workspace/prepack-aio-release-4.2/prepack-aio/src/main/resources/scripts/RemoteDatabaseConnection.pytexecute3s cCs+|idƒ|iiƒ|iiƒdS(Nsquit;(RRtcloseR(R((sr/home/jenkins/workspace/prepack-aio-release-4.2/prepack-aio/src/main/resources/scripts/RemoteDatabaseConnection.pytlogout8s  cCsXxQy|iidƒ}|GHWqtiij oPqtij oPqXqdS(Ni(RtrecvRt buffered_pipet PipeTimeouttsocketttimeout(Rtresp((sr/home/jenkins/workspace/prepack-aio-release-4.2/prepack-aio/src/main/resources/scripts/RemoteDatabaseConnection.pyR>s cCs8|ii|ddg|ƒ}|iƒ|iƒdS(Nts (RRR(RtcommandtaddLFt bytesSent((sr/home/jenkins/workspace/prepack-aio-release-4.2/prepack-aio/src/main/resources/scripts/RemoteDatabaseConnection.pyRKs  ( t__name__t __module__t__doc__RRtFalseRRRtTrueR(((sr/home/jenkins/workspace/prepack-aio-release-4.2/prepack-aio/src/main/resources/scripts/RemoteDatabaseConnection.pyR s     cCs–ddk}|itdƒƒ}y@tƒ}x&|dD]}|i|dtƒq8W|iƒWn.tj o"}ti ƒ|GH|iƒnXdS(Niÿÿÿÿs ../azuki.jsontqueriestQUERY( tjsontloadtopenRRR.Rt Exceptiont tracebackt print_exc(RR1tftrdcte((sr/home/jenkins/workspace/prepack-aio-release-4.2/prepack-aio/src/main/resources/scripts/RemoteDatabaseConnection.pytmainTs    t__main__s‰create or replace view wfs.title_ingestion_info as SELECT distinct extractvalue(sys_nc_rowinfo$,'/ECMFSpec/Package/Fields/ProviderInfo/Identifier/Id') as provider_id, extractvalue(sys_nc_rowinfo$,'/ECMFSpec/Package/Fields/ProviderInfo/Name') as provider_name, extractvalue(sys_nc_rowinfo$,'/ECMFSpec/@documentId') as document_id, extractvalue(sys_nc_rowinfo$,'/ECMFSpec/Package/Title/Fields/Title/ShortTitle/Value') as title_brief, extractvalue(sys_nc_rowinfo$,'/ECMFSpec/Package/Title/Fields/Rights/LicensingWindowStart') as License_start_date, extractvalue(sys_nc_rowinfo$,'/ECMFSpec/Package/Title/Fields/Rights/LicensingWindowEnd') as license_end_date, count(x.assetid) over (PARTITION BY t.id_ order by t.id_) as asset_count, --count(x.assetid) as asset_count, to_date(to_char(pi.start_,'yyyy-mm-dd'),'yyyy-mm-dd') as wo_start, to_date(to_char(pi.end_ ,'yyyy-mm-dd'),'yyyy-mm-dd') as wo_end, (pi.end_ - pi.start_) day(2) to second(0) ingestion_time, round((extract(second from (pi.end_ - pi.start_))+ extract(minute from (pi.end_ - pi.start_))*60 + extract(hour from (pi.end_ - pi.start_))*60*60 + extract(day from (pi.end_ - pi.start_))*60*60*24),0) as ingestion_time_seconds FROM wfs.MDM_METADATA m, xmltable('/ECMFSpec/*/*/@assetId' passing m.object_value columns assetid number path '.') x, wfs.pmm_title t, wfs.jbpm_variableinstance vi, wfs.jbpm_processinstance pi, wfs.jbpm_processdefinition pd where t.mdmdocid=extractvalue(sys_nc_rowinfo$,'/ECMFSpec/@documentId') and t.originaltitle_id is null and t.id_ = vi.stringvalue_ and vi.name_='titleId' and vi.processinstance_ = pi.id_ and pi.operationalprocessstatusid=6 and pd.id_ = pi.processdefinition_ and pd.name_='Ingest Template';( R,RR#R5tobjectRR:R*R(((sr/home/jenkins/workspace/prepack-aio-release-4.2/prepack-aio/src/main/resources/scripts/RemoteDatabaseConnection.pyts   H