-í ™º‘;csdZdkZdkZdkZdkZ dkZ dkZ dkZdklZdk l Z dei fd„ƒYZ !dfd„ƒYZ -d„Z =d „ZPd „ZWd d „Z]d „Zcd d„Zrd„Zdeifd„ƒYZ8dfd„ƒYZjedjoµldkZndfd„ƒYZ­d„Z³dkZ´eeiƒdjoµdeid GHnH·eidd!\ZZZ¸eeeeedfƒZ ¹ei!ƒndS(s;$Id: async_mysql.py,v 1.3 1999/05/19 17:55:36 rushing Exp $N(s continuation(sfifos mysql_errorcsRS(N((((sO/usr/ports/www/adzapper/work/adzapper-0.4.0/src/medusa-old1/misc/async_mysql.pys mysql_errorss random_statecs!#d„Z(d„ZRS(Ncs9#$d|_%||i|_&||i|_dS(Niÿÿÿ?(sselfs max_valuesseedsseed2(sselfsseedsseed2((sO/usr/ports/www/adzapper/work/adzapper-0.4.0/src/medusa-old1/misc/async_mysql.pys__init__#s csf()|id|i|i|_*|i|id|i|_+t|iƒt|iƒSdS(Nii!(sselfsseedsseed2s max_valuesfloat(sself((sO/usr/ports/www/adzapper/work/adzapper-0.4.0/src/medusa-old1/misc/async_mysql.pysrnd(s!!(s__init__srnd(((sO/usr/ports/www/adzapper/work/adzapper-0.4.0/src/medusa-old1/misc/async_mysql.pys random_state!s cs×-.d}/d}0d}1xŠ|D1]}2|djp |djo 3q(n4t|ƒ}5||d@|||d>A}6||d>|A}7||}q(W8|dd >d@|dd >d@fSdS( Nl5W` ilqVh$s s i?ili(snrsaddsnr2spasswordschsordstmp(spasswordstmpsaddschsnr2snr((sO/usr/ports/www/adzapper/work/adzapper-0.4.0/src/medusa-old1/misc/async_mysql.pys hash_password-s     !c s=>t|ƒ}?t|ƒ}@t|d|dAB|d|dAƒ}Dg}Ex>|DE]3}F|i t t i |i ƒddƒƒƒqaWGt t i |i ƒdƒƒ}Hx2tt|ƒƒDH]}I|||A||B|d>B}U||fSdS(Niii(smapsordspsasbscsssl(spsascsbsssl((sO/usr/ports/www/adzapper/work/adzapper-0.4.0/src/medusa-old1/misc/async_mysql.pysunpacketPs"icszWXt|ƒ}Y|d@|d?d@|d?d@f\}}}Ztt||||gƒ}[t i |dƒ|SdS(Niÿiis( slensdataslsasbscsmapschrssshsstringsjoin(sdatasssascsbshsl((sO/usr/ports/www/adzapper/work/adzapper-0.4.0/src/medusa-old1/misc/async_mysql.pyspacketWs/csS]^d}_x6t|ƒD_]%}`|t||ƒd|>B}qWa|SdS(Nii(sresultsrangesnsisordsdata(sdatasnsresultsi((sO/usr/ports/www/adzapper/work/adzapper-0.4.0/src/medusa-old1/misc/async_mysql.pys n_byte_num]s   #csÆcdt||ƒ}e|djof|dfSnŒg|djohtdfSnki|djojt|dƒdfSnAk|djolt|dƒdfSnot|dƒdfSdS( Niûiiüiiiýii(sordsdataspossnsNones n_byte_num(sdataspossn((sO/usr/ports/www/adzapper/work/adzapper-0.4.0/src/medusa-old1/misc/async_mysql.pysnet_field_lengthcscsºrsg}tg}uxv|Du]k}v|idt|ƒƒw|tijp |tijox|id|ƒnz|idƒqW{ti |dƒti |dƒfSdS(Ns %02xs %cs s( sr1sr2ssschsappendsordsstringsletterssdigitssjoin(ssschsr1sr2((sO/usr/ports/www/adzapper/work/adzapper-0.4.0/src/medusa-old1/misc/async_mysql.pysdump_hexrs   #s mysql_clientcsq„dZ…dZˆdZ‰dZŠdZŒddfd„Z”d„Z£d„Z¦d „Z¬d „Z Äd „Z èd „Z ïe d d„Z üd„Z d„ZddddddddddddddgZhZx.eeeƒƒD]Z eeee@ed„ZHd„ZRd„ZRS(sunpack a result setcsO@A||_Bg|_Ct|_Dg|_Et|_Ft|_dS(N(scallbacksselfspacketssNonesnfieldssfieldssdatas data_callback(sselfscallbacks data_callback((sO/usr/ports/www/adzapper/work/adzapper-0.4.0/src/medusa-old1/misc/async_mysql.pys__init__@s      cs‰HIg}Jd}KxcK|t|ƒjoLLt||ƒ}M|d}N|i||||!ƒO||}qWP|SdS(Nii(srsislensdsordsflsappend(sselfsdsrsisfl((sO/usr/ports/www/adzapper/work/adzapper-0.4.0/src/medusa-old1/misc/async_mysql.pys unpack_dataHs   cs>RS|itjoJUt|dƒ}V|djoW|iggƒn Y||_nÛZ|itjoJ[t|dƒdjo ]|ii|i |ƒƒn _g|_n~bt|dƒdjoJc|i od|i |i |ƒƒnf|ii|i |ƒƒnh|i|i|iƒdS(Niiþ( sselfsnfieldssNonesordsdatasnscallbacksfieldssappends unpack_datas data_callback(sselfsseqsdatasn((sO/usr/ports/www/adzapper/work/adzapper-0.4.0/src/medusa-old1/misc/async_mysql.pys__call__Rs   (s__doc__sNones__init__s unpack_datas__call__(((sO/usr/ports/www/adzapper/work/adzapper-0.4.0/src/medusa-old1/misc/async_mysql.pys result_set8s  s__main__stest_mysql_clientcsznpd„Ztd„Zxd„ZddddgZd„Z†d „Z—d „Z¦d „Zªd „ZRS( Ncs,pq||_r|iid|iƒdS(Nscreate database test_async(sclientsselfs cmd_queryscallback_create(sselfsclient((sO/usr/ports/www/adzapper/work/adzapper-0.4.0/src/medusa-old1/misc/async_mysql.pys__init__ps cs,tudG|GHv|iid|iƒdS(Nscreate database=>s test_async(sinfosselfsclientscmd_uses callback_use(sselfsinfo((sO/usr/ports/www/adzapper/work/adzapper-0.4.0/src/medusa-old1/misc/async_mysql.pyscallback_createts cs/xydG|GHz|iid||iƒdS(Nsuse=>s,create table users (name char(30), cool int)(sinfosselfsclients cmd_queryscallback_create_table(sselfsinfo((sO/usr/ports/www/adzapper/work/adzapper-0.4.0/src/medusa-old1/misc/async_mysql.pys callback_usexs sjohnspaulsgeorgesringocs,‚dG|GHƒd|_„|iƒdS(Nscreate_table=>i(sinfosselfs people_indexscallback_insert(sselfsinfo((sO/usr/ports/www/adzapper/work/adzapper-0.4.0/src/medusa-old1/misc/async_mysql.pyscallback_create_tables  csž†‡dG|GHˆ|it|iƒjo ‰|iid‹|iƒnPŽ|iid|i|iti ddƒf“|i ƒ•|id|_dS(Nsinsert=>sselect * from userss#insert into users values ("%s", %s)ii( sinfosselfs people_indexslenspeoplesclients cmd_queryscallback_querysrandomsrandintscallback_insert(sselfsinfo((sO/usr/ports/www/adzapper/work/adzapper-0.4.0/src/medusa-old1/misc/async_mysql.pyscallback_insert†s / cs“—˜dGH™dGHšx#|Dš]}›dt|ƒGHqWœdGHx#|D]}ždt|ƒGHqNW |iid¢d£|iƒdS(Nsquery=>s fields:s %ss data:sdrop_dbs test_async( sfieldssfieldsreprsdatasdsselfsclientscommands callback_drop(sselfsfieldssdatasfieldsd((sO/usr/ports/www/adzapper/work/adzapper-0.4.0/src/medusa-old1/misc/async_mysql.pyscallback_query—s  cs)¦§dG|GH¨|ii|iƒdS(Nsdrop=>(sinfosselfsclientscmd_quits callback_quit(sselfsinfo((sO/usr/ports/www/adzapper/work/adzapper-0.4.0/src/medusa-old1/misc/async_mysql.pys callback_drop¦s csª«dG|GHdS(Nsquit=>(sinfo(sselfsinfo((sO/usr/ports/www/adzapper/work/adzapper-0.4.0/src/medusa-old1/misc/async_mysql.pys callback_quitªs( s__init__scallback_creates callback_usespeoplescallback_create_tablescallback_insertscallback_querys callback_drops callback_quit(((sO/usr/ports/www/adzapper/work/adzapper-0.4.0/src/medusa-old1/misc/async_mysql.pystest_mysql_clientns       cs*­®|o¯t|ƒn ±dGHdS(NsFailed to log in(syesnostest_mysql_clientsclient(sclientsyesno((sO/usr/ports/www/adzapper/work/adzapper-0.4.0/src/medusa-old1/misc/async_mysql.pysgo­s is&Usage: %s iiê ("sVERSION_STRINGs exceptionssmathssocketsstringssyssasyncoresasynchats continuationsfifos Exceptions mysql_errors random_states hash_passwordsscramblesunpacketspackets n_byte_numsnet_field_lengthsdump_hexs async_chats mysql_clients result_sets__name__srandomstest_mysql_clientsgoslensargvsusernamespasswordshostscsloop(s n_byte_numsusernamesasyncoresstrings mysql_clients continuationsrandoms result_setstest_mysql_clientsfifossysshostsdump_hexspacketsgospasswords hash_passwordsnet_field_lengthsVERSION_STRINGsasynchatssocketscs mysql_errorsunpackets random_states exceptionssscramblesmath((sO/usr/ports/www/adzapper/work/adzapper-0.4.0/src/medusa-old1/misc/async_mysql.pys?s<             ·2 ?