TCLIService.py 146 KB

12345678910111213141516171819202122232425262728293031323334353637383940414243444546474849505152535455565758596061626364656667686970717273747576777879808182838485868788899091929394959697989910010110210310410510610710810911011111211311411511611711811912012112212312412512612712812913013113213313413513613713813914014114214314414514614714814915015115215315415515615715815916016116216316416516616716816917017117217317417517617717817918018118218318418518618718818919019119219319419519619719819920020120220320420520620720820921021121221321421521621721821922022122222322422522622722822923023123223323423523623723823924024124224324424524624724824925025125225325425525625725825926026126226326426526626726826927027127227327427527627727827928028128228328428528628728828929029129229329429529629729829930030130230330430530630730830931031131231331431531631731831932032132232332432532632732832933033133233333433533633733833934034134234334434534634734834935035135235335435535635735835936036136236336436536636736836937037137237337437537637737837938038138238338438538638738838939039139239339439539639739839940040140240340440540640740840941041141241341441541641741841942042142242342442542642742842943043143243343443543643743843944044144244344444544644744844945045145245345445545645745845946046146246346446546646746846947047147247347447547647747847948048148248348448548648748848949049149249349449549649749849950050150250350450550650750850951051151251351451551651751851952052152252352452552652752852953053153253353453553653753853954054154254354454554654754854955055155255355455555655755855956056156256356456556656756856957057157257357457557657757857958058158258358458558658758858959059159259359459559659759859960060160260360460560660760860961061161261361461561661761861962062162262362462562662762862963063163263363463563663763863964064164264364464564664764864965065165265365465565665765865966066166266366466566666766866967067167267367467567667767867968068168268368468568668768868969069169269369469569669769869970070170270370470570670770870971071171271371471571671771871972072172272372472572672772872973073173273373473573673773873974074174274374474574674774874975075175275375475575675775875976076176276376476576676776876977077177277377477577677777877978078178278378478578678778878979079179279379479579679779879980080180280380480580680780880981081181281381481581681781881982082182282382482582682782882983083183283383483583683783883984084184284384484584684784884985085185285385485585685785885986086186286386486586686786886987087187287387487587687787887988088188288388488588688788888989089189289389489589689789889990090190290390490590690790890991091191291391491591691791891992092192292392492592692792892993093193293393493593693793893994094194294394494594694794894995095195295395495595695795895996096196296396496596696796896997097197297397497597697797897998098198298398498598698798898999099199299399499599699799899910001001100210031004100510061007100810091010101110121013101410151016101710181019102010211022102310241025102610271028102910301031103210331034103510361037103810391040104110421043104410451046104710481049105010511052105310541055105610571058105910601061106210631064106510661067106810691070107110721073107410751076107710781079108010811082108310841085108610871088108910901091109210931094109510961097109810991100110111021103110411051106110711081109111011111112111311141115111611171118111911201121112211231124112511261127112811291130113111321133113411351136113711381139114011411142114311441145114611471148114911501151115211531154115511561157115811591160116111621163116411651166116711681169117011711172117311741175117611771178117911801181118211831184118511861187118811891190119111921193119411951196119711981199120012011202120312041205120612071208120912101211121212131214121512161217121812191220122112221223122412251226122712281229123012311232123312341235123612371238123912401241124212431244124512461247124812491250125112521253125412551256125712581259126012611262126312641265126612671268126912701271127212731274127512761277127812791280128112821283128412851286128712881289129012911292129312941295129612971298129913001301130213031304130513061307130813091310131113121313131413151316131713181319132013211322132313241325132613271328132913301331133213331334133513361337133813391340134113421343134413451346134713481349135013511352135313541355135613571358135913601361136213631364136513661367136813691370137113721373137413751376137713781379138013811382138313841385138613871388138913901391139213931394139513961397139813991400140114021403140414051406140714081409141014111412141314141415141614171418141914201421142214231424142514261427142814291430143114321433143414351436143714381439144014411442144314441445144614471448144914501451145214531454145514561457145814591460146114621463146414651466146714681469147014711472147314741475147614771478147914801481148214831484148514861487148814891490149114921493149414951496149714981499150015011502150315041505150615071508150915101511151215131514151515161517151815191520152115221523152415251526152715281529153015311532153315341535153615371538153915401541154215431544154515461547154815491550155115521553155415551556155715581559156015611562156315641565156615671568156915701571157215731574157515761577157815791580158115821583158415851586158715881589159015911592159315941595159615971598159916001601160216031604160516061607160816091610161116121613161416151616161716181619162016211622162316241625162616271628162916301631163216331634163516361637163816391640164116421643164416451646164716481649165016511652165316541655165616571658165916601661166216631664166516661667166816691670167116721673167416751676167716781679168016811682168316841685168616871688168916901691169216931694169516961697169816991700170117021703170417051706170717081709171017111712171317141715171617171718171917201721172217231724172517261727172817291730173117321733173417351736173717381739174017411742174317441745174617471748174917501751175217531754175517561757175817591760176117621763176417651766176717681769177017711772177317741775177617771778177917801781178217831784178517861787178817891790179117921793179417951796179717981799180018011802180318041805180618071808180918101811181218131814181518161817181818191820182118221823182418251826182718281829183018311832183318341835183618371838183918401841184218431844184518461847184818491850185118521853185418551856185718581859186018611862186318641865186618671868186918701871187218731874187518761877187818791880188118821883188418851886188718881889189018911892189318941895189618971898189919001901190219031904190519061907190819091910191119121913191419151916191719181919192019211922192319241925192619271928192919301931193219331934193519361937193819391940194119421943194419451946194719481949195019511952195319541955195619571958195919601961196219631964196519661967196819691970197119721973197419751976197719781979198019811982198319841985198619871988198919901991199219931994199519961997199819992000200120022003200420052006200720082009201020112012201320142015201620172018201920202021202220232024202520262027202820292030203120322033203420352036203720382039204020412042204320442045204620472048204920502051205220532054205520562057205820592060206120622063206420652066206720682069207020712072207320742075207620772078207920802081208220832084208520862087208820892090209120922093209420952096209720982099210021012102210321042105210621072108210921102111211221132114211521162117211821192120212121222123212421252126212721282129213021312132213321342135213621372138213921402141214221432144214521462147214821492150215121522153215421552156215721582159216021612162216321642165216621672168216921702171217221732174217521762177217821792180218121822183218421852186218721882189219021912192219321942195219621972198219922002201220222032204220522062207220822092210221122122213221422152216221722182219222022212222222322242225222622272228222922302231223222332234223522362237223822392240224122422243224422452246224722482249225022512252225322542255225622572258225922602261226222632264226522662267226822692270227122722273227422752276227722782279228022812282228322842285228622872288228922902291229222932294229522962297229822992300230123022303230423052306230723082309231023112312231323142315231623172318231923202321232223232324232523262327232823292330233123322333233423352336233723382339234023412342234323442345234623472348234923502351235223532354235523562357235823592360236123622363236423652366236723682369237023712372237323742375237623772378237923802381238223832384238523862387238823892390239123922393239423952396239723982399240024012402240324042405240624072408240924102411241224132414241524162417241824192420242124222423242424252426242724282429243024312432243324342435243624372438243924402441244224432444244524462447244824492450245124522453245424552456245724582459246024612462246324642465246624672468246924702471247224732474247524762477247824792480248124822483248424852486248724882489249024912492249324942495249624972498249925002501250225032504250525062507250825092510251125122513251425152516251725182519252025212522252325242525252625272528252925302531253225332534253525362537253825392540254125422543254425452546254725482549255025512552255325542555255625572558255925602561256225632564256525662567256825692570257125722573257425752576257725782579258025812582258325842585258625872588258925902591259225932594259525962597259825992600260126022603260426052606260726082609261026112612261326142615261626172618261926202621262226232624262526262627262826292630263126322633263426352636263726382639264026412642264326442645264626472648264926502651265226532654265526562657265826592660266126622663266426652666266726682669267026712672267326742675267626772678267926802681268226832684268526862687268826892690269126922693269426952696269726982699270027012702270327042705270627072708270927102711271227132714271527162717271827192720272127222723272427252726272727282729273027312732273327342735273627372738273927402741274227432744274527462747274827492750275127522753275427552756275727582759276027612762276327642765276627672768276927702771277227732774277527762777277827792780278127822783278427852786278727882789279027912792279327942795279627972798279928002801280228032804280528062807280828092810281128122813281428152816281728182819282028212822282328242825282628272828282928302831283228332834283528362837283828392840284128422843284428452846284728482849285028512852285328542855285628572858285928602861286228632864286528662867286828692870287128722873287428752876287728782879288028812882288328842885288628872888288928902891289228932894289528962897289828992900290129022903290429052906290729082909291029112912291329142915291629172918291929202921292229232924292529262927292829292930293129322933293429352936293729382939294029412942294329442945294629472948294929502951295229532954295529562957295829592960296129622963296429652966296729682969297029712972297329742975297629772978297929802981298229832984298529862987298829892990299129922993299429952996299729982999300030013002300330043005300630073008300930103011301230133014301530163017301830193020302130223023302430253026302730283029303030313032303330343035303630373038303930403041304230433044304530463047304830493050305130523053305430553056305730583059306030613062306330643065306630673068306930703071307230733074307530763077307830793080308130823083308430853086308730883089309030913092309330943095309630973098309931003101310231033104310531063107310831093110311131123113311431153116311731183119312031213122312331243125312631273128312931303131313231333134313531363137313831393140314131423143314431453146314731483149315031513152315331543155315631573158315931603161316231633164316531663167316831693170317131723173317431753176317731783179318031813182318331843185318631873188318931903191319231933194319531963197319831993200320132023203320432053206320732083209321032113212321332143215321632173218321932203221322232233224322532263227322832293230323132323233323432353236323732383239324032413242324332443245324632473248324932503251325232533254325532563257325832593260326132623263326432653266326732683269327032713272327332743275327632773278327932803281328232833284328532863287328832893290329132923293329432953296329732983299330033013302330333043305330633073308330933103311331233133314331533163317331833193320332133223323332433253326332733283329333033313332333333343335333633373338333933403341334233433344334533463347334833493350335133523353335433553356335733583359336033613362336333643365336633673368336933703371337233733374337533763377337833793380338133823383338433853386338733883389339033913392339333943395339633973398339934003401340234033404340534063407340834093410341134123413341434153416341734183419342034213422342334243425342634273428342934303431343234333434343534363437343834393440344134423443344434453446344734483449345034513452345334543455345634573458345934603461346234633464346534663467346834693470347134723473347434753476347734783479348034813482348334843485348634873488348934903491349234933494349534963497349834993500350135023503350435053506350735083509351035113512351335143515351635173518351935203521352235233524352535263527352835293530353135323533353435353536353735383539354035413542354335443545354635473548354935503551355235533554355535563557355835593560356135623563356435653566356735683569357035713572357335743575357635773578357935803581358235833584358535863587358835893590359135923593359435953596359735983599360036013602360336043605360636073608360936103611361236133614361536163617361836193620362136223623362436253626362736283629363036313632363336343635363636373638363936403641364236433644364536463647364836493650365136523653365436553656365736583659366036613662366336643665366636673668366936703671367236733674367536763677367836793680368136823683368436853686368736883689369036913692369336943695369636973698369937003701370237033704370537063707370837093710371137123713371437153716371737183719372037213722372337243725372637273728372937303731373237333734373537363737373837393740374137423743374437453746374737483749375037513752375337543755375637573758375937603761376237633764376537663767376837693770377137723773377437753776377737783779378037813782378337843785378637873788378937903791379237933794379537963797379837993800380138023803380438053806380738083809381038113812381338143815381638173818381938203821382238233824382538263827382838293830383138323833383438353836383738383839384038413842384338443845384638473848384938503851385238533854385538563857385838593860386138623863386438653866386738683869387038713872387338743875387638773878387938803881388238833884388538863887388838893890389138923893389438953896389738983899390039013902390339043905390639073908390939103911391239133914391539163917391839193920392139223923392439253926392739283929393039313932393339343935393639373938393939403941394239433944394539463947394839493950395139523953395439553956395739583959396039613962396339643965396639673968396939703971397239733974397539763977397839793980398139823983398439853986398739883989399039913992399339943995399639973998399940004001400240034004400540064007400840094010401140124013401440154016401740184019402040214022402340244025402640274028402940304031403240334034403540364037403840394040404140424043404440454046404740484049405040514052405340544055405640574058405940604061406240634064406540664067406840694070407140724073407440754076407740784079408040814082408340844085408640874088408940904091409240934094409540964097409840994100410141024103410441054106410741084109411041114112411341144115411641174118411941204121412241234124412541264127412841294130413141324133413441354136413741384139414041414142414341444145414641474148414941504151415241534154415541564157415841594160416141624163416441654166416741684169417041714172417341744175417641774178417941804181418241834184418541864187418841894190419141924193419441954196419741984199420042014202420342044205420642074208420942104211421242134214421542164217421842194220422142224223422442254226422742284229423042314232423342344235423642374238423942404241424242434244424542464247424842494250425142524253425442554256425742584259426042614262426342644265426642674268426942704271427242734274427542764277427842794280428142824283428442854286428742884289429042914292429342944295429642974298429943004301430243034304430543064307430843094310431143124313431443154316431743184319432043214322432343244325432643274328432943304331433243334334433543364337433843394340434143424343434443454346434743484349435043514352435343544355435643574358435943604361436243634364436543664367436843694370437143724373437443754376437743784379438043814382438343844385438643874388438943904391439243934394439543964397439843994400440144024403440444054406440744084409441044114412441344144415441644174418441944204421442244234424442544264427442844294430443144324433443444354436443744384439444044414442444344444445444644474448444944504451445244534454445544564457445844594460446144624463446444654466446744684469447044714472447344744475447644774478447944804481448244834484448544864487448844894490449144924493449444954496449744984499450045014502450345044505450645074508450945104511451245134514451545164517451845194520452145224523452445254526452745284529453045314532453345344535453645374538453945404541454245434544454545464547454845494550455145524553455445554556455745584559456045614562456345644565456645674568456945704571457245734574457545764577457845794580458145824583458445854586458745884589459045914592459345944595459645974598459946004601460246034604460546064607460846094610461146124613461446154616461746184619462046214622
  1. #
  2. # Autogenerated by Thrift Compiler (0.13.0)
  3. #
  4. # DO NOT EDIT UNLESS YOU ARE SURE THAT YOU KNOW WHAT YOU ARE DOING
  5. #
  6. # options string: py:new_style
  7. #
  8. from thrift.Thrift import TType, TMessageType, TFrozenDict, TException, TApplicationException
  9. from thrift.protocol.TProtocol import TProtocolException
  10. from thrift.TRecursive import fix_spec
  11. import sys
  12. import logging
  13. from .ttypes import *
  14. from thrift.Thrift import TProcessor
  15. from thrift.transport import TTransport
  16. from django.utils.functional import wraps
  17. from django.utils.encoding import smart_str
  18. all_structs = []
  19. LOG = logging.getLogger()
  20. class Iface(object):
  21. def OpenSession(self, req):
  22. """
  23. Parameters:
  24. - req
  25. """
  26. pass
  27. def CloseSession(self, req):
  28. """
  29. Parameters:
  30. - req
  31. """
  32. pass
  33. def GetInfo(self, req):
  34. """
  35. Parameters:
  36. - req
  37. """
  38. pass
  39. def ExecuteStatement(self, req):
  40. """
  41. Parameters:
  42. - req
  43. """
  44. pass
  45. def GetTypeInfo(self, req):
  46. """
  47. Parameters:
  48. - req
  49. """
  50. pass
  51. def GetCatalogs(self, req):
  52. """
  53. Parameters:
  54. - req
  55. """
  56. pass
  57. def GetSchemas(self, req):
  58. """
  59. Parameters:
  60. - req
  61. """
  62. pass
  63. def GetTables(self, req):
  64. """
  65. Parameters:
  66. - req
  67. """
  68. pass
  69. def GetTableTypes(self, req):
  70. """
  71. Parameters:
  72. - req
  73. """
  74. pass
  75. def GetColumns(self, req):
  76. """
  77. Parameters:
  78. - req
  79. """
  80. pass
  81. def GetFunctions(self, req):
  82. """
  83. Parameters:
  84. - req
  85. """
  86. pass
  87. def GetPrimaryKeys(self, req):
  88. """
  89. Parameters:
  90. - req
  91. """
  92. pass
  93. def GetCrossReference(self, req):
  94. """
  95. Parameters:
  96. - req
  97. """
  98. pass
  99. def GetOperationStatus(self, req):
  100. """
  101. Parameters:
  102. - req
  103. """
  104. pass
  105. def CancelOperation(self, req):
  106. """
  107. Parameters:
  108. - req
  109. """
  110. pass
  111. def CloseOperation(self, req):
  112. """
  113. Parameters:
  114. - req
  115. """
  116. pass
  117. def GetResultSetMetadata(self, req):
  118. """
  119. Parameters:
  120. - req
  121. """
  122. pass
  123. def FetchResults(self, req):
  124. """
  125. Parameters:
  126. - req
  127. """
  128. pass
  129. def GetDelegationToken(self, req):
  130. """
  131. Parameters:
  132. - req
  133. """
  134. pass
  135. def CancelDelegationToken(self, req):
  136. """
  137. Parameters:
  138. - req
  139. """
  140. pass
  141. def RenewDelegationToken(self, req):
  142. """
  143. Parameters:
  144. - req
  145. """
  146. pass
  147. def GetQueryId(self, req):
  148. """
  149. Parameters:
  150. - req
  151. """
  152. pass
  153. def SetClientInfo(self, req):
  154. """
  155. Parameters:
  156. - req
  157. """
  158. pass
  159. def GetLog(self, req):
  160. """
  161. Parameters:
  162. - req
  163. """
  164. pass
  165. def add_xff_header(func):
  166. def decorate(*args, **kwargs):
  167. self = args[0]
  168. xff = None
  169. configuration = None
  170. if args[1].__dict__ is not None and 'configuration' in args[1].__dict__:
  171. configuration = args[1].__dict__['configuration']
  172. if configuration is not None and 'X-Forwarded-For' in configuration:
  173. xff = configuration.get('X-Forwarded-For')
  174. try:
  175. if hasattr(self._oprot.trans, 'TFramedTransport'):
  176. trans_client = self._oprot.trans._TFramedTransport__trans
  177. else:
  178. trans_client = self._oprot.trans._TBufferedTransport__trans
  179. trans_client.setCustomHeaders({'X-Forwarded-For': xff})
  180. except AttributeError as e:
  181. LOG.error('Could not set HTTP-X-FORWARDED-FOR header: %s' % smart_str(e))
  182. return func(*args, **kwargs)
  183. return wraps(func)(decorate)
  184. class Client(Iface):
  185. def __init__(self, iprot, oprot=None):
  186. self._iprot = self._oprot = iprot
  187. if oprot is not None:
  188. self._oprot = oprot
  189. self._seqid = 0
  190. @add_xff_header
  191. def OpenSession(self, req):
  192. """
  193. Parameters:
  194. - req
  195. """
  196. self.send_OpenSession(req)
  197. return self.recv_OpenSession()
  198. def send_OpenSession(self, req):
  199. self._oprot.writeMessageBegin('OpenSession', TMessageType.CALL, self._seqid)
  200. args = OpenSession_args()
  201. args.req = req
  202. args.write(self._oprot)
  203. self._oprot.writeMessageEnd()
  204. self._oprot.trans.flush()
  205. def recv_OpenSession(self):
  206. iprot = self._iprot
  207. (fname, mtype, rseqid) = iprot.readMessageBegin()
  208. if mtype == TMessageType.EXCEPTION:
  209. x = TApplicationException()
  210. x.read(iprot)
  211. iprot.readMessageEnd()
  212. raise x
  213. result = OpenSession_result()
  214. result.read(iprot)
  215. iprot.readMessageEnd()
  216. if result.success is not None:
  217. return result.success
  218. raise TApplicationException(TApplicationException.MISSING_RESULT, "OpenSession failed: unknown result")
  219. def CloseSession(self, req):
  220. """
  221. Parameters:
  222. - req
  223. """
  224. self.send_CloseSession(req)
  225. return self.recv_CloseSession()
  226. def send_CloseSession(self, req):
  227. self._oprot.writeMessageBegin('CloseSession', TMessageType.CALL, self._seqid)
  228. args = CloseSession_args()
  229. args.req = req
  230. args.write(self._oprot)
  231. self._oprot.writeMessageEnd()
  232. self._oprot.trans.flush()
  233. def recv_CloseSession(self):
  234. iprot = self._iprot
  235. (fname, mtype, rseqid) = iprot.readMessageBegin()
  236. if mtype == TMessageType.EXCEPTION:
  237. x = TApplicationException()
  238. x.read(iprot)
  239. iprot.readMessageEnd()
  240. raise x
  241. result = CloseSession_result()
  242. result.read(iprot)
  243. iprot.readMessageEnd()
  244. if result.success is not None:
  245. return result.success
  246. raise TApplicationException(TApplicationException.MISSING_RESULT, "CloseSession failed: unknown result")
  247. def GetInfo(self, req):
  248. """
  249. Parameters:
  250. - req
  251. """
  252. self.send_GetInfo(req)
  253. return self.recv_GetInfo()
  254. def send_GetInfo(self, req):
  255. self._oprot.writeMessageBegin('GetInfo', TMessageType.CALL, self._seqid)
  256. args = GetInfo_args()
  257. args.req = req
  258. args.write(self._oprot)
  259. self._oprot.writeMessageEnd()
  260. self._oprot.trans.flush()
  261. def recv_GetInfo(self):
  262. iprot = self._iprot
  263. (fname, mtype, rseqid) = iprot.readMessageBegin()
  264. if mtype == TMessageType.EXCEPTION:
  265. x = TApplicationException()
  266. x.read(iprot)
  267. iprot.readMessageEnd()
  268. raise x
  269. result = GetInfo_result()
  270. result.read(iprot)
  271. iprot.readMessageEnd()
  272. if result.success is not None:
  273. return result.success
  274. raise TApplicationException(TApplicationException.MISSING_RESULT, "GetInfo failed: unknown result")
  275. def ExecuteStatement(self, req):
  276. """
  277. Parameters:
  278. - req
  279. """
  280. self.send_ExecuteStatement(req)
  281. return self.recv_ExecuteStatement()
  282. def send_ExecuteStatement(self, req):
  283. self._oprot.writeMessageBegin('ExecuteStatement', TMessageType.CALL, self._seqid)
  284. args = ExecuteStatement_args()
  285. args.req = req
  286. args.write(self._oprot)
  287. self._oprot.writeMessageEnd()
  288. self._oprot.trans.flush()
  289. def recv_ExecuteStatement(self):
  290. iprot = self._iprot
  291. (fname, mtype, rseqid) = iprot.readMessageBegin()
  292. if mtype == TMessageType.EXCEPTION:
  293. x = TApplicationException()
  294. x.read(iprot)
  295. iprot.readMessageEnd()
  296. raise x
  297. result = ExecuteStatement_result()
  298. result.read(iprot)
  299. iprot.readMessageEnd()
  300. if result.success is not None:
  301. return result.success
  302. raise TApplicationException(TApplicationException.MISSING_RESULT, "ExecuteStatement failed: unknown result")
  303. def GetTypeInfo(self, req):
  304. """
  305. Parameters:
  306. - req
  307. """
  308. self.send_GetTypeInfo(req)
  309. return self.recv_GetTypeInfo()
  310. def send_GetTypeInfo(self, req):
  311. self._oprot.writeMessageBegin('GetTypeInfo', TMessageType.CALL, self._seqid)
  312. args = GetTypeInfo_args()
  313. args.req = req
  314. args.write(self._oprot)
  315. self._oprot.writeMessageEnd()
  316. self._oprot.trans.flush()
  317. def recv_GetTypeInfo(self):
  318. iprot = self._iprot
  319. (fname, mtype, rseqid) = iprot.readMessageBegin()
  320. if mtype == TMessageType.EXCEPTION:
  321. x = TApplicationException()
  322. x.read(iprot)
  323. iprot.readMessageEnd()
  324. raise x
  325. result = GetTypeInfo_result()
  326. result.read(iprot)
  327. iprot.readMessageEnd()
  328. if result.success is not None:
  329. return result.success
  330. raise TApplicationException(TApplicationException.MISSING_RESULT, "GetTypeInfo failed: unknown result")
  331. def GetCatalogs(self, req):
  332. """
  333. Parameters:
  334. - req
  335. """
  336. self.send_GetCatalogs(req)
  337. return self.recv_GetCatalogs()
  338. def send_GetCatalogs(self, req):
  339. self._oprot.writeMessageBegin('GetCatalogs', TMessageType.CALL, self._seqid)
  340. args = GetCatalogs_args()
  341. args.req = req
  342. args.write(self._oprot)
  343. self._oprot.writeMessageEnd()
  344. self._oprot.trans.flush()
  345. def recv_GetCatalogs(self):
  346. iprot = self._iprot
  347. (fname, mtype, rseqid) = iprot.readMessageBegin()
  348. if mtype == TMessageType.EXCEPTION:
  349. x = TApplicationException()
  350. x.read(iprot)
  351. iprot.readMessageEnd()
  352. raise x
  353. result = GetCatalogs_result()
  354. result.read(iprot)
  355. iprot.readMessageEnd()
  356. if result.success is not None:
  357. return result.success
  358. raise TApplicationException(TApplicationException.MISSING_RESULT, "GetCatalogs failed: unknown result")
  359. def GetSchemas(self, req):
  360. """
  361. Parameters:
  362. - req
  363. """
  364. self.send_GetSchemas(req)
  365. return self.recv_GetSchemas()
  366. def send_GetSchemas(self, req):
  367. self._oprot.writeMessageBegin('GetSchemas', TMessageType.CALL, self._seqid)
  368. args = GetSchemas_args()
  369. args.req = req
  370. args.write(self._oprot)
  371. self._oprot.writeMessageEnd()
  372. self._oprot.trans.flush()
  373. def recv_GetSchemas(self):
  374. iprot = self._iprot
  375. (fname, mtype, rseqid) = iprot.readMessageBegin()
  376. if mtype == TMessageType.EXCEPTION:
  377. x = TApplicationException()
  378. x.read(iprot)
  379. iprot.readMessageEnd()
  380. raise x
  381. result = GetSchemas_result()
  382. result.read(iprot)
  383. iprot.readMessageEnd()
  384. if result.success is not None:
  385. return result.success
  386. raise TApplicationException(TApplicationException.MISSING_RESULT, "GetSchemas failed: unknown result")
  387. def GetTables(self, req):
  388. """
  389. Parameters:
  390. - req
  391. """
  392. self.send_GetTables(req)
  393. return self.recv_GetTables()
  394. def send_GetTables(self, req):
  395. self._oprot.writeMessageBegin('GetTables', TMessageType.CALL, self._seqid)
  396. args = GetTables_args()
  397. args.req = req
  398. args.write(self._oprot)
  399. self._oprot.writeMessageEnd()
  400. self._oprot.trans.flush()
  401. def recv_GetTables(self):
  402. iprot = self._iprot
  403. (fname, mtype, rseqid) = iprot.readMessageBegin()
  404. if mtype == TMessageType.EXCEPTION:
  405. x = TApplicationException()
  406. x.read(iprot)
  407. iprot.readMessageEnd()
  408. raise x
  409. result = GetTables_result()
  410. result.read(iprot)
  411. iprot.readMessageEnd()
  412. if result.success is not None:
  413. return result.success
  414. raise TApplicationException(TApplicationException.MISSING_RESULT, "GetTables failed: unknown result")
  415. def GetTableTypes(self, req):
  416. """
  417. Parameters:
  418. - req
  419. """
  420. self.send_GetTableTypes(req)
  421. return self.recv_GetTableTypes()
  422. def send_GetTableTypes(self, req):
  423. self._oprot.writeMessageBegin('GetTableTypes', TMessageType.CALL, self._seqid)
  424. args = GetTableTypes_args()
  425. args.req = req
  426. args.write(self._oprot)
  427. self._oprot.writeMessageEnd()
  428. self._oprot.trans.flush()
  429. def recv_GetTableTypes(self):
  430. iprot = self._iprot
  431. (fname, mtype, rseqid) = iprot.readMessageBegin()
  432. if mtype == TMessageType.EXCEPTION:
  433. x = TApplicationException()
  434. x.read(iprot)
  435. iprot.readMessageEnd()
  436. raise x
  437. result = GetTableTypes_result()
  438. result.read(iprot)
  439. iprot.readMessageEnd()
  440. if result.success is not None:
  441. return result.success
  442. raise TApplicationException(TApplicationException.MISSING_RESULT, "GetTableTypes failed: unknown result")
  443. def GetColumns(self, req):
  444. """
  445. Parameters:
  446. - req
  447. """
  448. self.send_GetColumns(req)
  449. return self.recv_GetColumns()
  450. def send_GetColumns(self, req):
  451. self._oprot.writeMessageBegin('GetColumns', TMessageType.CALL, self._seqid)
  452. args = GetColumns_args()
  453. args.req = req
  454. args.write(self._oprot)
  455. self._oprot.writeMessageEnd()
  456. self._oprot.trans.flush()
  457. def recv_GetColumns(self):
  458. iprot = self._iprot
  459. (fname, mtype, rseqid) = iprot.readMessageBegin()
  460. if mtype == TMessageType.EXCEPTION:
  461. x = TApplicationException()
  462. x.read(iprot)
  463. iprot.readMessageEnd()
  464. raise x
  465. result = GetColumns_result()
  466. result.read(iprot)
  467. iprot.readMessageEnd()
  468. if result.success is not None:
  469. return result.success
  470. raise TApplicationException(TApplicationException.MISSING_RESULT, "GetColumns failed: unknown result")
  471. def GetFunctions(self, req):
  472. """
  473. Parameters:
  474. - req
  475. """
  476. self.send_GetFunctions(req)
  477. return self.recv_GetFunctions()
  478. def send_GetFunctions(self, req):
  479. self._oprot.writeMessageBegin('GetFunctions', TMessageType.CALL, self._seqid)
  480. args = GetFunctions_args()
  481. args.req = req
  482. args.write(self._oprot)
  483. self._oprot.writeMessageEnd()
  484. self._oprot.trans.flush()
  485. def recv_GetFunctions(self):
  486. iprot = self._iprot
  487. (fname, mtype, rseqid) = iprot.readMessageBegin()
  488. if mtype == TMessageType.EXCEPTION:
  489. x = TApplicationException()
  490. x.read(iprot)
  491. iprot.readMessageEnd()
  492. raise x
  493. result = GetFunctions_result()
  494. result.read(iprot)
  495. iprot.readMessageEnd()
  496. if result.success is not None:
  497. return result.success
  498. raise TApplicationException(TApplicationException.MISSING_RESULT, "GetFunctions failed: unknown result")
  499. def GetPrimaryKeys(self, req):
  500. """
  501. Parameters:
  502. - req
  503. """
  504. self.send_GetPrimaryKeys(req)
  505. return self.recv_GetPrimaryKeys()
  506. def send_GetPrimaryKeys(self, req):
  507. self._oprot.writeMessageBegin('GetPrimaryKeys', TMessageType.CALL, self._seqid)
  508. args = GetPrimaryKeys_args()
  509. args.req = req
  510. args.write(self._oprot)
  511. self._oprot.writeMessageEnd()
  512. self._oprot.trans.flush()
  513. def recv_GetPrimaryKeys(self):
  514. iprot = self._iprot
  515. (fname, mtype, rseqid) = iprot.readMessageBegin()
  516. if mtype == TMessageType.EXCEPTION:
  517. x = TApplicationException()
  518. x.read(iprot)
  519. iprot.readMessageEnd()
  520. raise x
  521. result = GetPrimaryKeys_result()
  522. result.read(iprot)
  523. iprot.readMessageEnd()
  524. if result.success is not None:
  525. return result.success
  526. raise TApplicationException(TApplicationException.MISSING_RESULT, "GetPrimaryKeys failed: unknown result")
  527. def GetCrossReference(self, req):
  528. """
  529. Parameters:
  530. - req
  531. """
  532. self.send_GetCrossReference(req)
  533. return self.recv_GetCrossReference()
  534. def send_GetCrossReference(self, req):
  535. self._oprot.writeMessageBegin('GetCrossReference', TMessageType.CALL, self._seqid)
  536. args = GetCrossReference_args()
  537. args.req = req
  538. args.write(self._oprot)
  539. self._oprot.writeMessageEnd()
  540. self._oprot.trans.flush()
  541. def recv_GetCrossReference(self):
  542. iprot = self._iprot
  543. (fname, mtype, rseqid) = iprot.readMessageBegin()
  544. if mtype == TMessageType.EXCEPTION:
  545. x = TApplicationException()
  546. x.read(iprot)
  547. iprot.readMessageEnd()
  548. raise x
  549. result = GetCrossReference_result()
  550. result.read(iprot)
  551. iprot.readMessageEnd()
  552. if result.success is not None:
  553. return result.success
  554. raise TApplicationException(TApplicationException.MISSING_RESULT, "GetCrossReference failed: unknown result")
  555. def GetOperationStatus(self, req):
  556. """
  557. Parameters:
  558. - req
  559. """
  560. self.send_GetOperationStatus(req)
  561. return self.recv_GetOperationStatus()
  562. def send_GetOperationStatus(self, req):
  563. self._oprot.writeMessageBegin('GetOperationStatus', TMessageType.CALL, self._seqid)
  564. args = GetOperationStatus_args()
  565. args.req = req
  566. args.write(self._oprot)
  567. self._oprot.writeMessageEnd()
  568. self._oprot.trans.flush()
  569. def recv_GetOperationStatus(self):
  570. iprot = self._iprot
  571. (fname, mtype, rseqid) = iprot.readMessageBegin()
  572. if mtype == TMessageType.EXCEPTION:
  573. x = TApplicationException()
  574. x.read(iprot)
  575. iprot.readMessageEnd()
  576. raise x
  577. result = GetOperationStatus_result()
  578. result.read(iprot)
  579. iprot.readMessageEnd()
  580. if result.success is not None:
  581. return result.success
  582. raise TApplicationException(TApplicationException.MISSING_RESULT, "GetOperationStatus failed: unknown result")
  583. def CancelOperation(self, req):
  584. """
  585. Parameters:
  586. - req
  587. """
  588. self.send_CancelOperation(req)
  589. return self.recv_CancelOperation()
  590. def send_CancelOperation(self, req):
  591. self._oprot.writeMessageBegin('CancelOperation', TMessageType.CALL, self._seqid)
  592. args = CancelOperation_args()
  593. args.req = req
  594. args.write(self._oprot)
  595. self._oprot.writeMessageEnd()
  596. self._oprot.trans.flush()
  597. def recv_CancelOperation(self):
  598. iprot = self._iprot
  599. (fname, mtype, rseqid) = iprot.readMessageBegin()
  600. if mtype == TMessageType.EXCEPTION:
  601. x = TApplicationException()
  602. x.read(iprot)
  603. iprot.readMessageEnd()
  604. raise x
  605. result = CancelOperation_result()
  606. result.read(iprot)
  607. iprot.readMessageEnd()
  608. if result.success is not None:
  609. return result.success
  610. raise TApplicationException(TApplicationException.MISSING_RESULT, "CancelOperation failed: unknown result")
  611. def CloseOperation(self, req):
  612. """
  613. Parameters:
  614. - req
  615. """
  616. self.send_CloseOperation(req)
  617. return self.recv_CloseOperation()
  618. def send_CloseOperation(self, req):
  619. self._oprot.writeMessageBegin('CloseOperation', TMessageType.CALL, self._seqid)
  620. args = CloseOperation_args()
  621. args.req = req
  622. args.write(self._oprot)
  623. self._oprot.writeMessageEnd()
  624. self._oprot.trans.flush()
  625. def recv_CloseOperation(self):
  626. iprot = self._iprot
  627. (fname, mtype, rseqid) = iprot.readMessageBegin()
  628. if mtype == TMessageType.EXCEPTION:
  629. x = TApplicationException()
  630. x.read(iprot)
  631. iprot.readMessageEnd()
  632. raise x
  633. result = CloseOperation_result()
  634. result.read(iprot)
  635. iprot.readMessageEnd()
  636. if result.success is not None:
  637. return result.success
  638. raise TApplicationException(TApplicationException.MISSING_RESULT, "CloseOperation failed: unknown result")
  639. def GetResultSetMetadata(self, req):
  640. """
  641. Parameters:
  642. - req
  643. """
  644. self.send_GetResultSetMetadata(req)
  645. return self.recv_GetResultSetMetadata()
  646. def send_GetResultSetMetadata(self, req):
  647. self._oprot.writeMessageBegin('GetResultSetMetadata', TMessageType.CALL, self._seqid)
  648. args = GetResultSetMetadata_args()
  649. args.req = req
  650. args.write(self._oprot)
  651. self._oprot.writeMessageEnd()
  652. self._oprot.trans.flush()
  653. def recv_GetResultSetMetadata(self):
  654. iprot = self._iprot
  655. (fname, mtype, rseqid) = iprot.readMessageBegin()
  656. if mtype == TMessageType.EXCEPTION:
  657. x = TApplicationException()
  658. x.read(iprot)
  659. iprot.readMessageEnd()
  660. raise x
  661. result = GetResultSetMetadata_result()
  662. result.read(iprot)
  663. iprot.readMessageEnd()
  664. if result.success is not None:
  665. return result.success
  666. raise TApplicationException(TApplicationException.MISSING_RESULT, "GetResultSetMetadata failed: unknown result")
  667. def FetchResults(self, req):
  668. """
  669. Parameters:
  670. - req
  671. """
  672. self.send_FetchResults(req)
  673. return self.recv_FetchResults()
  674. def send_FetchResults(self, req):
  675. self._oprot.writeMessageBegin('FetchResults', TMessageType.CALL, self._seqid)
  676. args = FetchResults_args()
  677. args.req = req
  678. args.write(self._oprot)
  679. self._oprot.writeMessageEnd()
  680. self._oprot.trans.flush()
  681. def recv_FetchResults(self):
  682. iprot = self._iprot
  683. (fname, mtype, rseqid) = iprot.readMessageBegin()
  684. if mtype == TMessageType.EXCEPTION:
  685. x = TApplicationException()
  686. x.read(iprot)
  687. iprot.readMessageEnd()
  688. raise x
  689. result = FetchResults_result()
  690. result.read(iprot)
  691. iprot.readMessageEnd()
  692. if result.success is not None:
  693. return result.success
  694. raise TApplicationException(TApplicationException.MISSING_RESULT, "FetchResults failed: unknown result")
  695. def GetDelegationToken(self, req):
  696. """
  697. Parameters:
  698. - req
  699. """
  700. self.send_GetDelegationToken(req)
  701. return self.recv_GetDelegationToken()
  702. def send_GetDelegationToken(self, req):
  703. self._oprot.writeMessageBegin('GetDelegationToken', TMessageType.CALL, self._seqid)
  704. args = GetDelegationToken_args()
  705. args.req = req
  706. args.write(self._oprot)
  707. self._oprot.writeMessageEnd()
  708. self._oprot.trans.flush()
  709. def recv_GetDelegationToken(self):
  710. iprot = self._iprot
  711. (fname, mtype, rseqid) = iprot.readMessageBegin()
  712. if mtype == TMessageType.EXCEPTION:
  713. x = TApplicationException()
  714. x.read(iprot)
  715. iprot.readMessageEnd()
  716. raise x
  717. result = GetDelegationToken_result()
  718. result.read(iprot)
  719. iprot.readMessageEnd()
  720. if result.success is not None:
  721. return result.success
  722. raise TApplicationException(TApplicationException.MISSING_RESULT, "GetDelegationToken failed: unknown result")
  723. def CancelDelegationToken(self, req):
  724. """
  725. Parameters:
  726. - req
  727. """
  728. self.send_CancelDelegationToken(req)
  729. return self.recv_CancelDelegationToken()
  730. def send_CancelDelegationToken(self, req):
  731. self._oprot.writeMessageBegin('CancelDelegationToken', TMessageType.CALL, self._seqid)
  732. args = CancelDelegationToken_args()
  733. args.req = req
  734. args.write(self._oprot)
  735. self._oprot.writeMessageEnd()
  736. self._oprot.trans.flush()
  737. def recv_CancelDelegationToken(self):
  738. iprot = self._iprot
  739. (fname, mtype, rseqid) = iprot.readMessageBegin()
  740. if mtype == TMessageType.EXCEPTION:
  741. x = TApplicationException()
  742. x.read(iprot)
  743. iprot.readMessageEnd()
  744. raise x
  745. result = CancelDelegationToken_result()
  746. result.read(iprot)
  747. iprot.readMessageEnd()
  748. if result.success is not None:
  749. return result.success
  750. raise TApplicationException(TApplicationException.MISSING_RESULT, "CancelDelegationToken failed: unknown result")
  751. def RenewDelegationToken(self, req):
  752. """
  753. Parameters:
  754. - req
  755. """
  756. self.send_RenewDelegationToken(req)
  757. return self.recv_RenewDelegationToken()
  758. def send_RenewDelegationToken(self, req):
  759. self._oprot.writeMessageBegin('RenewDelegationToken', TMessageType.CALL, self._seqid)
  760. args = RenewDelegationToken_args()
  761. args.req = req
  762. args.write(self._oprot)
  763. self._oprot.writeMessageEnd()
  764. self._oprot.trans.flush()
  765. def recv_RenewDelegationToken(self):
  766. iprot = self._iprot
  767. (fname, mtype, rseqid) = iprot.readMessageBegin()
  768. if mtype == TMessageType.EXCEPTION:
  769. x = TApplicationException()
  770. x.read(iprot)
  771. iprot.readMessageEnd()
  772. raise x
  773. result = RenewDelegationToken_result()
  774. result.read(iprot)
  775. iprot.readMessageEnd()
  776. if result.success is not None:
  777. return result.success
  778. raise TApplicationException(TApplicationException.MISSING_RESULT, "RenewDelegationToken failed: unknown result")
  779. def GetQueryId(self, req):
  780. """
  781. Parameters:
  782. - req
  783. """
  784. self.send_GetQueryId(req)
  785. return self.recv_GetQueryId()
  786. def send_GetQueryId(self, req):
  787. self._oprot.writeMessageBegin('GetQueryId', TMessageType.CALL, self._seqid)
  788. args = GetQueryId_args()
  789. args.req = req
  790. args.write(self._oprot)
  791. self._oprot.writeMessageEnd()
  792. self._oprot.trans.flush()
  793. def recv_GetQueryId(self):
  794. iprot = self._iprot
  795. (fname, mtype, rseqid) = iprot.readMessageBegin()
  796. if mtype == TMessageType.EXCEPTION:
  797. x = TApplicationException()
  798. x.read(iprot)
  799. iprot.readMessageEnd()
  800. raise x
  801. result = GetQueryId_result()
  802. result.read(iprot)
  803. iprot.readMessageEnd()
  804. if result.success is not None:
  805. return result.success
  806. raise TApplicationException(TApplicationException.MISSING_RESULT, "GetQueryId failed: unknown result")
  807. def SetClientInfo(self, req):
  808. """
  809. Parameters:
  810. - req
  811. """
  812. self.send_SetClientInfo(req)
  813. return self.recv_SetClientInfo()
  814. def send_SetClientInfo(self, req):
  815. self._oprot.writeMessageBegin('SetClientInfo', TMessageType.CALL, self._seqid)
  816. args = SetClientInfo_args()
  817. args.req = req
  818. args.write(self._oprot)
  819. self._oprot.writeMessageEnd()
  820. self._oprot.trans.flush()
  821. def recv_SetClientInfo(self):
  822. iprot = self._iprot
  823. (fname, mtype, rseqid) = iprot.readMessageBegin()
  824. if mtype == TMessageType.EXCEPTION:
  825. x = TApplicationException()
  826. x.read(iprot)
  827. iprot.readMessageEnd()
  828. raise x
  829. result = SetClientInfo_result()
  830. result.read(iprot)
  831. iprot.readMessageEnd()
  832. if result.success is not None:
  833. return result.success
  834. raise TApplicationException(TApplicationException.MISSING_RESULT, "SetClientInfo failed: unknown result")
  835. def GetLog(self, req):
  836. """
  837. Parameters:
  838. - req
  839. """
  840. self.send_GetLog(req)
  841. return self.recv_GetLog()
  842. def send_GetLog(self, req):
  843. self._oprot.writeMessageBegin('GetLog', TMessageType.CALL, self._seqid)
  844. args = GetLog_args()
  845. args.req = req
  846. args.write(self._oprot)
  847. self._oprot.writeMessageEnd()
  848. self._oprot.trans.flush()
  849. def recv_GetLog(self):
  850. iprot = self._iprot
  851. (fname, mtype, rseqid) = iprot.readMessageBegin()
  852. if mtype == TMessageType.EXCEPTION:
  853. x = TApplicationException()
  854. x.read(iprot)
  855. iprot.readMessageEnd()
  856. raise x
  857. result = GetLog_result()
  858. result.read(iprot)
  859. iprot.readMessageEnd()
  860. if result.success is not None:
  861. return result.success
  862. raise TApplicationException(TApplicationException.MISSING_RESULT, "GetLog failed: unknown result")
  863. class Processor(Iface, TProcessor):
  864. def __init__(self, handler):
  865. self._handler = handler
  866. self._processMap = {}
  867. self._processMap["OpenSession"] = Processor.process_OpenSession
  868. self._processMap["CloseSession"] = Processor.process_CloseSession
  869. self._processMap["GetInfo"] = Processor.process_GetInfo
  870. self._processMap["ExecuteStatement"] = Processor.process_ExecuteStatement
  871. self._processMap["GetTypeInfo"] = Processor.process_GetTypeInfo
  872. self._processMap["GetCatalogs"] = Processor.process_GetCatalogs
  873. self._processMap["GetSchemas"] = Processor.process_GetSchemas
  874. self._processMap["GetTables"] = Processor.process_GetTables
  875. self._processMap["GetTableTypes"] = Processor.process_GetTableTypes
  876. self._processMap["GetColumns"] = Processor.process_GetColumns
  877. self._processMap["GetFunctions"] = Processor.process_GetFunctions
  878. self._processMap["GetPrimaryKeys"] = Processor.process_GetPrimaryKeys
  879. self._processMap["GetCrossReference"] = Processor.process_GetCrossReference
  880. self._processMap["GetOperationStatus"] = Processor.process_GetOperationStatus
  881. self._processMap["CancelOperation"] = Processor.process_CancelOperation
  882. self._processMap["CloseOperation"] = Processor.process_CloseOperation
  883. self._processMap["GetResultSetMetadata"] = Processor.process_GetResultSetMetadata
  884. self._processMap["FetchResults"] = Processor.process_FetchResults
  885. self._processMap["GetDelegationToken"] = Processor.process_GetDelegationToken
  886. self._processMap["CancelDelegationToken"] = Processor.process_CancelDelegationToken
  887. self._processMap["RenewDelegationToken"] = Processor.process_RenewDelegationToken
  888. self._processMap["GetQueryId"] = Processor.process_GetQueryId
  889. self._processMap["SetClientInfo"] = Processor.process_SetClientInfo
  890. self._processMap["GetLog"] = Processor.process_GetLog
  891. self._on_message_begin = None
  892. def on_message_begin(self, func):
  893. self._on_message_begin = func
  894. def process(self, iprot, oprot):
  895. (name, type, seqid) = iprot.readMessageBegin()
  896. if self._on_message_begin:
  897. self._on_message_begin(name, type, seqid)
  898. if name not in self._processMap:
  899. iprot.skip(TType.STRUCT)
  900. iprot.readMessageEnd()
  901. x = TApplicationException(TApplicationException.UNKNOWN_METHOD, 'Unknown function %s' % (name))
  902. oprot.writeMessageBegin(name, TMessageType.EXCEPTION, seqid)
  903. x.write(oprot)
  904. oprot.writeMessageEnd()
  905. oprot.trans.flush()
  906. return
  907. else:
  908. self._processMap[name](self, seqid, iprot, oprot)
  909. return True
  910. def process_OpenSession(self, seqid, iprot, oprot):
  911. args = OpenSession_args()
  912. args.read(iprot)
  913. iprot.readMessageEnd()
  914. result = OpenSession_result()
  915. try:
  916. result.success = self._handler.OpenSession(args.req)
  917. msg_type = TMessageType.REPLY
  918. except TTransport.TTransportException:
  919. raise
  920. except TApplicationException as ex:
  921. logging.exception('TApplication exception in handler')
  922. msg_type = TMessageType.EXCEPTION
  923. result = ex
  924. except Exception:
  925. logging.exception('Unexpected exception in handler')
  926. msg_type = TMessageType.EXCEPTION
  927. result = TApplicationException(TApplicationException.INTERNAL_ERROR, 'Internal error')
  928. oprot.writeMessageBegin("OpenSession", msg_type, seqid)
  929. result.write(oprot)
  930. oprot.writeMessageEnd()
  931. oprot.trans.flush()
  932. def process_CloseSession(self, seqid, iprot, oprot):
  933. args = CloseSession_args()
  934. args.read(iprot)
  935. iprot.readMessageEnd()
  936. result = CloseSession_result()
  937. try:
  938. result.success = self._handler.CloseSession(args.req)
  939. msg_type = TMessageType.REPLY
  940. except TTransport.TTransportException:
  941. raise
  942. except TApplicationException as ex:
  943. logging.exception('TApplication exception in handler')
  944. msg_type = TMessageType.EXCEPTION
  945. result = ex
  946. except Exception:
  947. logging.exception('Unexpected exception in handler')
  948. msg_type = TMessageType.EXCEPTION
  949. result = TApplicationException(TApplicationException.INTERNAL_ERROR, 'Internal error')
  950. oprot.writeMessageBegin("CloseSession", msg_type, seqid)
  951. result.write(oprot)
  952. oprot.writeMessageEnd()
  953. oprot.trans.flush()
  954. def process_GetInfo(self, seqid, iprot, oprot):
  955. args = GetInfo_args()
  956. args.read(iprot)
  957. iprot.readMessageEnd()
  958. result = GetInfo_result()
  959. try:
  960. result.success = self._handler.GetInfo(args.req)
  961. msg_type = TMessageType.REPLY
  962. except TTransport.TTransportException:
  963. raise
  964. except TApplicationException as ex:
  965. logging.exception('TApplication exception in handler')
  966. msg_type = TMessageType.EXCEPTION
  967. result = ex
  968. except Exception:
  969. logging.exception('Unexpected exception in handler')
  970. msg_type = TMessageType.EXCEPTION
  971. result = TApplicationException(TApplicationException.INTERNAL_ERROR, 'Internal error')
  972. oprot.writeMessageBegin("GetInfo", msg_type, seqid)
  973. result.write(oprot)
  974. oprot.writeMessageEnd()
  975. oprot.trans.flush()
  976. def process_ExecuteStatement(self, seqid, iprot, oprot):
  977. args = ExecuteStatement_args()
  978. args.read(iprot)
  979. iprot.readMessageEnd()
  980. result = ExecuteStatement_result()
  981. try:
  982. result.success = self._handler.ExecuteStatement(args.req)
  983. msg_type = TMessageType.REPLY
  984. except TTransport.TTransportException:
  985. raise
  986. except TApplicationException as ex:
  987. logging.exception('TApplication exception in handler')
  988. msg_type = TMessageType.EXCEPTION
  989. result = ex
  990. except Exception:
  991. logging.exception('Unexpected exception in handler')
  992. msg_type = TMessageType.EXCEPTION
  993. result = TApplicationException(TApplicationException.INTERNAL_ERROR, 'Internal error')
  994. oprot.writeMessageBegin("ExecuteStatement", msg_type, seqid)
  995. result.write(oprot)
  996. oprot.writeMessageEnd()
  997. oprot.trans.flush()
  998. def process_GetTypeInfo(self, seqid, iprot, oprot):
  999. args = GetTypeInfo_args()
  1000. args.read(iprot)
  1001. iprot.readMessageEnd()
  1002. result = GetTypeInfo_result()
  1003. try:
  1004. result.success = self._handler.GetTypeInfo(args.req)
  1005. msg_type = TMessageType.REPLY
  1006. except TTransport.TTransportException:
  1007. raise
  1008. except TApplicationException as ex:
  1009. logging.exception('TApplication exception in handler')
  1010. msg_type = TMessageType.EXCEPTION
  1011. result = ex
  1012. except Exception:
  1013. logging.exception('Unexpected exception in handler')
  1014. msg_type = TMessageType.EXCEPTION
  1015. result = TApplicationException(TApplicationException.INTERNAL_ERROR, 'Internal error')
  1016. oprot.writeMessageBegin("GetTypeInfo", msg_type, seqid)
  1017. result.write(oprot)
  1018. oprot.writeMessageEnd()
  1019. oprot.trans.flush()
  1020. def process_GetCatalogs(self, seqid, iprot, oprot):
  1021. args = GetCatalogs_args()
  1022. args.read(iprot)
  1023. iprot.readMessageEnd()
  1024. result = GetCatalogs_result()
  1025. try:
  1026. result.success = self._handler.GetCatalogs(args.req)
  1027. msg_type = TMessageType.REPLY
  1028. except TTransport.TTransportException:
  1029. raise
  1030. except TApplicationException as ex:
  1031. logging.exception('TApplication exception in handler')
  1032. msg_type = TMessageType.EXCEPTION
  1033. result = ex
  1034. except Exception:
  1035. logging.exception('Unexpected exception in handler')
  1036. msg_type = TMessageType.EXCEPTION
  1037. result = TApplicationException(TApplicationException.INTERNAL_ERROR, 'Internal error')
  1038. oprot.writeMessageBegin("GetCatalogs", msg_type, seqid)
  1039. result.write(oprot)
  1040. oprot.writeMessageEnd()
  1041. oprot.trans.flush()
  1042. def process_GetSchemas(self, seqid, iprot, oprot):
  1043. args = GetSchemas_args()
  1044. args.read(iprot)
  1045. iprot.readMessageEnd()
  1046. result = GetSchemas_result()
  1047. try:
  1048. result.success = self._handler.GetSchemas(args.req)
  1049. msg_type = TMessageType.REPLY
  1050. except TTransport.TTransportException:
  1051. raise
  1052. except TApplicationException as ex:
  1053. logging.exception('TApplication exception in handler')
  1054. msg_type = TMessageType.EXCEPTION
  1055. result = ex
  1056. except Exception:
  1057. logging.exception('Unexpected exception in handler')
  1058. msg_type = TMessageType.EXCEPTION
  1059. result = TApplicationException(TApplicationException.INTERNAL_ERROR, 'Internal error')
  1060. oprot.writeMessageBegin("GetSchemas", msg_type, seqid)
  1061. result.write(oprot)
  1062. oprot.writeMessageEnd()
  1063. oprot.trans.flush()
  1064. def process_GetTables(self, seqid, iprot, oprot):
  1065. args = GetTables_args()
  1066. args.read(iprot)
  1067. iprot.readMessageEnd()
  1068. result = GetTables_result()
  1069. try:
  1070. result.success = self._handler.GetTables(args.req)
  1071. msg_type = TMessageType.REPLY
  1072. except TTransport.TTransportException:
  1073. raise
  1074. except TApplicationException as ex:
  1075. logging.exception('TApplication exception in handler')
  1076. msg_type = TMessageType.EXCEPTION
  1077. result = ex
  1078. except Exception:
  1079. logging.exception('Unexpected exception in handler')
  1080. msg_type = TMessageType.EXCEPTION
  1081. result = TApplicationException(TApplicationException.INTERNAL_ERROR, 'Internal error')
  1082. oprot.writeMessageBegin("GetTables", msg_type, seqid)
  1083. result.write(oprot)
  1084. oprot.writeMessageEnd()
  1085. oprot.trans.flush()
  1086. def process_GetTableTypes(self, seqid, iprot, oprot):
  1087. args = GetTableTypes_args()
  1088. args.read(iprot)
  1089. iprot.readMessageEnd()
  1090. result = GetTableTypes_result()
  1091. try:
  1092. result.success = self._handler.GetTableTypes(args.req)
  1093. msg_type = TMessageType.REPLY
  1094. except TTransport.TTransportException:
  1095. raise
  1096. except TApplicationException as ex:
  1097. logging.exception('TApplication exception in handler')
  1098. msg_type = TMessageType.EXCEPTION
  1099. result = ex
  1100. except Exception:
  1101. logging.exception('Unexpected exception in handler')
  1102. msg_type = TMessageType.EXCEPTION
  1103. result = TApplicationException(TApplicationException.INTERNAL_ERROR, 'Internal error')
  1104. oprot.writeMessageBegin("GetTableTypes", msg_type, seqid)
  1105. result.write(oprot)
  1106. oprot.writeMessageEnd()
  1107. oprot.trans.flush()
  1108. def process_GetColumns(self, seqid, iprot, oprot):
  1109. args = GetColumns_args()
  1110. args.read(iprot)
  1111. iprot.readMessageEnd()
  1112. result = GetColumns_result()
  1113. try:
  1114. result.success = self._handler.GetColumns(args.req)
  1115. msg_type = TMessageType.REPLY
  1116. except TTransport.TTransportException:
  1117. raise
  1118. except TApplicationException as ex:
  1119. logging.exception('TApplication exception in handler')
  1120. msg_type = TMessageType.EXCEPTION
  1121. result = ex
  1122. except Exception:
  1123. logging.exception('Unexpected exception in handler')
  1124. msg_type = TMessageType.EXCEPTION
  1125. result = TApplicationException(TApplicationException.INTERNAL_ERROR, 'Internal error')
  1126. oprot.writeMessageBegin("GetColumns", msg_type, seqid)
  1127. result.write(oprot)
  1128. oprot.writeMessageEnd()
  1129. oprot.trans.flush()
  1130. def process_GetFunctions(self, seqid, iprot, oprot):
  1131. args = GetFunctions_args()
  1132. args.read(iprot)
  1133. iprot.readMessageEnd()
  1134. result = GetFunctions_result()
  1135. try:
  1136. result.success = self._handler.GetFunctions(args.req)
  1137. msg_type = TMessageType.REPLY
  1138. except TTransport.TTransportException:
  1139. raise
  1140. except TApplicationException as ex:
  1141. logging.exception('TApplication exception in handler')
  1142. msg_type = TMessageType.EXCEPTION
  1143. result = ex
  1144. except Exception:
  1145. logging.exception('Unexpected exception in handler')
  1146. msg_type = TMessageType.EXCEPTION
  1147. result = TApplicationException(TApplicationException.INTERNAL_ERROR, 'Internal error')
  1148. oprot.writeMessageBegin("GetFunctions", msg_type, seqid)
  1149. result.write(oprot)
  1150. oprot.writeMessageEnd()
  1151. oprot.trans.flush()
  1152. def process_GetPrimaryKeys(self, seqid, iprot, oprot):
  1153. args = GetPrimaryKeys_args()
  1154. args.read(iprot)
  1155. iprot.readMessageEnd()
  1156. result = GetPrimaryKeys_result()
  1157. try:
  1158. result.success = self._handler.GetPrimaryKeys(args.req)
  1159. msg_type = TMessageType.REPLY
  1160. except TTransport.TTransportException:
  1161. raise
  1162. except TApplicationException as ex:
  1163. logging.exception('TApplication exception in handler')
  1164. msg_type = TMessageType.EXCEPTION
  1165. result = ex
  1166. except Exception:
  1167. logging.exception('Unexpected exception in handler')
  1168. msg_type = TMessageType.EXCEPTION
  1169. result = TApplicationException(TApplicationException.INTERNAL_ERROR, 'Internal error')
  1170. oprot.writeMessageBegin("GetPrimaryKeys", msg_type, seqid)
  1171. result.write(oprot)
  1172. oprot.writeMessageEnd()
  1173. oprot.trans.flush()
  1174. def process_GetCrossReference(self, seqid, iprot, oprot):
  1175. args = GetCrossReference_args()
  1176. args.read(iprot)
  1177. iprot.readMessageEnd()
  1178. result = GetCrossReference_result()
  1179. try:
  1180. result.success = self._handler.GetCrossReference(args.req)
  1181. msg_type = TMessageType.REPLY
  1182. except TTransport.TTransportException:
  1183. raise
  1184. except TApplicationException as ex:
  1185. logging.exception('TApplication exception in handler')
  1186. msg_type = TMessageType.EXCEPTION
  1187. result = ex
  1188. except Exception:
  1189. logging.exception('Unexpected exception in handler')
  1190. msg_type = TMessageType.EXCEPTION
  1191. result = TApplicationException(TApplicationException.INTERNAL_ERROR, 'Internal error')
  1192. oprot.writeMessageBegin("GetCrossReference", msg_type, seqid)
  1193. result.write(oprot)
  1194. oprot.writeMessageEnd()
  1195. oprot.trans.flush()
  1196. def process_GetOperationStatus(self, seqid, iprot, oprot):
  1197. args = GetOperationStatus_args()
  1198. args.read(iprot)
  1199. iprot.readMessageEnd()
  1200. result = GetOperationStatus_result()
  1201. try:
  1202. result.success = self._handler.GetOperationStatus(args.req)
  1203. msg_type = TMessageType.REPLY
  1204. except TTransport.TTransportException:
  1205. raise
  1206. except TApplicationException as ex:
  1207. logging.exception('TApplication exception in handler')
  1208. msg_type = TMessageType.EXCEPTION
  1209. result = ex
  1210. except Exception:
  1211. logging.exception('Unexpected exception in handler')
  1212. msg_type = TMessageType.EXCEPTION
  1213. result = TApplicationException(TApplicationException.INTERNAL_ERROR, 'Internal error')
  1214. oprot.writeMessageBegin("GetOperationStatus", msg_type, seqid)
  1215. result.write(oprot)
  1216. oprot.writeMessageEnd()
  1217. oprot.trans.flush()
  1218. def process_CancelOperation(self, seqid, iprot, oprot):
  1219. args = CancelOperation_args()
  1220. args.read(iprot)
  1221. iprot.readMessageEnd()
  1222. result = CancelOperation_result()
  1223. try:
  1224. result.success = self._handler.CancelOperation(args.req)
  1225. msg_type = TMessageType.REPLY
  1226. except TTransport.TTransportException:
  1227. raise
  1228. except TApplicationException as ex:
  1229. logging.exception('TApplication exception in handler')
  1230. msg_type = TMessageType.EXCEPTION
  1231. result = ex
  1232. except Exception:
  1233. logging.exception('Unexpected exception in handler')
  1234. msg_type = TMessageType.EXCEPTION
  1235. result = TApplicationException(TApplicationException.INTERNAL_ERROR, 'Internal error')
  1236. oprot.writeMessageBegin("CancelOperation", msg_type, seqid)
  1237. result.write(oprot)
  1238. oprot.writeMessageEnd()
  1239. oprot.trans.flush()
  1240. def process_CloseOperation(self, seqid, iprot, oprot):
  1241. args = CloseOperation_args()
  1242. args.read(iprot)
  1243. iprot.readMessageEnd()
  1244. result = CloseOperation_result()
  1245. try:
  1246. result.success = self._handler.CloseOperation(args.req)
  1247. msg_type = TMessageType.REPLY
  1248. except TTransport.TTransportException:
  1249. raise
  1250. except TApplicationException as ex:
  1251. logging.exception('TApplication exception in handler')
  1252. msg_type = TMessageType.EXCEPTION
  1253. result = ex
  1254. except Exception:
  1255. logging.exception('Unexpected exception in handler')
  1256. msg_type = TMessageType.EXCEPTION
  1257. result = TApplicationException(TApplicationException.INTERNAL_ERROR, 'Internal error')
  1258. oprot.writeMessageBegin("CloseOperation", msg_type, seqid)
  1259. result.write(oprot)
  1260. oprot.writeMessageEnd()
  1261. oprot.trans.flush()
  1262. def process_GetResultSetMetadata(self, seqid, iprot, oprot):
  1263. args = GetResultSetMetadata_args()
  1264. args.read(iprot)
  1265. iprot.readMessageEnd()
  1266. result = GetResultSetMetadata_result()
  1267. try:
  1268. result.success = self._handler.GetResultSetMetadata(args.req)
  1269. msg_type = TMessageType.REPLY
  1270. except TTransport.TTransportException:
  1271. raise
  1272. except TApplicationException as ex:
  1273. logging.exception('TApplication exception in handler')
  1274. msg_type = TMessageType.EXCEPTION
  1275. result = ex
  1276. except Exception:
  1277. logging.exception('Unexpected exception in handler')
  1278. msg_type = TMessageType.EXCEPTION
  1279. result = TApplicationException(TApplicationException.INTERNAL_ERROR, 'Internal error')
  1280. oprot.writeMessageBegin("GetResultSetMetadata", msg_type, seqid)
  1281. result.write(oprot)
  1282. oprot.writeMessageEnd()
  1283. oprot.trans.flush()
  1284. def process_FetchResults(self, seqid, iprot, oprot):
  1285. args = FetchResults_args()
  1286. args.read(iprot)
  1287. iprot.readMessageEnd()
  1288. result = FetchResults_result()
  1289. try:
  1290. result.success = self._handler.FetchResults(args.req)
  1291. msg_type = TMessageType.REPLY
  1292. except TTransport.TTransportException:
  1293. raise
  1294. except TApplicationException as ex:
  1295. logging.exception('TApplication exception in handler')
  1296. msg_type = TMessageType.EXCEPTION
  1297. result = ex
  1298. except Exception:
  1299. logging.exception('Unexpected exception in handler')
  1300. msg_type = TMessageType.EXCEPTION
  1301. result = TApplicationException(TApplicationException.INTERNAL_ERROR, 'Internal error')
  1302. oprot.writeMessageBegin("FetchResults", msg_type, seqid)
  1303. result.write(oprot)
  1304. oprot.writeMessageEnd()
  1305. oprot.trans.flush()
  1306. def process_GetDelegationToken(self, seqid, iprot, oprot):
  1307. args = GetDelegationToken_args()
  1308. args.read(iprot)
  1309. iprot.readMessageEnd()
  1310. result = GetDelegationToken_result()
  1311. try:
  1312. result.success = self._handler.GetDelegationToken(args.req)
  1313. msg_type = TMessageType.REPLY
  1314. except TTransport.TTransportException:
  1315. raise
  1316. except TApplicationException as ex:
  1317. logging.exception('TApplication exception in handler')
  1318. msg_type = TMessageType.EXCEPTION
  1319. result = ex
  1320. except Exception:
  1321. logging.exception('Unexpected exception in handler')
  1322. msg_type = TMessageType.EXCEPTION
  1323. result = TApplicationException(TApplicationException.INTERNAL_ERROR, 'Internal error')
  1324. oprot.writeMessageBegin("GetDelegationToken", msg_type, seqid)
  1325. result.write(oprot)
  1326. oprot.writeMessageEnd()
  1327. oprot.trans.flush()
  1328. def process_CancelDelegationToken(self, seqid, iprot, oprot):
  1329. args = CancelDelegationToken_args()
  1330. args.read(iprot)
  1331. iprot.readMessageEnd()
  1332. result = CancelDelegationToken_result()
  1333. try:
  1334. result.success = self._handler.CancelDelegationToken(args.req)
  1335. msg_type = TMessageType.REPLY
  1336. except TTransport.TTransportException:
  1337. raise
  1338. except TApplicationException as ex:
  1339. logging.exception('TApplication exception in handler')
  1340. msg_type = TMessageType.EXCEPTION
  1341. result = ex
  1342. except Exception:
  1343. logging.exception('Unexpected exception in handler')
  1344. msg_type = TMessageType.EXCEPTION
  1345. result = TApplicationException(TApplicationException.INTERNAL_ERROR, 'Internal error')
  1346. oprot.writeMessageBegin("CancelDelegationToken", msg_type, seqid)
  1347. result.write(oprot)
  1348. oprot.writeMessageEnd()
  1349. oprot.trans.flush()
  1350. def process_RenewDelegationToken(self, seqid, iprot, oprot):
  1351. args = RenewDelegationToken_args()
  1352. args.read(iprot)
  1353. iprot.readMessageEnd()
  1354. result = RenewDelegationToken_result()
  1355. try:
  1356. result.success = self._handler.RenewDelegationToken(args.req)
  1357. msg_type = TMessageType.REPLY
  1358. except TTransport.TTransportException:
  1359. raise
  1360. except TApplicationException as ex:
  1361. logging.exception('TApplication exception in handler')
  1362. msg_type = TMessageType.EXCEPTION
  1363. result = ex
  1364. except Exception:
  1365. logging.exception('Unexpected exception in handler')
  1366. msg_type = TMessageType.EXCEPTION
  1367. result = TApplicationException(TApplicationException.INTERNAL_ERROR, 'Internal error')
  1368. oprot.writeMessageBegin("RenewDelegationToken", msg_type, seqid)
  1369. result.write(oprot)
  1370. oprot.writeMessageEnd()
  1371. oprot.trans.flush()
  1372. def process_GetQueryId(self, seqid, iprot, oprot):
  1373. args = GetQueryId_args()
  1374. args.read(iprot)
  1375. iprot.readMessageEnd()
  1376. result = GetQueryId_result()
  1377. try:
  1378. result.success = self._handler.GetQueryId(args.req)
  1379. msg_type = TMessageType.REPLY
  1380. except TTransport.TTransportException:
  1381. raise
  1382. except TApplicationException as ex:
  1383. logging.exception('TApplication exception in handler')
  1384. msg_type = TMessageType.EXCEPTION
  1385. result = ex
  1386. except Exception:
  1387. logging.exception('Unexpected exception in handler')
  1388. msg_type = TMessageType.EXCEPTION
  1389. result = TApplicationException(TApplicationException.INTERNAL_ERROR, 'Internal error')
  1390. oprot.writeMessageBegin("GetQueryId", msg_type, seqid)
  1391. result.write(oprot)
  1392. oprot.writeMessageEnd()
  1393. oprot.trans.flush()
  1394. def process_SetClientInfo(self, seqid, iprot, oprot):
  1395. args = SetClientInfo_args()
  1396. args.read(iprot)
  1397. iprot.readMessageEnd()
  1398. result = SetClientInfo_result()
  1399. try:
  1400. result.success = self._handler.SetClientInfo(args.req)
  1401. msg_type = TMessageType.REPLY
  1402. except TTransport.TTransportException:
  1403. raise
  1404. except TApplicationException as ex:
  1405. logging.exception('TApplication exception in handler')
  1406. msg_type = TMessageType.EXCEPTION
  1407. result = ex
  1408. except Exception:
  1409. logging.exception('Unexpected exception in handler')
  1410. msg_type = TMessageType.EXCEPTION
  1411. result = TApplicationException(TApplicationException.INTERNAL_ERROR, 'Internal error')
  1412. oprot.writeMessageBegin("SetClientInfo", msg_type, seqid)
  1413. result.write(oprot)
  1414. oprot.writeMessageEnd()
  1415. oprot.trans.flush()
  1416. def process_GetLog(self, seqid, iprot, oprot):
  1417. args = GetLog_args()
  1418. args.read(iprot)
  1419. iprot.readMessageEnd()
  1420. result = GetLog_result()
  1421. try:
  1422. result.success = self._handler.GetLog(args.req)
  1423. msg_type = TMessageType.REPLY
  1424. except TTransport.TTransportException:
  1425. raise
  1426. except TApplicationException as ex:
  1427. logging.exception('TApplication exception in handler')
  1428. msg_type = TMessageType.EXCEPTION
  1429. result = ex
  1430. except Exception:
  1431. logging.exception('Unexpected exception in handler')
  1432. msg_type = TMessageType.EXCEPTION
  1433. result = TApplicationException(TApplicationException.INTERNAL_ERROR, 'Internal error')
  1434. oprot.writeMessageBegin("GetLog", msg_type, seqid)
  1435. result.write(oprot)
  1436. oprot.writeMessageEnd()
  1437. oprot.trans.flush()
  1438. # HELPER FUNCTIONS AND STRUCTURES
  1439. class OpenSession_args(object):
  1440. """
  1441. Attributes:
  1442. - req
  1443. """
  1444. def __init__(self, req=None,):
  1445. self.req = req
  1446. def read(self, iprot):
  1447. if iprot._fast_decode is not None and isinstance(iprot.trans, TTransport.CReadableTransport) and self.thrift_spec is not None:
  1448. iprot._fast_decode(self, iprot, [self.__class__, self.thrift_spec])
  1449. return
  1450. iprot.readStructBegin()
  1451. while True:
  1452. (fname, ftype, fid) = iprot.readFieldBegin()
  1453. if ftype == TType.STOP:
  1454. break
  1455. if fid == 1:
  1456. if ftype == TType.STRUCT:
  1457. self.req = TOpenSessionReq()
  1458. self.req.read(iprot)
  1459. else:
  1460. iprot.skip(ftype)
  1461. else:
  1462. iprot.skip(ftype)
  1463. iprot.readFieldEnd()
  1464. iprot.readStructEnd()
  1465. def write(self, oprot):
  1466. if oprot._fast_encode is not None and self.thrift_spec is not None:
  1467. oprot.trans.write(oprot._fast_encode(self, [self.__class__, self.thrift_spec]))
  1468. return
  1469. oprot.writeStructBegin('OpenSession_args')
  1470. if self.req is not None:
  1471. oprot.writeFieldBegin('req', TType.STRUCT, 1)
  1472. self.req.write(oprot)
  1473. oprot.writeFieldEnd()
  1474. oprot.writeFieldStop()
  1475. oprot.writeStructEnd()
  1476. def validate(self):
  1477. return
  1478. def __repr__(self):
  1479. L = ['%s=%r' % (key, value)
  1480. for key, value in self.__dict__.items()]
  1481. return '%s(%s)' % (self.__class__.__name__, ', '.join(L))
  1482. def __eq__(self, other):
  1483. return isinstance(other, self.__class__) and self.__dict__ == other.__dict__
  1484. def __ne__(self, other):
  1485. return not (self == other)
  1486. all_structs.append(OpenSession_args)
  1487. OpenSession_args.thrift_spec = (
  1488. None, # 0
  1489. (1, TType.STRUCT, 'req', [TOpenSessionReq, None], None, ), # 1
  1490. )
  1491. class OpenSession_result(object):
  1492. """
  1493. Attributes:
  1494. - success
  1495. """
  1496. def __init__(self, success=None,):
  1497. self.success = success
  1498. def read(self, iprot):
  1499. if iprot._fast_decode is not None and isinstance(iprot.trans, TTransport.CReadableTransport) and self.thrift_spec is not None:
  1500. iprot._fast_decode(self, iprot, [self.__class__, self.thrift_spec])
  1501. return
  1502. iprot.readStructBegin()
  1503. while True:
  1504. (fname, ftype, fid) = iprot.readFieldBegin()
  1505. if ftype == TType.STOP:
  1506. break
  1507. if fid == 0:
  1508. if ftype == TType.STRUCT:
  1509. self.success = TOpenSessionResp()
  1510. self.success.read(iprot)
  1511. else:
  1512. iprot.skip(ftype)
  1513. else:
  1514. iprot.skip(ftype)
  1515. iprot.readFieldEnd()
  1516. iprot.readStructEnd()
  1517. def write(self, oprot):
  1518. if oprot._fast_encode is not None and self.thrift_spec is not None:
  1519. oprot.trans.write(oprot._fast_encode(self, [self.__class__, self.thrift_spec]))
  1520. return
  1521. oprot.writeStructBegin('OpenSession_result')
  1522. if self.success is not None:
  1523. oprot.writeFieldBegin('success', TType.STRUCT, 0)
  1524. self.success.write(oprot)
  1525. oprot.writeFieldEnd()
  1526. oprot.writeFieldStop()
  1527. oprot.writeStructEnd()
  1528. def validate(self):
  1529. return
  1530. def __repr__(self):
  1531. L = ['%s=%r' % (key, value)
  1532. for key, value in self.__dict__.items()]
  1533. return '%s(%s)' % (self.__class__.__name__, ', '.join(L))
  1534. def __eq__(self, other):
  1535. return isinstance(other, self.__class__) and self.__dict__ == other.__dict__
  1536. def __ne__(self, other):
  1537. return not (self == other)
  1538. all_structs.append(OpenSession_result)
  1539. OpenSession_result.thrift_spec = (
  1540. (0, TType.STRUCT, 'success', [TOpenSessionResp, None], None, ), # 0
  1541. )
  1542. class CloseSession_args(object):
  1543. """
  1544. Attributes:
  1545. - req
  1546. """
  1547. def __init__(self, req=None,):
  1548. self.req = req
  1549. def read(self, iprot):
  1550. if iprot._fast_decode is not None and isinstance(iprot.trans, TTransport.CReadableTransport) and self.thrift_spec is not None:
  1551. iprot._fast_decode(self, iprot, [self.__class__, self.thrift_spec])
  1552. return
  1553. iprot.readStructBegin()
  1554. while True:
  1555. (fname, ftype, fid) = iprot.readFieldBegin()
  1556. if ftype == TType.STOP:
  1557. break
  1558. if fid == 1:
  1559. if ftype == TType.STRUCT:
  1560. self.req = TCloseSessionReq()
  1561. self.req.read(iprot)
  1562. else:
  1563. iprot.skip(ftype)
  1564. else:
  1565. iprot.skip(ftype)
  1566. iprot.readFieldEnd()
  1567. iprot.readStructEnd()
  1568. def write(self, oprot):
  1569. if oprot._fast_encode is not None and self.thrift_spec is not None:
  1570. oprot.trans.write(oprot._fast_encode(self, [self.__class__, self.thrift_spec]))
  1571. return
  1572. oprot.writeStructBegin('CloseSession_args')
  1573. if self.req is not None:
  1574. oprot.writeFieldBegin('req', TType.STRUCT, 1)
  1575. self.req.write(oprot)
  1576. oprot.writeFieldEnd()
  1577. oprot.writeFieldStop()
  1578. oprot.writeStructEnd()
  1579. def validate(self):
  1580. return
  1581. def __repr__(self):
  1582. L = ['%s=%r' % (key, value)
  1583. for key, value in self.__dict__.items()]
  1584. return '%s(%s)' % (self.__class__.__name__, ', '.join(L))
  1585. def __eq__(self, other):
  1586. return isinstance(other, self.__class__) and self.__dict__ == other.__dict__
  1587. def __ne__(self, other):
  1588. return not (self == other)
  1589. all_structs.append(CloseSession_args)
  1590. CloseSession_args.thrift_spec = (
  1591. None, # 0
  1592. (1, TType.STRUCT, 'req', [TCloseSessionReq, None], None, ), # 1
  1593. )
  1594. class CloseSession_result(object):
  1595. """
  1596. Attributes:
  1597. - success
  1598. """
  1599. def __init__(self, success=None,):
  1600. self.success = success
  1601. def read(self, iprot):
  1602. if iprot._fast_decode is not None and isinstance(iprot.trans, TTransport.CReadableTransport) and self.thrift_spec is not None:
  1603. iprot._fast_decode(self, iprot, [self.__class__, self.thrift_spec])
  1604. return
  1605. iprot.readStructBegin()
  1606. while True:
  1607. (fname, ftype, fid) = iprot.readFieldBegin()
  1608. if ftype == TType.STOP:
  1609. break
  1610. if fid == 0:
  1611. if ftype == TType.STRUCT:
  1612. self.success = TCloseSessionResp()
  1613. self.success.read(iprot)
  1614. else:
  1615. iprot.skip(ftype)
  1616. else:
  1617. iprot.skip(ftype)
  1618. iprot.readFieldEnd()
  1619. iprot.readStructEnd()
  1620. def write(self, oprot):
  1621. if oprot._fast_encode is not None and self.thrift_spec is not None:
  1622. oprot.trans.write(oprot._fast_encode(self, [self.__class__, self.thrift_spec]))
  1623. return
  1624. oprot.writeStructBegin('CloseSession_result')
  1625. if self.success is not None:
  1626. oprot.writeFieldBegin('success', TType.STRUCT, 0)
  1627. self.success.write(oprot)
  1628. oprot.writeFieldEnd()
  1629. oprot.writeFieldStop()
  1630. oprot.writeStructEnd()
  1631. def validate(self):
  1632. return
  1633. def __repr__(self):
  1634. L = ['%s=%r' % (key, value)
  1635. for key, value in self.__dict__.items()]
  1636. return '%s(%s)' % (self.__class__.__name__, ', '.join(L))
  1637. def __eq__(self, other):
  1638. return isinstance(other, self.__class__) and self.__dict__ == other.__dict__
  1639. def __ne__(self, other):
  1640. return not (self == other)
  1641. all_structs.append(CloseSession_result)
  1642. CloseSession_result.thrift_spec = (
  1643. (0, TType.STRUCT, 'success', [TCloseSessionResp, None], None, ), # 0
  1644. )
  1645. class GetInfo_args(object):
  1646. """
  1647. Attributes:
  1648. - req
  1649. """
  1650. def __init__(self, req=None,):
  1651. self.req = req
  1652. def read(self, iprot):
  1653. if iprot._fast_decode is not None and isinstance(iprot.trans, TTransport.CReadableTransport) and self.thrift_spec is not None:
  1654. iprot._fast_decode(self, iprot, [self.__class__, self.thrift_spec])
  1655. return
  1656. iprot.readStructBegin()
  1657. while True:
  1658. (fname, ftype, fid) = iprot.readFieldBegin()
  1659. if ftype == TType.STOP:
  1660. break
  1661. if fid == 1:
  1662. if ftype == TType.STRUCT:
  1663. self.req = TGetInfoReq()
  1664. self.req.read(iprot)
  1665. else:
  1666. iprot.skip(ftype)
  1667. else:
  1668. iprot.skip(ftype)
  1669. iprot.readFieldEnd()
  1670. iprot.readStructEnd()
  1671. def write(self, oprot):
  1672. if oprot._fast_encode is not None and self.thrift_spec is not None:
  1673. oprot.trans.write(oprot._fast_encode(self, [self.__class__, self.thrift_spec]))
  1674. return
  1675. oprot.writeStructBegin('GetInfo_args')
  1676. if self.req is not None:
  1677. oprot.writeFieldBegin('req', TType.STRUCT, 1)
  1678. self.req.write(oprot)
  1679. oprot.writeFieldEnd()
  1680. oprot.writeFieldStop()
  1681. oprot.writeStructEnd()
  1682. def validate(self):
  1683. return
  1684. def __repr__(self):
  1685. L = ['%s=%r' % (key, value)
  1686. for key, value in self.__dict__.items()]
  1687. return '%s(%s)' % (self.__class__.__name__, ', '.join(L))
  1688. def __eq__(self, other):
  1689. return isinstance(other, self.__class__) and self.__dict__ == other.__dict__
  1690. def __ne__(self, other):
  1691. return not (self == other)
  1692. all_structs.append(GetInfo_args)
  1693. GetInfo_args.thrift_spec = (
  1694. None, # 0
  1695. (1, TType.STRUCT, 'req', [TGetInfoReq, None], None, ), # 1
  1696. )
  1697. class GetInfo_result(object):
  1698. """
  1699. Attributes:
  1700. - success
  1701. """
  1702. def __init__(self, success=None,):
  1703. self.success = success
  1704. def read(self, iprot):
  1705. if iprot._fast_decode is not None and isinstance(iprot.trans, TTransport.CReadableTransport) and self.thrift_spec is not None:
  1706. iprot._fast_decode(self, iprot, [self.__class__, self.thrift_spec])
  1707. return
  1708. iprot.readStructBegin()
  1709. while True:
  1710. (fname, ftype, fid) = iprot.readFieldBegin()
  1711. if ftype == TType.STOP:
  1712. break
  1713. if fid == 0:
  1714. if ftype == TType.STRUCT:
  1715. self.success = TGetInfoResp()
  1716. self.success.read(iprot)
  1717. else:
  1718. iprot.skip(ftype)
  1719. else:
  1720. iprot.skip(ftype)
  1721. iprot.readFieldEnd()
  1722. iprot.readStructEnd()
  1723. def write(self, oprot):
  1724. if oprot._fast_encode is not None and self.thrift_spec is not None:
  1725. oprot.trans.write(oprot._fast_encode(self, [self.__class__, self.thrift_spec]))
  1726. return
  1727. oprot.writeStructBegin('GetInfo_result')
  1728. if self.success is not None:
  1729. oprot.writeFieldBegin('success', TType.STRUCT, 0)
  1730. self.success.write(oprot)
  1731. oprot.writeFieldEnd()
  1732. oprot.writeFieldStop()
  1733. oprot.writeStructEnd()
  1734. def validate(self):
  1735. return
  1736. def __repr__(self):
  1737. L = ['%s=%r' % (key, value)
  1738. for key, value in self.__dict__.items()]
  1739. return '%s(%s)' % (self.__class__.__name__, ', '.join(L))
  1740. def __eq__(self, other):
  1741. return isinstance(other, self.__class__) and self.__dict__ == other.__dict__
  1742. def __ne__(self, other):
  1743. return not (self == other)
  1744. all_structs.append(GetInfo_result)
  1745. GetInfo_result.thrift_spec = (
  1746. (0, TType.STRUCT, 'success', [TGetInfoResp, None], None, ), # 0
  1747. )
  1748. class ExecuteStatement_args(object):
  1749. """
  1750. Attributes:
  1751. - req
  1752. """
  1753. def __init__(self, req=None,):
  1754. self.req = req
  1755. def read(self, iprot):
  1756. if iprot._fast_decode is not None and isinstance(iprot.trans, TTransport.CReadableTransport) and self.thrift_spec is not None:
  1757. iprot._fast_decode(self, iprot, [self.__class__, self.thrift_spec])
  1758. return
  1759. iprot.readStructBegin()
  1760. while True:
  1761. (fname, ftype, fid) = iprot.readFieldBegin()
  1762. if ftype == TType.STOP:
  1763. break
  1764. if fid == 1:
  1765. if ftype == TType.STRUCT:
  1766. self.req = TExecuteStatementReq()
  1767. self.req.read(iprot)
  1768. else:
  1769. iprot.skip(ftype)
  1770. else:
  1771. iprot.skip(ftype)
  1772. iprot.readFieldEnd()
  1773. iprot.readStructEnd()
  1774. def write(self, oprot):
  1775. if oprot._fast_encode is not None and self.thrift_spec is not None:
  1776. oprot.trans.write(oprot._fast_encode(self, [self.__class__, self.thrift_spec]))
  1777. return
  1778. oprot.writeStructBegin('ExecuteStatement_args')
  1779. if self.req is not None:
  1780. oprot.writeFieldBegin('req', TType.STRUCT, 1)
  1781. self.req.write(oprot)
  1782. oprot.writeFieldEnd()
  1783. oprot.writeFieldStop()
  1784. oprot.writeStructEnd()
  1785. def validate(self):
  1786. return
  1787. def __repr__(self):
  1788. L = ['%s=%r' % (key, value)
  1789. for key, value in self.__dict__.items()]
  1790. return '%s(%s)' % (self.__class__.__name__, ', '.join(L))
  1791. def __eq__(self, other):
  1792. return isinstance(other, self.__class__) and self.__dict__ == other.__dict__
  1793. def __ne__(self, other):
  1794. return not (self == other)
  1795. all_structs.append(ExecuteStatement_args)
  1796. ExecuteStatement_args.thrift_spec = (
  1797. None, # 0
  1798. (1, TType.STRUCT, 'req', [TExecuteStatementReq, None], None, ), # 1
  1799. )
  1800. class ExecuteStatement_result(object):
  1801. """
  1802. Attributes:
  1803. - success
  1804. """
  1805. def __init__(self, success=None,):
  1806. self.success = success
  1807. def read(self, iprot):
  1808. if iprot._fast_decode is not None and isinstance(iprot.trans, TTransport.CReadableTransport) and self.thrift_spec is not None:
  1809. iprot._fast_decode(self, iprot, [self.__class__, self.thrift_spec])
  1810. return
  1811. iprot.readStructBegin()
  1812. while True:
  1813. (fname, ftype, fid) = iprot.readFieldBegin()
  1814. if ftype == TType.STOP:
  1815. break
  1816. if fid == 0:
  1817. if ftype == TType.STRUCT:
  1818. self.success = TExecuteStatementResp()
  1819. self.success.read(iprot)
  1820. else:
  1821. iprot.skip(ftype)
  1822. else:
  1823. iprot.skip(ftype)
  1824. iprot.readFieldEnd()
  1825. iprot.readStructEnd()
  1826. def write(self, oprot):
  1827. if oprot._fast_encode is not None and self.thrift_spec is not None:
  1828. oprot.trans.write(oprot._fast_encode(self, [self.__class__, self.thrift_spec]))
  1829. return
  1830. oprot.writeStructBegin('ExecuteStatement_result')
  1831. if self.success is not None:
  1832. oprot.writeFieldBegin('success', TType.STRUCT, 0)
  1833. self.success.write(oprot)
  1834. oprot.writeFieldEnd()
  1835. oprot.writeFieldStop()
  1836. oprot.writeStructEnd()
  1837. def validate(self):
  1838. return
  1839. def __repr__(self):
  1840. L = ['%s=%r' % (key, value)
  1841. for key, value in self.__dict__.items()]
  1842. return '%s(%s)' % (self.__class__.__name__, ', '.join(L))
  1843. def __eq__(self, other):
  1844. return isinstance(other, self.__class__) and self.__dict__ == other.__dict__
  1845. def __ne__(self, other):
  1846. return not (self == other)
  1847. all_structs.append(ExecuteStatement_result)
  1848. ExecuteStatement_result.thrift_spec = (
  1849. (0, TType.STRUCT, 'success', [TExecuteStatementResp, None], None, ), # 0
  1850. )
  1851. class GetTypeInfo_args(object):
  1852. """
  1853. Attributes:
  1854. - req
  1855. """
  1856. def __init__(self, req=None,):
  1857. self.req = req
  1858. def read(self, iprot):
  1859. if iprot._fast_decode is not None and isinstance(iprot.trans, TTransport.CReadableTransport) and self.thrift_spec is not None:
  1860. iprot._fast_decode(self, iprot, [self.__class__, self.thrift_spec])
  1861. return
  1862. iprot.readStructBegin()
  1863. while True:
  1864. (fname, ftype, fid) = iprot.readFieldBegin()
  1865. if ftype == TType.STOP:
  1866. break
  1867. if fid == 1:
  1868. if ftype == TType.STRUCT:
  1869. self.req = TGetTypeInfoReq()
  1870. self.req.read(iprot)
  1871. else:
  1872. iprot.skip(ftype)
  1873. else:
  1874. iprot.skip(ftype)
  1875. iprot.readFieldEnd()
  1876. iprot.readStructEnd()
  1877. def write(self, oprot):
  1878. if oprot._fast_encode is not None and self.thrift_spec is not None:
  1879. oprot.trans.write(oprot._fast_encode(self, [self.__class__, self.thrift_spec]))
  1880. return
  1881. oprot.writeStructBegin('GetTypeInfo_args')
  1882. if self.req is not None:
  1883. oprot.writeFieldBegin('req', TType.STRUCT, 1)
  1884. self.req.write(oprot)
  1885. oprot.writeFieldEnd()
  1886. oprot.writeFieldStop()
  1887. oprot.writeStructEnd()
  1888. def validate(self):
  1889. return
  1890. def __repr__(self):
  1891. L = ['%s=%r' % (key, value)
  1892. for key, value in self.__dict__.items()]
  1893. return '%s(%s)' % (self.__class__.__name__, ', '.join(L))
  1894. def __eq__(self, other):
  1895. return isinstance(other, self.__class__) and self.__dict__ == other.__dict__
  1896. def __ne__(self, other):
  1897. return not (self == other)
  1898. all_structs.append(GetTypeInfo_args)
  1899. GetTypeInfo_args.thrift_spec = (
  1900. None, # 0
  1901. (1, TType.STRUCT, 'req', [TGetTypeInfoReq, None], None, ), # 1
  1902. )
  1903. class GetTypeInfo_result(object):
  1904. """
  1905. Attributes:
  1906. - success
  1907. """
  1908. def __init__(self, success=None,):
  1909. self.success = success
  1910. def read(self, iprot):
  1911. if iprot._fast_decode is not None and isinstance(iprot.trans, TTransport.CReadableTransport) and self.thrift_spec is not None:
  1912. iprot._fast_decode(self, iprot, [self.__class__, self.thrift_spec])
  1913. return
  1914. iprot.readStructBegin()
  1915. while True:
  1916. (fname, ftype, fid) = iprot.readFieldBegin()
  1917. if ftype == TType.STOP:
  1918. break
  1919. if fid == 0:
  1920. if ftype == TType.STRUCT:
  1921. self.success = TGetTypeInfoResp()
  1922. self.success.read(iprot)
  1923. else:
  1924. iprot.skip(ftype)
  1925. else:
  1926. iprot.skip(ftype)
  1927. iprot.readFieldEnd()
  1928. iprot.readStructEnd()
  1929. def write(self, oprot):
  1930. if oprot._fast_encode is not None and self.thrift_spec is not None:
  1931. oprot.trans.write(oprot._fast_encode(self, [self.__class__, self.thrift_spec]))
  1932. return
  1933. oprot.writeStructBegin('GetTypeInfo_result')
  1934. if self.success is not None:
  1935. oprot.writeFieldBegin('success', TType.STRUCT, 0)
  1936. self.success.write(oprot)
  1937. oprot.writeFieldEnd()
  1938. oprot.writeFieldStop()
  1939. oprot.writeStructEnd()
  1940. def validate(self):
  1941. return
  1942. def __repr__(self):
  1943. L = ['%s=%r' % (key, value)
  1944. for key, value in self.__dict__.items()]
  1945. return '%s(%s)' % (self.__class__.__name__, ', '.join(L))
  1946. def __eq__(self, other):
  1947. return isinstance(other, self.__class__) and self.__dict__ == other.__dict__
  1948. def __ne__(self, other):
  1949. return not (self == other)
  1950. all_structs.append(GetTypeInfo_result)
  1951. GetTypeInfo_result.thrift_spec = (
  1952. (0, TType.STRUCT, 'success', [TGetTypeInfoResp, None], None, ), # 0
  1953. )
  1954. class GetCatalogs_args(object):
  1955. """
  1956. Attributes:
  1957. - req
  1958. """
  1959. def __init__(self, req=None,):
  1960. self.req = req
  1961. def read(self, iprot):
  1962. if iprot._fast_decode is not None and isinstance(iprot.trans, TTransport.CReadableTransport) and self.thrift_spec is not None:
  1963. iprot._fast_decode(self, iprot, [self.__class__, self.thrift_spec])
  1964. return
  1965. iprot.readStructBegin()
  1966. while True:
  1967. (fname, ftype, fid) = iprot.readFieldBegin()
  1968. if ftype == TType.STOP:
  1969. break
  1970. if fid == 1:
  1971. if ftype == TType.STRUCT:
  1972. self.req = TGetCatalogsReq()
  1973. self.req.read(iprot)
  1974. else:
  1975. iprot.skip(ftype)
  1976. else:
  1977. iprot.skip(ftype)
  1978. iprot.readFieldEnd()
  1979. iprot.readStructEnd()
  1980. def write(self, oprot):
  1981. if oprot._fast_encode is not None and self.thrift_spec is not None:
  1982. oprot.trans.write(oprot._fast_encode(self, [self.__class__, self.thrift_spec]))
  1983. return
  1984. oprot.writeStructBegin('GetCatalogs_args')
  1985. if self.req is not None:
  1986. oprot.writeFieldBegin('req', TType.STRUCT, 1)
  1987. self.req.write(oprot)
  1988. oprot.writeFieldEnd()
  1989. oprot.writeFieldStop()
  1990. oprot.writeStructEnd()
  1991. def validate(self):
  1992. return
  1993. def __repr__(self):
  1994. L = ['%s=%r' % (key, value)
  1995. for key, value in self.__dict__.items()]
  1996. return '%s(%s)' % (self.__class__.__name__, ', '.join(L))
  1997. def __eq__(self, other):
  1998. return isinstance(other, self.__class__) and self.__dict__ == other.__dict__
  1999. def __ne__(self, other):
  2000. return not (self == other)
  2001. all_structs.append(GetCatalogs_args)
  2002. GetCatalogs_args.thrift_spec = (
  2003. None, # 0
  2004. (1, TType.STRUCT, 'req', [TGetCatalogsReq, None], None, ), # 1
  2005. )
  2006. class GetCatalogs_result(object):
  2007. """
  2008. Attributes:
  2009. - success
  2010. """
  2011. def __init__(self, success=None,):
  2012. self.success = success
  2013. def read(self, iprot):
  2014. if iprot._fast_decode is not None and isinstance(iprot.trans, TTransport.CReadableTransport) and self.thrift_spec is not None:
  2015. iprot._fast_decode(self, iprot, [self.__class__, self.thrift_spec])
  2016. return
  2017. iprot.readStructBegin()
  2018. while True:
  2019. (fname, ftype, fid) = iprot.readFieldBegin()
  2020. if ftype == TType.STOP:
  2021. break
  2022. if fid == 0:
  2023. if ftype == TType.STRUCT:
  2024. self.success = TGetCatalogsResp()
  2025. self.success.read(iprot)
  2026. else:
  2027. iprot.skip(ftype)
  2028. else:
  2029. iprot.skip(ftype)
  2030. iprot.readFieldEnd()
  2031. iprot.readStructEnd()
  2032. def write(self, oprot):
  2033. if oprot._fast_encode is not None and self.thrift_spec is not None:
  2034. oprot.trans.write(oprot._fast_encode(self, [self.__class__, self.thrift_spec]))
  2035. return
  2036. oprot.writeStructBegin('GetCatalogs_result')
  2037. if self.success is not None:
  2038. oprot.writeFieldBegin('success', TType.STRUCT, 0)
  2039. self.success.write(oprot)
  2040. oprot.writeFieldEnd()
  2041. oprot.writeFieldStop()
  2042. oprot.writeStructEnd()
  2043. def validate(self):
  2044. return
  2045. def __repr__(self):
  2046. L = ['%s=%r' % (key, value)
  2047. for key, value in self.__dict__.items()]
  2048. return '%s(%s)' % (self.__class__.__name__, ', '.join(L))
  2049. def __eq__(self, other):
  2050. return isinstance(other, self.__class__) and self.__dict__ == other.__dict__
  2051. def __ne__(self, other):
  2052. return not (self == other)
  2053. all_structs.append(GetCatalogs_result)
  2054. GetCatalogs_result.thrift_spec = (
  2055. (0, TType.STRUCT, 'success', [TGetCatalogsResp, None], None, ), # 0
  2056. )
  2057. class GetSchemas_args(object):
  2058. """
  2059. Attributes:
  2060. - req
  2061. """
  2062. def __init__(self, req=None,):
  2063. self.req = req
  2064. def read(self, iprot):
  2065. if iprot._fast_decode is not None and isinstance(iprot.trans, TTransport.CReadableTransport) and self.thrift_spec is not None:
  2066. iprot._fast_decode(self, iprot, [self.__class__, self.thrift_spec])
  2067. return
  2068. iprot.readStructBegin()
  2069. while True:
  2070. (fname, ftype, fid) = iprot.readFieldBegin()
  2071. if ftype == TType.STOP:
  2072. break
  2073. if fid == 1:
  2074. if ftype == TType.STRUCT:
  2075. self.req = TGetSchemasReq()
  2076. self.req.read(iprot)
  2077. else:
  2078. iprot.skip(ftype)
  2079. else:
  2080. iprot.skip(ftype)
  2081. iprot.readFieldEnd()
  2082. iprot.readStructEnd()
  2083. def write(self, oprot):
  2084. if oprot._fast_encode is not None and self.thrift_spec is not None:
  2085. oprot.trans.write(oprot._fast_encode(self, [self.__class__, self.thrift_spec]))
  2086. return
  2087. oprot.writeStructBegin('GetSchemas_args')
  2088. if self.req is not None:
  2089. oprot.writeFieldBegin('req', TType.STRUCT, 1)
  2090. self.req.write(oprot)
  2091. oprot.writeFieldEnd()
  2092. oprot.writeFieldStop()
  2093. oprot.writeStructEnd()
  2094. def validate(self):
  2095. return
  2096. def __repr__(self):
  2097. L = ['%s=%r' % (key, value)
  2098. for key, value in self.__dict__.items()]
  2099. return '%s(%s)' % (self.__class__.__name__, ', '.join(L))
  2100. def __eq__(self, other):
  2101. return isinstance(other, self.__class__) and self.__dict__ == other.__dict__
  2102. def __ne__(self, other):
  2103. return not (self == other)
  2104. all_structs.append(GetSchemas_args)
  2105. GetSchemas_args.thrift_spec = (
  2106. None, # 0
  2107. (1, TType.STRUCT, 'req', [TGetSchemasReq, None], None, ), # 1
  2108. )
  2109. class GetSchemas_result(object):
  2110. """
  2111. Attributes:
  2112. - success
  2113. """
  2114. def __init__(self, success=None,):
  2115. self.success = success
  2116. def read(self, iprot):
  2117. if iprot._fast_decode is not None and isinstance(iprot.trans, TTransport.CReadableTransport) and self.thrift_spec is not None:
  2118. iprot._fast_decode(self, iprot, [self.__class__, self.thrift_spec])
  2119. return
  2120. iprot.readStructBegin()
  2121. while True:
  2122. (fname, ftype, fid) = iprot.readFieldBegin()
  2123. if ftype == TType.STOP:
  2124. break
  2125. if fid == 0:
  2126. if ftype == TType.STRUCT:
  2127. self.success = TGetSchemasResp()
  2128. self.success.read(iprot)
  2129. else:
  2130. iprot.skip(ftype)
  2131. else:
  2132. iprot.skip(ftype)
  2133. iprot.readFieldEnd()
  2134. iprot.readStructEnd()
  2135. def write(self, oprot):
  2136. if oprot._fast_encode is not None and self.thrift_spec is not None:
  2137. oprot.trans.write(oprot._fast_encode(self, [self.__class__, self.thrift_spec]))
  2138. return
  2139. oprot.writeStructBegin('GetSchemas_result')
  2140. if self.success is not None:
  2141. oprot.writeFieldBegin('success', TType.STRUCT, 0)
  2142. self.success.write(oprot)
  2143. oprot.writeFieldEnd()
  2144. oprot.writeFieldStop()
  2145. oprot.writeStructEnd()
  2146. def validate(self):
  2147. return
  2148. def __repr__(self):
  2149. L = ['%s=%r' % (key, value)
  2150. for key, value in self.__dict__.items()]
  2151. return '%s(%s)' % (self.__class__.__name__, ', '.join(L))
  2152. def __eq__(self, other):
  2153. return isinstance(other, self.__class__) and self.__dict__ == other.__dict__
  2154. def __ne__(self, other):
  2155. return not (self == other)
  2156. all_structs.append(GetSchemas_result)
  2157. GetSchemas_result.thrift_spec = (
  2158. (0, TType.STRUCT, 'success', [TGetSchemasResp, None], None, ), # 0
  2159. )
  2160. class GetTables_args(object):
  2161. """
  2162. Attributes:
  2163. - req
  2164. """
  2165. def __init__(self, req=None,):
  2166. self.req = req
  2167. def read(self, iprot):
  2168. if iprot._fast_decode is not None and isinstance(iprot.trans, TTransport.CReadableTransport) and self.thrift_spec is not None:
  2169. iprot._fast_decode(self, iprot, [self.__class__, self.thrift_spec])
  2170. return
  2171. iprot.readStructBegin()
  2172. while True:
  2173. (fname, ftype, fid) = iprot.readFieldBegin()
  2174. if ftype == TType.STOP:
  2175. break
  2176. if fid == 1:
  2177. if ftype == TType.STRUCT:
  2178. self.req = TGetTablesReq()
  2179. self.req.read(iprot)
  2180. else:
  2181. iprot.skip(ftype)
  2182. else:
  2183. iprot.skip(ftype)
  2184. iprot.readFieldEnd()
  2185. iprot.readStructEnd()
  2186. def write(self, oprot):
  2187. if oprot._fast_encode is not None and self.thrift_spec is not None:
  2188. oprot.trans.write(oprot._fast_encode(self, [self.__class__, self.thrift_spec]))
  2189. return
  2190. oprot.writeStructBegin('GetTables_args')
  2191. if self.req is not None:
  2192. oprot.writeFieldBegin('req', TType.STRUCT, 1)
  2193. self.req.write(oprot)
  2194. oprot.writeFieldEnd()
  2195. oprot.writeFieldStop()
  2196. oprot.writeStructEnd()
  2197. def validate(self):
  2198. return
  2199. def __repr__(self):
  2200. L = ['%s=%r' % (key, value)
  2201. for key, value in self.__dict__.items()]
  2202. return '%s(%s)' % (self.__class__.__name__, ', '.join(L))
  2203. def __eq__(self, other):
  2204. return isinstance(other, self.__class__) and self.__dict__ == other.__dict__
  2205. def __ne__(self, other):
  2206. return not (self == other)
  2207. all_structs.append(GetTables_args)
  2208. GetTables_args.thrift_spec = (
  2209. None, # 0
  2210. (1, TType.STRUCT, 'req', [TGetTablesReq, None], None, ), # 1
  2211. )
  2212. class GetTables_result(object):
  2213. """
  2214. Attributes:
  2215. - success
  2216. """
  2217. def __init__(self, success=None,):
  2218. self.success = success
  2219. def read(self, iprot):
  2220. if iprot._fast_decode is not None and isinstance(iprot.trans, TTransport.CReadableTransport) and self.thrift_spec is not None:
  2221. iprot._fast_decode(self, iprot, [self.__class__, self.thrift_spec])
  2222. return
  2223. iprot.readStructBegin()
  2224. while True:
  2225. (fname, ftype, fid) = iprot.readFieldBegin()
  2226. if ftype == TType.STOP:
  2227. break
  2228. if fid == 0:
  2229. if ftype == TType.STRUCT:
  2230. self.success = TGetTablesResp()
  2231. self.success.read(iprot)
  2232. else:
  2233. iprot.skip(ftype)
  2234. else:
  2235. iprot.skip(ftype)
  2236. iprot.readFieldEnd()
  2237. iprot.readStructEnd()
  2238. def write(self, oprot):
  2239. if oprot._fast_encode is not None and self.thrift_spec is not None:
  2240. oprot.trans.write(oprot._fast_encode(self, [self.__class__, self.thrift_spec]))
  2241. return
  2242. oprot.writeStructBegin('GetTables_result')
  2243. if self.success is not None:
  2244. oprot.writeFieldBegin('success', TType.STRUCT, 0)
  2245. self.success.write(oprot)
  2246. oprot.writeFieldEnd()
  2247. oprot.writeFieldStop()
  2248. oprot.writeStructEnd()
  2249. def validate(self):
  2250. return
  2251. def __repr__(self):
  2252. L = ['%s=%r' % (key, value)
  2253. for key, value in self.__dict__.items()]
  2254. return '%s(%s)' % (self.__class__.__name__, ', '.join(L))
  2255. def __eq__(self, other):
  2256. return isinstance(other, self.__class__) and self.__dict__ == other.__dict__
  2257. def __ne__(self, other):
  2258. return not (self == other)
  2259. all_structs.append(GetTables_result)
  2260. GetTables_result.thrift_spec = (
  2261. (0, TType.STRUCT, 'success', [TGetTablesResp, None], None, ), # 0
  2262. )
  2263. class GetTableTypes_args(object):
  2264. """
  2265. Attributes:
  2266. - req
  2267. """
  2268. def __init__(self, req=None,):
  2269. self.req = req
  2270. def read(self, iprot):
  2271. if iprot._fast_decode is not None and isinstance(iprot.trans, TTransport.CReadableTransport) and self.thrift_spec is not None:
  2272. iprot._fast_decode(self, iprot, [self.__class__, self.thrift_spec])
  2273. return
  2274. iprot.readStructBegin()
  2275. while True:
  2276. (fname, ftype, fid) = iprot.readFieldBegin()
  2277. if ftype == TType.STOP:
  2278. break
  2279. if fid == 1:
  2280. if ftype == TType.STRUCT:
  2281. self.req = TGetTableTypesReq()
  2282. self.req.read(iprot)
  2283. else:
  2284. iprot.skip(ftype)
  2285. else:
  2286. iprot.skip(ftype)
  2287. iprot.readFieldEnd()
  2288. iprot.readStructEnd()
  2289. def write(self, oprot):
  2290. if oprot._fast_encode is not None and self.thrift_spec is not None:
  2291. oprot.trans.write(oprot._fast_encode(self, [self.__class__, self.thrift_spec]))
  2292. return
  2293. oprot.writeStructBegin('GetTableTypes_args')
  2294. if self.req is not None:
  2295. oprot.writeFieldBegin('req', TType.STRUCT, 1)
  2296. self.req.write(oprot)
  2297. oprot.writeFieldEnd()
  2298. oprot.writeFieldStop()
  2299. oprot.writeStructEnd()
  2300. def validate(self):
  2301. return
  2302. def __repr__(self):
  2303. L = ['%s=%r' % (key, value)
  2304. for key, value in self.__dict__.items()]
  2305. return '%s(%s)' % (self.__class__.__name__, ', '.join(L))
  2306. def __eq__(self, other):
  2307. return isinstance(other, self.__class__) and self.__dict__ == other.__dict__
  2308. def __ne__(self, other):
  2309. return not (self == other)
  2310. all_structs.append(GetTableTypes_args)
  2311. GetTableTypes_args.thrift_spec = (
  2312. None, # 0
  2313. (1, TType.STRUCT, 'req', [TGetTableTypesReq, None], None, ), # 1
  2314. )
  2315. class GetTableTypes_result(object):
  2316. """
  2317. Attributes:
  2318. - success
  2319. """
  2320. def __init__(self, success=None,):
  2321. self.success = success
  2322. def read(self, iprot):
  2323. if iprot._fast_decode is not None and isinstance(iprot.trans, TTransport.CReadableTransport) and self.thrift_spec is not None:
  2324. iprot._fast_decode(self, iprot, [self.__class__, self.thrift_spec])
  2325. return
  2326. iprot.readStructBegin()
  2327. while True:
  2328. (fname, ftype, fid) = iprot.readFieldBegin()
  2329. if ftype == TType.STOP:
  2330. break
  2331. if fid == 0:
  2332. if ftype == TType.STRUCT:
  2333. self.success = TGetTableTypesResp()
  2334. self.success.read(iprot)
  2335. else:
  2336. iprot.skip(ftype)
  2337. else:
  2338. iprot.skip(ftype)
  2339. iprot.readFieldEnd()
  2340. iprot.readStructEnd()
  2341. def write(self, oprot):
  2342. if oprot._fast_encode is not None and self.thrift_spec is not None:
  2343. oprot.trans.write(oprot._fast_encode(self, [self.__class__, self.thrift_spec]))
  2344. return
  2345. oprot.writeStructBegin('GetTableTypes_result')
  2346. if self.success is not None:
  2347. oprot.writeFieldBegin('success', TType.STRUCT, 0)
  2348. self.success.write(oprot)
  2349. oprot.writeFieldEnd()
  2350. oprot.writeFieldStop()
  2351. oprot.writeStructEnd()
  2352. def validate(self):
  2353. return
  2354. def __repr__(self):
  2355. L = ['%s=%r' % (key, value)
  2356. for key, value in self.__dict__.items()]
  2357. return '%s(%s)' % (self.__class__.__name__, ', '.join(L))
  2358. def __eq__(self, other):
  2359. return isinstance(other, self.__class__) and self.__dict__ == other.__dict__
  2360. def __ne__(self, other):
  2361. return not (self == other)
  2362. all_structs.append(GetTableTypes_result)
  2363. GetTableTypes_result.thrift_spec = (
  2364. (0, TType.STRUCT, 'success', [TGetTableTypesResp, None], None, ), # 0
  2365. )
  2366. class GetColumns_args(object):
  2367. """
  2368. Attributes:
  2369. - req
  2370. """
  2371. def __init__(self, req=None,):
  2372. self.req = req
  2373. def read(self, iprot):
  2374. if iprot._fast_decode is not None and isinstance(iprot.trans, TTransport.CReadableTransport) and self.thrift_spec is not None:
  2375. iprot._fast_decode(self, iprot, [self.__class__, self.thrift_spec])
  2376. return
  2377. iprot.readStructBegin()
  2378. while True:
  2379. (fname, ftype, fid) = iprot.readFieldBegin()
  2380. if ftype == TType.STOP:
  2381. break
  2382. if fid == 1:
  2383. if ftype == TType.STRUCT:
  2384. self.req = TGetColumnsReq()
  2385. self.req.read(iprot)
  2386. else:
  2387. iprot.skip(ftype)
  2388. else:
  2389. iprot.skip(ftype)
  2390. iprot.readFieldEnd()
  2391. iprot.readStructEnd()
  2392. def write(self, oprot):
  2393. if oprot._fast_encode is not None and self.thrift_spec is not None:
  2394. oprot.trans.write(oprot._fast_encode(self, [self.__class__, self.thrift_spec]))
  2395. return
  2396. oprot.writeStructBegin('GetColumns_args')
  2397. if self.req is not None:
  2398. oprot.writeFieldBegin('req', TType.STRUCT, 1)
  2399. self.req.write(oprot)
  2400. oprot.writeFieldEnd()
  2401. oprot.writeFieldStop()
  2402. oprot.writeStructEnd()
  2403. def validate(self):
  2404. return
  2405. def __repr__(self):
  2406. L = ['%s=%r' % (key, value)
  2407. for key, value in self.__dict__.items()]
  2408. return '%s(%s)' % (self.__class__.__name__, ', '.join(L))
  2409. def __eq__(self, other):
  2410. return isinstance(other, self.__class__) and self.__dict__ == other.__dict__
  2411. def __ne__(self, other):
  2412. return not (self == other)
  2413. all_structs.append(GetColumns_args)
  2414. GetColumns_args.thrift_spec = (
  2415. None, # 0
  2416. (1, TType.STRUCT, 'req', [TGetColumnsReq, None], None, ), # 1
  2417. )
  2418. class GetColumns_result(object):
  2419. """
  2420. Attributes:
  2421. - success
  2422. """
  2423. def __init__(self, success=None,):
  2424. self.success = success
  2425. def read(self, iprot):
  2426. if iprot._fast_decode is not None and isinstance(iprot.trans, TTransport.CReadableTransport) and self.thrift_spec is not None:
  2427. iprot._fast_decode(self, iprot, [self.__class__, self.thrift_spec])
  2428. return
  2429. iprot.readStructBegin()
  2430. while True:
  2431. (fname, ftype, fid) = iprot.readFieldBegin()
  2432. if ftype == TType.STOP:
  2433. break
  2434. if fid == 0:
  2435. if ftype == TType.STRUCT:
  2436. self.success = TGetColumnsResp()
  2437. self.success.read(iprot)
  2438. else:
  2439. iprot.skip(ftype)
  2440. else:
  2441. iprot.skip(ftype)
  2442. iprot.readFieldEnd()
  2443. iprot.readStructEnd()
  2444. def write(self, oprot):
  2445. if oprot._fast_encode is not None and self.thrift_spec is not None:
  2446. oprot.trans.write(oprot._fast_encode(self, [self.__class__, self.thrift_spec]))
  2447. return
  2448. oprot.writeStructBegin('GetColumns_result')
  2449. if self.success is not None:
  2450. oprot.writeFieldBegin('success', TType.STRUCT, 0)
  2451. self.success.write(oprot)
  2452. oprot.writeFieldEnd()
  2453. oprot.writeFieldStop()
  2454. oprot.writeStructEnd()
  2455. def validate(self):
  2456. return
  2457. def __repr__(self):
  2458. L = ['%s=%r' % (key, value)
  2459. for key, value in self.__dict__.items()]
  2460. return '%s(%s)' % (self.__class__.__name__, ', '.join(L))
  2461. def __eq__(self, other):
  2462. return isinstance(other, self.__class__) and self.__dict__ == other.__dict__
  2463. def __ne__(self, other):
  2464. return not (self == other)
  2465. all_structs.append(GetColumns_result)
  2466. GetColumns_result.thrift_spec = (
  2467. (0, TType.STRUCT, 'success', [TGetColumnsResp, None], None, ), # 0
  2468. )
  2469. class GetFunctions_args(object):
  2470. """
  2471. Attributes:
  2472. - req
  2473. """
  2474. def __init__(self, req=None,):
  2475. self.req = req
  2476. def read(self, iprot):
  2477. if iprot._fast_decode is not None and isinstance(iprot.trans, TTransport.CReadableTransport) and self.thrift_spec is not None:
  2478. iprot._fast_decode(self, iprot, [self.__class__, self.thrift_spec])
  2479. return
  2480. iprot.readStructBegin()
  2481. while True:
  2482. (fname, ftype, fid) = iprot.readFieldBegin()
  2483. if ftype == TType.STOP:
  2484. break
  2485. if fid == 1:
  2486. if ftype == TType.STRUCT:
  2487. self.req = TGetFunctionsReq()
  2488. self.req.read(iprot)
  2489. else:
  2490. iprot.skip(ftype)
  2491. else:
  2492. iprot.skip(ftype)
  2493. iprot.readFieldEnd()
  2494. iprot.readStructEnd()
  2495. def write(self, oprot):
  2496. if oprot._fast_encode is not None and self.thrift_spec is not None:
  2497. oprot.trans.write(oprot._fast_encode(self, [self.__class__, self.thrift_spec]))
  2498. return
  2499. oprot.writeStructBegin('GetFunctions_args')
  2500. if self.req is not None:
  2501. oprot.writeFieldBegin('req', TType.STRUCT, 1)
  2502. self.req.write(oprot)
  2503. oprot.writeFieldEnd()
  2504. oprot.writeFieldStop()
  2505. oprot.writeStructEnd()
  2506. def validate(self):
  2507. return
  2508. def __repr__(self):
  2509. L = ['%s=%r' % (key, value)
  2510. for key, value in self.__dict__.items()]
  2511. return '%s(%s)' % (self.__class__.__name__, ', '.join(L))
  2512. def __eq__(self, other):
  2513. return isinstance(other, self.__class__) and self.__dict__ == other.__dict__
  2514. def __ne__(self, other):
  2515. return not (self == other)
  2516. all_structs.append(GetFunctions_args)
  2517. GetFunctions_args.thrift_spec = (
  2518. None, # 0
  2519. (1, TType.STRUCT, 'req', [TGetFunctionsReq, None], None, ), # 1
  2520. )
  2521. class GetFunctions_result(object):
  2522. """
  2523. Attributes:
  2524. - success
  2525. """
  2526. def __init__(self, success=None,):
  2527. self.success = success
  2528. def read(self, iprot):
  2529. if iprot._fast_decode is not None and isinstance(iprot.trans, TTransport.CReadableTransport) and self.thrift_spec is not None:
  2530. iprot._fast_decode(self, iprot, [self.__class__, self.thrift_spec])
  2531. return
  2532. iprot.readStructBegin()
  2533. while True:
  2534. (fname, ftype, fid) = iprot.readFieldBegin()
  2535. if ftype == TType.STOP:
  2536. break
  2537. if fid == 0:
  2538. if ftype == TType.STRUCT:
  2539. self.success = TGetFunctionsResp()
  2540. self.success.read(iprot)
  2541. else:
  2542. iprot.skip(ftype)
  2543. else:
  2544. iprot.skip(ftype)
  2545. iprot.readFieldEnd()
  2546. iprot.readStructEnd()
  2547. def write(self, oprot):
  2548. if oprot._fast_encode is not None and self.thrift_spec is not None:
  2549. oprot.trans.write(oprot._fast_encode(self, [self.__class__, self.thrift_spec]))
  2550. return
  2551. oprot.writeStructBegin('GetFunctions_result')
  2552. if self.success is not None:
  2553. oprot.writeFieldBegin('success', TType.STRUCT, 0)
  2554. self.success.write(oprot)
  2555. oprot.writeFieldEnd()
  2556. oprot.writeFieldStop()
  2557. oprot.writeStructEnd()
  2558. def validate(self):
  2559. return
  2560. def __repr__(self):
  2561. L = ['%s=%r' % (key, value)
  2562. for key, value in self.__dict__.items()]
  2563. return '%s(%s)' % (self.__class__.__name__, ', '.join(L))
  2564. def __eq__(self, other):
  2565. return isinstance(other, self.__class__) and self.__dict__ == other.__dict__
  2566. def __ne__(self, other):
  2567. return not (self == other)
  2568. all_structs.append(GetFunctions_result)
  2569. GetFunctions_result.thrift_spec = (
  2570. (0, TType.STRUCT, 'success', [TGetFunctionsResp, None], None, ), # 0
  2571. )
  2572. class GetPrimaryKeys_args(object):
  2573. """
  2574. Attributes:
  2575. - req
  2576. """
  2577. def __init__(self, req=None,):
  2578. self.req = req
  2579. def read(self, iprot):
  2580. if iprot._fast_decode is not None and isinstance(iprot.trans, TTransport.CReadableTransport) and self.thrift_spec is not None:
  2581. iprot._fast_decode(self, iprot, [self.__class__, self.thrift_spec])
  2582. return
  2583. iprot.readStructBegin()
  2584. while True:
  2585. (fname, ftype, fid) = iprot.readFieldBegin()
  2586. if ftype == TType.STOP:
  2587. break
  2588. if fid == 1:
  2589. if ftype == TType.STRUCT:
  2590. self.req = TGetPrimaryKeysReq()
  2591. self.req.read(iprot)
  2592. else:
  2593. iprot.skip(ftype)
  2594. else:
  2595. iprot.skip(ftype)
  2596. iprot.readFieldEnd()
  2597. iprot.readStructEnd()
  2598. def write(self, oprot):
  2599. if oprot._fast_encode is not None and self.thrift_spec is not None:
  2600. oprot.trans.write(oprot._fast_encode(self, [self.__class__, self.thrift_spec]))
  2601. return
  2602. oprot.writeStructBegin('GetPrimaryKeys_args')
  2603. if self.req is not None:
  2604. oprot.writeFieldBegin('req', TType.STRUCT, 1)
  2605. self.req.write(oprot)
  2606. oprot.writeFieldEnd()
  2607. oprot.writeFieldStop()
  2608. oprot.writeStructEnd()
  2609. def validate(self):
  2610. return
  2611. def __repr__(self):
  2612. L = ['%s=%r' % (key, value)
  2613. for key, value in self.__dict__.items()]
  2614. return '%s(%s)' % (self.__class__.__name__, ', '.join(L))
  2615. def __eq__(self, other):
  2616. return isinstance(other, self.__class__) and self.__dict__ == other.__dict__
  2617. def __ne__(self, other):
  2618. return not (self == other)
  2619. all_structs.append(GetPrimaryKeys_args)
  2620. GetPrimaryKeys_args.thrift_spec = (
  2621. None, # 0
  2622. (1, TType.STRUCT, 'req', [TGetPrimaryKeysReq, None], None, ), # 1
  2623. )
  2624. class GetPrimaryKeys_result(object):
  2625. """
  2626. Attributes:
  2627. - success
  2628. """
  2629. def __init__(self, success=None,):
  2630. self.success = success
  2631. def read(self, iprot):
  2632. if iprot._fast_decode is not None and isinstance(iprot.trans, TTransport.CReadableTransport) and self.thrift_spec is not None:
  2633. iprot._fast_decode(self, iprot, [self.__class__, self.thrift_spec])
  2634. return
  2635. iprot.readStructBegin()
  2636. while True:
  2637. (fname, ftype, fid) = iprot.readFieldBegin()
  2638. if ftype == TType.STOP:
  2639. break
  2640. if fid == 0:
  2641. if ftype == TType.STRUCT:
  2642. self.success = TGetPrimaryKeysResp()
  2643. self.success.read(iprot)
  2644. else:
  2645. iprot.skip(ftype)
  2646. else:
  2647. iprot.skip(ftype)
  2648. iprot.readFieldEnd()
  2649. iprot.readStructEnd()
  2650. def write(self, oprot):
  2651. if oprot._fast_encode is not None and self.thrift_spec is not None:
  2652. oprot.trans.write(oprot._fast_encode(self, [self.__class__, self.thrift_spec]))
  2653. return
  2654. oprot.writeStructBegin('GetPrimaryKeys_result')
  2655. if self.success is not None:
  2656. oprot.writeFieldBegin('success', TType.STRUCT, 0)
  2657. self.success.write(oprot)
  2658. oprot.writeFieldEnd()
  2659. oprot.writeFieldStop()
  2660. oprot.writeStructEnd()
  2661. def validate(self):
  2662. return
  2663. def __repr__(self):
  2664. L = ['%s=%r' % (key, value)
  2665. for key, value in self.__dict__.items()]
  2666. return '%s(%s)' % (self.__class__.__name__, ', '.join(L))
  2667. def __eq__(self, other):
  2668. return isinstance(other, self.__class__) and self.__dict__ == other.__dict__
  2669. def __ne__(self, other):
  2670. return not (self == other)
  2671. all_structs.append(GetPrimaryKeys_result)
  2672. GetPrimaryKeys_result.thrift_spec = (
  2673. (0, TType.STRUCT, 'success', [TGetPrimaryKeysResp, None], None, ), # 0
  2674. )
  2675. class GetCrossReference_args(object):
  2676. """
  2677. Attributes:
  2678. - req
  2679. """
  2680. def __init__(self, req=None,):
  2681. self.req = req
  2682. def read(self, iprot):
  2683. if iprot._fast_decode is not None and isinstance(iprot.trans, TTransport.CReadableTransport) and self.thrift_spec is not None:
  2684. iprot._fast_decode(self, iprot, [self.__class__, self.thrift_spec])
  2685. return
  2686. iprot.readStructBegin()
  2687. while True:
  2688. (fname, ftype, fid) = iprot.readFieldBegin()
  2689. if ftype == TType.STOP:
  2690. break
  2691. if fid == 1:
  2692. if ftype == TType.STRUCT:
  2693. self.req = TGetCrossReferenceReq()
  2694. self.req.read(iprot)
  2695. else:
  2696. iprot.skip(ftype)
  2697. else:
  2698. iprot.skip(ftype)
  2699. iprot.readFieldEnd()
  2700. iprot.readStructEnd()
  2701. def write(self, oprot):
  2702. if oprot._fast_encode is not None and self.thrift_spec is not None:
  2703. oprot.trans.write(oprot._fast_encode(self, [self.__class__, self.thrift_spec]))
  2704. return
  2705. oprot.writeStructBegin('GetCrossReference_args')
  2706. if self.req is not None:
  2707. oprot.writeFieldBegin('req', TType.STRUCT, 1)
  2708. self.req.write(oprot)
  2709. oprot.writeFieldEnd()
  2710. oprot.writeFieldStop()
  2711. oprot.writeStructEnd()
  2712. def validate(self):
  2713. return
  2714. def __repr__(self):
  2715. L = ['%s=%r' % (key, value)
  2716. for key, value in self.__dict__.items()]
  2717. return '%s(%s)' % (self.__class__.__name__, ', '.join(L))
  2718. def __eq__(self, other):
  2719. return isinstance(other, self.__class__) and self.__dict__ == other.__dict__
  2720. def __ne__(self, other):
  2721. return not (self == other)
  2722. all_structs.append(GetCrossReference_args)
  2723. GetCrossReference_args.thrift_spec = (
  2724. None, # 0
  2725. (1, TType.STRUCT, 'req', [TGetCrossReferenceReq, None], None, ), # 1
  2726. )
  2727. class GetCrossReference_result(object):
  2728. """
  2729. Attributes:
  2730. - success
  2731. """
  2732. def __init__(self, success=None,):
  2733. self.success = success
  2734. def read(self, iprot):
  2735. if iprot._fast_decode is not None and isinstance(iprot.trans, TTransport.CReadableTransport) and self.thrift_spec is not None:
  2736. iprot._fast_decode(self, iprot, [self.__class__, self.thrift_spec])
  2737. return
  2738. iprot.readStructBegin()
  2739. while True:
  2740. (fname, ftype, fid) = iprot.readFieldBegin()
  2741. if ftype == TType.STOP:
  2742. break
  2743. if fid == 0:
  2744. if ftype == TType.STRUCT:
  2745. self.success = TGetCrossReferenceResp()
  2746. self.success.read(iprot)
  2747. else:
  2748. iprot.skip(ftype)
  2749. else:
  2750. iprot.skip(ftype)
  2751. iprot.readFieldEnd()
  2752. iprot.readStructEnd()
  2753. def write(self, oprot):
  2754. if oprot._fast_encode is not None and self.thrift_spec is not None:
  2755. oprot.trans.write(oprot._fast_encode(self, [self.__class__, self.thrift_spec]))
  2756. return
  2757. oprot.writeStructBegin('GetCrossReference_result')
  2758. if self.success is not None:
  2759. oprot.writeFieldBegin('success', TType.STRUCT, 0)
  2760. self.success.write(oprot)
  2761. oprot.writeFieldEnd()
  2762. oprot.writeFieldStop()
  2763. oprot.writeStructEnd()
  2764. def validate(self):
  2765. return
  2766. def __repr__(self):
  2767. L = ['%s=%r' % (key, value)
  2768. for key, value in self.__dict__.items()]
  2769. return '%s(%s)' % (self.__class__.__name__, ', '.join(L))
  2770. def __eq__(self, other):
  2771. return isinstance(other, self.__class__) and self.__dict__ == other.__dict__
  2772. def __ne__(self, other):
  2773. return not (self == other)
  2774. all_structs.append(GetCrossReference_result)
  2775. GetCrossReference_result.thrift_spec = (
  2776. (0, TType.STRUCT, 'success', [TGetCrossReferenceResp, None], None, ), # 0
  2777. )
  2778. class GetOperationStatus_args(object):
  2779. """
  2780. Attributes:
  2781. - req
  2782. """
  2783. def __init__(self, req=None,):
  2784. self.req = req
  2785. def read(self, iprot):
  2786. if iprot._fast_decode is not None and isinstance(iprot.trans, TTransport.CReadableTransport) and self.thrift_spec is not None:
  2787. iprot._fast_decode(self, iprot, [self.__class__, self.thrift_spec])
  2788. return
  2789. iprot.readStructBegin()
  2790. while True:
  2791. (fname, ftype, fid) = iprot.readFieldBegin()
  2792. if ftype == TType.STOP:
  2793. break
  2794. if fid == 1:
  2795. if ftype == TType.STRUCT:
  2796. self.req = TGetOperationStatusReq()
  2797. self.req.read(iprot)
  2798. else:
  2799. iprot.skip(ftype)
  2800. else:
  2801. iprot.skip(ftype)
  2802. iprot.readFieldEnd()
  2803. iprot.readStructEnd()
  2804. def write(self, oprot):
  2805. if oprot._fast_encode is not None and self.thrift_spec is not None:
  2806. oprot.trans.write(oprot._fast_encode(self, [self.__class__, self.thrift_spec]))
  2807. return
  2808. oprot.writeStructBegin('GetOperationStatus_args')
  2809. if self.req is not None:
  2810. oprot.writeFieldBegin('req', TType.STRUCT, 1)
  2811. self.req.write(oprot)
  2812. oprot.writeFieldEnd()
  2813. oprot.writeFieldStop()
  2814. oprot.writeStructEnd()
  2815. def validate(self):
  2816. return
  2817. def __repr__(self):
  2818. L = ['%s=%r' % (key, value)
  2819. for key, value in self.__dict__.items()]
  2820. return '%s(%s)' % (self.__class__.__name__, ', '.join(L))
  2821. def __eq__(self, other):
  2822. return isinstance(other, self.__class__) and self.__dict__ == other.__dict__
  2823. def __ne__(self, other):
  2824. return not (self == other)
  2825. all_structs.append(GetOperationStatus_args)
  2826. GetOperationStatus_args.thrift_spec = (
  2827. None, # 0
  2828. (1, TType.STRUCT, 'req', [TGetOperationStatusReq, None], None, ), # 1
  2829. )
  2830. class GetOperationStatus_result(object):
  2831. """
  2832. Attributes:
  2833. - success
  2834. """
  2835. def __init__(self, success=None,):
  2836. self.success = success
  2837. def read(self, iprot):
  2838. if iprot._fast_decode is not None and isinstance(iprot.trans, TTransport.CReadableTransport) and self.thrift_spec is not None:
  2839. iprot._fast_decode(self, iprot, [self.__class__, self.thrift_spec])
  2840. return
  2841. iprot.readStructBegin()
  2842. while True:
  2843. (fname, ftype, fid) = iprot.readFieldBegin()
  2844. if ftype == TType.STOP:
  2845. break
  2846. if fid == 0:
  2847. if ftype == TType.STRUCT:
  2848. self.success = TGetOperationStatusResp()
  2849. self.success.read(iprot)
  2850. else:
  2851. iprot.skip(ftype)
  2852. else:
  2853. iprot.skip(ftype)
  2854. iprot.readFieldEnd()
  2855. iprot.readStructEnd()
  2856. def write(self, oprot):
  2857. if oprot._fast_encode is not None and self.thrift_spec is not None:
  2858. oprot.trans.write(oprot._fast_encode(self, [self.__class__, self.thrift_spec]))
  2859. return
  2860. oprot.writeStructBegin('GetOperationStatus_result')
  2861. if self.success is not None:
  2862. oprot.writeFieldBegin('success', TType.STRUCT, 0)
  2863. self.success.write(oprot)
  2864. oprot.writeFieldEnd()
  2865. oprot.writeFieldStop()
  2866. oprot.writeStructEnd()
  2867. def validate(self):
  2868. return
  2869. def __repr__(self):
  2870. L = ['%s=%r' % (key, value)
  2871. for key, value in self.__dict__.items()]
  2872. return '%s(%s)' % (self.__class__.__name__, ', '.join(L))
  2873. def __eq__(self, other):
  2874. return isinstance(other, self.__class__) and self.__dict__ == other.__dict__
  2875. def __ne__(self, other):
  2876. return not (self == other)
  2877. all_structs.append(GetOperationStatus_result)
  2878. GetOperationStatus_result.thrift_spec = (
  2879. (0, TType.STRUCT, 'success', [TGetOperationStatusResp, None], None, ), # 0
  2880. )
  2881. class CancelOperation_args(object):
  2882. """
  2883. Attributes:
  2884. - req
  2885. """
  2886. def __init__(self, req=None,):
  2887. self.req = req
  2888. def read(self, iprot):
  2889. if iprot._fast_decode is not None and isinstance(iprot.trans, TTransport.CReadableTransport) and self.thrift_spec is not None:
  2890. iprot._fast_decode(self, iprot, [self.__class__, self.thrift_spec])
  2891. return
  2892. iprot.readStructBegin()
  2893. while True:
  2894. (fname, ftype, fid) = iprot.readFieldBegin()
  2895. if ftype == TType.STOP:
  2896. break
  2897. if fid == 1:
  2898. if ftype == TType.STRUCT:
  2899. self.req = TCancelOperationReq()
  2900. self.req.read(iprot)
  2901. else:
  2902. iprot.skip(ftype)
  2903. else:
  2904. iprot.skip(ftype)
  2905. iprot.readFieldEnd()
  2906. iprot.readStructEnd()
  2907. def write(self, oprot):
  2908. if oprot._fast_encode is not None and self.thrift_spec is not None:
  2909. oprot.trans.write(oprot._fast_encode(self, [self.__class__, self.thrift_spec]))
  2910. return
  2911. oprot.writeStructBegin('CancelOperation_args')
  2912. if self.req is not None:
  2913. oprot.writeFieldBegin('req', TType.STRUCT, 1)
  2914. self.req.write(oprot)
  2915. oprot.writeFieldEnd()
  2916. oprot.writeFieldStop()
  2917. oprot.writeStructEnd()
  2918. def validate(self):
  2919. return
  2920. def __repr__(self):
  2921. L = ['%s=%r' % (key, value)
  2922. for key, value in self.__dict__.items()]
  2923. return '%s(%s)' % (self.__class__.__name__, ', '.join(L))
  2924. def __eq__(self, other):
  2925. return isinstance(other, self.__class__) and self.__dict__ == other.__dict__
  2926. def __ne__(self, other):
  2927. return not (self == other)
  2928. all_structs.append(CancelOperation_args)
  2929. CancelOperation_args.thrift_spec = (
  2930. None, # 0
  2931. (1, TType.STRUCT, 'req', [TCancelOperationReq, None], None, ), # 1
  2932. )
  2933. class CancelOperation_result(object):
  2934. """
  2935. Attributes:
  2936. - success
  2937. """
  2938. def __init__(self, success=None,):
  2939. self.success = success
  2940. def read(self, iprot):
  2941. if iprot._fast_decode is not None and isinstance(iprot.trans, TTransport.CReadableTransport) and self.thrift_spec is not None:
  2942. iprot._fast_decode(self, iprot, [self.__class__, self.thrift_spec])
  2943. return
  2944. iprot.readStructBegin()
  2945. while True:
  2946. (fname, ftype, fid) = iprot.readFieldBegin()
  2947. if ftype == TType.STOP:
  2948. break
  2949. if fid == 0:
  2950. if ftype == TType.STRUCT:
  2951. self.success = TCancelOperationResp()
  2952. self.success.read(iprot)
  2953. else:
  2954. iprot.skip(ftype)
  2955. else:
  2956. iprot.skip(ftype)
  2957. iprot.readFieldEnd()
  2958. iprot.readStructEnd()
  2959. def write(self, oprot):
  2960. if oprot._fast_encode is not None and self.thrift_spec is not None:
  2961. oprot.trans.write(oprot._fast_encode(self, [self.__class__, self.thrift_spec]))
  2962. return
  2963. oprot.writeStructBegin('CancelOperation_result')
  2964. if self.success is not None:
  2965. oprot.writeFieldBegin('success', TType.STRUCT, 0)
  2966. self.success.write(oprot)
  2967. oprot.writeFieldEnd()
  2968. oprot.writeFieldStop()
  2969. oprot.writeStructEnd()
  2970. def validate(self):
  2971. return
  2972. def __repr__(self):
  2973. L = ['%s=%r' % (key, value)
  2974. for key, value in self.__dict__.items()]
  2975. return '%s(%s)' % (self.__class__.__name__, ', '.join(L))
  2976. def __eq__(self, other):
  2977. return isinstance(other, self.__class__) and self.__dict__ == other.__dict__
  2978. def __ne__(self, other):
  2979. return not (self == other)
  2980. all_structs.append(CancelOperation_result)
  2981. CancelOperation_result.thrift_spec = (
  2982. (0, TType.STRUCT, 'success', [TCancelOperationResp, None], None, ), # 0
  2983. )
  2984. class CloseOperation_args(object):
  2985. """
  2986. Attributes:
  2987. - req
  2988. """
  2989. def __init__(self, req=None,):
  2990. self.req = req
  2991. def read(self, iprot):
  2992. if iprot._fast_decode is not None and isinstance(iprot.trans, TTransport.CReadableTransport) and self.thrift_spec is not None:
  2993. iprot._fast_decode(self, iprot, [self.__class__, self.thrift_spec])
  2994. return
  2995. iprot.readStructBegin()
  2996. while True:
  2997. (fname, ftype, fid) = iprot.readFieldBegin()
  2998. if ftype == TType.STOP:
  2999. break
  3000. if fid == 1:
  3001. if ftype == TType.STRUCT:
  3002. self.req = TCloseOperationReq()
  3003. self.req.read(iprot)
  3004. else:
  3005. iprot.skip(ftype)
  3006. else:
  3007. iprot.skip(ftype)
  3008. iprot.readFieldEnd()
  3009. iprot.readStructEnd()
  3010. def write(self, oprot):
  3011. if oprot._fast_encode is not None and self.thrift_spec is not None:
  3012. oprot.trans.write(oprot._fast_encode(self, [self.__class__, self.thrift_spec]))
  3013. return
  3014. oprot.writeStructBegin('CloseOperation_args')
  3015. if self.req is not None:
  3016. oprot.writeFieldBegin('req', TType.STRUCT, 1)
  3017. self.req.write(oprot)
  3018. oprot.writeFieldEnd()
  3019. oprot.writeFieldStop()
  3020. oprot.writeStructEnd()
  3021. def validate(self):
  3022. return
  3023. def __repr__(self):
  3024. L = ['%s=%r' % (key, value)
  3025. for key, value in self.__dict__.items()]
  3026. return '%s(%s)' % (self.__class__.__name__, ', '.join(L))
  3027. def __eq__(self, other):
  3028. return isinstance(other, self.__class__) and self.__dict__ == other.__dict__
  3029. def __ne__(self, other):
  3030. return not (self == other)
  3031. all_structs.append(CloseOperation_args)
  3032. CloseOperation_args.thrift_spec = (
  3033. None, # 0
  3034. (1, TType.STRUCT, 'req', [TCloseOperationReq, None], None, ), # 1
  3035. )
  3036. class CloseOperation_result(object):
  3037. """
  3038. Attributes:
  3039. - success
  3040. """
  3041. def __init__(self, success=None,):
  3042. self.success = success
  3043. def read(self, iprot):
  3044. if iprot._fast_decode is not None and isinstance(iprot.trans, TTransport.CReadableTransport) and self.thrift_spec is not None:
  3045. iprot._fast_decode(self, iprot, [self.__class__, self.thrift_spec])
  3046. return
  3047. iprot.readStructBegin()
  3048. while True:
  3049. (fname, ftype, fid) = iprot.readFieldBegin()
  3050. if ftype == TType.STOP:
  3051. break
  3052. if fid == 0:
  3053. if ftype == TType.STRUCT:
  3054. self.success = TCloseOperationResp()
  3055. self.success.read(iprot)
  3056. else:
  3057. iprot.skip(ftype)
  3058. else:
  3059. iprot.skip(ftype)
  3060. iprot.readFieldEnd()
  3061. iprot.readStructEnd()
  3062. def write(self, oprot):
  3063. if oprot._fast_encode is not None and self.thrift_spec is not None:
  3064. oprot.trans.write(oprot._fast_encode(self, [self.__class__, self.thrift_spec]))
  3065. return
  3066. oprot.writeStructBegin('CloseOperation_result')
  3067. if self.success is not None:
  3068. oprot.writeFieldBegin('success', TType.STRUCT, 0)
  3069. self.success.write(oprot)
  3070. oprot.writeFieldEnd()
  3071. oprot.writeFieldStop()
  3072. oprot.writeStructEnd()
  3073. def validate(self):
  3074. return
  3075. def __repr__(self):
  3076. L = ['%s=%r' % (key, value)
  3077. for key, value in self.__dict__.items()]
  3078. return '%s(%s)' % (self.__class__.__name__, ', '.join(L))
  3079. def __eq__(self, other):
  3080. return isinstance(other, self.__class__) and self.__dict__ == other.__dict__
  3081. def __ne__(self, other):
  3082. return not (self == other)
  3083. all_structs.append(CloseOperation_result)
  3084. CloseOperation_result.thrift_spec = (
  3085. (0, TType.STRUCT, 'success', [TCloseOperationResp, None], None, ), # 0
  3086. )
  3087. class GetResultSetMetadata_args(object):
  3088. """
  3089. Attributes:
  3090. - req
  3091. """
  3092. def __init__(self, req=None,):
  3093. self.req = req
  3094. def read(self, iprot):
  3095. if iprot._fast_decode is not None and isinstance(iprot.trans, TTransport.CReadableTransport) and self.thrift_spec is not None:
  3096. iprot._fast_decode(self, iprot, [self.__class__, self.thrift_spec])
  3097. return
  3098. iprot.readStructBegin()
  3099. while True:
  3100. (fname, ftype, fid) = iprot.readFieldBegin()
  3101. if ftype == TType.STOP:
  3102. break
  3103. if fid == 1:
  3104. if ftype == TType.STRUCT:
  3105. self.req = TGetResultSetMetadataReq()
  3106. self.req.read(iprot)
  3107. else:
  3108. iprot.skip(ftype)
  3109. else:
  3110. iprot.skip(ftype)
  3111. iprot.readFieldEnd()
  3112. iprot.readStructEnd()
  3113. def write(self, oprot):
  3114. if oprot._fast_encode is not None and self.thrift_spec is not None:
  3115. oprot.trans.write(oprot._fast_encode(self, [self.__class__, self.thrift_spec]))
  3116. return
  3117. oprot.writeStructBegin('GetResultSetMetadata_args')
  3118. if self.req is not None:
  3119. oprot.writeFieldBegin('req', TType.STRUCT, 1)
  3120. self.req.write(oprot)
  3121. oprot.writeFieldEnd()
  3122. oprot.writeFieldStop()
  3123. oprot.writeStructEnd()
  3124. def validate(self):
  3125. return
  3126. def __repr__(self):
  3127. L = ['%s=%r' % (key, value)
  3128. for key, value in self.__dict__.items()]
  3129. return '%s(%s)' % (self.__class__.__name__, ', '.join(L))
  3130. def __eq__(self, other):
  3131. return isinstance(other, self.__class__) and self.__dict__ == other.__dict__
  3132. def __ne__(self, other):
  3133. return not (self == other)
  3134. all_structs.append(GetResultSetMetadata_args)
  3135. GetResultSetMetadata_args.thrift_spec = (
  3136. None, # 0
  3137. (1, TType.STRUCT, 'req', [TGetResultSetMetadataReq, None], None, ), # 1
  3138. )
  3139. class GetResultSetMetadata_result(object):
  3140. """
  3141. Attributes:
  3142. - success
  3143. """
  3144. def __init__(self, success=None,):
  3145. self.success = success
  3146. def read(self, iprot):
  3147. if iprot._fast_decode is not None and isinstance(iprot.trans, TTransport.CReadableTransport) and self.thrift_spec is not None:
  3148. iprot._fast_decode(self, iprot, [self.__class__, self.thrift_spec])
  3149. return
  3150. iprot.readStructBegin()
  3151. while True:
  3152. (fname, ftype, fid) = iprot.readFieldBegin()
  3153. if ftype == TType.STOP:
  3154. break
  3155. if fid == 0:
  3156. if ftype == TType.STRUCT:
  3157. self.success = TGetResultSetMetadataResp()
  3158. self.success.read(iprot)
  3159. else:
  3160. iprot.skip(ftype)
  3161. else:
  3162. iprot.skip(ftype)
  3163. iprot.readFieldEnd()
  3164. iprot.readStructEnd()
  3165. def write(self, oprot):
  3166. if oprot._fast_encode is not None and self.thrift_spec is not None:
  3167. oprot.trans.write(oprot._fast_encode(self, [self.__class__, self.thrift_spec]))
  3168. return
  3169. oprot.writeStructBegin('GetResultSetMetadata_result')
  3170. if self.success is not None:
  3171. oprot.writeFieldBegin('success', TType.STRUCT, 0)
  3172. self.success.write(oprot)
  3173. oprot.writeFieldEnd()
  3174. oprot.writeFieldStop()
  3175. oprot.writeStructEnd()
  3176. def validate(self):
  3177. return
  3178. def __repr__(self):
  3179. L = ['%s=%r' % (key, value)
  3180. for key, value in self.__dict__.items()]
  3181. return '%s(%s)' % (self.__class__.__name__, ', '.join(L))
  3182. def __eq__(self, other):
  3183. return isinstance(other, self.__class__) and self.__dict__ == other.__dict__
  3184. def __ne__(self, other):
  3185. return not (self == other)
  3186. all_structs.append(GetResultSetMetadata_result)
  3187. GetResultSetMetadata_result.thrift_spec = (
  3188. (0, TType.STRUCT, 'success', [TGetResultSetMetadataResp, None], None, ), # 0
  3189. )
  3190. class FetchResults_args(object):
  3191. """
  3192. Attributes:
  3193. - req
  3194. """
  3195. def __init__(self, req=None,):
  3196. self.req = req
  3197. def read(self, iprot):
  3198. if iprot._fast_decode is not None and isinstance(iprot.trans, TTransport.CReadableTransport) and self.thrift_spec is not None:
  3199. iprot._fast_decode(self, iprot, [self.__class__, self.thrift_spec])
  3200. return
  3201. iprot.readStructBegin()
  3202. while True:
  3203. (fname, ftype, fid) = iprot.readFieldBegin()
  3204. if ftype == TType.STOP:
  3205. break
  3206. if fid == 1:
  3207. if ftype == TType.STRUCT:
  3208. self.req = TFetchResultsReq()
  3209. self.req.read(iprot)
  3210. else:
  3211. iprot.skip(ftype)
  3212. else:
  3213. iprot.skip(ftype)
  3214. iprot.readFieldEnd()
  3215. iprot.readStructEnd()
  3216. def write(self, oprot):
  3217. if oprot._fast_encode is not None and self.thrift_spec is not None:
  3218. oprot.trans.write(oprot._fast_encode(self, [self.__class__, self.thrift_spec]))
  3219. return
  3220. oprot.writeStructBegin('FetchResults_args')
  3221. if self.req is not None:
  3222. oprot.writeFieldBegin('req', TType.STRUCT, 1)
  3223. self.req.write(oprot)
  3224. oprot.writeFieldEnd()
  3225. oprot.writeFieldStop()
  3226. oprot.writeStructEnd()
  3227. def validate(self):
  3228. return
  3229. def __repr__(self):
  3230. L = ['%s=%r' % (key, value)
  3231. for key, value in self.__dict__.items()]
  3232. return '%s(%s)' % (self.__class__.__name__, ', '.join(L))
  3233. def __eq__(self, other):
  3234. return isinstance(other, self.__class__) and self.__dict__ == other.__dict__
  3235. def __ne__(self, other):
  3236. return not (self == other)
  3237. all_structs.append(FetchResults_args)
  3238. FetchResults_args.thrift_spec = (
  3239. None, # 0
  3240. (1, TType.STRUCT, 'req', [TFetchResultsReq, None], None, ), # 1
  3241. )
  3242. class FetchResults_result(object):
  3243. """
  3244. Attributes:
  3245. - success
  3246. """
  3247. def __init__(self, success=None,):
  3248. self.success = success
  3249. def read(self, iprot):
  3250. if iprot._fast_decode is not None and isinstance(iprot.trans, TTransport.CReadableTransport) and self.thrift_spec is not None:
  3251. iprot._fast_decode(self, iprot, [self.__class__, self.thrift_spec])
  3252. return
  3253. iprot.readStructBegin()
  3254. while True:
  3255. (fname, ftype, fid) = iprot.readFieldBegin()
  3256. if ftype == TType.STOP:
  3257. break
  3258. if fid == 0:
  3259. if ftype == TType.STRUCT:
  3260. self.success = TFetchResultsResp()
  3261. self.success.read(iprot)
  3262. else:
  3263. iprot.skip(ftype)
  3264. else:
  3265. iprot.skip(ftype)
  3266. iprot.readFieldEnd()
  3267. iprot.readStructEnd()
  3268. def write(self, oprot):
  3269. if oprot._fast_encode is not None and self.thrift_spec is not None:
  3270. oprot.trans.write(oprot._fast_encode(self, [self.__class__, self.thrift_spec]))
  3271. return
  3272. oprot.writeStructBegin('FetchResults_result')
  3273. if self.success is not None:
  3274. oprot.writeFieldBegin('success', TType.STRUCT, 0)
  3275. self.success.write(oprot)
  3276. oprot.writeFieldEnd()
  3277. oprot.writeFieldStop()
  3278. oprot.writeStructEnd()
  3279. def validate(self):
  3280. return
  3281. def __repr__(self):
  3282. L = ['%s=%r' % (key, value)
  3283. for key, value in self.__dict__.items()]
  3284. return '%s(%s)' % (self.__class__.__name__, ', '.join(L))
  3285. def __eq__(self, other):
  3286. return isinstance(other, self.__class__) and self.__dict__ == other.__dict__
  3287. def __ne__(self, other):
  3288. return not (self == other)
  3289. all_structs.append(FetchResults_result)
  3290. FetchResults_result.thrift_spec = (
  3291. (0, TType.STRUCT, 'success', [TFetchResultsResp, None], None, ), # 0
  3292. )
  3293. class GetDelegationToken_args(object):
  3294. """
  3295. Attributes:
  3296. - req
  3297. """
  3298. def __init__(self, req=None,):
  3299. self.req = req
  3300. def read(self, iprot):
  3301. if iprot._fast_decode is not None and isinstance(iprot.trans, TTransport.CReadableTransport) and self.thrift_spec is not None:
  3302. iprot._fast_decode(self, iprot, [self.__class__, self.thrift_spec])
  3303. return
  3304. iprot.readStructBegin()
  3305. while True:
  3306. (fname, ftype, fid) = iprot.readFieldBegin()
  3307. if ftype == TType.STOP:
  3308. break
  3309. if fid == 1:
  3310. if ftype == TType.STRUCT:
  3311. self.req = TGetDelegationTokenReq()
  3312. self.req.read(iprot)
  3313. else:
  3314. iprot.skip(ftype)
  3315. else:
  3316. iprot.skip(ftype)
  3317. iprot.readFieldEnd()
  3318. iprot.readStructEnd()
  3319. def write(self, oprot):
  3320. if oprot._fast_encode is not None and self.thrift_spec is not None:
  3321. oprot.trans.write(oprot._fast_encode(self, [self.__class__, self.thrift_spec]))
  3322. return
  3323. oprot.writeStructBegin('GetDelegationToken_args')
  3324. if self.req is not None:
  3325. oprot.writeFieldBegin('req', TType.STRUCT, 1)
  3326. self.req.write(oprot)
  3327. oprot.writeFieldEnd()
  3328. oprot.writeFieldStop()
  3329. oprot.writeStructEnd()
  3330. def validate(self):
  3331. return
  3332. def __repr__(self):
  3333. L = ['%s=%r' % (key, value)
  3334. for key, value in self.__dict__.items()]
  3335. return '%s(%s)' % (self.__class__.__name__, ', '.join(L))
  3336. def __eq__(self, other):
  3337. return isinstance(other, self.__class__) and self.__dict__ == other.__dict__
  3338. def __ne__(self, other):
  3339. return not (self == other)
  3340. all_structs.append(GetDelegationToken_args)
  3341. GetDelegationToken_args.thrift_spec = (
  3342. None, # 0
  3343. (1, TType.STRUCT, 'req', [TGetDelegationTokenReq, None], None, ), # 1
  3344. )
  3345. class GetDelegationToken_result(object):
  3346. """
  3347. Attributes:
  3348. - success
  3349. """
  3350. def __init__(self, success=None,):
  3351. self.success = success
  3352. def read(self, iprot):
  3353. if iprot._fast_decode is not None and isinstance(iprot.trans, TTransport.CReadableTransport) and self.thrift_spec is not None:
  3354. iprot._fast_decode(self, iprot, [self.__class__, self.thrift_spec])
  3355. return
  3356. iprot.readStructBegin()
  3357. while True:
  3358. (fname, ftype, fid) = iprot.readFieldBegin()
  3359. if ftype == TType.STOP:
  3360. break
  3361. if fid == 0:
  3362. if ftype == TType.STRUCT:
  3363. self.success = TGetDelegationTokenResp()
  3364. self.success.read(iprot)
  3365. else:
  3366. iprot.skip(ftype)
  3367. else:
  3368. iprot.skip(ftype)
  3369. iprot.readFieldEnd()
  3370. iprot.readStructEnd()
  3371. def write(self, oprot):
  3372. if oprot._fast_encode is not None and self.thrift_spec is not None:
  3373. oprot.trans.write(oprot._fast_encode(self, [self.__class__, self.thrift_spec]))
  3374. return
  3375. oprot.writeStructBegin('GetDelegationToken_result')
  3376. if self.success is not None:
  3377. oprot.writeFieldBegin('success', TType.STRUCT, 0)
  3378. self.success.write(oprot)
  3379. oprot.writeFieldEnd()
  3380. oprot.writeFieldStop()
  3381. oprot.writeStructEnd()
  3382. def validate(self):
  3383. return
  3384. def __repr__(self):
  3385. L = ['%s=%r' % (key, value)
  3386. for key, value in self.__dict__.items()]
  3387. return '%s(%s)' % (self.__class__.__name__, ', '.join(L))
  3388. def __eq__(self, other):
  3389. return isinstance(other, self.__class__) and self.__dict__ == other.__dict__
  3390. def __ne__(self, other):
  3391. return not (self == other)
  3392. all_structs.append(GetDelegationToken_result)
  3393. GetDelegationToken_result.thrift_spec = (
  3394. (0, TType.STRUCT, 'success', [TGetDelegationTokenResp, None], None, ), # 0
  3395. )
  3396. class CancelDelegationToken_args(object):
  3397. """
  3398. Attributes:
  3399. - req
  3400. """
  3401. def __init__(self, req=None,):
  3402. self.req = req
  3403. def read(self, iprot):
  3404. if iprot._fast_decode is not None and isinstance(iprot.trans, TTransport.CReadableTransport) and self.thrift_spec is not None:
  3405. iprot._fast_decode(self, iprot, [self.__class__, self.thrift_spec])
  3406. return
  3407. iprot.readStructBegin()
  3408. while True:
  3409. (fname, ftype, fid) = iprot.readFieldBegin()
  3410. if ftype == TType.STOP:
  3411. break
  3412. if fid == 1:
  3413. if ftype == TType.STRUCT:
  3414. self.req = TCancelDelegationTokenReq()
  3415. self.req.read(iprot)
  3416. else:
  3417. iprot.skip(ftype)
  3418. else:
  3419. iprot.skip(ftype)
  3420. iprot.readFieldEnd()
  3421. iprot.readStructEnd()
  3422. def write(self, oprot):
  3423. if oprot._fast_encode is not None and self.thrift_spec is not None:
  3424. oprot.trans.write(oprot._fast_encode(self, [self.__class__, self.thrift_spec]))
  3425. return
  3426. oprot.writeStructBegin('CancelDelegationToken_args')
  3427. if self.req is not None:
  3428. oprot.writeFieldBegin('req', TType.STRUCT, 1)
  3429. self.req.write(oprot)
  3430. oprot.writeFieldEnd()
  3431. oprot.writeFieldStop()
  3432. oprot.writeStructEnd()
  3433. def validate(self):
  3434. return
  3435. def __repr__(self):
  3436. L = ['%s=%r' % (key, value)
  3437. for key, value in self.__dict__.items()]
  3438. return '%s(%s)' % (self.__class__.__name__, ', '.join(L))
  3439. def __eq__(self, other):
  3440. return isinstance(other, self.__class__) and self.__dict__ == other.__dict__
  3441. def __ne__(self, other):
  3442. return not (self == other)
  3443. all_structs.append(CancelDelegationToken_args)
  3444. CancelDelegationToken_args.thrift_spec = (
  3445. None, # 0
  3446. (1, TType.STRUCT, 'req', [TCancelDelegationTokenReq, None], None, ), # 1
  3447. )
  3448. class CancelDelegationToken_result(object):
  3449. """
  3450. Attributes:
  3451. - success
  3452. """
  3453. def __init__(self, success=None,):
  3454. self.success = success
  3455. def read(self, iprot):
  3456. if iprot._fast_decode is not None and isinstance(iprot.trans, TTransport.CReadableTransport) and self.thrift_spec is not None:
  3457. iprot._fast_decode(self, iprot, [self.__class__, self.thrift_spec])
  3458. return
  3459. iprot.readStructBegin()
  3460. while True:
  3461. (fname, ftype, fid) = iprot.readFieldBegin()
  3462. if ftype == TType.STOP:
  3463. break
  3464. if fid == 0:
  3465. if ftype == TType.STRUCT:
  3466. self.success = TCancelDelegationTokenResp()
  3467. self.success.read(iprot)
  3468. else:
  3469. iprot.skip(ftype)
  3470. else:
  3471. iprot.skip(ftype)
  3472. iprot.readFieldEnd()
  3473. iprot.readStructEnd()
  3474. def write(self, oprot):
  3475. if oprot._fast_encode is not None and self.thrift_spec is not None:
  3476. oprot.trans.write(oprot._fast_encode(self, [self.__class__, self.thrift_spec]))
  3477. return
  3478. oprot.writeStructBegin('CancelDelegationToken_result')
  3479. if self.success is not None:
  3480. oprot.writeFieldBegin('success', TType.STRUCT, 0)
  3481. self.success.write(oprot)
  3482. oprot.writeFieldEnd()
  3483. oprot.writeFieldStop()
  3484. oprot.writeStructEnd()
  3485. def validate(self):
  3486. return
  3487. def __repr__(self):
  3488. L = ['%s=%r' % (key, value)
  3489. for key, value in self.__dict__.items()]
  3490. return '%s(%s)' % (self.__class__.__name__, ', '.join(L))
  3491. def __eq__(self, other):
  3492. return isinstance(other, self.__class__) and self.__dict__ == other.__dict__
  3493. def __ne__(self, other):
  3494. return not (self == other)
  3495. all_structs.append(CancelDelegationToken_result)
  3496. CancelDelegationToken_result.thrift_spec = (
  3497. (0, TType.STRUCT, 'success', [TCancelDelegationTokenResp, None], None, ), # 0
  3498. )
  3499. class RenewDelegationToken_args(object):
  3500. """
  3501. Attributes:
  3502. - req
  3503. """
  3504. def __init__(self, req=None,):
  3505. self.req = req
  3506. def read(self, iprot):
  3507. if iprot._fast_decode is not None and isinstance(iprot.trans, TTransport.CReadableTransport) and self.thrift_spec is not None:
  3508. iprot._fast_decode(self, iprot, [self.__class__, self.thrift_spec])
  3509. return
  3510. iprot.readStructBegin()
  3511. while True:
  3512. (fname, ftype, fid) = iprot.readFieldBegin()
  3513. if ftype == TType.STOP:
  3514. break
  3515. if fid == 1:
  3516. if ftype == TType.STRUCT:
  3517. self.req = TRenewDelegationTokenReq()
  3518. self.req.read(iprot)
  3519. else:
  3520. iprot.skip(ftype)
  3521. else:
  3522. iprot.skip(ftype)
  3523. iprot.readFieldEnd()
  3524. iprot.readStructEnd()
  3525. def write(self, oprot):
  3526. if oprot._fast_encode is not None and self.thrift_spec is not None:
  3527. oprot.trans.write(oprot._fast_encode(self, [self.__class__, self.thrift_spec]))
  3528. return
  3529. oprot.writeStructBegin('RenewDelegationToken_args')
  3530. if self.req is not None:
  3531. oprot.writeFieldBegin('req', TType.STRUCT, 1)
  3532. self.req.write(oprot)
  3533. oprot.writeFieldEnd()
  3534. oprot.writeFieldStop()
  3535. oprot.writeStructEnd()
  3536. def validate(self):
  3537. return
  3538. def __repr__(self):
  3539. L = ['%s=%r' % (key, value)
  3540. for key, value in self.__dict__.items()]
  3541. return '%s(%s)' % (self.__class__.__name__, ', '.join(L))
  3542. def __eq__(self, other):
  3543. return isinstance(other, self.__class__) and self.__dict__ == other.__dict__
  3544. def __ne__(self, other):
  3545. return not (self == other)
  3546. all_structs.append(RenewDelegationToken_args)
  3547. RenewDelegationToken_args.thrift_spec = (
  3548. None, # 0
  3549. (1, TType.STRUCT, 'req', [TRenewDelegationTokenReq, None], None, ), # 1
  3550. )
  3551. class RenewDelegationToken_result(object):
  3552. """
  3553. Attributes:
  3554. - success
  3555. """
  3556. def __init__(self, success=None,):
  3557. self.success = success
  3558. def read(self, iprot):
  3559. if iprot._fast_decode is not None and isinstance(iprot.trans, TTransport.CReadableTransport) and self.thrift_spec is not None:
  3560. iprot._fast_decode(self, iprot, [self.__class__, self.thrift_spec])
  3561. return
  3562. iprot.readStructBegin()
  3563. while True:
  3564. (fname, ftype, fid) = iprot.readFieldBegin()
  3565. if ftype == TType.STOP:
  3566. break
  3567. if fid == 0:
  3568. if ftype == TType.STRUCT:
  3569. self.success = TRenewDelegationTokenResp()
  3570. self.success.read(iprot)
  3571. else:
  3572. iprot.skip(ftype)
  3573. else:
  3574. iprot.skip(ftype)
  3575. iprot.readFieldEnd()
  3576. iprot.readStructEnd()
  3577. def write(self, oprot):
  3578. if oprot._fast_encode is not None and self.thrift_spec is not None:
  3579. oprot.trans.write(oprot._fast_encode(self, [self.__class__, self.thrift_spec]))
  3580. return
  3581. oprot.writeStructBegin('RenewDelegationToken_result')
  3582. if self.success is not None:
  3583. oprot.writeFieldBegin('success', TType.STRUCT, 0)
  3584. self.success.write(oprot)
  3585. oprot.writeFieldEnd()
  3586. oprot.writeFieldStop()
  3587. oprot.writeStructEnd()
  3588. def validate(self):
  3589. return
  3590. def __repr__(self):
  3591. L = ['%s=%r' % (key, value)
  3592. for key, value in self.__dict__.items()]
  3593. return '%s(%s)' % (self.__class__.__name__, ', '.join(L))
  3594. def __eq__(self, other):
  3595. return isinstance(other, self.__class__) and self.__dict__ == other.__dict__
  3596. def __ne__(self, other):
  3597. return not (self == other)
  3598. all_structs.append(RenewDelegationToken_result)
  3599. RenewDelegationToken_result.thrift_spec = (
  3600. (0, TType.STRUCT, 'success', [TRenewDelegationTokenResp, None], None, ), # 0
  3601. )
  3602. class GetQueryId_args(object):
  3603. """
  3604. Attributes:
  3605. - req
  3606. """
  3607. def __init__(self, req=None,):
  3608. self.req = req
  3609. def read(self, iprot):
  3610. if iprot._fast_decode is not None and isinstance(iprot.trans, TTransport.CReadableTransport) and self.thrift_spec is not None:
  3611. iprot._fast_decode(self, iprot, [self.__class__, self.thrift_spec])
  3612. return
  3613. iprot.readStructBegin()
  3614. while True:
  3615. (fname, ftype, fid) = iprot.readFieldBegin()
  3616. if ftype == TType.STOP:
  3617. break
  3618. if fid == 1:
  3619. if ftype == TType.STRUCT:
  3620. self.req = TGetQueryIdReq()
  3621. self.req.read(iprot)
  3622. else:
  3623. iprot.skip(ftype)
  3624. else:
  3625. iprot.skip(ftype)
  3626. iprot.readFieldEnd()
  3627. iprot.readStructEnd()
  3628. def write(self, oprot):
  3629. if oprot._fast_encode is not None and self.thrift_spec is not None:
  3630. oprot.trans.write(oprot._fast_encode(self, [self.__class__, self.thrift_spec]))
  3631. return
  3632. oprot.writeStructBegin('GetQueryId_args')
  3633. if self.req is not None:
  3634. oprot.writeFieldBegin('req', TType.STRUCT, 1)
  3635. self.req.write(oprot)
  3636. oprot.writeFieldEnd()
  3637. oprot.writeFieldStop()
  3638. oprot.writeStructEnd()
  3639. def validate(self):
  3640. return
  3641. def __repr__(self):
  3642. L = ['%s=%r' % (key, value)
  3643. for key, value in self.__dict__.items()]
  3644. return '%s(%s)' % (self.__class__.__name__, ', '.join(L))
  3645. def __eq__(self, other):
  3646. return isinstance(other, self.__class__) and self.__dict__ == other.__dict__
  3647. def __ne__(self, other):
  3648. return not (self == other)
  3649. all_structs.append(GetQueryId_args)
  3650. GetQueryId_args.thrift_spec = (
  3651. None, # 0
  3652. (1, TType.STRUCT, 'req', [TGetQueryIdReq, None], None, ), # 1
  3653. )
  3654. class GetQueryId_result(object):
  3655. """
  3656. Attributes:
  3657. - success
  3658. """
  3659. def __init__(self, success=None,):
  3660. self.success = success
  3661. def read(self, iprot):
  3662. if iprot._fast_decode is not None and isinstance(iprot.trans, TTransport.CReadableTransport) and self.thrift_spec is not None:
  3663. iprot._fast_decode(self, iprot, [self.__class__, self.thrift_spec])
  3664. return
  3665. iprot.readStructBegin()
  3666. while True:
  3667. (fname, ftype, fid) = iprot.readFieldBegin()
  3668. if ftype == TType.STOP:
  3669. break
  3670. if fid == 0:
  3671. if ftype == TType.STRUCT:
  3672. self.success = TGetQueryIdResp()
  3673. self.success.read(iprot)
  3674. else:
  3675. iprot.skip(ftype)
  3676. else:
  3677. iprot.skip(ftype)
  3678. iprot.readFieldEnd()
  3679. iprot.readStructEnd()
  3680. def write(self, oprot):
  3681. if oprot._fast_encode is not None and self.thrift_spec is not None:
  3682. oprot.trans.write(oprot._fast_encode(self, [self.__class__, self.thrift_spec]))
  3683. return
  3684. oprot.writeStructBegin('GetQueryId_result')
  3685. if self.success is not None:
  3686. oprot.writeFieldBegin('success', TType.STRUCT, 0)
  3687. self.success.write(oprot)
  3688. oprot.writeFieldEnd()
  3689. oprot.writeFieldStop()
  3690. oprot.writeStructEnd()
  3691. def validate(self):
  3692. return
  3693. def __repr__(self):
  3694. L = ['%s=%r' % (key, value)
  3695. for key, value in self.__dict__.items()]
  3696. return '%s(%s)' % (self.__class__.__name__, ', '.join(L))
  3697. def __eq__(self, other):
  3698. return isinstance(other, self.__class__) and self.__dict__ == other.__dict__
  3699. def __ne__(self, other):
  3700. return not (self == other)
  3701. all_structs.append(GetQueryId_result)
  3702. GetQueryId_result.thrift_spec = (
  3703. (0, TType.STRUCT, 'success', [TGetQueryIdResp, None], None, ), # 0
  3704. )
  3705. class SetClientInfo_args(object):
  3706. """
  3707. Attributes:
  3708. - req
  3709. """
  3710. def __init__(self, req=None,):
  3711. self.req = req
  3712. def read(self, iprot):
  3713. if iprot._fast_decode is not None and isinstance(iprot.trans, TTransport.CReadableTransport) and self.thrift_spec is not None:
  3714. iprot._fast_decode(self, iprot, [self.__class__, self.thrift_spec])
  3715. return
  3716. iprot.readStructBegin()
  3717. while True:
  3718. (fname, ftype, fid) = iprot.readFieldBegin()
  3719. if ftype == TType.STOP:
  3720. break
  3721. if fid == 1:
  3722. if ftype == TType.STRUCT:
  3723. self.req = TSetClientInfoReq()
  3724. self.req.read(iprot)
  3725. else:
  3726. iprot.skip(ftype)
  3727. else:
  3728. iprot.skip(ftype)
  3729. iprot.readFieldEnd()
  3730. iprot.readStructEnd()
  3731. def write(self, oprot):
  3732. if oprot._fast_encode is not None and self.thrift_spec is not None:
  3733. oprot.trans.write(oprot._fast_encode(self, [self.__class__, self.thrift_spec]))
  3734. return
  3735. oprot.writeStructBegin('SetClientInfo_args')
  3736. if self.req is not None:
  3737. oprot.writeFieldBegin('req', TType.STRUCT, 1)
  3738. self.req.write(oprot)
  3739. oprot.writeFieldEnd()
  3740. oprot.writeFieldStop()
  3741. oprot.writeStructEnd()
  3742. def validate(self):
  3743. return
  3744. def __repr__(self):
  3745. L = ['%s=%r' % (key, value)
  3746. for key, value in self.__dict__.items()]
  3747. return '%s(%s)' % (self.__class__.__name__, ', '.join(L))
  3748. def __eq__(self, other):
  3749. return isinstance(other, self.__class__) and self.__dict__ == other.__dict__
  3750. def __ne__(self, other):
  3751. return not (self == other)
  3752. all_structs.append(SetClientInfo_args)
  3753. SetClientInfo_args.thrift_spec = (
  3754. None, # 0
  3755. (1, TType.STRUCT, 'req', [TSetClientInfoReq, None], None, ), # 1
  3756. )
  3757. class SetClientInfo_result(object):
  3758. """
  3759. Attributes:
  3760. - success
  3761. """
  3762. def __init__(self, success=None,):
  3763. self.success = success
  3764. def read(self, iprot):
  3765. if iprot._fast_decode is not None and isinstance(iprot.trans, TTransport.CReadableTransport) and self.thrift_spec is not None:
  3766. iprot._fast_decode(self, iprot, [self.__class__, self.thrift_spec])
  3767. return
  3768. iprot.readStructBegin()
  3769. while True:
  3770. (fname, ftype, fid) = iprot.readFieldBegin()
  3771. if ftype == TType.STOP:
  3772. break
  3773. if fid == 0:
  3774. if ftype == TType.STRUCT:
  3775. self.success = TSetClientInfoResp()
  3776. self.success.read(iprot)
  3777. else:
  3778. iprot.skip(ftype)
  3779. else:
  3780. iprot.skip(ftype)
  3781. iprot.readFieldEnd()
  3782. iprot.readStructEnd()
  3783. def write(self, oprot):
  3784. if oprot._fast_encode is not None and self.thrift_spec is not None:
  3785. oprot.trans.write(oprot._fast_encode(self, [self.__class__, self.thrift_spec]))
  3786. return
  3787. oprot.writeStructBegin('SetClientInfo_result')
  3788. if self.success is not None:
  3789. oprot.writeFieldBegin('success', TType.STRUCT, 0)
  3790. self.success.write(oprot)
  3791. oprot.writeFieldEnd()
  3792. oprot.writeFieldStop()
  3793. oprot.writeStructEnd()
  3794. def validate(self):
  3795. return
  3796. def __repr__(self):
  3797. L = ['%s=%r' % (key, value)
  3798. for key, value in self.__dict__.items()]
  3799. return '%s(%s)' % (self.__class__.__name__, ', '.join(L))
  3800. def __eq__(self, other):
  3801. return isinstance(other, self.__class__) and self.__dict__ == other.__dict__
  3802. def __ne__(self, other):
  3803. return not (self == other)
  3804. all_structs.append(SetClientInfo_result)
  3805. SetClientInfo_result.thrift_spec = (
  3806. (0, TType.STRUCT, 'success', [TSetClientInfoResp, None], None, ), # 0
  3807. )
  3808. class GetLog_args(object):
  3809. """
  3810. Attributes:
  3811. - req
  3812. """
  3813. def __init__(self, req=None,):
  3814. self.req = req
  3815. def read(self, iprot):
  3816. if iprot._fast_decode is not None and isinstance(iprot.trans, TTransport.CReadableTransport) and self.thrift_spec is not None:
  3817. iprot._fast_decode(self, iprot, [self.__class__, self.thrift_spec])
  3818. return
  3819. iprot.readStructBegin()
  3820. while True:
  3821. (fname, ftype, fid) = iprot.readFieldBegin()
  3822. if ftype == TType.STOP:
  3823. break
  3824. if fid == 1:
  3825. if ftype == TType.STRUCT:
  3826. self.req = TGetLogReq()
  3827. self.req.read(iprot)
  3828. else:
  3829. iprot.skip(ftype)
  3830. else:
  3831. iprot.skip(ftype)
  3832. iprot.readFieldEnd()
  3833. iprot.readStructEnd()
  3834. def write(self, oprot):
  3835. if oprot._fast_encode is not None and self.thrift_spec is not None:
  3836. oprot.trans.write(oprot._fast_encode(self, [self.__class__, self.thrift_spec]))
  3837. return
  3838. oprot.writeStructBegin('GetLog_args')
  3839. if self.req is not None:
  3840. oprot.writeFieldBegin('req', TType.STRUCT, 1)
  3841. self.req.write(oprot)
  3842. oprot.writeFieldEnd()
  3843. oprot.writeFieldStop()
  3844. oprot.writeStructEnd()
  3845. def validate(self):
  3846. return
  3847. def __repr__(self):
  3848. L = ['%s=%r' % (key, value)
  3849. for key, value in self.__dict__.items()]
  3850. return '%s(%s)' % (self.__class__.__name__, ', '.join(L))
  3851. def __eq__(self, other):
  3852. return isinstance(other, self.__class__) and self.__dict__ == other.__dict__
  3853. def __ne__(self, other):
  3854. return not (self == other)
  3855. all_structs.append(GetLog_args)
  3856. GetLog_args.thrift_spec = (
  3857. None, # 0
  3858. (1, TType.STRUCT, 'req', [TGetLogReq, None], None, ), # 1
  3859. )
  3860. class GetLog_result(object):
  3861. """
  3862. Attributes:
  3863. - success
  3864. """
  3865. def __init__(self, success=None,):
  3866. self.success = success
  3867. def read(self, iprot):
  3868. if iprot._fast_decode is not None and isinstance(iprot.trans, TTransport.CReadableTransport) and self.thrift_spec is not None:
  3869. iprot._fast_decode(self, iprot, [self.__class__, self.thrift_spec])
  3870. return
  3871. iprot.readStructBegin()
  3872. while True:
  3873. (fname, ftype, fid) = iprot.readFieldBegin()
  3874. if ftype == TType.STOP:
  3875. break
  3876. if fid == 0:
  3877. if ftype == TType.STRUCT:
  3878. self.success = TGetLogResp()
  3879. self.success.read(iprot)
  3880. else:
  3881. iprot.skip(ftype)
  3882. else:
  3883. iprot.skip(ftype)
  3884. iprot.readFieldEnd()
  3885. iprot.readStructEnd()
  3886. def write(self, oprot):
  3887. if oprot._fast_encode is not None and self.thrift_spec is not None:
  3888. oprot.trans.write(oprot._fast_encode(self, [self.__class__, self.thrift_spec]))
  3889. return
  3890. oprot.writeStructBegin('GetLog_result')
  3891. if self.success is not None:
  3892. oprot.writeFieldBegin('success', TType.STRUCT, 0)
  3893. self.success.write(oprot)
  3894. oprot.writeFieldEnd()
  3895. oprot.writeFieldStop()
  3896. oprot.writeStructEnd()
  3897. def validate(self):
  3898. return
  3899. def __repr__(self):
  3900. L = ['%s=%r' % (key, value)
  3901. for key, value in self.__dict__.items()]
  3902. return '%s(%s)' % (self.__class__.__name__, ', '.join(L))
  3903. def __eq__(self, other):
  3904. return isinstance(other, self.__class__) and self.__dict__ == other.__dict__
  3905. def __ne__(self, other):
  3906. return not (self == other)
  3907. all_structs.append(GetLog_result)
  3908. GetLog_result.thrift_spec = (
  3909. (0, TType.STRUCT, 'success', [TGetLogResp, None], None, ), # 0
  3910. )
  3911. fix_spec(all_structs)
  3912. del all_structs