Updates for java 8 compliance

pom.xml

@@ -125,16 +125,13 @@
 			<version>${bouncycastle.bcprov.version}</version>
 			<optional>true</optional>
 		</dependency>
-
 		<!-- dependencies for Client Certificate Authentication -->
 		<dependency>
 			<groupId>org.bouncycastle</groupId>
 			<artifactId>bcpkix-jdk15on</artifactId>
 			<version>${bouncycastle.bcpkix.version}</version>
 			<optional>true</optional>
 		</dependency>
-
-
 		<!-- dependencies provided by an OSGi-Framework -->
 		<dependency>
 			<groupId>org.osgi</groupId>
@@ -278,6 +275,8 @@
 						<configuration>
 							<!-- Exclude [xJDBC42] For tests not compatible with JDBC 4.2 Specifications -->
 							<excludedGroups>${excludedGroups}, xJDBC42</excludedGroups>
+							<!-- needs to be overridden as illegal-access and MaxPermSize=256m not valid in java 8 -->
+							<argLine>-Xmx1024m</argLine>
 						</configuration>
 					</plugin>
 				</plugins>

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

@@ -29,7 +29,7 @@
 
 
 /**
- * Utility class for all Data Dependant Conversions (DDC).
+ * Utility class for all Data Dependent Conversions (DDC).
  */
 
 final class DDC {
@@ -614,9 +614,9 @@ private static LocalDateTime parseStringIntoLDT(String s) {
         if (firstDash > 0 && secondDash > 0 && secondDash < dividingSpace - 1) {
             if (firstDash == YEAR_LENGTH && (secondDash - firstDash > 1 && secondDash - firstDash <= MONTH_LENGTH + 1)
                     && (dividingSpace - secondDash > 1 && dividingSpace - secondDash <= DAY_LENGTH + 1)) {
-                year = Integer.parseInt(s, 0, firstDash, 10);
-                month = Integer.parseInt(s, firstDash + 1, secondDash, 10);
-                day = Integer.parseInt(s, secondDash + 1, dividingSpace, 10);
+                year = Integer.parseInt(s.subSequence(0, firstDash).toString());
+                month = Integer.parseInt(s.subSequence(firstDash + 1, secondDash).toString());
+                day = Integer.parseInt(s.subSequence(secondDash + 1, dividingSpace).toString());
 
                 if ((month >= 1 && month <= MAX_MONTH) && (day >= 1 && day <= MAX_DAY)) {
                     parsedDate = true;
@@ -630,16 +630,16 @@ private static LocalDateTime parseStringIntoLDT(String s) {
         // Convert the time; default missing nanos
         int len = s.length();
         if (firstColon > 0 && secondColon > 0 && secondColon < len - 1) {
-            hour = Integer.parseInt(s, dividingSpace + 1, firstColon, 10);
-            minute = Integer.parseInt(s, firstColon + 1, secondColon, 10);
+            hour = Integer.parseInt(s.subSequence(dividingSpace + 1, firstColon).toString());
+            minute = Integer.parseInt(s.subSequence(firstColon + 1, secondColon).toString());
             if (period > 0 && period < len - 1) {
-                second = Integer.parseInt(s, secondColon + 1, period, 10);
+                second = Integer.parseInt(s.subSequence(secondColon + 1, period).toString());
                 int nanoPrecision = len - (period + 1);
                 if (nanoPrecision > 9)
                     throw new java.lang.IllegalArgumentException(formatError);
                 if (!Character.isDigit(s.charAt(period + 1)))
                     throw new java.lang.IllegalArgumentException(formatError);
-                int tmpNanos = Integer.parseInt(s, period + 1, len, 10);
+                int tmpNanos = Integer.parseInt(s.subSequence(period + 1, len).toString());
                 while (nanoPrecision < 9) {
                     tmpNanos *= 10;
                     nanoPrecision++;
@@ -648,7 +648,7 @@ private static LocalDateTime parseStringIntoLDT(String s) {
             } else if (period > 0) {
                 throw new java.lang.IllegalArgumentException(formatError);
             } else {
-                second = Integer.parseInt(s, secondColon + 1, len, 10);
+                second = Integer.parseInt(s.subSequence(secondColon + 1, len).toString());
             }
         } else {
             throw new java.lang.IllegalArgumentException(formatError);
@@ -1274,7 +1274,8 @@ private static Object convertTemporalToObject(JDBCType jdbcType, SSType ssType,
 
                     case DATETIME2: {
                         return String.format(Locale.US, "%1$tF %1$tT%2$s", // yyyy-mm-dd hh:mm:ss[.nnnnnnn]
-                                java.sql.Timestamp.valueOf(ldt), fractionalSecondsString(subSecondNanos, fractionalSecondsScale));
+                                java.sql.Timestamp.valueOf(ldt),
+                                fractionalSecondsString(subSecondNanos, fractionalSecondsScale));
                     }
 
                     case DATETIME: // and SMALLDATETIME

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

@@ -14,6 +14,7 @@
 import java.io.InputStream;
 import java.io.StringReader;
 import java.math.BigInteger;
+import java.nio.Buffer;
 import java.nio.ByteBuffer;
 import java.nio.ByteOrder;
 import java.nio.file.Files;
@@ -153,22 +154,23 @@ private static PrivateKey loadPrivateKeyFromPVK(String keyPath,
         ByteBuffer buffer = ByteBuffer.allocate((int) f.length());
         try (FileInputStream in = new FileInputStream(f)) {
             in.getChannel().read(buffer);
-            buffer.order(ByteOrder.LITTLE_ENDIAN).rewind();
+            ((Buffer) buffer.order(ByteOrder.LITTLE_ENDIAN)).rewind();
 
             long magic = buffer.getInt() & 0xFFFFFFFFL;
             if (PVK_MAGIC != magic) {
                 SQLServerException.makeFromDriverError(null, magic, SQLServerResource.getResource("R_pvkHeaderError"),
                         "", false);
             }
 
-            buffer.position(buffer.position() + 8); // skip reserved and keytype
+            ((Buffer) buffer).position(((Buffer) buffer).position() + 8); // skip reserved and keytype
             boolean encrypted = buffer.getInt() != 0;
             int saltLength = buffer.getInt();
             int keyLength = buffer.getInt();
             byte[] salt = new byte[saltLength];
             buffer.get(salt);
 
-            buffer.position(buffer.position() + 8); // skip btype(1b), version(1b), reserved(2b), and keyalg(4b)
+            ((Buffer) buffer).position(((Buffer) buffer).position() + 8); // skip btype(1b), version(1b), reserved(2b),
+                                                                          // and keyalg(4b)
 
             byte[] key = new byte[keyLength - 8];
             buffer.get(key);
@@ -184,7 +186,7 @@ private static PrivateKey loadPrivateKeyFromPVK(String keyPath,
             }
 
             ByteBuffer buff = ByteBuffer.wrap(key).order(ByteOrder.LITTLE_ENDIAN);
-            buff.position(RSA2_MAGIC.length); // skip the header
+            ((Buffer) buff).position(RSA2_MAGIC.length); // skip the header
 
             int byteLength = buff.getInt() / 8;
             BigInteger publicExponent = BigInteger.valueOf(buff.getInt());

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

@@ -667,7 +667,7 @@ private static List<String> getTrustedEndpoints() {
         boolean append = true;
         if (null != mssqlJdbcProperties) {
             String endpoints = mssqlJdbcProperties.getProperty(AKV_TRUSTED_ENDPOINTS_KEYWORD);
-            if (null != endpoints && !endpoints.isBlank()) {
+            if (null != endpoints && !endpoints.trim().isEmpty()) {
                 endpoints = endpoints.trim();
                 // Append if the list starts with a semicolon.
                 if (';' != endpoints.charAt(0)) {
@@ -677,7 +677,7 @@ private static List<String> getTrustedEndpoints() {
                 }
                 String[] entries = endpoints.split(";");
                 for (String entry : entries) {
-                    if (null != entry && !entry.isBlank()) {
+                    if (null != entry && !entry.trim().isEmpty()) {
                         trustedEndpoints.add(entry.trim());
                     }
                 }

src/test/java/com/microsoft/sqlserver/jdbc/JDBC43Test.java

@@ -25,6 +25,7 @@
  *
  */
 @RunWith(JUnitPlatform.class)
+@Tag(Constants.xJDBC42)
 public class JDBC43Test extends AbstractTest {
     ShardingKey superShardingKey = null;
     ShardingKey shardingKey = null;
@@ -128,7 +129,6 @@ public void connectionPoolDataSourceTest() throws TestAbortedException, SQLExcep
      * @since 1.9
      */
     @Test
-    @Tag(Constants.xJDBC42)
     public void setShardingKeyIfValidTest() throws TestAbortedException, SQLException {
         try (SQLServerConnection connection43 = (SQLServerConnection43) getConnection()) {
             try {
@@ -152,7 +152,6 @@ public void setShardingKeyIfValidTest() throws TestAbortedException, SQLExceptio
      * @since 1.9
      */
     @Test
-    @Tag(Constants.xJDBC42)
     public void setShardingKeyTest() throws TestAbortedException, SQLException {
         try (SQLServerConnection connection43 = (SQLServerConnection43) getConnection()) {
             try {

src/test/java/com/microsoft/sqlserver/jdbc/NTLMConnectionTest.java

@@ -81,8 +81,7 @@ public static void setUp() throws Exception {
      */
     @Test
     public void testNTLMBasicConnection() throws SQLException {
-        try (Connection con1 = dsNTLMLocal.getConnection();
-                Connection con2 = dsNTLMXA.getConnection();
+        try (Connection con1 = dsNTLMLocal.getConnection(); Connection con2 = dsNTLMXA.getConnection();
                 Connection con3 = dsNTLMPool.getConnection();
                 Connection con4 = PrepUtil.getConnection(connectionStringNTLM)) {
             verifyNTLM(con1);
@@ -372,17 +371,20 @@ private byte[] getChallengeToken(int offset, byte[] badBytes) {
 
         token.put(challengeTargetInfo2);
 
-        // update targetinfo len
-        token.position(ntlmChallengeTargetInfoLenOffset);
-        token.putShort((short) targetInfoLen); // len
-        token.putShort((short) targetInfoLen); // maxlen
+        /*
+         * update target info - the cast is necessary as JDK 8 calls method Buffer.position(I)LBuffer while in JDK 9+
+         * calls method ByteBuffer.position(I)LByteBuffer
+         */
+        ((java.nio.Buffer) token).position(ntlmChallengeTargetInfoLenOffset);
+        token.putShort((short) targetInfoLen); // update target info len
+        token.putShort((short) targetInfoLen); // update target info maxlen
 
         // write bad bytes
         if (0 <= offset) {
-            token.position(offset);
+            ((java.nio.Buffer) token).position(offset);
             token.put(badBytes);
         } else {
-            token.position(tokenLen + offset);
+            ((java.nio.Buffer) token).position(tokenLen + offset);
             token.put(badBytes);
         }
 

src/test/java/com/microsoft/sqlserver/jdbc/SQLServerDriverTest.java

@@ -17,6 +17,7 @@
 import java.util.logging.Logger;
 import java.util.stream.Stream;
 
+import org.junit.jupiter.api.Tag;
 import org.junit.jupiter.api.Test;
 import org.junit.platform.runner.JUnitPlatform;
 import org.junit.runner.RunWith;
@@ -59,9 +60,8 @@ public void testDriverRegistrationDM() throws SQLException, ClassNotFoundExcepti
             current = drivers.nextElement();
             DriverManager.deregisterDriver(current);
         }
-        Stream<Driver> currentDrivers = DriverManager.drivers();
-        Object[] driversArray = currentDrivers.toArray();
-        assertEquals(0, driversArray.length);
+        Enumeration<Driver> currentDrivers = DriverManager.getDrivers();
+        assertEquals(false, currentDrivers.hasMoreElements());
         DriverManager.registerDriver(current);
     }
 

src/test/java/com/microsoft/sqlserver/jdbc/connection/SSLProtocolTest.java

@@ -46,6 +46,7 @@ public void testWithSupportedProtocols(String sslProtocol) throws Exception {
             // Example, if the highest TLS version enabled in the server is TLSv1.1,
             // the connection will fail if we enable only TLSv1.2
             assertTrue(e.getMessage().contains(TestResource.getResource("R_noProtocolVersion"))
+                    || e.getCause().getMessage().contains(TestResource.getResource("R_connectionClosed"))
                     || e.getCause().getCause().getMessage().contains(TestResource.getResource("R_connectionClosed")));
         }
     }

src/test/java/com/microsoft/sqlserver/jdbc/datatypes/DataTypesTest.java

@@ -1824,7 +1824,7 @@ public void testGetLocalDateTimePriorGregorian() throws Exception {
             }
         }
     }
-    
+
     @Test
     public void testNullValuesWithGetObject() throws Exception {
         String ldtTable = AbstractSQLGenerator.escapeIdentifier(RandomUtil.getIdentifier("ldtTable"));

src/test/java/com/microsoft/sqlserver/jdbc/unit/lobs/LobsStreamingTest.java

@@ -5,6 +5,7 @@
 import java.io.IOException;
 import java.io.InputStream;
 import java.io.Reader;
+import java.nio.charset.Charset;
 import java.sql.Clob;
 import java.sql.Connection;
 import java.sql.NClob;
@@ -145,8 +146,7 @@ public void testClobsVarcharASCII() throws SQLException, IOException {
                         Clob c = rs.getClob(2);
                         assertEquals(c.length(), lob_data.get(index).length());
                         try (InputStream is = c.getAsciiStream();
-                                Scanner s = new Scanner(is, java.nio.charset.StandardCharsets.US_ASCII)
-                                        .useDelimiter("\\A")) {
+                                Scanner s = new Scanner(is, "US-ASCII").useDelimiter("\\A")) {
                             String received = getStringFromInputStream(is, s);// streaming string
                             assertEquals(lob_data.get(index), received);// compare streamed string to initial string
                             c.free();
@@ -187,8 +187,7 @@ public void testNClobsVarcharASCII() throws SQLException, IOException {
                         NClob c = rs.getNClob(2);
                         assertEquals(c.length(), lob_data.get(index).length());
                         try (InputStream is = c.getAsciiStream();
-                                Scanner s = new Scanner(is, java.nio.charset.StandardCharsets.US_ASCII)
-                                        .useDelimiter("\\A")) {
+                                Scanner s = new Scanner(is, "US-ASCII").useDelimiter("\\A")) {
                             String received = getStringFromInputStream(is, s);// NClob AsciiStream is never streamed
                             c.free();
                             assertEquals(lob_data.get(index), received);// compare string to initial string