;t/Uc@sddlZddlZddlmZddlmZmZmZmZddl m Z ddl m Z m Z ddlmZd efd YZdS( iNi(tIDENTITY(tTabletQuerytFieldt Expression(tSQLALL(tuse_common_filterstxorifyi(t NoSQLAdaptertMongoDBAdapterc BseZdIZddgZeZied6ed6ed6ed6ed6ed6ed 6ed 6ed 6e d 6e d 6e j d6e j d6e j d6ed6ed6e d6e d6e d6Ziddd6ZdddJdeiiedJd ZdJdZdZdZd ZeedJed!ZdJed"ZdJd#Zd$d%ZdJd&ZdJd'Zeed(ZdJd)ZdJd*Z dJd+Z!d,Z"d-Z#d.Z$d/Z%d0Z&d1Z'dJd2Z(dJd3Z)dJd4Z*dJd5Z+d6Z,dJd7Z-d8Z.d9Z/d:Z0d;Z1d<Z2d=Z3d>Z4d?Z5d@Z6dAZ7dBZ8dCZ9edDZ:dEZ6dFZ8dGZ9edHZ:RS(Ktpymongotloadstdumpstbooleantstringttexttjsontpasswordtblobtuploadtintegertbiginttfloattdoubletdatettimetdatetimetidt references list:strings list:integerslist:referencesThis must yet be replaceds" with javascript in order to work.tjavascript_neededsmongodb://127.0.0.1:5984/dbisUTF-8c sz|_|_| r(j|nddl} ddlm} ddlm} ddl}|j j |}| _| _| _d_ |_ d|d") -> ObjectId (not unique) instance it0xR!tLiss0x%sLt0123456789abcdefs0x%ss$invalid objectid argument string: %ss"Invalid objectid argument string. s$Requires an integer or base 16 values#object_id argument must be of type s-ObjectId or an objectid representable integeri(R@t basestringtlentreplacetisdigittinttjointrangeR3tchoicetisalnumt startswitht ValueErrorRtlongt TypeErrorthextrstriptzfill(R.targtrawhextxtethexvalue((sQ/var/www/c4bv.valis/web2py-ge-R-2.10.3/gluon/packages/dal/pydal/adapters/mongo.pyt object_id]s6 *  5    "cCsCt||jr*tt|d}ntt|j||S(Ni(R@RRZtstrtsuperR tparse_reference(R.tvaluet field_type((sQ/var/www/c4bv.valis/web2py-ge-R-2.10.3/gluon/packages/dal/pydal/adapters/mongo.pyRgscCsCt||jr*tt|d}ntt|j||S(Ni(R@RRZReRfR tparse_id(R.RhRi((sQ/var/www/c4bv.valis/web2py-ge-R-2.10.3/gluon/packages/dal/pydal/adapters/mongo.pyRjsc Cst||jr|}ntj|||}|dkrt|dkrL|Stjddd}tjj||S|dkr|dkr|Stjddd}tjj||S|dkr |dkr|Sddl m }t||st|t s|t |S||S|St|t r|j d r|j d r~g}x$|D]}|j|j|qZW|S|St|t r|j d st|ts|d kr|j|}n|S( NRiRiiRi(tBinaryslist:slist:referenceRR(R@RRt representRBRRtcombineRtbsonRkROReRXtappendRdR( R.tobjt fieldtypeRhtttdRktnewvaltv((sQ/var/www/c4bv.valis/web2py-ge-R-2.10.3/gluon/packages/dal/pydal/adapters/mongo.pyRlsF         cCs"|rtdnd|_dS(NsNot implemented(t RuntimeErrorRBt_dbt(R.ttabletmigratet fake_migratet polymodeltisCapped((sQ/var/www/c4bv.valis/web2py-ge-R-2.10.3/gluon/packages/dal/pydal/adapters/mongo.pyt create_tablesc Csx|rtdnt|ts3tdn|j|}t|j||j|jgidt d|dS(NsCOUNT DISTINCT not supporteds Not Supportedtcounttsnapshot( RvR@RRCt get_tableRZtselectR1t_idR?(R.tquerytdistinctRt tablename((sQ/var/www/c4bv.valis/web2py-ge-R-2.10.3/gluon/packages/dal/pydal/adapters/mongo.pyR~s"cCst|trt|jtr|jjdksEd|jjkr|jjdkrfd|j_nt|jttt frg|jD]}|j |^q|_n|j |j|_|j |j|j}qnt|tr|jdkrd}q|j}nt|t tfr|jdk rQ|j |j|j}q|jdk ru|j |j}qt|j ts|j }q|j }n^|r|j||}nCt|ttfrg|D]}|j||^q}n|}|S(NRRR(R@RtfirstRttypetnametsecondRAtlisttsetRdtopRRBReRl(R.t expressionRititemtresult((sQ/var/www/c4bv.valis/web2py-ge-R-2.10.3/gluon/packages/dal/pydal/adapters/mongo.pytexpands<(   %R!cCs+|j|j}|j|j|dS(N(t connectiont _tablenametdropt _drop_cleanup(R.Rxtmodetctable((sQ/var/www/c4bv.valis/web2py-ge-R-2.10.3/gluon/packages/dal/pydal/adapters/mongo.pyRs  cCs!|dkr|jS|rdSdS(Nii(RBR$(R.tval((sQ/var/www/c4bv.valis/web2py-ge-R-2.10.3/gluon/packages/dal/pydal/adapters/mongo.pyt _get_safes cCs0|j|j}|jdd|j|dS(NR'(RRtremoveRBR(R.RxRR$R((sQ/var/www/c4bv.valis/web2py-ge-R-2.10.3/gluon/packages/dal/pydal/adapters/mongo.pyttruncatesc Cs$|j}gg}}|jdt} |jdt} d|kr_|jjjdnxNt|jtdD]0} || dk r||jjjd| q|q|W| r| dt | dd} } n d} } | rnt | t t fr t | } nx_|j| jdD]B}|jd rT|j|dd fq%|j|dfq%Wnx:|D]2}t |tr||j7}qu|j|quW|}t |tr|j|}n2t|dkr|dj}ntd d |r1t|r1|j||g}q1n|j|}|pP|j|}x|D]}d||jss$settmultiR'tns)uncaught exception when updating rows: %s(R@RRvR~RERCRRRBRRRtupdateR?RtKeyErrortAttributeErrorR[t Exception( R.RRRR$tamounttfiltertmodifyRRb((R.sQ/var/www/c4bv.valis/web2py-ge-R-2.10.3/gluon/packages/dal/pydal/adapters/mongo.pyRts0  cCsd}|j|t}t|ts@tdt|n|rmt|rm|j||g}qmn|j|}|j |j |d|j ||S(Nisquery type %s is not supportedR'( R~RER@RRvRRRRRRR(R.RRR$RR((sQ/var/www/c4bv.valis/web2py-ge-R-2.10.3/gluon/packages/dal/pydal/adapters/mongo.pytdeletes #cCs#g|D]}|j||^qS(N(R(R.RxtitemsR((sQ/var/www/c4bv.valis/web2py-ge-R-2.10.3/gluon/packages/dal/pydal/adapters/mongo.pyt bulk_insertscCsd|j|S(Ns-%s(R(R.R((sQ/var/www/c4bv.valis/web2py-ge-R-2.10.3/gluon/packages/dal/pydal/adapters/mongo.pytINVERTscCs|j|}|jd}||}t|tkr|dkrMdnd}i|j|j|j|jg|6}nii|d6|6}|S(Nis$ors$ands$not(RRRRtNOTRR(R.RRtop_ktop_bodytnot_optr((sQ/var/www/c4bv.valis/web2py-ge-R-2.10.3/gluon/packages/dal/pydal/adapters/mongo.pyRs .cCs#i|j||j|gd6S(Ns$and(R(R.RR((sQ/var/www/c4bv.valis/web2py-ge-R-2.10.3/gluon/packages/dal/pydal/adapters/mongo.pytANDscCs#i|j||j|gd6S(Ns$or(R(R.RR((sQ/var/www/c4bv.valis/web2py-ge-R-2.10.3/gluon/packages/dal/pydal/adapters/mongo.pytORscCst|tr1ii|d gd6|j|6S|gksX|dksX|tkrcidd6Sg|D]}|j||j^qj}ii|d6|j|6S(Nis$inii((R@ReRRR(R.RRRR((sQ/var/www/c4bv.valis/web2py-ge-R-2.10.3/gluon/packages/dal/pydal/adapters/mongo.pytBELONGSs "' (cCs&i}|j|||j|<|S(N(R(R.RRR((sQ/var/www/c4bv.valis/web2py-ge-R-2.10.3/gluon/packages/dal/pydal/adapters/mongo.pytEQscCs-i}i|j|d6||j|<|S(Ns$ne(R(R.RRR((sQ/var/www/c4bv.valis/web2py-ge-R-2.10.3/gluon/packages/dal/pydal/adapters/mongo.pytNEs#cCsL|dkrtd|ni}i|j|d6||j|<|S(NsCannot compare %s < Nones$lt(RBRvR(R.RRR((sQ/var/www/c4bv.valis/web2py-ge-R-2.10.3/gluon/packages/dal/pydal/adapters/mongo.pytLTs  #cCsL|dkrtd|ni}i|j|d6||j|<|S(NsCannot compare %s <= Nones$lte(RBRvR(R.RRR((sQ/var/www/c4bv.valis/web2py-ge-R-2.10.3/gluon/packages/dal/pydal/adapters/mongo.pytLEs  #cCs-i}i|j|d6||j|<|S(Ns$gt(R(R.RRR((sQ/var/www/c4bv.valis/web2py-ge-R-2.10.3/gluon/packages/dal/pydal/adapters/mongo.pytGTs#cCsL|dkrtd|ni}i|j|d6||j|<|S(NsCannot compare %s >= Nones$gte(RBRvR(R.RRR((sQ/var/www/c4bv.valis/web2py-ge-R-2.10.3/gluon/packages/dal/pydal/adapters/mongo.pytGEs  #cCs9t|jdd|j||j||jfS(NRs%s + %s(tNotImplementedErrorterror_messagesRR(R.RR((sQ/var/www/c4bv.valis/web2py-ge-R-2.10.3/gluon/packages/dal/pydal/adapters/mongo.pytADDscCs9t|jdd|j||j||jfS(NRs (%s - %s)(RRRR(R.RR((sQ/var/www/c4bv.valis/web2py-ge-R-2.10.3/gluon/packages/dal/pydal/adapters/mongo.pytSUBscCs9t|jdd|j||j||jfS(NRs (%s * %s)(RRRR(R.RR((sQ/var/www/c4bv.valis/web2py-ge-R-2.10.3/gluon/packages/dal/pydal/adapters/mongo.pytMULscCs9t|jdd|j||j||jfS(NRs (%s / %s)(RRRR(R.RR((sQ/var/www/c4bv.valis/web2py-ge-R-2.10.3/gluon/packages/dal/pydal/adapters/mongo.pytDIVscCs9t|jdd|j||j||jfS(NRs (%s %% %s)(RRRR(R.RR((sQ/var/www/c4bv.valis/web2py-ge-R-2.10.3/gluon/packages/dal/pydal/adapters/mongo.pytMODscCs*t|jdd|j||fS(NRs%s AS %s(RRR(R.RR((sQ/var/www/c4bv.valis/web2py-ge-R-2.10.3/gluon/packages/dal/pydal/adapters/mongo.pytASscCs0tddd|j||j|fS(NsThis is not possible in NoSQLs% but can be simulated with a wrapper.s%s ON %s(RR(R.RR((sQ/var/www/c4bv.valis/web2py-ge-R-2.10.3/gluon/packages/dal/pydal/adapters/mongo.pytON s cCs d|j||j|fS(Ns%s, %s(R(R.RR((sQ/var/www/c4bv.valis/web2py-ge-R-2.10.3/gluon/packages/dal/pydal/adapters/mongo.pytCOMMAscCs0id|j|djdd|j|6S(Ns%sRt%t/(RRQ(R.RR((sQ/var/www/c4bv.valis/web2py-ge-R-2.10.3/gluon/packages/dal/pydal/adapters/mongo.pytLIKEscCsLt||jr|ni|jddd6dd6}i||j|6S(NRR!s$regextis$options(R@RRQR(R.RRR((sQ/var/www/c4bv.valis/web2py-ge-R-2.10.3/gluon/packages/dal/pydal/adapters/mongo.pytILIKEscCs$id|j|d|j|6S(Ns/^%s/R(R(R.RR((sQ/var/www/c4bv.valis/web2py-ge-R-2.10.3/gluon/packages/dal/pydal/adapters/mongo.pyt STARTSWITH"scCs$id|j|d|j|6S(Ns/%s^/R(R(R.RR((sQ/var/www/c4bv.valis/web2py-ge-R-2.10.3/gluon/packages/dal/pydal/adapters/mongo.pytENDSWITH'scCsVt||jr|n'idtj|j|ddd6}i||j|6S(Ns.*Rs$regex(R@RtretescapeR(R.RRtcase_sensitiveR((sQ/var/www/c4bv.valis/web2py-ge-R-2.10.3/gluon/packages/dal/pydal/adapters/mongo.pytCONTAINS,s*cCsHddl}ii|j|j|djddd6|j|6S(NiRRs.*s$regex(RRRRQ(R.RRR((sQ/var/www/c4bv.valis/web2py-ge-R-2.10.3/gluon/packages/dal/pydal/adapters/mongo.pyR4s cCs@ddl}iid|j|j|dd6|j|6S(Nit^Rs$regex(RRR(R.RRR((sQ/var/www/c4bv.valis/web2py-ge-R-2.10.3/gluon/packages/dal/pydal/adapters/mongo.pyR;s  cCs@ddl}ii|j|j|ddd6|j|6S(NiRt$s$regex(RRR(R.RRR((sQ/var/www/c4bv.valis/web2py-ge-R-2.10.3/gluon/packages/dal/pydal/adapters/mongo.pyRCs cCs8iidtj|j|ddd6|j|6S(Ns.*Rs$regex(RRR(R.RRR((sQ/var/www/c4bv.valis/web2py-ge-R-2.10.3/gluon/packages/dal/pydal/adapters/mongo.pyRMs(spymongoN(;t__name__t __module__tdriverstdriver_auto_jsonREtuploads_in_blobtboolReRZRRRRRttypesRRBRR?RKRdRgRjRlR}R~RRRRRRRRRRRRRRRRRRRRRRRRRRRRRRRRR(((sQ/var/www/c4bv.valis/web2py-ge-R-2.10.3/gluon/packages/dal/pydal/adapters/mongo.pyR s       / #   . +    [  "                            (RRt_globalsRtobjectsRRRRthelpers.classesRthelpers.methodsRRtbaseRR (((sQ/var/www/c4bv.valis/web2py-ge-R-2.10.3/gluon/packages/dal/pydal/adapters/mongo.pyts  "