
    Ѷ'iz                        d Z ddiddiddiddiddiddiddidddddd	Zd
did
diddiddiddiddiddiddidZddiddiddidi iddddidddid	Zddiddiddddiddiddddiddid 
Zi d!d" d#d$ d%d& d'd( d)d* d+d, d-d. d/d0 d1d2 d3d4 d5d6 d7d8 d9d: d;d< d=d> d?d@ dAdB dC dD dE dFZg dGdH dIg dJdK dIg dLdM dIg dNdO dIdPZdS )Qzg
MongoDB Command Mappings
Contains all command mappings and method translations for MongoDB operations
dbStats   hostInfoserverStatus	currentOpdropDatabaselistCollectionsN)statsr   r   r   r   getCollectionInfosr   adminCommand
runCommandkillOpcreateCollectiongetCollectionlistDatabases	usersInfo	rolesInfoprofilegetLogglobal)dbs	databasescollectionstablesusersrolesr   logsreplSetGetConfigreplSetGetStatusreplSetInitiatereplSetStepDown<   
setSlaveOk)	confconfigstatusinitiateaddremovestepDownfreezeslaveOkshardingStatehelpshardinggetShardMapbalancerStatusbalancerStartbalancerStop)
r&   r.   enableShardingshardCollectionr0   isBalancerRunningdisableBalancingenableBalancingstartBalancerstopBalancerfindc                      | |r|d         ni dS )N    )r;   filter collection_nameparamss     K/Users/user/workspace/sujinbaek/cqa-test-app/products/dbs/mongo_mappings.py<lambda>rD   :   s!    %-&))2- -     findOnec                 "    | |r|d         ni ddS )Nr=   r   )r;   r>   limitr?   r@   s     rC   rD   rD   >   s$    %-&))20 0 rE   	insertOnec                     | |dS )Ninsert	documentsr?   r@   s     rC   rD   rD   C   s    !2 2 rE   
insertManyc                 V    | |r#t          |d         t                    r|d         n|dS Nr=   rK   
isinstancelistr@   s     rC   rD   rD   G   s4    !"(TZq	4-H-HTVAYYf3 3 rE   rL   c                 V    | |r#t          |d         t                    r|d         n|dS rP   rQ   r@   s     rC   rD   rD   K   s4    !"(TZq	4-H-HTVAYYf/ / rE   	updateOnec                 .    | |d         |d         ddgdS )Nr=   r   Fqumultiupdateupdatesr?   r@   s     rC   rD   rD   O   s)    ! )&)eDDE2 2 rE   
updateManyc                 .    | |d         |d         ddgdS Nr=   r   TrW   r[   r?   r@   s     rC   rD   rD   S   s)    ! )&)dCCD3 3 rE   r\   c                 .    | |d         |d         ddgdS r`   r?   r@   s     rC   rD   rD   W   s)    ! )&)dCCD/ / rE   	deleteOnec                 (    | |r|d         ni ddgdS )Nr=   r   rX   rH   deletedeletesr?   r@   s     rC   rD   rD   [   s,    !'-5&))2BBC2 2 rE   
deleteManyc                 (    | |r|d         ni ddgdS Nr=   rd   re   r?   r@   s     rC   rD   rD   _   s,    !'-5&))2BBC3 3 rE   r)   c                 (    | |r|d         ni ddgdS rj   r?   r@   s     rC   rD   rD   c   s,    !'-5&))2BBC/ / rE   countc                      | |r|d         ni dS Nr=   )rl   queryr?   r@   s     rC   rD   rD   g   s!     $,". . rE   countDocumentsc                      | |r|d         ni dS rn   r?   r@   s     rC   rD   rD   k   s!     $,"7 7 rE   createIndexc                     | |d         d|  dt          t          |d                              dt          |          dk    r|d         ni gdS Nr=   idx__)keynamer   )createIndexesindexeshashstrlenr@   s     rC   rD   rD   o   l    (!9C?CCT#fQi..-A-ACC
 
  KK!OOvayy
 4 4 rE   ensureIndexc                     | |d         d|  dt          t          |d                              dt          |          dk    r|d         ni gdS rt   r{   r@   s     rC   rD   rD   w   r   rE   	dropIndexc                      | |r|d         ni dS )Nr=   )dropIndexesindexr?   r@   s     rC   rD   rD      s!    &$,"2 2 rE   
getIndexesc                 
    d| iS NlistIndexesr?   r@   s     rC   rD   rD      s    3 rE   c                 
    d| iS r   r?   r@   s     rC   rD   rD      s    4 rE   c                     | di igi dS )Nz$changeStream	aggregatepipelinecursorr?   r@   s     rC   rD   rD      s    $%r*+. . rE   c                     | |r#t          |d         t                    r|d         ng t          |          dk    r#t          |d         t                    r|d         ni dS )Nr=   r   r   )rR   rS   r~   dictr@   s     rC   rD   rD      s`    $!'OJvay$,G,GOF1IIR"6{{Q:fQi3N3N&))TV2 2 rE   )r   watchr   )version
