Edit C:\galaxie\jobs\GALAXIE__JOBs\GALAXIE__PCKG_0.5\lib\org\postgresql\core\QueryExecutorBase.class
Êþº¾ 4! %org/postgresql/core/QueryExecutorBase java/lang/Object !org/postgresql/core/QueryExecutor QueryExecutorBase.java 'org/postgresql/core/QueryExecutorBase$1 )org/postgresql/util/LruCache$CreateAction org/postgresql/util/LruCache CreateAction (org/postgresql/util/LruCache$EvictAction EvictAction LOGGER Ljava/util/logging/Logger; pgStream Lorg/postgresql/core/PGStream; user Ljava/lang/String; database cancelSignalTimeout I cancelPid cancelKey closed Z serverVersion serverVersionNum transactionState &Lorg/postgresql/core/TransactionState; reWriteBatchedInserts columnSanitiserDisabled escapeSyntaxCallMode *Lorg/postgresql/jdbc/EscapeSyntaxCallMode; preferQueryMode %Lorg/postgresql/jdbc/PreferQueryMode; autoSave Lorg/postgresql/jdbc/AutoSave; flushCacheOnDeallocate logServerErrorDetail standardConformingStrings warnings Ljava/sql/SQLWarning; notifications Ljava/util/ArrayList; 6Ljava/util/ArrayList<Lorg/postgresql/PGNotification;>; statementCache Lorg/postgresql/util/LruCache; SLorg/postgresql/util/LruCache<Ljava/lang/Object;Lorg/postgresql/core/CachedQuery;>; cachedQueryCreateAction -Lorg/postgresql/core/CachedQueryCreateAction; parameterStatuses Ljava/util/TreeMap; 9Ljava/util/TreeMap<Ljava/lang/String;Ljava/lang/String;>; <init> \(Lorg/postgresql/core/PGStream;Ljava/lang/String;Ljava/lang/String;ILjava/util/Properties;)V java/sql/SQLException = ()V ; ? @ B D + F - H java/util/ArrayList J K @ 0 1 M java/util/TreeMap O java/lang/String Q CASE_INSENSITIVE_ORDER Ljava/util/Comparator; S T R U (Ljava/util/Comparator;)V ; W P X 8 9 Z \ ^ ` b org/postgresql/PGProperty d REWRITE_BATCHED_INSERTS Lorg/postgresql/PGProperty; f g e h getBoolean (Ljava/util/Properties;)Z j k e l # n DISABLE_COLUMN_SANITISER p g e q $ s ESCAPE_SYNTAX_CALL_MODE u g e v get *(Ljava/util/Properties;)Ljava/lang/String; x y e z (org/postgresql/jdbc/EscapeSyntaxCallMode | of >(Ljava/lang/String;)Lorg/postgresql/jdbc/EscapeSyntaxCallMode; ~ } ? % & ? PREFER_QUERY_MODE ? g e ? #org/postgresql/jdbc/PreferQueryMode ? 9(Ljava/lang/String;)Lorg/postgresql/jdbc/PreferQueryMode; ~ ? ? ? ' ( ? AUTOSAVE ? g e ? org/postgresql/jdbc/AutoSave ? 2(Ljava/lang/String;)Lorg/postgresql/jdbc/AutoSave; ~ ? ? ? ) * ? LOG_SERVER_ERROR_DETAIL ? g e ? , ? +org/postgresql/core/CachedQueryCreateAction ? &(Lorg/postgresql/core/QueryExecutor;)V ; ? ? 6 7 ¢ PREPARED_STATEMENT_CACHE_QUERIES ¤ g e ¥ getInt (Ljava/util/Properties;)I § ¨ e © java/lang/Math « max (II)I ® ¬ ¯ !PREPARED_STATEMENT_CACHE_SIZE_MIB ± g e ² *(Lorg/postgresql/core/QueryExecutorBase;)V ; ´ µ [(IJZLorg/postgresql/util/LruCache$CreateAction;Lorg/postgresql/util/LruCache$EvictAction;)V ; · ¸ 3 4 º this 'Lorg/postgresql/core/QueryExecutorBase; info Ljava/util/Properties; callMode preferMode sendCloseMessage java/io/IOException à setNetworkTimeout (I)V org/postgresql/core/PGStream Ç Å Æ È É milliseconds getNetworkTimeout ()I Ì Í È Î getHostSpec ()Lorg/postgresql/util/HostSpec; Ð Ñ È Ò getUser ()Ljava/lang/String; getDatabase setBackendKeyData (II)V Ù Û getBackendPID abort getSocket ()Ljava/net/Socket; ß à È á java/net/Socket ã close å ? ä æ è java/util/logging/Level ê FINEST Ljava/util/logging/Level; ì í ë î FE=> Terminate ð java/util/logging/Logger ò log .(Ljava/util/logging/Level;Ljava/lang/String;)V ô õ ó ö  ? ø flush ú ? È û È æ Discarding IOException on close: þ C(Ljava/util/logging/Level;Ljava/lang/String;Ljava/lang/Throwable;)V ô ó ioe Ljava/io/IOException; isClosed ()Z sendQueryCancel isLoggable (Ljava/util/logging/Level;)Z ó % FE=> CancelRequest(pid={0},ckey={1}) java/lang/Integer valueOf (I)Ljava/lang/Integer; A(Ljava/util/logging/Level;Ljava/lang/String;[Ljava/lang/Object;)V ô ó getSocketFactory ()Ljavax/net/SocketFactory; È ;(Ljavax/net/SocketFactory;Lorg/postgresql/util/HostSpec;I)V ; È setSoTimeout Æ ä sendInteger4! Æ È" sendInteger2$ Æ È% receiveEOF' ? È( %Ignoring exception on cancel request:* java/lang/Throwable, e cancelStream addWarning (Ljava/sql/SQLWarning;)V . / 2 java/sql/SQLWarning4 setNextWarning61 57 newWarning addNotification "(Lorg/postgresql/PGNotification;)V add (Ljava/lang/Object;)Z<= K> notification Lorg/postgresql/PGNotification; getNotifications "()[Lorg/postgresql/PGNotification; org/postgresql/PGNotificationD toArray (([Ljava/lang/Object;)[Ljava/lang/Object;FG KH [Lorg/postgresql/PGNotification;J clearL ? KM array getWarnings ()Ljava/sql/SQLWarning; chain getServerVersion T getServerVersionNum org/postgresql/core/UtilsW parseServerVersionStr (Ljava/lang/String;)IYZ X[ setServerVersion (Ljava/lang/String;)V setServerVersionNum setTransactionState )(Lorg/postgresql/core/TransactionState;)V ! " b state setStandardConformingStrings (Z)V value getStandardConformingStrings getTransactionState (()Lorg/postgresql/core/TransactionState; setEncoding !(Lorg/postgresql/core/Encoding;)Vkl Èm encoding Lorg/postgresql/core/Encoding; getEncoding ()Lorg/postgresql/core/Encoding;qr Ès isReWriteBatchedInsertsEnabled borrowQuery 5(Ljava/lang/String;)Lorg/postgresql/core/CachedQuery; borrow 9(Ljava/lang/Object;)Lorg/postgresql/util/CanEstimateSize;xy z org/postgresql/core/CachedQuery| sql borrowCallableQuery $org/postgresql/core/CallableQueryKey? ;^ ?? borrowReturningQuery H(Ljava/lang/String;[Ljava/lang/String;)Lorg/postgresql/core/CachedQuery; 0org/postgresql/core/QueryWithReturningColumnsKey? *(Ljava/lang/String;ZZ[Ljava/lang/String;)V ;? ?? columnNames [Ljava/lang/String; borrowQueryByKey 5(Ljava/lang/Object;)Lorg/postgresql/core/CachedQuery; key Ljava/lang/Object; releaseQuery $(Lorg/postgresql/core/CachedQuery;)V?? }? put :(Ljava/lang/Object;Lorg/postgresql/util/CanEstimateSize;)V?? ? cachedQuery !Lorg/postgresql/core/CachedQuery; createQueryKey ;(Ljava/lang/String;ZZ[Ljava/lang/String;)Ljava/lang/Object; org/postgresql/core/BaseQueryKey? (Ljava/lang/String;ZZ)V ;? ? escapeProcessing isParameterized createQueryByKey create¥? ?¦ createQuery J(Ljava/lang/String;ZZ[Ljava/lang/String;)Lorg/postgresql/core/CachedQuery;?? ª¤? ¬ isColumnSanitiserDisabled getEscapeSyntaxCallMode ,()Lorg/postgresql/jdbc/EscapeSyntaxCallMode; getPreferQueryMode '()Lorg/postgresql/jdbc/PreferQueryMode; getAutoSave ()Lorg/postgresql/jdbc/AutoSave; setAutoSave !(Lorg/postgresql/jdbc/AutoSave;)V willHealViaReparse (Ljava/sql/SQLException;)Z getSQLState¹ Õ >º org/postgresql/util/PSQLState¼ INVALID_SQL_STATEMENT_NAME Lorg/postgresql/util/PSQLState;¾¿ ½À getStateÂ Õ ½Ã equalsÅ= RÆ NOT_IMPLEMENTEDÈ¿ ½É !org/postgresql/util/PSQLExceptionË getServerErrorMessage *()Lorg/postgresql/util/ServerErrorMessage;ÍÎ ÌÏ &org/postgresql/util/ServerErrorMessageÑ getRoutineÓ Õ ÒÔ RevalidateCachedQueryÖ RevalidateCachedPlanØ Ljava/sql/SQLException; pe #Lorg/postgresql/util/PSQLException; serverErrorMessage (Lorg/postgresql/util/ServerErrorMessage; routine willHealOnRetry NEVERá * ?âij ä $org/postgresql/core/TransactionStateæ FAILEDè " çé·¸ ë isFlushCacheOnDeallocate setFlushCacheOnDeallocate hasNotifications sizeð Í Kñ getParameterStatuses ()Ljava/util/Map; java/util/Collectionsõ unmodifiableMap (Ljava/util/Map;)Ljava/util/Map;÷ø öù getParameterStatus &(Ljava/lang/String;)Ljava/lang/String; &(Ljava/lang/Object;)Ljava/lang/Object; xý Pþ parameterName onParameterStatus '(Ljava/lang/String;Ljava/lang/String;)V java/lang/IllegalStateException Battempt to set GUC_REPORT parameter with null or empty-string name ? 8(Ljava/lang/Object;Ljava/lang/Object;)Ljava/lang/Object;? P parameterStatus <clinit> java/lang/Class getName Õ getLogger .(Ljava/lang/String;)Ljava/util/logging/Logger; ó Signature Code LocalVariableTable LineNumberTable Exceptions StackMapTable 7()Ljava/util/Map<Ljava/lang/String;Ljava/lang/String;>; SourceFile InnerClasses! ! "