]> granicus.if.org Git - postgresql/commitdiff
backed out changes for cancel, no need to look for two 'Z' responses
authorDave Cramer <davec@fastcrypt.com>
Tue, 5 Mar 2002 20:11:57 +0000 (20:11 +0000)
committerDave Cramer <davec@fastcrypt.com>
Tue, 5 Mar 2002 20:11:57 +0000 (20:11 +0000)
src/interfaces/jdbc/org/postgresql/core/QueryExecutor.java

index 4bac6413db4b1839f87fa233c74ae4d8e53b9326..f5b9aef492fc5b4e262223f70ed8815ff8415ca1 100644 (file)
@@ -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);
                }