try {                    int n = Integer.parseInt(remaining.substring(0, pos));                    this.serverSubMinorVersion = n;                } catch (NumberFormatException nfe) {                    ;                }            }        }        if (versionMeetsMinimum(4, 0, 8)) {            this.maxThreeBytes = (256 * 256 * 256) - 1;            this.useNewLargePackets = true;        } else {            this.maxThreeBytes = 255 * 255 * 255;            this.useNewLargePackets = false;        }        this.colDecimalNeedsBump = versionMeetsMinimum(3, 23, 0);        this.colDecimalNeedsBump = !versionMeetsMinimum(3, 23, 15); // guess? Not noted in changelog        this.useNewUpdateCounts = versionMeetsMinimum(3, 22, 5);        threadId = buf.readLong();         this.seed = buf.readString();        this.serverCapabilities = 0;        if (buf.getPosition() < buf.getBufLength()) {            this.serverCapabilities = buf.readInt();        }        if (versionMeetsMinimum(4, 1, 1)) {            int position = buf.getPosition();            /* New protocol with 16 bytes to describe server characteristics */            this.serverCharsetIndex = buf.readByte() & 0xff;            this.serverStatus = buf.readInt();            buf.setPosition(position + 16);            String seedPart2 = buf.readString();            StringBuffer newSeed = new StringBuffer(20);            newSeed.append(this.seed);            newSeed.append(seedPart2);            this.seed = newSeed.toString();        }        if (((this.serverCapabilities & CLIENT_COMPRESS) != 0) &&                this.connection.getUseCompression()) {            this.clientParam |= CLIENT_COMPRESS;        }		this.useConnectWithDb = (database != null) && 			(database.length() > 0) &&			!this.connection.getCreateDatabaseIfNotExist();		        if (this.useConnectWithDb) {            this.clientParam |= CLIENT_CONNECT_WITH_DB;        }        if (((this.serverCapabilities & CLIENT_SSL) == 0) &&                this.connection.getUseSSL()) {            if (this.connection.getRequireSSL()) {                this.connection.close();                forceClose();                throw SQLError.createSQLException(Messages.getString("MysqlIO.15"), //$NON-NLS-1$                    SQLError.SQL_STATE_UNABLE_TO_CONNECT_TO_DATASOURCE);            }            this.connection.setUseSSL(false);        }        if ((this.serverCapabilities & CLIENT_LONG_FLAG) != 0) {            // We understand other column flags, as well            this.clientParam |= CLIENT_LONG_FLAG;            this.hasLongColumnInfo = true;        }        // return FOUND rows        this.clientParam |= CLIENT_FOUND_ROWS;        if (this.connection.getAllowLoadLocalInfile()) {            this.clientParam |= CLIENT_LOCAL_FILES;        }        if (this.isInteractiveClient) {            this.clientParam |= CLIENT_INTERACTIVE;        }        // Authenticate        if (this.protocolVersion > 9) {            this.clientParam |= CLIENT_LONG_PASSWORD; // for long passwords        } else {            this.clientParam &= ~CLIENT_LONG_PASSWORD;        }        //        // 4.1 has some differences in the protocol        //        if (versionMeetsMinimum(4, 1, 0)) {            if (versionMeetsMinimum(4, 1, 1)) {                this.clientParam |= CLIENT_PROTOCOL_41;                this.has41NewNewProt = true;                // Need this to get server status values                this.clientParam |= CLIENT_TRANSACTIONS;                // We always allow multiple result sets                this.clientParam |= CLIENT_MULTI_RESULTS;                // We allow the user to configure whether                // or not they want to support multiple queries                // (by default, this is disabled).                if (this.connection.getAllowMultiQueries()) {                    this.clientParam |= CLIENT_MULTI_QUERIES;                }            } else {                this.clientParam |= CLIENT_RESERVED;                this.has41NewNewProt = false;            }            this.use41Extensions = true;        }        int passwordLength = 16;        int userLength = (user != null) ? user.length() : 0;        int databaseLength = (database != null) ? database.length() : 0;                int packLength = ((userLength + passwordLength + databaseLength) * 2) + 7 + HEADER_LENGTH + AUTH_411_OVERHEAD;                Buffer packet = null;        if (!this.connection.getUseSSL()) {            if ((this.serverCapabilities & CLIENT_SECURE_CONNECTION) != 0) {                this.clientParam |= CLIENT_SECURE_CONNECTION;                if (versionMeetsMinimum(4, 1, 1)) {                    secureAuth411(null, packLength, user, password, database,                        true);                } else {                    secureAuth(null, packLength, user, password, database, true);                }            } else {                // Passwords can be 16 chars long                packet = new Buffer(packLength);                if ((this.clientParam & CLIENT_RESERVED) != 0) {                    if (versionMeetsMinimum(4, 1, 1)) {                        packet.writeLong(this.clientParam);                        packet.writeLong(this.maxThreeBytes);                        // charset, JDBC will connect as 'latin1',                        // and use 'SET NAMES' to change to the desired                        // charset after the connection is established.                        packet.writeByte((byte) 8);                        // Set of bytes reserved for future use.                        packet.writeBytesNoNull(new byte[23]);                    } else {                        packet.writeLong(this.clientParam);                        packet.writeLong(this.maxThreeBytes);                    }                } else {                    packet.writeInt((int) this.clientParam);                    packet.writeLongInt(this.maxThreeBytes);                }                // User/Password data                packet.writeString(user, "Cp1252", this.connection);                if (this.protocolVersion > 9) {                    packet.writeString(Util.newCrypt(password, this.seed), "Cp1252", this.connection);                } else {                    packet.writeString(Util.oldCrypt(password, this.seed), "Cp1252", this.connection);                }                if (this.useConnectWithDb) {                    packet.writeString(database, "Cp1252", this.connection);                }                send(packet, packet.getPosition());            }        } else {            negotiateSSLConnection(user, password, database, packLength);        }        // Check for errors, not for 4.1.1 or newer,        // as the new auth protocol doesn't work that way        // (see secureAuth411() for more details...)        if (!versionMeetsMinimum(4, 1, 1)) {            checkErrorPacket();        }        //        // Can't enable compression until after handshake        //        if (((this.serverCapabilities & CLIENT_COMPRESS) != 0) &&                this.connection.getUseCompression()) {            // The following matches with ZLIB's            // compress()            this.deflater = new Deflater();            this.useCompression = true;            this.mysqlInput = new CompressedInputStream(this.connection,                    this.mysqlInput);        }        if (!this.useConnectWithDb) {            changeDatabaseTo(database);        }    }	private void changeDatabaseTo(String database) throws SQLException, CommunicationsException {		if (database == null || database.length() == 0) {			return;		}				try {		    sendCommand(MysqlDefs.INIT_DB, database, null, false, null);		} catch (Exception ex) {			if (this.connection.getCreateDatabaseIfNotExist()) {				sendCommand(MysqlDefs.QUERY, "CREATE DATABASE IF NOT EXISTS " +					database,					null, false, null);				sendCommand(MysqlDefs.INIT_DB, database, null, false, null);			} else {				throw new CommunicationsException(this.connection,						this.lastPacketSentTimeMs, ex);			}		}	}    /**    * Retrieve one row from the MySQL server. Note: this method is not    * thread-safe, but it is only called from methods that are guarded by    * synchronizing on this object.    *    * @param fields DOCUMENT ME!    * @param columnCount DOCUMENT ME!    * @param isBinaryEncoded DOCUMENT ME!    * @param resultSetConcurrency DOCUMENT ME!    *    * @return DOCUMENT ME!    *    * @throws SQLException DOCUMENT ME!    */    final Object[] nextRow(Field[] fields, int columnCount,        boolean isBinaryEncoded, int resultSetConcurrency)        throws SQLException {        // Get the next incoming packet, re-using the packet because        // all the data we need gets copied out of it.        Buffer rowPacket = checkErrorPacket();        if (!isBinaryEncoded) {            //            // Didn't read an error, so re-position to beginning            // of packet in order to read result set data            //            rowPacket.setPosition(rowPacket.getPosition() - 1);            if (!rowPacket.isLastDataPacket()) {                byte[][] rowData = new byte[columnCount][];                int offset = 0;                for (int i = 0; i < columnCount; i++) {                    rowData[i] = rowPacket.readLenByteArray(offset);                }                return rowData;            }            readServerStatusForResultSets(rowPacket);            return null;        }        //         // Handle binary-encoded data for server-side           // PreparedStatements...        //        if (!rowPacket.isLastDataPacket()) {            return unpackBinaryResultSetRow(fields, rowPacket,                resultSetConcurrency);        }        rowPacket.setPosition(rowPacket.getPosition() - 1);        readServerStatusForResultSets(rowPacket);        return null;    }    /**     * Log-off of the MySQL server and close the socket.     *     * @throws SQLException DOCUMENT ME!     */    final void quit() throws SQLException {        Buffer packet = new Buffer(6);        this.packetSequence = -1;        packet.writeByte((byte) MysqlDefs.QUIT);        send(packet, packet.getPosition());        forceClose();    }    /**     * Returns the packet used for sending data (used by PreparedStatement)     * Guarded by external synchronization on a mutex.     *     * @return A packet to send data with     */    Buffer getSharedSendPacket() {        if (this.sharedSendPacket == null) {        	this.sharedSendPacket = new Buffer(INITIAL_PACKET_SIZE);        }        return this.sharedSendPacket;    }    void closeStreamer(RowData streamer) throws SQLException {        if (this.streamingData == null) {            throw SQLError.createSQLException(Messages.getString("MysqlIO.17") //$NON-NLS-1$                 +streamer + Messages.getString("MysqlIO.18")); //$NON-NLS-1$        }        if (streamer != this.streamingData) {            throw SQLError.createSQLException(Messages.getString("MysqlIO.19") //$NON-NLS-1$                 +streamer + Messages.getString("MysqlIO.20") //$NON-NLS-1$                 +Messages.getString("MysqlIO.21") //$NON-NLS-1$                 +Messages.getString("MysqlIO.22")); //$NON-NLS-1$        }        this.streamingData = null;    }    ResultSet readAllResults(Statement callingStatement, int maxRows,        int resultSetType, int resultSetConcurrency, boolean streamResults,        String catalog, Buffer resultPacket, boolean isBinaryEncoded,        long preSentColumnCount, boolean unpackFieldInfo, Field[] metadataFromCache)        throws SQLException {        resultPacket.setPosition(resultPacket.getPosition() - 1);        ResultSet topLevelResultSet = readResultsForQueryOrUpdate(callingStatement,                maxRows, resultSetType, resultSetConcurrency, streamResults,                catalog, resultPacket, isBinaryEncoded, preSentColumnCount,                unpackFieldInfo, metadataFromCache);        ResultSet currentResultSet = topLevelResultSet;        boolean checkForMoreResults = ((this.clientParam &            CLIENT_MULTI_RESULTS) != 0);        boolean serverHasMoreResults = (this.serverStatus &            SERVER_MORE_RESULTS_EXISTS) != 0;        //        // TODO: We need to support streaming of multiple result sets        //        if (serverHasMoreResults && streamResults) {            clearInputStream();            throw SQLError.createSQLException(Messages.getString("MysqlIO.23"), //$NON-NLS-1$                SQLError.SQL_STATE_DRIVER_NOT_CAPABLE);        }        boolean moreRowSetsExist = checkForMoreResults & serverHasMoreResults;        while (moreRowSetsExist) {        	Buffer fieldPacket = checkErrorPacket();            fieldPacket.setPosition(0);                        ResultSet newResultSet = readResultsForQueryOrUpdate(callingStatement,