Edit C:\edeal\jobs\JOB_EQUALITING\lib\org\postgresql\core\v3\QueryExecutorImpl.class
Êþº¾ 1í í¶ ·¸ ¶ ¹º ¶ » ¼ ½¾ ¶ ¿ À Á  à ÄÅÆÇ È É Ê Ë Ì? ÍÎ Ï Ð ÑÒÓ ÔÕ Ö× Ø ÙÚ íÛ íÜÝÞ ß à á âã ä åæ åç åè åé åê ë ì í î ï ð ñ ò ó ô õÁö A÷ øùú D¶û Dü Dýþ Dÿ D ø P P T Ö [ â Ö T â !" l$ %& ' ()* s+ o,-. o/0 o1 o2 34 35 36 o7 o8 39 3: 3; < = > â?@A ?B ÔC ?D E 3FGH 3I JKL 3M NO 3P Q RS TUVWXY ?Z[ â\]^ Ö_` abc ?defgh 3ijkl 3mnop qr Rstu ív wx ?¶ yz{ ¡¶| 3}~ ¡??? ?? ??? ?? `? W? P?? o? ? ? ?? D? ? ??Î ? ? ???? à?? à?? # o¡¢ ࣠¤ ¥¦§¨© o?ª « ¬ ] ?ÿÿÿ®¯ ° [± ]² ]³ â´µ ¶·¸ ¹ º»¼½¾ ¿ À oÀ Á  oà ÄÅÆ Ç È É ÊË Ì Í Î Ï Ð Ñ ò Ò Î ÓnÔÕ Ö× Ø Ù?Ú ÛÜÝÞß à 9 3áâã Öäåìæçèéêë 3ìíîïð ñòóô õö÷ø âùú ûüýþ Öÿ 3 Z ] a â 3 ø f f m ? ! D" â#$%& ErrorTrackingResultHandler InnerClasses lockedFor Ljava/lang/Object; MAX_BUFFERED_QUERIES I ConstantValue 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 queryCount 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 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 offset 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; sendQueryPreamble I(Lorg/postgresql/core/ResultHandler;I)Lorg/postgresql/core/ResultHandler; delegateHandler fastpathCall )(ILorg/postgresql/core/ParameterList;Z)[B ioe fnid suppressBegin doSubprotocolBegin createFastpathParameters &(I)Lorg/postgresql/core/ParameterList; count sendFastpathCall 0(ILorg/postgresql/core/v3/SimpleParameterList;)V params ,Lorg/postgresql/core/v3/SimpleParameterList; paramCount encodedSize 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 fieldFormats cancelCopy next msg errors 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; status block endReceiving len sendQuery ?(Lorg/postgresql/core/v3/V3Query;Lorg/postgresql/core/v3/V3ParameterList;IIILorg/postgresql/core/v3/QueryExecutorImpl$ErrorTrackingResultHandler;)V subparam subparams -[Lorg/postgresql/core/v3/SimpleParameterList; disallowBatching sendSync sendParse T(Lorg/postgresql/core/v3/SimpleQuery;Lorg/postgresql/core/v3/SimpleParameterList;Z)V sbuf Ljava/lang/StringBuffer; 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; bindException 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 l_len name value failedQueryAndStatement failedQuery parsedQueryAndStatement parsedQuery parsedStatementName boundPortal tuple bothRowsAndStatus tuples Ljava/util/List; doneAfterRowDescNoData parseIndex describeIndex describePortalIndex bindIndex executeIndex skipMessage fetch I(Lorg/postgresql/core/ResultCursor;Lorg/postgresql/core/ResultHandler;I)V cursor "Lorg/postgresql/core/ResultCursor; 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 nfe !Ljava/lang/NumberFormatException; update_count insert_oid receiveRFQ tStatus C <clinit> SourceFile QueryExecutorImpl.java£³?? java/util/HashMap?? java/lang/ref/ReferenceQueue?????? java/util/ArrayList???????????? "org/postgresql/core/v3/SimpleQuery java/lang/String BEGIN£' ¡??????()*+,-.?? !org/postgresql/util/PSQLException -Tried to obtain lock while already holding it/0*123£4²³ *Tried to break lock on database connection5³6³ java/lang/InterruptedException ?Interrupted while waiting to obtain lock on database connection£7½¾£89:.;<=>?@ABACADAEFG·?HIJK©vHLMN³EOP.¢¡ %org/postgresql/core/v3/CompositeQuery£QRS. java/lang/StringBuilder simple execute, handler=TUTV , maxRows=TW , fetchSize= , flags=X©YRZ÷ &org/postgresql/core/v3/V3ParameterList[³\³èé Corg/postgresql/core/v3/QueryExecutorImpl$ErrorTrackingResultHandler£]?? org/postgresql/core/v3/V3Query)*/³jk #org/postgresql/core/PGBindException .Unable to bind parameter values for statement.^3_`abc java/io/IOExceptiond³ 2An I/O error occured while sending to the backend.e3f³ batch execute queries, handler=g.d³h³hHUV *org/postgresql/core/v3/QueryExecutorImpl$1 £ið³ *org/postgresql/core/v3/SimpleParameterListôõþÿ +Issuing BEGIN before fastpath or copy call. *org/postgresql/core/v3/QueryExecutorImpl$2£j£k FE=> FunctionCall( , lH params)mnopqr8s8t8unvwx³y.zH?³??¤¥{| Unknown Response Type {0}. java/lang/Character£}0~c°³?H <=BE FunctionCallResponse( bytes)????? FE=> Query(CopyStart)??#$ -Database connection failed when starting copy?H¬???¶· *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?3 5Got {0} error responses to single copy cancel request+O 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?H + <=BE CommandStatus, Ignored until CopyDone - <=BE Asynchronous Notification while copying <=BE Notification while copying¨© AReceived CommandComplete ''{0}'' without an active copy operation?R <=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 RowDescription (during copy ignored)?³ # <=BE DataRow (during copy ignored) 'Unexpected packet type during copy: {0}?XO£R???? FE=> Sync?? ¡¢³£¤ S_T¥¦RΧ¨©ª«ÿ¬ java/lang/StringBuffer FE=> Parse(stmt= ,query=" $T® ",oids={ ,¯p }) java/lang/Object°©±ÿ FE=> Bind(stmt= ,portal= ,$ =< >²?FG³8 ?Bind message length {0} too long. This can be caused by very large or incorrect length specifications on InputStream parameters. java/lang/Long£´£µ¶H·H¸n FE=> Describe(portal=¹º FE=> Describe(statement= java/lang/Boolean£º»º FE=> Execute(portal= ,limit= FE=> ClosePortal( FE=> CloseStatement(01¼.½.¾?¿ÀM1 C_ org/postgresql/core/v3/Portal£a;<KLNO java/lang/ref/PhantomReference£ÁÂÃÄÅÆÇÈÉTRÊ©QR <=BE ParseComplete [ ]`a <=BE ParameterDescriptionË·Î <=BE BindComplete [fg <=BE CloseComplete <=BE NoDataÌÍ <=BE PortalSuspendedª«ÎÏ java/lang/OutOfMemoryError +Ran out of memory retrieving query results.Ð3Ñ <=BE DataRow(len= <=BE EmptyQuery org/postgresql/core/Query EMPTY?ÒÓ|Ô© <=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.?? FE=> CopyFail ;The JDBC driver currently does not support COPY operations. 6The driver currently does not support COPY operations.Ù3 Unexpected packet type: Ú8 *org/postgresql/core/v3/QueryExecutorImpl$3£ÛÜÝ org/postgresql/core/Field <=BE RowDescription(£Þ org/postgresql/core/Notification£ßàá <=BE AsyncNotify(ÔO &org/postgresql/util/ServerErrorMessageâH£ã <=BE ErrorMessage(£ä <=BE NoticeResponse( org/postgresql/util/PSQLWarning <=BE CommandStatus( INSERT UPDATE DELETE MOVEåpæçèpéê java/lang/NumberFormatException DUnable to interpret the update count in command completion tag: {0}. *unexpected length of ReadyForQuery message <=BE ReadyForQuery(Tëì8 7unexpected transaction state in ReadyForQuery message: (org/postgresql/core/v3/QueryExecutorImpl !org/postgresql/core/QueryExecutor E([Ljava/lang/String;Lorg/postgresql/core/v3/ProtocolConnectionImpl;)V java/util/Properties getProperty &(Ljava/lang/String;)Ljava/lang/String; valueOf '(Ljava/lang/String;)Ljava/lang/Boolean; booleanValue ()Z org/postgresql/util/GT tr 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 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; !org/postgresql/core/ResultHandler 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 org/postgresql/core/PGStream 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 (org/postgresql/core/v3/CopyOperationImpl init 0(Lorg/postgresql/core/v3/QueryExecutorImpl;I[I)V getNextException sendQueryCancel COMMUNICATION_ERROR getHandledRowCount ()J PeekChar handleCommandStatus getClass ()Ljava/lang/Class; java/lang/Class getName (I)[B handleCopydata java/lang/Integer 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; ,(Ljava/lang/String;)Ljava/lang/StringBuffer; getTypeOID getStatementName getEncodedPortalName getFields setFormat (J)V (Ljava/io/IOException;)V getFormat getOID useBinaryForReceive setPortalDescribed (Z)V setStatementDescribed hasUnresolvedTypes isStatementDescribed 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 equals handleResultRows l(Lorg/postgresql/core/Query;[Lorg/postgresql/core/Field;Ljava/util/List;Lorg/postgresql/core/ResultCursor;)V ReceiveTupleV3 ()[[B OUT_OF_MEMORY java/util/List (Ljava/lang/String;IJ)V handleWarning ReceiveString equalsIgnoreCase (Ljava/lang/String;)Z startsWith setStandardConformingStrings 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 parseInt (Ljava/lang/String;)I indexOf parseLong (Ljava/lang/String;)J (C)Ljava/lang/StringBuilder; setTransactionState ! í ? ?? ?? ? ? ?? ?? ?? ?? ?? ?? ?? ?? ?? ?? ?? ?? ?? ?? ?? ¡ ¢¡ 3 £¤ ¥ V ¸*· *µ *» Y· µ *» Y· µ *» Y· µ *» Y· µ *» Y· µ *» Y· µ *» Y· µ *» Y· µ *» Y· µ * µ *» Y½ YS· µ *+µ *,µ *µ -¶ Æ *-¶ ¸ ¶ µ § *µ ± ¦ R ! 9 U V t *u 5¸ @¹ Kº V» a¼ l¾ qÊ ? "