Edit C:\Users\Administrator\Desktop\LIV\lib\org\postgresql\core\v3\QueryExecutorImpl.class
Êþº¾ 2 ëÏ |ÐÑ Ï |ÒÓ Ï |Ô |Õ |Ö× Ï |Ø |Ù |Ú |Û |Ü |ÝÞßà á |â |ã |ä |å? æç è é |êëì íî ïð ñ |òó ëô ëõö÷ ø |ù ú ûü ý þÿ þ þ þ þ |Å A DÏ D D D D P P |!" T# |$% |& |' |()* ï+ [,-./ û01 ï2-345 T6 |7 |8 û9 |:; l= |>? |@ |ABC sD oEFG oHI oJ oK LM LN LO oP oQ LR LS LT |U |V |W ûXYZ ?[ í\ ?] |^ L_`a Lb cd Le |fg Lh |i jk |lmnopq ?rs ûtuv ïwx yz ?{|}~ L???? L???? |?? j??? ë? ?? ?Ï |??? Ï? L???? ??? |?? |??? ¡ `¢ W£ P¤¥ o¦ § ¨© Dª « ¬Ò ® ¯ °±²³ Þ¢´ Þµ¶·< o¸¹ Þº » ¼½¾¿À o¡Á ?ÿÿÿÂà ûÄ [ÅÆ ÇÈÉ Ê ËÌÍÎÏ |Ð Ñ oÑ Ò Ó oÔ |ÕÖ× Ø |Ù Ú |Û |ÜÝ Þ ß à á â |ã ä à |å?æç |èé ê ëì |íîï ðñ -Ï-òó |ô 0 Lõö÷ ïø -ùúûüý-þ-ÿ L û0 | ï L W Z Z ^ û!" L#$ % c&' c ()* j(+,-./ 0 1 2 û34567 D8 û9:;< 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; StackMapTable;=>?@ 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 doSubprotocolBeginA 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 returnValueq 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 fieldFormatsB cancelCopy next msg errorsºqC 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;B 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Þ±N sendBind r(Lorg/postgresql/core/v3/SimpleQuery;Lorg/postgresql/core/v3/SimpleParameterList;Lorg/postgresql/core/v3/Portal;)V be portal Lorg/postgresql/core/v3/Portal; encodedPortalName bindException×) 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 fields [Lorg/postgresql/core/Field; executeData currentPortal oome Ljava/lang/OutOfMemoryError; l_len name value failedQueryAndStatement failedQuery parsedQueryAndStatement parsedQuery parsedStatementName boundPortal tuple bothRowsAndStatus tuples Ljava/util/Vector; doneAfterRowDescNoData parseIndex describeIndex describePortalIndex bindIndex executeIndexñ?ö skipMessage fetch I(Lorg/postgresql/core/ResultCursor;Lorg/postgresql/core/ResultHandler;I)V cursor "Lorg/postgresql/core/ResultCursor;D 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_oid4 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 E?????????FGHIJK?? !org/postgresql/util/PSQLException -Tried to obtain lock while already holding itLMGNOP Qµ¶ *Tried to break lock on database connectionR¶S¶ java/lang/InterruptedException ?Interrupted while waiting to obtain lock on database connection TÁ U=VKWXYZ[\]^]_]`]abc»°defgÁhdijk¶almK?? %org/postgresql/core/v3/CompositeQuery n@oK java/lang/StringBuilder simple execute, handler=pqpr , maxRows=ps , fetchSize= , flags=tÁucv &org/postgresql/core/v3/V3ParameterListw¶x¶õö Corg/postgresql/core/v3/QueryExecutorImpl$ErrorTrackingResultHandler y?? org/postgresql/core/v3/V3Query>?D¶|} #org/postgresql/core/PGBindException .Unable to bind parameter values for statement.zP{|A}~ java/io/IOException¶ 2An I/O error occured while sending to the backend.?P?¶ batch execute queries, handler=?Ku¶z¶?dfg *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( , ?d params)????>?U?U?U?????¶?K?d±¶µ¶¼½?? Unknown Response Type {0}. java/lang/Character ?M??~ɶ?d <=BE FunctionCallResponse( bytes)????? ¡78 -Database connection failed when starting copy¢d¯°B£¤º» *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§P 5Got {0} error responses to single copy cancel requestHl Tried to end inactive copy¨© +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ªd + <=BE CommandStatus, Ignored until CopyDone - <=BE Asynchronous Notification while copying <=BE Notification while copyingÀÁ AReceived CommandComplete ''{0}'' without an active copy operation«c <=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} null±¡ <=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}²tl c³´µ¶ FE=> Sync·¸¹º»¶ S_p¼½cÒ¾¿ÀÁÂÃÄ java/lang/StringBuffer FE=> Parse(stmt= ,query=" $pÅ ",oids={ ,Æ? }) java/lang/ObjectÇÁÈ FE=> Bind(stmt= ,portal= ,$ =< > ?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(EFÎKÏKиÑÒ^F C_ org/postgresql/core/v3/Portal rSTÓK\]_` java/lang/ref/PhantomReference ÔÕÖ×ØÙÚÛÜecÝÁbc <=BE ParseComplete [ ]qr <=BE ParameterDescriptionÞ»Ò <=BE BindComplete [xy <=BE CloseComplete <=BE NoDataߧ java/util/Vectoràá <=BE PortalSuspendedÂÃâã java/lang/OutOfMemoryError +Ran out of memory retrieving query results.äPå° <=BE DataRow <=BE EmptyQuery org/postgresql/core/Query EMPTY«æç?èÁ <=BE ParameterStatus( = client_encoding UNICODEéê UTF8 ?The server''s client_encoding parameter was changed to {0}. The JDBC driver requires client_encoding to be UNICODE 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.ïP Unexpected packet type: ðU *org/postgresql/core/v3/QueryExecutorImpl$3 ñòó org/postgresql/core/Field <=BE RowDescription( ôõU org/postgresql/core/Notification ö÷ø <=BE AsyncNotify(èl &org/postgresql/util/ServerErrorMessageùd ú <=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(pU 7unexpected transaction state in ReadyForQuery message: (org/postgresql/core/v3/QueryExecutorImpl !org/postgresql/core/QueryExecutor -org/postgresql/core/v3/ProtocolConnectionImpl org/postgresql/core/PGStream java/util/Properties org/postgresql/core/Logger !org/postgresql/core/ResultHandler (org/postgresql/core/v3/CopyOperationImpl java/lang/Throwable org/postgresql/core/ResultCursor E([Ljava/lang/String;Lorg/postgresql/core/v3/ProtocolConnectionImpl;)V 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 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 length toArray (([Ljava/lang/Object;)[Ljava/lang/Object; clear (I)Ljava/lang/String; isEmpty *([Lorg/postgresql/core/v3/SimpleQuery;[I)V 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 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 (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 (J)V (Ljava/io/IOException;)V setPortalDescribed (Z)V setStatementDescribed hasUnresolvedTypes isStatementDescribed getStatementTypes setResolvedType (II)V isPortalDescribed 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 getFields handleResultRows n(Lorg/postgresql/core/Query;[Lorg/postgresql/core/Field;Ljava/util/Vector;Lorg/postgresql/core/ResultCursor;)V ReceiveTupleV3 ()[[B OUT_OF_MEMORY addElement (Ljava/lang/String;IJ)V handleWarning ReceiveString equalsIgnoreCase (Ljava/lang/String;)Z startsWith setStandardConformingStrings setFields ([Lorg/postgresql/core/Field;)V 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 setFormat ((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 !| ë } ?? ?? ? ? ?? ?? ?? ?? ?? ?? ?? ?? ?? ?? ?? ?? ?? ?? ?? ?? ?? 2 ¡ ¢ u ¸*· *µ *» Y· µ *» Y· µ *» Y· µ *» Y· µ *» Y· µ *» Y· µ *» Y· µ *» Y· µ *» Y· µ * µ *» Y½ YS· µ *+µ *,µ *µ -¶ Æ *-¶ ¸ ¶ µ § *µ ± £ R # ; ' ( F *G 5{ @| K} V~ a l? q? ? $ ? % ? &