Edit C:\Users\Administrator\Desktop\LIV\lib\org\postgresql\core\v2\QueryExecutorImpl.class
Êþº¾ 2 ? ?! ?" ?#$ %& ' () *+, *-. 1/ ?2 345 ?6 ?789: ;< => ? ?@ ?A BC D E FGH I JK JL M JN JO JP ?Q ?R ?S (TUV 2W ;X Y ¼Z[ J\ J]^_ ?`a =bcd ?ef gh ijk Eb (lcmn op Jq rs t B u rvw xy Jz{ f|} =~ j f? J??c? ?????c?? ??? f ? J??? j???? o? (? ??? =?? ?? ???? yx ?? ( ¡¢£ ?¤¥¦§ ?¨ ©ª ?« ?¬ ®¯°c±² =³´µ¶ protoConnection /Lorg/postgresql/core/v2/ProtocolConnectionImpl; pgStream Lorg/postgresql/core/PGStream; logger Lorg/postgresql/core/Logger; <init> l(Lorg/postgresql/core/v2/ProtocolConnectionImpl;Lorg/postgresql/core/PGStream;Lorg/postgresql/core/Logger;)V Code LineNumberTable LocalVariableTable this *Lorg/postgresql/core/v2/QueryExecutorImpl; createSimpleQuery /(Ljava/lang/String;)Lorg/postgresql/core/Query; sql Ljava/lang/String; createParameterizedQuery createFastpathParameters &(I)Lorg/postgresql/core/ParameterList; count I fastpathCall )(ILorg/postgresql/core/ParameterList;Z)[B query Lorg/postgresql/core/v2/V2Query; params ,Lorg/postgresql/core/v2/SimpleParameterList; ioe Ljava/io/IOException; handler #Lorg/postgresql/core/ResultHandler; fnid parameters #Lorg/postgresql/core/ParameterList; suppressBegin Z StackMapTable´·¸8 Exceptions¹ sendFastpathCall 2(ILorg/postgresql/core/v2/FastpathParameterList;)V i .Lorg/postgresql/core/v2/FastpathParameterList; processNotifies ()V c receiveFastpathResult ()[B len newError Ljava/sql/SQLException; error endQuery result [B¹ Ì execute g(Lorg/postgresql/core/Query;Lorg/postgresql/core/ParameterList;Lorg/postgresql/core/ResultHandler;III)V Lorg/postgresql/core/Query; maxRows fetchSize flags i([Lorg/postgresql/core/Query;[Lorg/postgresql/core/ParameterList;Lorg/postgresql/core/ResultHandler;III)V queries [Lorg/postgresql/core/Query; $[Lorg/postgresql/core/ParameterList; delegateHandler fetch I(Lorg/postgresql/core/ResultCursor;Lorg/postgresql/core/ResultHandler;I)V cursor "Lorg/postgresql/core/ResultCursor; rows t(Lorg/postgresql/core/v2/V2Query;Lorg/postgresql/core/v2/SimpleParameterList;Lorg/postgresql/core/ResultHandler;II)V e queryPrefixº sendQuery a(Lorg/postgresql/core/v2/V2Query;Lorg/postgresql/core/v2/SimpleParameterList;Ljava/lang/String;)V encodingWriter Ljava/io/Writer; fragments [Ljava/lang/String;$4»C¼ è processResults C(Lorg/postgresql/core/Query;Lorg/postgresql/core/ResultHandler;II)V oome Ljava/lang/OutOfMemoryError; tuple Ljava/lang/Object; status portalName originalQuery bothRowsAndStatus fields [Lorg/postgresql/core/Field; tuples Ljava/util/Vector;½ ú?µ{{ receiveFields ()[Lorg/postgresql/core/Field; columnLabel typeOid typeLength typeModifier size receiveAsyncNotify pid msg receiveErrorMessage ()Ljava/sql/SQLException; errorMsg receiveNotification ()Ljava/sql/SQLWarning; warnMsg severityMark interpretCommandStatus 8(Ljava/lang/String;Lorg/postgresql/core/ResultHandler;)V nfe !Ljava/lang/NumberFormatException; update_count insert_oid J¯ startCopy 8(Ljava/lang/String;Z)Lorg/postgresql/copy/CopyOperation; SourceFile QueryExecutorImpl.java ?  ? ? ? ? ? ? org/postgresql/core/v2/V2Query ?¾ ,org/postgresql/core/v2/FastpathParameterList ?¿ÀÁ»ÃÄ #Issuing BEGIN before fastpath call.ÅÆ *org/postgresql/core/v2/QueryExecutorImpl$1 InnerClasses ?Ç ? ?ÈÉ *org/postgresql/core/v2/SimpleParameterList BEGIN ã ä ï ð java/io/IOException !org/postgresql/util/PSQLException 2An I/O error occured while sending to the backend.ÊËÌÍÎÏ ?Ð ½ ¾ Ä ÅÑ java/lang/StringBuilder FE=> FastpathCall(fnid=ÒÓÒÔ ,paramCount= )ÕÖ×ؿٿÚÛÜ ÂÝÄÞ  ßà Unknown Response Type {0}. java/lang/Character ?áËâ ?ãäå <=BE FastpathResultæÂçè <=BE FastpathVoidResult <=BE ReadyForQuery Ï ß *org/postgresql/core/v2/QueryExecutorImpl$2 ?é¸ê Âëì %fetch(ResultCursor,ResultHandler,int)íîïð  BEGIN; *org/postgresql/core/v2/QueryExecutorImpl$3ñ Âòå FE=> Query("Õó ")ôõ¼öÆ÷øùúö¿ #Data transfer before field metadata ?Æ <=BE BinaryRowûü java/lang/OutOfMemoryError  +Ran out of memory retrieving query results.ýÏþ¿ÿ Ö <=BE CommandStatus( <=BE DataRow <=BE EmptyQuery #Expected \0 after EmptyQuery, got: à <=BE PortalName( java/util/Vector Unexpected packet type:  org/postgresql/core/Field <=BE RowDescription( ? <=BE AsyncNotify(pid= ,msg= org/postgresql/core/Notification ? º Ö <=BE ErrorResponse(Ï : <=BE NoticeResponse( java/sql/SQLWarning¿ COMMIT ROLLBACK INSERT UPDATE DELETE MOVE java/lang/NumberFormatException DUnable to interpret the update count in command completion tag: {0}. +Copy not implemented for protocol version 2Ï (org/postgresql/core/v2/QueryExecutorImpl java/lang/Object !org/postgresql/core/QueryExecutor !org/postgresql/core/ParameterList !org/postgresql/core/ResultHandler java/sql/SQLException java/lang/String org/postgresql/core/Logger java/io/Writer org/postgresql/core/Query >(Ljava/lang/String;ZLorg/postgresql/core/ProtocolConnection;)V (I)V -org/postgresql/core/v2/ProtocolConnectionImpl getTransactionState ()I logDebug ()Z debug (Ljava/lang/String;)V -(Lorg/postgresql/core/v2/QueryExecutorImpl;)V createParameterList %()Lorg/postgresql/core/ParameterList; org/postgresql/util/GT tr &(Ljava/lang/String;)Ljava/lang/String; org/postgresql/util/PSQLState CONNECTION_FAILURE Lorg/postgresql/util/PSQLState; I(Ljava/lang/String;Lorg/postgresql/util/PSQLState;Ljava/lang/Throwable;)V getParameterCount append -(Ljava/lang/String;)Ljava/lang/StringBuilder; (I)Ljava/lang/StringBuilder; toString ()Ljava/lang/String; org/postgresql/core/PGStream SendChar SendInteger4 writeV2FastpathValue "(ILorg/postgresql/core/PGStream;)V flush hasMessagePending ReceiveChar addWarning (Ljava/sql/SQLWarning;)V (C)V 8(Ljava/lang/String;Ljava/lang/Object;)Ljava/lang/String; 4(Ljava/lang/String;Lorg/postgresql/util/PSQLState;)V setNextException (Ljava/sql/SQLException;)V ReceiveInteger4 Receive (I)[B P(Lorg/postgresql/core/v2/QueryExecutorImpl;Lorg/postgresql/core/ResultHandler;)V handleCompletion getClass ()Ljava/lang/Class; org/postgresql/Driver notImplemented <(Ljava/lang/Class;Ljava/lang/String;)Ljava/sql/SQLException; checkAllParametersSet close handleError 7(Lorg/postgresql/core/ParameterList;)Ljava/lang/String; getEncodingWriter ()Ljava/io/Writer; write getFragments ()[Ljava/lang/String; writeV2Value (ILjava/io/Writer;)V ReceiveTupleV2 (IZ)[[B OUT_OF_MEMORY setFormat addElement (Ljava/lang/Object;)V ReceiveString handleResultRows n(Lorg/postgresql/core/Query;[Lorg/postgresql/core/Field;Ljava/util/Vector;Lorg/postgresql/core/ResultCursor;)V handleWarning ReceiveInteger2 ,(Ljava/lang/String;Ljava/lang/String;IIIII)V (Ljava/lang/String;I)V addNotification "(Lorg/postgresql/PGNotification;)V trim UNKNOWN_STATE indexOf (Ljava/lang/String;)I substring (I)Ljava/lang/String; equals (Ljava/lang/Object;)Z setTransactionState startsWith (Ljava/lang/String;)Z lastIndexOf (I)I java/lang/Integer parseInt (II)Ljava/lang/String; java/lang/Long parseLong (Ljava/lang/String;)J handleCommandStatus (Ljava/lang/String;IJ)V NOT_IMPLEMENTED ! ? ? ? ? ? ? ? ? ? ? ? ? l *· *+µ *,µ *-µ ± ? ? * ? ? ? ? ? ? ? ? ? ? ? B » Y+*´ · ° ? ' ? ? ? ¡ ¢ ? ? B » Y+*´ · ° ? + ? ? ? ¡ £ ¤ ? = » Y· ° ? 3 ? ? ? ¥ ¦ ! § ¨ ? t ?*´ ¶ ? d? `*´ ¶ ? *´ ¶ » Y*· :*¶ À :¶ À :*¶ *¶ § :» Y¸ ² · ¿*,À · *· °:» Y¸ ² · ¿ + T W k x y ? >