ó
|
à6hc @ s5 d d l Z d d l Z y d d l Z Wn e k
|
rG d d l Z n Xd d l m Z m Z m Z d d l m
|
Z
|
m Z d d l Z e d Z d d l Z d a d a e j a d a e j a d Z d Z d Z d
|
Z d Z d Z d Z d Z d Z d Z d Z d Z! d S( iÿÿÿÿN( t
|
CommFuncExt CommFunct mylog( t CommonDefinet errors Config.DBConfigi i" c C s" t j t d 7a t j t S( Ni ( t AdoExceptionCounterLockt acquiret ADOExceptionCntt release( ( ( s .\\ServersRoute\MangoDBCommon.pyt addADOExceptionCount s
|
|
|
c C s t S( N( R ( ( ( s .\\ServersRoute\MangoDBCommon.pyt getADOExceptionCount% s c C s@ t | t r< t j r% t j | St j t j | d S| S( Ni ( t
|
isinstancet unicodet DBConfigt base64t b64decodeR t UnicodeToEncodingt encoding( t text( ( s .\\ServersRoute\MangoDBCommon.pyt fix_outgoingText( s
|
c C s@ t | t r< t j r% t j | St j t j | d S| S( Ni ( R t strR R t b64encodeR t EncodingToUnicodeR ( R ( ( s .\\ServersRoute\MangoDBCommon.pyt fix_incomingText0 s
|
c C sa xZ | j D]L \ } } t | t r t j t j | \ } } | rY | | | <qY q q Wd S( N( t iteritemsR R R R R t ENCODING( t dictObjt kt vt resultt convertText( ( s .\\ServersRoute\MangoDBCommon.pyt fix_incoming8 s
|
c C sa xZ | j D]L \ } } t | t r t j t j | \ } } | rY | | | <qY q q Wd S( N( R R R R R R R ( R R R R R ( ( s .\\ServersRoute\MangoDBCommon.pyt fix_outgoing? s
|
c C s" t j t d 7a t j t S( Ni ( t SIDErrorCounterLockR t SIDErrorCntR ( ( ( s .\\ServersRoute\MangoDBCommon.pyt addSIDErrorCntF s
|
|
|
c C s t S( N( R" ( ( ( s .\\ServersRoute\MangoDBCommon.pyt getSIDErrorCntN s c C s t j | S( N( t binasciit crc32( t data( ( s .\\ServersRoute\MangoDBCommon.pyt makeSIDR s c C sT t j s t S| t k r t St | } | | k r9 t St j d | | f t S( Ns expectSID = %s calcSID = %s( R t checkSIDt Truet MAGIC_SIDR( R t debugt False( R' t expectSIDt calcSID( ( s .\\ServersRoute\MangoDBCommon.pyR) V s s c C s yÓ d } | d | } | j d i | d 6d i i | d 6d 6d t } | r] | d } nu | j d i | d 6d i i | d 6d 6d t d
|
t } | r© | d } n) t j d t j d } t j | d SWnE t j d t j d | | | | t j f } t j | n X| S( Ni s %s_seqt queryt _idt updatet seqs $inct news $sett upsertR s seq failed!sO seq failed, colname = %s, fieldname = %s, feed = %d, increment = %d, error = %s( t find_and_modifyR* R t formatMsgt ERROR_NO_35R t ERROR_NO_36t tracebackt
|
format_exc( t dbt collectionNamet fieldNamet feedt incrementR t
|
collectiont resultObjt msg( ( s .\\ServersRoute\MangoDBCommon.pyR3 f s" 3 0 1(" t sysR% t threadingt ImportErrort dummy_threadingt CommonR R R t DBCommonR R R: t
|
__import__R R R" R+ t LockR! R R R R
|
R R R R R# R$ R( R) t SPLITCHARR3 ( ( ( s .\\ServersRoute\MangoDBCommon.pyt <module> s6
|
