Edit C:\galaxie\jobs\GALAXIE__JOBs\backup\GALAXIE__PCKG_0.3\lib\org\postgresql\core\v3\QueryExecutorImpl.class
Êþº¾ 3 ÿá ?âã á ?äå á ?æ ?ç ?èé á ?ê ?ë ?ì ?í ?î ?ï ?ðñòó ô ?õ? ?ö ?÷ ?ø ?ù úû úü ?ýþÿ ! ? ÿ ÿ ! ? Ê! A" #$% Dá& D' D() D*+, D- #. /0 P1 P2 ?34 T56 ?7 ?8 ?9:; < Z=>?@ AB C>DEF TG ?H ?I J ?KL kM ?NO ?P ?QRS rT nUVW nXY nZ n[ \] \^ \_ n` na \b \c \d ?e ?f ?g hij ?k l ?m ?n \opq \r stu \v ?wx \y ?z {| ?}~??? ??? ??? ?? ??? ?????? \???? \???? ??? {??? ÿ? ¡ ?á ?¢£¤ ᥠ\¦§¨ ©ª« \¬®¯ °± ²³´µ ¶·¸¹ º7» ?¼½ ?¾¿À Á _Ã Ä ÅÆ ú Ç VÈ PÉ ?ÊË nÌ Í Î ÏÐ DÑ Ò ÓÔ× Õ Ö ×ØÙ DÃÚÛÜ nÝÞß à )áâãäå nÂæ ç ?è aé ?ÿÿÿêë ì Zí aî aï ðñ òóô õ ö÷øùú ?û ü nü ý nþ ?ÿ ) ? ? ? . ? . ) ) ?? ? Ô ?> Fà ? )A^ \ !"#$%&>'>( ?)*+, -. \/0 ^1 )234 a567 e8 9: \;< #= j>? j- !@AB q@CDEFG H I ÿÿÿ JKLMN DO PQRS ErrorTrackingResultHandler InnerClasses lockedFor Ljava/lang/Object; MAX_BUFFERED_RECV_BYTES I ConstantValue NODATA_QUERY_RESPONSE_SIZE_BYTES ú parsedQueryMap Ljava/util/HashMap; parsedQueryCleanupQueue Ljava/lang/ref/ReferenceQueue; openPortalMap openPortalCleanupQueue pendingParseQueue Ljava/util/ArrayList; pendingBindQueue pendingExecuteQueue pendingDescribeStatementQueue pendingDescribePortalQueue nextUniqueID J protoConnection /Lorg/postgresql/core/v3/ProtocolConnectionImpl; pgStream Lorg/postgresql/core/PGStream; logger Lorg/postgresql/core/Logger; allowEncodingChanges Z estimatedReceiveBufferBytes beginTransactionQuery $Lorg/postgresql/core/v3/SimpleQuery; EMPTY_QUERY <init> ?(Lorg/postgresql/core/v3/ProtocolConnectionImpl;Lorg/postgresql/core/PGStream;Ljava/util/Properties;Lorg/postgresql/core/Logger;)V Code LineNumberTable LocalVariableTable this *Lorg/postgresql/core/v3/QueryExecutorImpl; info Ljava/util/Properties; lock (Ljava/lang/Object;)V obtainer StackMapTable Exceptions unlock holder waitOnLock ()V ie Ljava/lang/InterruptedException; hasLock (Ljava/lang/Object;)Z createSimpleQuery /(Ljava/lang/String;)Lorg/postgresql/core/Query; sql Ljava/lang/String; createParameterizedQuery parseQuery 0(Ljava/lang/String;Z)Lorg/postgresql/core/Query; i fragments [Ljava/lang/String; query withParameters statementList fragmentList fragmentStart inParen standardConformingStrings aChars [C subqueries %[Lorg/postgresql/core/v3/SimpleQuery; offsets [I offsetRòéÓÕ execute g(Lorg/postgresql/core/Query;Lorg/postgresql/core/ParameterList;Lorg/postgresql/core/ResultHandler;III)V trackingHandler ELorg/postgresql/core/v3/QueryExecutorImpl$ErrorTrackingResultHandler; se %Lorg/postgresql/core/PGBindException; e Ljava/io/IOException; Lorg/postgresql/core/Query; parameters #Lorg/postgresql/core/ParameterList; handler #Lorg/postgresql/core/ResultHandler; maxRows fetchSize flags describeOnly:@ i([Lorg/postgresql/core/Query;[Lorg/postgresql/core/ParameterList;Lorg/postgresql/core/ResultHandler;III)V Lorg/postgresql/core/v3/V3Query; (Lorg/postgresql/core/v3/V3ParameterList; queries [Lorg/postgresql/core/Query; parameterLists $[Lorg/postgresql/core/ParameterList;460 sendQueryPreamble I(Lorg/postgresql/core/ResultHandler;I)Lorg/postgresql/core/ResultHandler; delegateHandler beginFlags fastpathCall )(ILorg/postgresql/core/ParameterList;Z)[B ioe fnid suppressBegin doSubprotocolBeginT createFastpathParameters &(I)Lorg/postgresql/core/ParameterList; count sendFastpathCall 0(ILorg/postgresql/core/v3/SimpleParameterList;)V params ,Lorg/postgresql/core/v3/SimpleParameterList; paramCount encodedSizeUO processNotifies warning Ljava/sql/SQLWarning; c receiveFastpathResult ()[B buf [B newError Ljava/sql/SQLException; msgLen valueLen endQuery error returnValue? startCopy 8(Ljava/lang/String;Z)Lorg/postgresql/copy/CopyOperation; initCopy -(Lorg/postgresql/core/v3/CopyOperationImpl;)V op *Lorg/postgresql/core/v3/CopyOperationImpl; rowFormat numFields fieldFormatsV cancelCopy next msg errorsßW endCopy &(Lorg/postgresql/core/v3/CopyInImpl;)J #Lorg/postgresql/core/v3/CopyInImpl; writeToCopy *(Lorg/postgresql/core/v3/CopyInImpl;[BII)V data off siz flushCopy &(Lorg/postgresql/core/v3/CopyInImpl;)V readFromCopy '(Lorg/postgresql/core/v3/CopyOutImpl;)V $Lorg/postgresql/core/v3/CopyOutImpl; processCopyResults W(Lorg/postgresql/core/v3/CopyOperationImpl;Z)Lorg/postgresql/core/v3/CopyOperationImpl; l_len name value status block endReceiving len flushIfDeadlockRisk e(Lorg/postgresql/core/Query;ZLorg/postgresql/core/v3/QueryExecutorImpl$ErrorTrackingResultHandler;I)V maxResultRowSize disallowBatching sqñ sendQuery ?(Lorg/postgresql/core/v3/V3Query;Lorg/postgresql/core/v3/V3ParameterList;IIILorg/postgresql/core/v3/QueryExecutorImpl$ErrorTrackingResultHandler;)V subquery subparam subparams -[Lorg/postgresql/core/v3/SimpleParameterList;R sendSync sendParse T(Lorg/postgresql/core/v3/SimpleQuery;Lorg/postgresql/core/v3/SimpleParameterList;Z)V sbuf Ljava/lang/StringBuilder; oneShot typeOIDs statementName encodedStatementName parts [[B j% sendBind s(Lorg/postgresql/core/v3/SimpleQuery;Lorg/postgresql/core/v3/SimpleParameterList;Lorg/postgresql/core/v3/Portal;Z)V be portal Lorg/postgresql/core/v3/Portal; noBinaryTransfer encodedPortalName numBinaryFields fields [Lorg/postgresql/core/Field; bindExceptionj useBinary (Lorg/postgresql/core/Field;)Z field Lorg/postgresql/core/Field; oid sendDescribePortal F(Lorg/postgresql/core/v3/SimpleQuery;Lorg/postgresql/core/v3/Portal;)V sendDescribeStatement sendExecute G(Lorg/postgresql/core/v3/SimpleQuery;Lorg/postgresql/core/v3/Portal;I)V limit sendClosePortal (Ljava/lang/String;)V portalName sendCloseStatement sendOneQuery V(Lorg/postgresql/core/v3/SimpleQuery;Lorg/postgresql/core/v3/SimpleParameterList;III)V rows queryOIDs paramOIDs noResults noMeta usePortal queryHasUnknown paramsHasUnknown describeStatement registerParsedQuery 9(Lorg/postgresql/core/v3/SimpleQuery;Ljava/lang/String;)V cleanupRef Ljava/lang/ref/PhantomReference; processDeadParsedQueries deadQuery registerOpenPortal "(Lorg/postgresql/core/v3/Portal;)V processDeadPortals deadPortal processResults '(Lorg/postgresql/core/ResultHandler;I)V typeOid describeData [Ljava/lang/Object; origStatementName numParams currentQuery executeData currentPortal oome Ljava/lang/OutOfMemoryError; length failedQueryAndStatement failedQuery parsedQueryAndStatement parsedQuery parsedStatementName boundPortal tuple bothRowsAndStatus tuples Ljava/util/List; doneAfterRowDescNoData parseIndex describeIndex describePortalIndex bindIndex executeIndexX skipMessage fetch I(Lorg/postgresql/core/ResultCursor;Lorg/postgresql/core/ResultHandler;I)V cursor "Lorg/postgresql/core/ResultCursor;Y receiveFields ()[Lorg/postgresql/core/Field; columnLabel tableOid positionInTable S typeLength typeModifier formatType l_msgSize size receiveAsyncNotify msglen pid param receiveErrorResponse ()Ljava/sql/SQLException; elen totalMessage errorMsg (Lorg/postgresql/util/ServerErrorMessage;< receiveNoticeResponse ()Ljava/sql/SQLWarning; nlen warnMsg receiveCommandStatus ()Ljava/lang/String; interpretCommandStatus 8(Ljava/lang/String;Lorg/postgresql/core/ResultHandler;)V updates nfe !Ljava/lang/NumberFormatException; update_count insert_oidK receiveRFQ tStatus C SourceFile QueryExecutorImpl.javaª»?? java/util/HashMap?? java/lang/ref/ReferenceQueue?????? java/util/ArrayList????????????¦? "org/postgresql/core/v3/SimpleQuery java/lang/String BEGINªZ§¨©¨?? ¡¢£[\]^_¤¥ !org/postgresql/util/PSQLException -Tried to obtain lock while already holding it`abcdeªfº» *Tried to break lock on database connectiong»h» java/lang/InterruptedException ?Interrupted while waiting to obtain lock on database connectionªiÆǪjklmnopqrstutvtwtxyzÀÂ{|}~Ó?{??»x??m %org/postgresql/core/v3/CompositeQueryª???m java/lang/StringBuilder simple execute, handler=???? , maxRows=?? , fetchSize= , flags=?Ó?z? &org/postgresql/core/v3/V3ParameterList?»?»ûü Corg/postgresql/core/v3/QueryExecutorImpl$ErrorTrackingResultHandlerª? org/postgresql/core/v3/V3QueryMNT»?? #org/postgresql/core/PGBindException .Unable to bind parameter values for statement.?e??T?? java/io/IOException?» 3An I/O error occurred while sending to the backend.?e?» batch execute queries, handler=?m?»?»?{}~ *org/postgresql/core/v3/QueryExecutorImpl$1ª?» *org/postgresql/core/v3/SimpleParameterList +Issuing BEGIN before fastpath or copy call. *org/postgresql/core/v3/QueryExecutorImpl$2ª?ª? FE=> FunctionCall( , ?{ params)? ¡¢U£j¤j¥j¦ §¨©»ªm«{ûÇÈÎϬ Unknown Response Type {0}. java/lang/Characterª®a¯°?Ü»±{ <=BE FunctionCallResponse( bytes)²³´µ¶ FE=> Query(CopyStart)·¸>? -Database connection failed when starting copy¹{³´Vº»¿À *Tried to cancel an inactive copy operation !org/postgresql/core/v3/CopyInImpl FE => CopyFail Copy cancel requested java/sql/SQLException¼È "org/postgresql/core/v3/CopyOutImpl½» 8Database connection failed when canceling copy operation 6Missing expected error response to copy cancel request¾e 5Got {0} error responses to single copy cancel request¿? Tried to end inactive copy FE=> CopyDoneÀÁ +Database connection failed when ending copy ,Tried to write to an inactive copy operation FE=> CopyData( )·³ /Database connection failed when writing to copy Tried to read from inactive copy 1Database connection failed when reading from copyÂ{ + <=BE CommandStatus, Ignored until CopyDone - <=BE Asynchronous Notification while copying <=BE Notification while copyingÒÓ AReceived CommandComplete ''{0}'' without an active copy operationÃz <=BE CopyInResponse 3Got CopyInResponse from server during an active {0}ÄÅÆÇÓ#$ <=BE CopyOutResponse 4Got CopyOutResponse from server during an active {0} <=BE CopyData²È -Got CopyData without an active copy operation 'Unexpected copydata from server for {0}ɸ <=BE CopyDone *Got CopyDone while not copying from serverÊÓ <=BE ParameterStatus( = client_encodingËÀ UTF8ÌÍ ?The server''s client_encoding parameter was changed to {0}. The JDBC driver requires client_encoding to be UTF8 for correct operation. DateStyle ISO,ÎÍ ?The server''s DateStyle parameter was changed to {0}. The JDBC driver requires DateStyle to begin with ISO for correct operation. standard_conforming_strings onÏÐ lThe server''s standard_conforming_strings parameter was reported as {0}. The JDBC driver expected on or off.¸´ * <=BE RowDescription (during copy ignored)²» # <=BE DataRow (during copy ignored) 'Unexpected packet type during copy: {0}Ñ??ªzÒmÓ{ ZCouldn't estimate result size or result size unbounded, disabling batching for this query. 8Forcing Sync, receive buffer full or batching disallowedÔÕÖ×GH FE=> SyncØÙÚÛÜ»ÝÞ S_?ßàz×áâãäåæç FE=> Parse(stmt= ,query=" $ ",oids={ ,è¢ }) java/lang/ObjectéÓê FE=> Bind(stmt= ,portal= ,$ =< >ë¹noìj ?Bind message length {0} too long. This can be caused by very large or incorrect length specifications on InputStream parameters. java/lang/Longªíªîï{ð{ñ FE=> Describe(portal=òÐ FE=> Describe(statement= java/lang/BooleanªÐóÐ FE=> Execute(portal= ,limit= FE=> ClosePortal( FE=> CloseStatement(UVômõÙö÷uV C_ org/postgresql/core/v3/Portalª?abstvw java/lang/ref/PhantomReferenceªøùúûüýþÿ |zÓyz <=BE ParseComplete [ ]?? <=BE ParameterDescriptionm× <=BE BindComplete [?? <=BE CloseComplete <=BE NoData <=BE PortalSuspended java/lang/IllegalStateException :Received resultset tuples, but no field structure for themÔÕ java/lang/OutOfMemoryError +Ran out of memory retrieving query results.eX <=BE DataRow(len= <=BE EmptyQuery org/postgresql/core/Query EMPTYà ¸¹ FE=> CopyFail ;The JDBC driver currently does not support COPY operations. 6The driver currently does not support COPY operations. e Unexpected packet type: j *org/postgresql/core/v3/QueryExecutorImpl$3ª org/postgresql/core/Field <=BE RowDescription(ª org/postgresql/core/Notificationª <=BE AsyncNotify(Ê? &org/postgresql/util/ServerErrorMessage{ª <=BE ErrorMessage(ª <=BE NoticeResponse( org/postgresql/util/PSQLWarning <=BE CommandStatus( INSERT UPDATE DELETE MOVE¢¢ java/lang/NumberFormatException DUnable to interpret the update count in command completion tag: {0}. *unexpected length of ReadyForQuery message <=BE ReadyForQuery(?j 7unexpected transaction state in ReadyForQuery message: (org/postgresql/core/v3/QueryExecutorImpl !org/postgresql/core/QueryExecutor !org/postgresql/core/ResultHandler org/postgresql/core/PGStream (org/postgresql/core/v3/CopyOperationImpl java/lang/Throwable java/util/List org/postgresql/core/ResultCursor E([Ljava/lang/String;Lorg/postgresql/core/v3/ProtocolConnectionImpl;)V org/postgresql/PGProperty ALLOW_ENCODING_CHANGES Lorg/postgresql/PGProperty; getBoolean (Ljava/util/Properties;)Z org/postgresql/util/GT tr &(Ljava/lang/String;)Ljava/lang/String; org/postgresql/util/PSQLState OBJECT_NOT_IN_STATE Lorg/postgresql/util/PSQLState; 4(Ljava/lang/String;Lorg/postgresql/util/PSQLState;)V notify wait I(Ljava/lang/String;Lorg/postgresql/util/PSQLState;Ljava/lang/Throwable;)V (I)V -org/postgresql/core/v3/ProtocolConnectionImpl getStandardConformingStrings ()Z toCharArray ()[C org/postgresql/core/Parser parseSingleQuotes ([CIZ)I parseDoubleQuotes ([CI)I parseLineComment parseBlockComment parseDollarQuotes substring (II)Ljava/lang/String; add ()I get (I)Ljava/lang/Object; trim toArray (([Ljava/lang/Object;)[Ljava/lang/Object; clear (I)Ljava/lang/String; isEmpty *([Lorg/postgresql/core/v3/SimpleQuery;[I)V org/postgresql/core/Logger logDebug append -(Ljava/lang/String;)Ljava/lang/StringBuilder; -(Ljava/lang/Object;)Ljava/lang/StringBuilder; (I)Ljava/lang/StringBuilder; toString debug NO_PARAMETERS convertFunctionOutParameters checkAllParametersSet &(Lorg/postgresql/core/ResultHandler;)V INVALID_PARAMETER_VALUE getIOException ()Ljava/io/IOException; handleError (Ljava/sql/SQLException;)V close CONNECTION_FAILURE handleCompletion hasErrors getTransactionState P(Lorg/postgresql/core/v3/QueryExecutorImpl;Lorg/postgresql/core/ResultHandler;)V -(Lorg/postgresql/core/v3/QueryExecutorImpl;)V 3(ILorg/postgresql/core/v3/ProtocolConnectionImpl;)V getParameterCount isNull (I)Z getV3Length (I)I SendChar SendInteger4 SendInteger2 isBinary writeV3Value "(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; setNextException ReceiveInteger4 Receive ([BII)V org/postgresql/core/Utils encodeUTF8 (Ljava/lang/String;)[B Send ([B)V ReceiveInteger2 init 0(Lorg/postgresql/core/v3/QueryExecutorImpl;I[I)V getNextException sendQueryCancel COMMUNICATION_ERROR valueOf getHandledRowCount ()J PeekChar handleCommandStatus getClass ()Ljava/lang/Class; java/lang/Class getName (I)[B handleCopydata ReceiveString equals equalsIgnoreCase (Ljava/lang/String;)Z startsWith setStandardConformingStrings (Z)V java/lang/Integer isStatementDescribed getMaxResultRowSize getSubqueries '()[Lorg/postgresql/core/v3/SimpleQuery; getSubparams /()[Lorg/postgresql/core/v3/SimpleParameterList; getTypeOIDs ()[I isPreparedFor ([I)Z unprepare setFields ([Lorg/postgresql/core/Field;)V (J)Ljava/lang/StringBuilder; setStatementName clone ()Ljava/lang/Object; setStatementTypes ([I)V getEncodedStatementName getFragments ()[Ljava/lang/String; getTypeOID getStatementName getEncodedPortalName getFields setFormat (J)V (Ljava/io/IOException;)V getFormat getOID useBinaryForReceive setPortalDescribed setStatementDescribed hasUnresolvedTypes getStatementTypes setResolvedType (II)V 3(Ljava/lang/Object;Ljava/lang/ref/ReferenceQueue;)V put 8(Ljava/lang/Object;Ljava/lang/Object;)Ljava/lang/Object; setCleanupRef #(Ljava/lang/ref/PhantomReference;)V poll ()Ljava/lang/ref/Reference; remove &(Ljava/lang/Object;)Ljava/lang/Object; getPortalName booleanValue handleResultRows l(Lorg/postgresql/core/Query;[Lorg/postgresql/core/Field;Ljava/util/List;Lorg/postgresql/core/ResultCursor;)V ReceiveTupleV3 ()[[B OUT_OF_MEMORY (Ljava/lang/String;IJ)V handleWarning NOT_IMPLEMENTED Skip o(Lorg/postgresql/core/v3/QueryExecutorImpl;Lorg/postgresql/core/ResultHandler;Lorg/postgresql/core/v3/Portal;)V getQuery &()Lorg/postgresql/core/v3/SimpleQuery; ,(Ljava/lang/String;Ljava/lang/String;IIIII)V ((Ljava/lang/String;ILjava/lang/String;)V addNotification "(Lorg/postgresql/PGNotification;)V getLogLevel (Ljava/lang/String;I)V +(Lorg/postgresql/util/ServerErrorMessage;)V lastIndexOf parseLong (Ljava/lang/String;)J indexOf (C)Ljava/lang/StringBuilder; setTransactionState !? ÿ ? ?? ?? ? ä ?? ? ? ?? ?? ?? ?? ?? ?? ?? ?? ?? ?? ?? ¡ ¢£ ¤¥ ¦? §¨ ©¨ 3 ª« ¬ Z ¼*· *µ *» Y· µ *» Y· µ *» Y· µ *» Y· µ *» Y· µ *» Y· µ *» Y· µ *» Y· µ *» Y· µ * µ *µ *» Y½ YS· µ *» Y½ YS· µ *+µ *,µ *µ *² -¶ µ ± R ! 5 ¼ ½ Û *Ü 5 0 @ 1 K 2 V 3 a 4 l 6 q D v F ? H "