Read SQL Server error message if status flag has DONE_ERROR set.

.gitignore

@@ -16,6 +16,7 @@ local.properties
 .classpath
 .settings/
 .loadpath
+*.class
 
 # External tool builders
 .externalToolBuilders/

src/main/java/com/microsoft/sqlserver/jdbc/IOBuffer.java

@@ -6844,6 +6844,17 @@ final int peekTokenType() throws SQLServerException
 		return currentPacket.payload[payloadOffset] & 0xFF;
 	}
 
+
+	final short peekStatusFlag() throws SQLServerException {
+		// skip the current packet(i.e, TDS packet type) and peek into the status flag (USHORT)
+		if (payloadOffset + 3 <= currentPacket.payloadLength) {
+			short value = Util.readShort(currentPacket.payload, payloadOffset + 1);
+			return value;
+		}
+
+		return Util.readShort(readWrappedBytes(3), 1);
+	}
+
 	final int readUnsignedByte() throws SQLServerException
 	{
 		// Ensure that we have a packet to read from.

src/main/java/com/microsoft/sqlserver/jdbc/SQLServerResultSet.java

@@ -327,13 +327,25 @@ boolean onError(TDSReader tdsReader) throws SQLServerException
                 return false;
             }
 
-            boolean onDone(TDSReader tdsReader) throws SQLServerException
-            {
-                // When initializing client-cursored ResultSets, a DONE token
-                // following the column metadata indicates an empty result set.
-                rowCount = 0;
-                return false;
-            }
+			boolean onDone(TDSReader tdsReader) throws SQLServerException {
+				// When initializing client-cursored ResultSets, a DONE token
+				// following the column metadata indicates an empty result set.
+				rowCount = 0;
+
+				// Continue to read the error message if DONE packet has error flag
+				int packetType = tdsReader.peekTokenType();
+				if (TDS.TDS_DONE == packetType) {
+					short status = tdsReader.peekStatusFlag();
+					if ((status & 0x0002) != 0) {
+						// Consume the DONE packet if there is error
+						StreamDone doneToken = new StreamDone();
+						doneToken.setFromTDS(tdsReader);
+						return true;
+					}
+				}
+
+				return false;
+			}
         }
 
         this.stmt = stmtIn;