ó
|
B hc @ sº d d l Td d l m Z e d Z d d l Z d d l m Z m Z d d l Z d Z
|
d Z d Z d Z d
|
Z d Z d Z e d k r¶ e e j d n d S( iÿÿÿÿ( t *( t mylogs Config.DBConfigN( t GlobalFunctionst errorc C s5 i } t j j | s- t j d | | St j d | zp y t | } | j } WnM t k
|
r¬ } t j d t j
|
d | | f } t j | t d | SXWd | j Xt j d | y t | } Wn@ t j d t j d | | f } t j | t d n Xt j d | | S( Ns %s not found!s Reading index file %s...t fatals Open %s exception %siÿÿÿÿs Parsing index file %s...s file %s content eval error %ss Read index file %s ok!( t ost patht isfileR t infot opent readt IOErrorR t formatMsgt ERROR_NO_164R t exitt closet evalt ERROR_NO_165( t indexInfoFilet indexInfoDictt fileObjt indexInfot et msg( ( s2 .\\ServersRoute\Collections\CheckAndUpdateIndex.pyt ReadIndexInfo s0 "
|
" c C s$ | j d d } | j d d } | d k rL | d k r? q | r t Sn< | d k rf | sb t St S| rw | rw t S| r | r t S| j d d } | j d d } | d k rÎ | d k rÇ q t SnR | d k rÞ t Sx | D] } | | k rå t Sqå Wx | D] } | | k rt SqWt S( Nt uniquet key( t gett Nonet Falset True( t curIndexDictt expectIndexDictt curUniquet expectUniquet
|
curKeyListt expectKeyListt pair( ( s2 .\\ServersRoute\Collections\CheckAndUpdateIndex.pyt CompareIndex/ s> c C s
|
| | } t j d | | j } xË | j D]½ \ } } | d k rR q4 n | | k r t j d t j d | | f } t j | t d t St
|
| | | s4 t j d t j d | | | | f } t j | t d t Sq4 Wt j d | t S( Ns checking index info on %s...t _id_R s unexpect index %s.%s found!iÿÿÿÿsC unmatched index %s.%s found! index in db:
|
%s
|
expect index:
|
%s
|
s check indx info on %s ok!( R R t index_informationt itemsR R t ERROR_NO_166R R R R& t ERROR_NO_167R ( t dbt colNamet expectIndexInfot colt indexDictt kt vR ( ( s2 .\\ServersRoute\Collections\CheckAndUpdateIndex.pyt CheckIndexes_ s$
|
"
|
(
|
c C s | | } t j d | | j } xÊ | j D]¼ \ } } | | k r4 | | } | j d t } y! | j | d d | d | WnP t k
|
rÛ } t j d t j
|
d | | | f }
|
t j |
|
t d t SXt j d | q4 q4 Wt j d | t S(
|
s Ìí¼ÓË÷Òýs adding index on %sR R t nameR s create index %s.%s failed!%siÿÿÿÿs create index %s ok!s add index on %s ok!( R R R( R) R R t create_indext ExceptionR R t ERROR_NO_168R R R ( R, R- t expectIndexesR/ t curIndexesDictR1 R2 R. t isUniqueR R ( ( s2 .\\ServersRoute\Collections\CheckAndUpdateIndex.pyt
|
AddIndexesx s"
|
|
!%
|
c C se t | } xR | j D]D \ } } | } | } t | | | sG t St | | | s t Sq Wt S( sf ¶ÔÓÚË÷ÒýÎļþÖеÄÿ¸ö±í£¬Êý¾Ý¿âÖиñíÓеÄË÷ÒýÐÅÏ¢£¬Ë÷ÒýÎļþÖбØÐëÓв¢ÇÒÆ¥ÅäuniqueºÍ(key, direction)list( R R) R3 R R; R ( R, R R R1 R2 R- t colIndexDict( ( s2 .\\ServersRoute\Collections\CheckAndUpdateIndex.pyt CheckAndUpdateIndexOnDb s c C s0 t j j t j d } t j t j t j d t
|
} t j t j t j d | s© t j d t j d t j t j t j t j f } t j | t t d d S| t j } t j j | d } t j d t j | f t | | st j d t j | f t
|
St j d
|
t j | f t S( Nt indext auto_start_requestt
|
connectiont DeployErrors: LoginMongoDB failed:ip = %s, port = %s, user = %s,pwd = %siÿÿÿÿs GameUser.txts" CheckAndUpdateIndexOnDb(%s, %s)...s' CheckAndUpdateIndexOnDb(%s, %s) failed!s# CheckAndUpdateIndexOnDb(%s, %s) ok!( R R t joinR t
|
getAppPatht pymongot
|
Connectiont DBConfigt
|
USER_DB_IPt USER_DB_PORTR t LoginMongoDBt userdb_usert
|
userdb_pwdR R t ERROR_NO_13R RA R R t USER_DB_NAMER R= ( t indexPatht usrDBConR t userDBt userDBIndexFileName( ( s2 .\\ServersRoute\Collections\CheckAndUpdateIndex.pyt CheckAndUpdateIndex s&
|
c C sp d d l } | j } | j } | j d d sI d GHt j d d St sZ d GHn d GHt j d d S( Niÿÿÿÿt sas auth failed!t pauses! #info CheckAndUpdateIndex failed!s #info CheckAndUpdateIndex ok( RD RE t admint authenticateR t systemRR ( RD t conR, ( ( s2 .\\ServersRoute\Collections\CheckAndUpdateIndex.pyt testµ s t __main__RT ( t CollectionDefinet CommonR t
|
__import__RF R t DBCommonR R RD R R& R3 R; R= RR RY t __name__RW ( ( ( s2 .\\ServersRoute\Collections\CheckAndUpdateIndex.pyt <module> s
|
0
|
