Edit C:\galaxie\jobs\GALAXIE__JOBs\GALAXIE__PCKG_0.5\lib\org\postgresql\core\v3\QueryExecutorImpl.class
Êþº¾ 4 (org/postgresql/core/v3/QueryExecutorImpl %org/postgresql/core/QueryExecutorBase QueryExecutorImpl.java *org/postgresql/core/v3/QueryExecutorImpl$4 *org/postgresql/core/v3/QueryExecutorImpl$3 *org/postgresql/core/v3/QueryExecutorImpl$2 *org/postgresql/core/v3/QueryExecutorImpl$1 2org/postgresql/core/EncodingPredictor$DecodeResult %org/postgresql/core/EncodingPredictor DecodeResult LOGGER Ljava/util/logging/Logger; COPY_ERROR_MESSAGE Ljava/lang/String; ;COPY commands are only supported using the CopyManager API. timeZone Ljava/util/TimeZone; applicationName integerDateTimes Z useBinaryReceiveForOids Ljava/util/Set; $Ljava/util/Set<Ljava/lang/Integer;>; useBinarySendForOids sync $Lorg/postgresql/core/v3/SimpleQuery; deallocateEpoch S lastSetSearchPathQuery transactionFailCause Ljava/sql/SQLException; replicationProtocol )Lorg/postgresql/core/ReplicationProtocol; commandCompleteParser +Lorg/postgresql/core/CommandCompleteParser; lockedFor Ljava/lang/Object; MAX_BUFFERED_RECV_BYTES I ú NODATA_QUERY_RESPONSE_SIZE_BYTES ú processingCopyResults +Ljava/util/concurrent/atomic/AtomicBoolean; parsedQueryMap Ljava/util/HashMap; mLjava/util/HashMap<Ljava/lang/ref/PhantomReference<Lorg/postgresql/core/v3/SimpleQuery;>;Ljava/lang/String;>; parsedQueryCleanupQueue Ljava/lang/ref/ReferenceQueue; DLjava/lang/ref/ReferenceQueue<Lorg/postgresql/core/v3/SimpleQuery;>; openPortalMap hLjava/util/HashMap<Ljava/lang/ref/PhantomReference<Lorg/postgresql/core/v3/Portal;>;Ljava/lang/String;>; openPortalCleanupQueue ?Ljava/lang/ref/ReferenceQueue<Lorg/postgresql/core/v3/Portal;>; UNNAMED_PORTAL Lorg/postgresql/core/v3/Portal; pendingParseQueue Ljava/util/Deque; 7Ljava/util/Deque<Lorg/postgresql/core/v3/SimpleQuery;>; pendingBindQueue 2Ljava/util/Deque<Lorg/postgresql/core/v3/Portal;>; pendingExecuteQueue :Ljava/util/Deque<Lorg/postgresql/core/v3/ExecuteRequest;>; pendingDescribeStatementQueue ;Ljava/util/Deque<Lorg/postgresql/core/v3/DescribeRequest;>; pendingDescribePortalQueue nextUniqueID J allowEncodingChanges cleanupSavePoints estimatedReceiveBufferBytes beginTransactionQuery beginReadOnlyTransactionQuery emptyQuery autoSaveQuery releaseAutoSave restoreToAutoSave $assertionsDisabled <init> \(Lorg/postgresql/core/PGStream;Ljava/lang/String;Ljava/lang/String;ILjava/util/Properties;)V java/sql/SQLException Z java/io/IOException \ X Y ^ java/util/HashSet ` ()V X b a c e ! g SYNC i java/lang/String k createQuery J(Ljava/lang/String;ZZ[Ljava/lang/String;)Lorg/postgresql/core/CachedQuery; m n o org/postgresql/core/CachedQuery q query Lorg/postgresql/core/Query; s t r u "org/postgresql/core/v3/SimpleQuery w "