private void connect() throws SQLException {
		for (;;) {
			try {
				db = DriverManager.getConnection("jdbc:mysql://" + host + ":"
						+ port + "/" + schema, username, password);
				break;
			} catch (SQLException ex) {
				if (autoCreate && isConnectionIssue(ex) && checkSchema()) {
					continue;
				}
				throw ex;
			}
		}
		stmtUpdate = db.createStatement();
		stmtQuery = db.createStatement(ResultSet.TYPE_FORWARD_ONLY,
				ResultSet.CONCUR_READ_ONLY);
		stmtUpdate.execute("USE `" + schema + "`");
		stmtQuery.execute("USE `" + schema + "`");
	}