From ffe356b5dd39ce5e48546d1f6299c6c6897eb501 Mon Sep 17 00:00:00 2001
From: Dave Cramer <davec@fastcrypt.com>
Date: Tue, 5 Mar 2002 20:11:57 +0000
Subject: [PATCH] backed out changes for cancel, no need to look for two 'Z'
 responses

---
 .../org/postgresql/core/QueryExecutor.java     | 18 +-----------------
 1 file changed, 1 insertion(+), 17 deletions(-)

diff --git a/src/interfaces/jdbc/org/postgresql/core/QueryExecutor.java b/src/interfaces/jdbc/org/postgresql/core/QueryExecutor.java
index 4bac6413db4..f5b9aef492f 100644
--- a/src/interfaces/jdbc/org/postgresql/core/QueryExecutor.java
+++ b/src/interfaces/jdbc/org/postgresql/core/QueryExecutor.java
@@ -13,7 +13,7 @@ import org.postgresql.util.PSQLException;
  * <p>The lifetime of a QueryExecutor object is from sending the query
  * until the response has been received from the backend.
  *
- * $Id: QueryExecutor.java,v 1.7 2002/03/05 18:01:27 davec Exp $
+ * $Id: QueryExecutor.java,v 1.8 2002/03/05 20:11:57 davec Exp $
  */
 
 public class QueryExecutor
@@ -57,7 +57,6 @@ public class QueryExecutor
 
 		int fqp = 0;
 		boolean hfr = false;
-		int lastMessage = 0;
 
 		synchronized (pg_stream)
 		{
@@ -113,26 +112,11 @@ public class QueryExecutor
 						receiveFields();
 						break;
 					case 'Z':		 // backend ready for query, ignore for now :-)
-						if ( lastMessage == 'Z' )
- 			                        {
-						     try
-                        			     {
-                                    			pg_stream.SendChar('Q');
-                                    			pg_stream.SendChar(' ');
-                                    			pg_stream.SendChar(0);
-                                    			pg_stream.flush();
-                                 		     } catch (IOException e) {
-                                    			throw new PSQLException("postgresql.con.ioerror",e);
-                                 		     }
-                              			     fqp++;
-                           			}
- 					
 						break;
 					default:
 						throw new PSQLException("postgresql.con.type",
 												new Character((char) c));
 				}
-				lastMessage = c;
 			}
 			return connection.getResultSet(connection, statement, fields, tuples, status, update_count, insert_oid, binaryCursor);
 		}
-- 
GitLab