--no commit message

--no commit message

h2/src/main/org/h2/engine/SessionRemote.java

@@ -93,6 +93,9 @@ public class SessionRemote implements SessionInterface, DataHandler {
         trans.setSSL(ci.isSSL());
         trans.init();
         trans.writeInt(clientVersion);
+        if (clientVersion >= Constants.TCP_PROTOCOL_VERSION_6) {
+            trans.writeInt(clientVersion);
+        }
         trans.writeString(db);
         trans.writeString(ci.getOriginalURL());
         trans.writeString(ci.getUserName());
@@ -106,6 +109,9 @@ public class SessionRemote implements SessionInterface, DataHandler {
         }
         try {
             done(trans);
+            if (clientVersion >= Constants.TCP_PROTOCOL_VERSION_6) {
+                clientVersion = trans.readInt();
+            }
         } catch (SQLException e) {
             trans.close();
             throw e;

h2/src/main/org/h2/server/TcpServerThread.java

@@ -69,7 +69,7 @@ public class TcpServerThread implements Runnable {
                 if (!server.allow(transfer.getSocket())) {
                     throw Message.getSQLException(ErrorCode.REMOTE_CONNECTION_NOT_ALLOWED);
                 }
-                if (clientVersion == Constants.TCP_PROTOCOL_VERSION_6) {
+                if (clientVersion >= Constants.TCP_PROTOCOL_VERSION_6) {
                     // version 6 and newer: read max version (currently not used)
                     transfer.readInt();
                 } else if (clientVersion != Constants.TCP_PROTOCOL_VERSION_5) {