Edit C:\edeal\jobs\JOB_EQUALITING\lib\org\postgresql\core\v2\QueryExecutorImpl.class
Êþº¾ 1 ? ? ? ? ? ?! ?"#$% &' () * ?+ ?, -. / 0 123 4 56 57 8 59 5: 5; ?< ?= ?> ?@A 2B &C D ·EF 5G 5HIJ ?KL =MNO ?PQ RS TUV EM WNXY Z[ 5\ ]^ _ - ` ]ab cd 5efghi (j jkgl 5mnNo ?pqrsNtu ?vw fx 5yz{ j|}~ o? ? ??? (?? ?? ???? yc ?? ???? ????? ?? ?? ?? ?? ????N?? (? ¡¢ 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 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; 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/List; 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/ArrayList 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 java/sql/SQLException >(Ljava/lang/String;ZLorg/postgresql/core/ProtocolConnection;)V (I)V -org/postgresql/core/v2/ProtocolConnectionImpl getTransactionState ()I org/postgresql/core/Logger 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 !org/postgresql/core/ResultHandler 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; java/io/Writer write getFragments ()[Ljava/lang/String; writeV2Value (ILjava/io/Writer;)V ReceiveTupleV2 (IZ)[[B java/util/List OUT_OF_MEMORY setFormat add (Ljava/lang/Object;)Z ReceiveString handleResultRows l(Lorg/postgresql/core/Query;[Lorg/postgresql/core/Field;Ljava/util/List;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 java/lang/String trim UNKNOWN_STATE indexOf (Ljava/lang/String;)I substring (I)Ljava/lang/String; equals 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+*´ · ° ? &