|
@@ -1949,12 +1949,12 @@ protected void processResults(ResultHandler handler, int flags) throws IOExcepti |
|
|
|
|
|
break; |
|
|
|
|
|
case 't': // ParameterDescription |
|
|
case 't': { // ParameterDescription |
|
|
pgStream.receiveInteger4(); // len, discarded |
|
|
|
|
|
LOGGER.log(Level.FINEST, " <=BE ParameterDescription"); |
|
|
|
|
|
{ |
|
|
|
|
|
DescribeRequest describeData = pendingDescribeStatementQueue.getFirst(); |
|
|
SimpleQuery query = describeData.query; |
|
|
SimpleParameterList params = describeData.parameterList; |
|
@@ -2022,14 +2022,14 @@ protected void processResults(ResultHandler handler, int flags) throws IOExcepti |
|
|
} |
|
|
break; |
|
|
|
|
|
case 's': // Portal Suspended (end of Execute) |
|
|
case 's': { // Portal Suspended (end of Execute) |
|
|
// nb: this appears *instead* of CommandStatus. |
|
|
// Must be a SELECT if we suspended, so don't worry about it. |
|
|
|
|
|
pgStream.receiveInteger4(); // len, discarded |
|
|
LOGGER.log(Level.FINEST, " <=BE PortalSuspended"); |
|
|
|
|
|
{ |
|
|
|
|
|
ExecuteRequest executeData = pendingExecuteQueue.removeFirst(); |
|
|
SimpleQuery currentQuery = executeData.query; |
|
|
Portal currentPortal = executeData.portal; |
|
@@ -2046,7 +2046,7 @@ protected void processResults(ResultHandler handler, int flags) throws IOExcepti |
|
|
break; |
|
|
} |
|
|
|
|
|
case 'C': // Command Status (end of Execute) |
|
|
case 'C': { // Command Status (end of Execute) |
|
|
// Handle status. |
|
|
String status = receiveCommandStatus(); |
|
|
if (isFlushCacheOnDeallocate() |
|
@@ -2056,7 +2056,7 @@ protected void processResults(ResultHandler handler, int flags) throws IOExcepti |
|
|
|
|
|
doneAfterRowDescNoData = false; |
|
|
|
|
|
{ |
|
|
|
|
|
ExecuteRequest executeData = pendingExecuteQueue.peekFirst(); |
|
|
SimpleQuery currentQuery = executeData.query; |
|
|
Portal currentPortal = executeData.portal; |
|
@@ -2179,12 +2179,11 @@ protected void processResults(ResultHandler handler, int flags) throws IOExcepti |
|
|
// keep processing |
|
|
break; |
|
|
|
|
|
case 'I': // Empty Query (end of Execute) |
|
|
case 'I': { // Empty Query (end of Execute) |
|
|
pgStream.receiveInteger4(); |
|
|
|
|
|
LOGGER.log(Level.FINEST, " <=BE EmptyQuery"); |
|
|
|
|
|
{ |
|
|
ExecuteRequest executeData = pendingExecuteQueue.removeFirst(); |
|
|
Portal currentPortal = executeData.portal; |
|
|
handler.handleCommandStatus("EMPTY", 0, 0); |
|
@@ -2200,15 +2199,13 @@ protected void processResults(ResultHandler handler, int flags) throws IOExcepti |
|
|
break; |
|
|
|
|
|
case 'S': // Parameter Status |
|
|
{ |
|
|
try { |
|
|
receiveParameterStatus(); |
|
|
} catch (SQLException e) { |
|
|
handler.handleError(e); |
|
|
endQuery = true; |
|
|
} |
|
|
break; |
|
|
} |
|
|
|
|
|
case 'T': // Row Description (response to Describe) |
|
|
Field[] fields = receiveFields(); |
|
|