Ñò ýɪWc@s}ddkZddkZddklZd„Zdefd„ƒYZdeifd„ƒYZdeifd „ƒYZ dS( iÿÿÿÿN(tDecimalcCsdt|iƒjS(Ntpsycopg2(tstrt __class__(tcursor((sa/home/jenkins/workspace/prepack-aio-release-4.2/prepack-aio/src/main/resources/scripts/dbutils.pyt ispgsqldbstDaocBskeZdZed„ƒZed„ƒZed„ƒZeed„ƒZed„ƒZ ed„ƒZ RS(s DataBase Access Object c Gs0|pdSg}t|tƒo |g}n.t|tƒo |}nt|ƒdGHdS|o|n|diƒ}di|ƒ}t|ƒoditd„|ƒƒ}nditd„|ƒƒ}d|||f}|o |i|t i ||ƒƒn|i||ƒt|i ƒdGHdS( sš insert data to specify table @param cursor Database cursor @param data A dictionary or a list of dictionaries; @param table The table name @param columns Specify the columns to be inserted to table - None (default). all of columns base on the keys of dictionary will be inserted to table Ns is not support data typeis, cSsd|S(s%%(%s)s((tx((sa/home/jenkins/workspace/prepack-aio-release-4.2/prepack-aio/src/main/resources/scripts/dbutils.pyt)scSsd|S(s:%s((R((sa/home/jenkins/workspace/prepack-aio-release-4.2/prepack-aio/src/main/resources/scripts/dbutils.pyR+ssINSERT INTO %s (%s) VALUES (%s)s record(s) is inserted( t isinstancetdicttlistRtkeystjoinRtmapt executemanyRt copyDictstrowcount( Rtdatattabletcolumnstdictstinsert_columnst columnsholdert valuesholdertsql((sa/home/jenkins/workspace/prepack-aio-release-4.2/prepack-aio/src/main/resources/scripts/dbutils.pytinserts&     cGs|pdSg}t|tƒo |g}n.t|tƒo |}ndt|ƒGHdS|ptdƒ‚nt|ƒoditd„|ƒƒ}nditd„|ƒƒ}d||f}|GH|i|t i ||ƒƒt|i ƒdGHdS( sš data data from specify table @param cursor Database cursor @param data A dictionary or a list of dictionaries; @param table The table name @param columns Specify the columns to be inserted to table - None (default). all of columns base on the keys of dictionary will be inserted to table NsUn-support data typesiYou should assign at least one id column for table! the id columns usually be a unique key(s) in databases and cSsd||fS(s %s=%%(%s)s((R((sa/home/jenkins/workspace/prepack-aio-release-4.2/prepack-aio/src/main/resources/scripts/dbutils.pyRSscSsd||fS(s%s=:%s((R((sa/home/jenkins/workspace/prepack-aio-release-4.2/prepack-aio/src/main/resources/scripts/dbutils.pyRUssDELETE FROM %s WHERE %ss record(s) is deleted( R R R Rt RuntimeErrorRR RRRRR(RRRt id_columnsRtcriteriaHoldersR((sa/home/jenkins/workspace/prepack-aio-release-4.2/prepack-aio/src/main/resources/scripts/dbutils.pytdelete8s$    c OsŠ|pdSg}t|tƒo |g}n.t|tƒo |}ndt|ƒGHdS|ptdƒ‚n|id|diƒƒ}t|ƒo:dit d„|ƒƒ}dit d „|ƒƒ}n7dit d „|ƒƒ}dit d „|ƒƒ}d |||f} | GH|idƒo0t|ƒ|} |i | t i || ƒƒn|i | |ƒt|i ƒd GHdS(s update data to specify table @param cursor Database cursor @param data A dictionary or a list of dictionaries; @param table The table name @param id_columns Specify a list of columns to identify a unique row in table @Keywords: update_columns : list Specify the columns to be updated: - None (default). Update all of columns base on the keys of dictionary Nsun-support data typesiYou should assign at least one id column for table! the id columns usually be a unique key(s) in databasetupdate_columnsis, cSsd||fS(s %s=%%(%s)s((R((sa/home/jenkins/workspace/prepack-aio-release-4.2/prepack-aio/src/main/resources/scripts/dbutils.pyR€ss and cSsd||fS(s %s=%%(%s)s((R((sa/home/jenkins/workspace/prepack-aio-release-4.2/prepack-aio/src/main/resources/scripts/dbutils.pyRscSsd||fS(s%s=:%s((R((sa/home/jenkins/workspace/prepack-aio-release-4.2/prepack-aio/src/main/resources/scripts/dbutils.pyRƒscSsd||fS(s%s=:%s((R((sa/home/jenkins/workspace/prepack-aio-release-4.2/prepack-aio/src/main/resources/scripts/dbutils.pyR„ssUPDATE %s SET %s WHERE %ss record(s) was updated(R R R RRtgetR RR RRRRR( RRRRtkwargsRRt setHoldersRRt dict_keys((sa/home/jenkins/workspace/prepack-aio-release-4.2/prepack-aio/src/main/resources/scripts/dbutils.pytupdatecs0    c suˆi|ƒg}ˆiƒD],}|t‡‡fd†t|ƒDƒƒq~}titi|dtddƒƒS(sÉ export the SQL result set to python dictionaries which reference to each rows in table. the column name map to the dictionary key,the column value map to the dictionary value, c3sPxI|]B\}}ˆi|diƒtiˆˆi|d|ƒfVqWdS(iiN(t descriptiontupperRtdate2Str(t.0titvalue(Rt formatDate(sa/home/jenkins/workspace/prepack-aio-release-4.2/prepack-aio/src/main/resources/scripts/dbutils.pys –s tclstindenti(texecutetfetchallR t enumeratetjsontloadstdumpst IntEncoder(RRR+t_[1]trowtobj((RR+sa/home/jenkins/workspace/prepack-aio-release-4.2/prepack-aio/src/main/resources/scripts/dbutils.pytexports FcCs|opt|dƒo@|idjp|idjo|dj o |iƒS|Sq{|djo |iƒS|Sn|SdS(Nt__name__tDATETIMEt TIMESTAMPiZ(thasattrR9tNonet isoformat(R+t dbDataTypeR*((sa/home/jenkins/workspace/prepack-aio-release-4.2/prepack-aio/src/main/resources/scripts/dbutils.pyR'šs-   cCsMg}x@|D]8}h}x|D]}||||tdatet timedeltatminttimeRtinttsuperRItdefault(tselfR7((sa/home/jenkins/workspace/prepack-aio-release-4.2/prepack-aio/src/main/resources/scripts/dbutils.pyRQ¶s   (R9RERQ(((sa/home/jenkins/workspace/prepack-aio-release-4.2/prepack-aio/src/main/resources/scripts/dbutils.pyRIµsR4cBseZdZd„ZRS(s¦ During export, Postgres will export numeric type to Decimal, But Decimal can not be serialized to file, so need to convert Decimal to int type. cCs5t|tƒo t|ƒStt|ƒi|ƒSdS(N(R RRORPR4RQ(RRR7((sa/home/jenkins/workspace/prepack-aio-release-4.2/prepack-aio/src/main/resources/scripts/dbutils.pyRQÊs (R9RERFRQ(((sa/home/jenkins/workspace/prepack-aio-release-4.2/prepack-aio/src/main/resources/scripts/dbutils.pyR4Ås( RJR1tdecimalRRtobjectRt JSONEncoderRIR4(((sa/home/jenkins/workspace/prepack-aio-release-4.2/prepack-aio/src/main/resources/scripts/dbutils.pyts   «