Commitffe356b

Dave Cramer

committed

backed out changes for cancel, no need to look for two 'Z' responses

1 parent29ea8ff commitffe356bCopy full SHA for ffe356b

File tree

-17

lines changed

-17

lines changed

Lines changed: 1 addition & 17 deletions

Original file line number	Diff line number	Diff line change
`@@ -13,7 +13,7 @@`
`13`	`13`	`* <p>The lifetime of a QueryExecutor object is from sending the query`
`14`	`14`	`* until the response has been received from the backend.`
`15`	`15`	`*`
`16`		`- * $Id: QueryExecutor.java,v 1.7 2002/03/0518:01:27 davec Exp $`
	`16`	`+ * $Id: QueryExecutor.java,v 1.8 2002/03/0520:11:57 davec Exp $`
`17`	`17`	`*/`
`18`	`18`
`19`	`19`	`publicclassQueryExecutor`
`@@ -57,7 +57,6 @@ public java.sql.ResultSet execute() throws SQLException`
`57`	`57`
`58`	`58`	`intfqp =0;`
`59`	`59`	`booleanhfr =false;`
`60`		`-intlastMessage =0;`
`61`	`60`
`62`	`61`	`synchronized (pg_stream)`
`63`	`62`	`{`
`@@ -113,26 +112,11 @@ public java.sql.ResultSet execute() throws SQLException`
`113`	`112`	`receiveFields();`
`114`	`113`	`break;`
`115`	`114`	`case'Z':// backend ready for query, ignore for now :-)`
`116`		`-if (lastMessage =='Z' )`
`117`		`- {`
`118`		`-try`
`119`		`- {`
`120`		`-pg_stream.SendChar('Q');`
`121`		`-pg_stream.SendChar(' ');`
`122`		`-pg_stream.SendChar(0);`
`123`		`-pg_stream.flush();`
`124`		`- }catch (IOExceptione) {`
`125`		`-thrownewPSQLException("postgresql.con.ioerror",e);`
`126`		`- }`
`127`		`-fqp++;`
`128`		`- }`
`129`		`-`
`130`	`115`	`break;`
`131`	`116`	`default:`
`132`	`117`	`thrownewPSQLException("postgresql.con.type",`
`133`	`118`	`newCharacter((char)c));`
`134`	`119`	`}`
`135`		`-lastMessage =c;`
`136`	`120`	`}`
`137`	`121`	`returnconnection.getResultSet(connection,statement,fields,tuples,status,update_count,insert_oid,binaryCursor);`
`138`	`122`	`}`

Comments

(0)