Edit C:\galaxie\jobs\GALAXIE__JOBs\backup\GALAXIE__PCKG_0.3\lib\org\postgresql\core\v2\QueryExecutorImpl.class
Êþº¾ 3 ?# ?$ ?% ?&' () * +, -./ -01 2 ? ?3 456 ?7 ?89:; <= >? @ ?A ?B CD #E F GHI J KL KM N KO KP KQ ?R ?S ?T +UVW 2X <Y Z ¿[\ K] K^_` ?ab =cde ?fg hi jkl Ec +mdno pq Kr st u C v swx yz K{|}~ >? j?}? K??d? ?????d?? ??? f#? K??? j???? o? +? ??? >?? ?? ??? yy ?¡ +¢£¤¥ ?¦§¨© ?ª «¬ ÿÿÿ ? ?®¯°d±² >³´µ¶ InnerClasses 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´·¸9 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;'5»D¼ ë 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 updates J nfe !Ljava/lang/NumberFormatException; update_count insert_oid¯ 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 ?È ¡ ¢ÉÊ *org/postgresql/core/v2/SimpleParameterList BEGIN æ ç ò ó java/io/IOException !org/postgresql/util/PSQLException 3An I/O error occurred 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 !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 java/util/List >(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 O(Ljava/lang/Class;Ljava/lang/String;)Ljava/sql/SQLFeatureNotSupportedException; 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 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 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/Long parseLong (Ljava/lang/String;)J (II)Ljava/lang/String; handleCommandStatus (Ljava/lang/String;IJ)V NOT_IMPLEMENTED ! ? ? ? ? ? ? ? ? ? ? ? ? l *· *+µ *,µ *-µ ± ? ? * ? ? ? ? ? ? ? ¡ ¢ ? B » Y+*´ · ° ? &