hwj35
10 天以前 aa0f971ae9a59f0fd98d57b6c1d1663a270be92c
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
±¼,Pc@sGddlZddlZyddlZWnek
rGddlZnXddlmZmZmZddl    m
Z
m Z ddl Z e dƒZddlZdadaejƒadaejƒad„Zd„Zd    „Zd
„Zd „Zd „Zd „Zd„Zd„Zd„ZdZ d„Z!d„Z"d„Z#dS(iÿÿÿÿN(t
CommFuncExtCommFunctmylog(t CommonDefineterrorsConfig.DBConfigii˜•"cCs"tjƒtd7atjƒtS(Ni(tAdoExceptionCounterLocktacquiretADOExceptionCnttrelease(((s..\server\db\PyMongoDataServer\MangoDBCommon.pytaddADOExceptionCounts
 
 
cCstS(N(R(((s..\server\db\PyMongoDataServer\MangoDBCommon.pytgetADOExceptionCount%scCs@t|tƒr<tjr%tj|ƒStjtj|ƒdS|S(Ni(t
isinstancetunicodetDBConfigtbase64t    b64decodeRtUnicodeToEncodingtencoding(ttext((s..\server\db\PyMongoDataServer\MangoDBCommon.pytfix_outgoingText(s
     cCs@t|tƒr<tjr%tj|ƒStjtj|ƒdS|S(Ni(R tstrR Rt    b64encodeRtEncodingToUnicodeR(R((s..\server\db\PyMongoDataServer\MangoDBCommon.pytfix_incomingText0s
     cCsaxZ|jƒD]L\}}t|tƒr tjtj|ƒ\}}|rY|||<qYq q WdS(N(t    iteritemsR RRRRtENCODING(tdictObjtktvtresultt convertText((s..\server\db\PyMongoDataServer\MangoDBCommon.pyt fix_incoming8s
cCsaxZ|jƒD]L\}}t|tƒr tjtj|ƒ\}}|rY|||<qYq q WdS(N(RR R RRRR(RRRRR((s..\server\db\PyMongoDataServer\MangoDBCommon.pyt fix_outgoing?s
cCs"tjƒtd7atjƒtS(Ni(tSIDErrorCounterLockRt SIDErrorCntR(((s..\server\db\PyMongoDataServer\MangoDBCommon.pytaddSIDErrorCntFs
 
 
cCstS(N(R"(((s..\server\db\PyMongoDataServer\MangoDBCommon.pytgetSIDErrorCntNscCs tj|ƒS(N(tbinasciitcrc32(tdata((s..\server\db\PyMongoDataServer\MangoDBCommon.pytmakeSIDRscCsTtjs tS|tkrtSt|ƒ}||kr9tStjd||fƒtS(NsexpectSID = %s calcSID = %s(R tcheckSIDtTruet    MAGIC_SIDR(RtdebugtFalse(R't    expectSIDtcalcSID((s..\server\db\PyMongoDataServer\MangoDBCommon.pyR)Vs       s    c Csd}y¢t|ddƒ}tjd|ƒy]|ƒ}d}xG|D]?}|d7}|dkrgqEn|j|ƒ||jƒ7}qEWWn»tk
rò\}}tjdtjd|||fƒ}    tj    |    t
ƒd}t j |dƒ}|Stjdtj d    |tjƒfƒ}    tj|    ƒd}t j |dƒ}|SX|jƒtjd
||dfƒd}
t j |
|dƒ}
t j|
t|ƒ|ƒ}
|
SWnKtk
rõ\} } tjdtjd || | fƒ}    tj    |    ƒnXd}t j |dƒ}|S( Nttrbis Loading %s...it DesignErrors-Read file "%s" failed! errno = %s stdErr = %stfatals%Read file"%s" failed!  Exception = %ssLoad %s cnt = %ss&Can not open %s!errno = %s stderr = %s(topenRtinfotreadLinet    getBuffertIOErrorRt    formatMsgt ERROR_NO_30R2R*Rt
WriteDWORDt ERROR_NO_31t    tracebackt
format_excR3tcloset WriteStringtlent ERROR_NO_32( t    classNametfileNameR'tfileObjtrowObjtrowCnttlinet    readErrNot
readStdErrtmsgtbufterrnotstderr((s..\server\db\PyMongoDataServer\MangoDBCommon.pytsysDBLoadFromFiledsJ     
  %( 
%c Cs,|jƒyÐt|ddƒ}z¬yZ|ƒ}d}xD|D]<}|d7}|dkr]q;n|j|ƒ|j|ƒq;WWnKtk
rÉ\}}tjdtjd|||fƒ}    tj    |    ƒnXWd|j
ƒXWnKtk
r'\}
} tjdtj d||
| fƒ}    tj    |    ƒnXdS(NR1iiR2s%Read %s failed!errno = %s stderr = %ss'Can not open %s! errno = %s stderr = %s( tdropR4R6t    adoInsertR8RR9t ERROR_NO_33RR2R?t ERROR_NO_34( RCt
collectionRDRERFtrowRHRIRJRKRMRN((s..\server\db\PyMongoDataServer\MangoDBCommon.pyt SysDBUpdates(
     
  %%c        CsyÓd}|d|}|jdi|d6dii|d6d6dtƒ}|r]|d}nu|jdi|d6dii|d6d    6dtd
tƒ}|r©|d}n)tjd tjd ƒ}tj|ƒdSWnEtjd tjd ||||tjƒfƒ}tj|ƒnX|S(Nis%s_seqtqueryt_idtupdatetseqs$inctnews$settupsertRs seq failed!sOseq failed, colname = %s, fieldname = %s, feed = %d, increment = %d, error = %s(    tfind_and_modifyR*RR9t ERROR_NO_35Rt ERROR_NO_36R=R>(    tdbtcollectionNamet    fieldNametfeedt    incrementRRTt    resultObjRK((s..\server\db\PyMongoDataServer\MangoDBCommon.pyRZ§s"3 0      1($tsysR%t    threadingt ImportErrortdummy_threadingtCommonRRRtDBCommonRRR=t
__import__R RR"R+tLockR!RRR    R
RRRR R#R$R(R)t    SPLITCHARRORVRZ(((s..\server\db\PyMongoDataServer\MangoDBCommon.pyt<module>s:                                                     ,