gitVersionbuildEnvironmentc                     |                      dd          |                      dd          t          |                      di                     ggS )Nr    r   r   getr}   results    rC   rD   rD      sJ    JJy"%%JJ|R((

-r2233&
 % rE   )result_keys	processor)uptimecurrent_connectionsavailable_connectionsc                     |                      dd          |                      di                                dd          |                      di                                dd          ggS )Nr   r=   connectionscurrent	availabler   r   s    rC   rD   rD      sa    JJx##JJ}b))--i;;JJ}b))--k1==&
 % rE   )opidactive	operation	namespacec                 f    d d |                      dg           D             d d         D             S )Nc           	          g | ]r}t          |                    d d                    t          |                    dd                    |                    dd          |                    dd          gsS )r   r   r   Fopns)r}   r   .0r   s     rC   
<listcomp>z<lambda>.<locals>.<listcomp>   s     %
 %
 %
 ##$$c"&&5*A*A&B&BBFF4QSDTDTVXV\V\]aceVfVfg%
 %
 %
rE   c                 >    g | ]}|                     d d          |S )r   Fr   r   s     rC   r   z<lambda>.<locals>.<listcomp>   s,    XXXbxQV@W@WXrXXXrE   inprog
   r   r   s    rC   rD   rD      sH     %
 %
XXFJJx$<$<XXXY\Z\Y\]%
 %
 %
 rE   )userdatabaser   c                 z      fd                      di                                dg           D             pg dgS )Nc           
          g | ]d}|                     d d          |                     dd          t                               di                                dg                     geS )r   r   dbauthInfoauthenticatedUserRolesr   )r   r   r   s     rC   r   z<lambda>.<locals>.<listcomp>   su     %
 %
 %
 XXfb!!488D"#5#5s6::jRT;U;U;Y;YZrtv;w;w7x7xy%
 %
 %
rE   r   authenticatedUsers)z+No authenticated user information availabler   r   r   r   s   `rC   rD   rD      sb     %
 %
 %
 %


:r22667KRPP%
 %
 %
 %G FEEF rE   )	buildInfor   r   connectionStatus)__doc__DB_METHOD_MAPPINGSHOW_MAPPINGRS_METHOD_MAPPINGSH_METHOD_MAPPINGCOLLECTION_METHOD_MAPPINGCOMMAND_PROCESSORSr?   rE   rC   <module>r      s    ^Q#Q'q!#Q',a0)1-    Q!1%%q) !$112x 	 	  #!1%!1%"B'"B'a 
 
  "Z !1%*A.%q)#Q'  Z
  Z
   Z   Z   Z$   %Z,   -Z4   5Z<   =ZD   EZL   MZT   UZ\   ]Zd   eZl   mZ|   }ZL   MZT   UZZ  
 kZ Z Z | EDD   RQQ   DCC
 
  544G G 1    rE   