Edit C:\Users\Administrator\Desktop\back-talend\lib\org\postgresql\core\v3\QueryExecutorImpl.class
Êþº¾ 0 ./ . 101 . 12 13 145 . 16 17 18 19 1:;<= > 1? 1@ 1A 1BL CD ·E ·F 1G 1H I JK L MN MO MP MQ MR S T U V W X Y Z [ \ 1]c^ 3_ `ab 6.c 6d 6ef 6ghi 6j `k lm Bn Bo 1pq 1r 1s 1tuvw xy z{ J| K}~? J?? z?~???? Y? Y? 1? 1? J? 1?? `??? c?? 1? 1? eI?? e?? e? e? ?? ?? ? e¡ e¢ ?£ ?¤ ?¥ 1¦ 1§ 1¨ J©ª« |¬ x K® ?¯ 1° ?±²³ ?´ Fµ B¶· e¸ ¹ º» 6¼ ½ ¾p ¿ À ÁÂà 6ÄÅÆÇ? eÈɨ ÊË ?ÌÍ Î ÁÏÐÑÒÓ eÔÕÖ ?ÿÿÿר ±Ù RÄ JÚÛÜÝ ·Þßàáâ eã 1ä 1åæç Áè 1é 1ê 1ëì Æí î ï ð ñ 1ò ÆZ Áó Áï 1ôãõö 1÷ø ?ù eú ûü 1ýþÿ ~ 1 1 Á? ? z ç. ç ~~ ? J 1 !"# 1$%& z'()* ?+, - Á./0 1 23 4 J56 ?78 `9 :; j K<=> < ??@ABCD E FG H ±IJKLM 6N JOPQR ErrorTrackingResultHandler InnerClasses MAX_BUFFERED_QUERIES I ConstantValue parsedQueryMap Ljava/util/HashMap; parsedQueryCleanupQueue Ljava/lang/ref/ReferenceQueue; openPortalMap openPortalCleanupQueue pendingParseQueue Ljava/util/ArrayList; pendingBindQueue pendingExecuteQueue pendingDescribeStatementQueue nextUniqueID J protoConnection /Lorg/postgresql/core/v3/ProtocolConnectionImpl; pgStream Lorg/postgresql/core/PGStream; logger Lorg/postgresql/core/Logger; allowEncodingChanges Z 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; 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 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 ExceptionsS 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; queryCount trackingHandler ELorg/postgresql/core/v3/QueryExecutorImpl$ErrorTrackingResultHandler; 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 createFastpathParameters &(I)Lorg/postgresql/core/ParameterList; count sendFastpathCall 0(ILorg/postgresql/core/v3/SimpleParameterList;)V params ,Lorg/postgresql/core/v3/SimpleParameterList; paramCount encodedSize processNotifies ()V warning Ljava/sql/SQLWarning; c receiveFastpathResult ()[B newError Ljava/sql/SQLException; buf [B msgLen valueLen endQuery error returnValue sendQuery N(Lorg/postgresql/core/v3/V3Query;Lorg/postgresql/core/v3/V3ParameterList;III)V subparam subparams -[Lorg/postgresql/core/v3/SimpleParameterList; 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 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 "(Lorg/postgresql/core/v3/Portal;)V sendDescribeStatement sendExecute >(Lorg/postgresql/core/Query;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 noResults noMeta usePortal describeStatement registerParsedQuery 9(Lorg/postgresql/core/v3/SimpleQuery;Ljava/lang/String;)V cleanupRef Ljava/lang/ref/PhantomReference; processDeadParsedQueries deadQuery registerOpenPortal processDeadPortals deadPortal processResults '(Lorg/postgresql/core/ResultHandler;I)V parsedQueryAndStatement [Ljava/lang/Object; parsedQuery parsedStatementName typeOid describeData origStatementName numParams boundPortal currentQuery executeData currentPortal status oome Ljava/lang/OutOfMemoryError; tuple Ljava/lang/Object; l_len name value failedQueryAndStatement failedQuery fields [Lorg/postgresql/core/Field; tuples Ljava/util/Vector; doneAfterRowDescNoData parseIndex describeIndex 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 msg 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.javaQ? java/util/HashMap9: java/lang/ref/ReferenceQueue;<=:>< java/util/ArrayList?@A@B@C@DE "org/postgresql/core/v3/SimpleQuery java/lang/String BEGINQTNOFGHIJKUVWXYZ[LM_`Q\]^[_`abcdefegeheijklmnop!qmrst?iuv[PO %org/postgresql/core/v3/CompositeQueryQwxy[ java/lang/StringBuffer simple execute, handler=z{z| , maxRows=z} , fetchSize= , flags=~!Í?? &org/postgresql/core/v3/V3ParameterList?????? org/postgresql/core/v3/V3Query®¯³?àá #org/postgresql/core/PGBindException !org/postgresql/util/PSQLException .Unable to bind parameter values for statement.??W?????Q???? java/io/IOException?? 2An I/O error occured while sending to the backend.???? batch execute queries, handler= Corg/postgresql/core/v3/QueryExecutorImpl$ErrorTrackingResultHandlerQ??[Û?Þ??mÐÑ *org/postgresql/core/v3/QueryExecutorImpl$1 Q? #Issuing BEGIN before fastpath call. *org/postgresql/core/v3/QueryExecutorImpl$2Q? *org/postgresql/core/v3/SimpleParameterList??£¤ FE=> FunctionCall( , ?m params)??????\?\?\?? ¡¢?£[¤m?¥¦ Unknown Response Type {0}. java/lang/CharacterQ§?¨Q©ª?(?«m <=BE FunctionCallResponse( bytes)¬®¯°± FE=> Sync²³´µ¶? S_z·¸Í¹º»¼½¤¾¿ FE=> Parse(stmt= ,query="QÍ $ ",oids={ ,À? })ÁÂÃÄÅ java/lang/ObjectÆ!Ǥ FE=> Bind(stmt= ,portal= ,$ =<~u > ) ?Bind message length {0} too long. This can be caused by very large or incorrect length specifications on InputStream parameters. java/lang/LongQÈQÉ FE=> Describe(portal= FE=> Describe(statement= java/lang/BooleanQÊ FE=> Execute(portal= ,limit= FE=> ClosePortal( FE=> CloseStatement(Ë[´µÈµ C_ org/postgresql/core/v3/PortalQØ¿ÀÆÇÉÊ java/lang/ref/PhantomReferenceQÌÍÎÏÐÑÒÓÔÏÍÕ!ÌÍ <=BE ParseComplete [ ]ר <=BE ParameterDescriptionÖmרÙl <=BE BindComplete [ÝÇ <=BE CloseComplete <=BE NoData org/postgresql/core/QueryÚÛ <=BE PortalSuspended !"#ÜÝ java/lang/OutOfMemoryError +Ran out of memory retrieving query results.Þ? java/util/Vectorßà <=BE DataRow <=BE EmptyQuery EMPTYáâã¦ä! <=BE ParameterStatus( = client_encoding UNICODEåæ ?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èÊ off lThe server''s standard_conforming_strings parameter was reported as {0}. The JDBC driver expected on or off. <=BE CopyInResponse FE=> CopyFail ;The JDBC driver currently does not support COPY operations.? <=BE CopyOutResponse 6The driver currently does not support COPY operations.é? <=BE CopyDone <=BE CopyData Unexpected packet type: ê\ *org/postgresql/core/v3/QueryExecutorImpl$3Qëìí org/postgresql/core/Field <=BE RowDescription(Qîï\ org/postgresql/core/NotificationQðñò <=BE AsyncNotify(äu &org/postgresql/util/ServerErrorMessageómQô <=BE ErrorMessage(Qõ <=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(zþÿ\ 7unexpected transaction state in ReadyForQuery message: (org/postgresql/core/v3/QueryExecutorImpl !org/postgresql/core/QueryExecutor java/sql/SQLException ([Ljava/lang/String;)V java/util/Properties getProperty &(Ljava/lang/String;)Ljava/lang/String; valueOf '(Ljava/lang/String;)Ljava/lang/Boolean; booleanValue ()Z (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 (Ljava/lang/Object;)Z ()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 org/postgresql/core/Logger logDebug append ,(Ljava/lang/String;)Ljava/lang/StringBuffer; ,(Ljava/lang/Object;)Ljava/lang/StringBuffer; (I)Ljava/lang/StringBuffer; toString debug NO_PARAMETERS convertFunctionOutParameters checkAllParametersSet org/postgresql/util/GT tr org/postgresql/util/PSQLState INVALID_PARAMETER_VALUE Lorg/postgresql/util/PSQLState; getIOException ()Ljava/io/IOException; I(Ljava/lang/String;Lorg/postgresql/util/PSQLState;Ljava/lang/Throwable;)V !org/postgresql/core/ResultHandler handleError (Ljava/sql/SQLException;)V close CONNECTION_FAILURE handleCompletion &(Lorg/postgresql/core/ResultHandler;)V hasErrors getTransactionState P(Lorg/postgresql/core/v3/QueryExecutorImpl;Lorg/postgresql/core/ResultHandler;)V -(Lorg/postgresql/core/v3/QueryExecutorImpl;)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; 4(Ljava/lang/String;Lorg/postgresql/util/PSQLState;)V setNextException ReceiveInteger4 Receive ([BII)V getSubqueries '()[Lorg/postgresql/core/v3/SimpleQuery; getSubparams /()[Lorg/postgresql/core/v3/SimpleParameterList; getTypeOIDs ()[I isPreparedFor ([I)Z unprepare (J)Ljava/lang/StringBuffer; setStatementName clone ()Ljava/lang/Object; setStatementTypes ([I)V getEncodedStatementName getFragments ()[Ljava/lang/String; getTypeOID org/postgresql/core/Utils encodeUTF8 (Ljava/lang/String;)[B Send ([B)V getStatementName getEncodedPortalName (J)V (Ljava/io/IOException;)V (Z)V hasUnresolvedTypes 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 ReceiveInteger2 setResolvedType (II)V equals 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/Object;)V handleCommandStatus (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 setFormat ((Ljava/lang/String;ILjava/lang/String;)V addNotification "(Lorg/postgresql/PGNotification;)V getLogLevel (Ljava/lang/String;I)V +(Lorg/postgresql/util/ServerErrorMessage;)V (I)[B lastIndexOf java/lang/Integer parseInt (Ljava/lang/String;)I indexOf parseLong (Ljava/lang/String;)J (C)Ljava/lang/StringBuffer; setTransactionState !1 2 56 7 8 9: ;<