EDIT

        logger.warn("Validate destination " +  destination.getDatabase());

//            success &= testReferences();

//            success &= testTaxa();

//            success &= testTaxonRelations();

//            success &= testCommonNames();

            success &= testDistributions();

    private boolean testDistributions() throws SQLException {

        boolean success = testDistributionCount();

        if (success){

              success &= testSingleDistributions(source.getUniqueInteger("SELECT count(*) FROM dr "));

        }

        return success;

    }

    private boolean testDistributionCount() {

        int countSrc = source.getUniqueInteger("SELECT count(*) FROM dr ");

        int countDest = destination.getUniqueInteger("SELECT count(*) FROM Occurrence ");

        return equals("Occurrence count ", countSrc, countDest, String.valueOf(-1));

    }

         int countSrc = source.getUniqueInteger("SELECT count(*) FROM tu WHERE id NOT IN (147415)");

                + " WHERE t.id NOT IN (147415) "

        success &= isNull("NomRefString", destRS);

        success &= equals("Taxon DisplayName", srcFullName(srcRS), destRS.getString("DisplayName"), id);  //according to SQL script same as FullName, no nom.ref. information attached

    private boolean testSingleDistributions(int n) throws SQLException {

        boolean success = true;

        ResultSet srcRs = source.getResultSet("SELECT CAST(ISNULL(tu.tu_accfinal, tu.id) as nvarchar(20)) tuId, gu.gazetteer_id, dr.*, gu.id guId, gu.gu_name "

                + " FROM dr INNER JOIN tu ON dr.tu_id = tu.id "

                + "    LEFT JOIN gu ON gu.id = dr.gu_id "

                + " ORDER BY CAST(ISNULL(tu.tu_accfinal, tu.id) as nvarchar(20)), gu.gazetteer_id, gu.gu_name ");  //, dr.note (not possible because ntext

        ResultSet destRs = destination.getResultSet("SELECT t.IdInSource, a.AreaERMSGazetteerId, oc.*, a.AreaName "

                + " FROM Occurrence oc INNER JOIN Taxon t ON t.TaxonId = oc.TaxonFk "

                + "    LEFT JOIN Area a ON a.AreaId = oc.AreaFk "

                + " WHERE t.OriginalDB = 'erms' "

                + " ORDER BY t.IdInSource, a.AreaERMSGazetteerId, a.AreaName, oc.Notes ");

        int count = 0;

        while (srcRs.next() && destRs.next()){

            success &= testSingleDistribution(srcRs, destRs);

            count++;

        }

        success &= equals("Distribution count differs", n, count, "-1");

        return success;

    }

    private boolean testSingleDistribution(ResultSet srcRs, ResultSet destRs) throws SQLException {

        String id = String.valueOf(srcRs.getInt("tuId") + "-" + srcRs.getString("gu_name"));

        boolean success = equals("Distribution taxonID ", "tu_id: " + String.valueOf(srcRs.getInt("tuId")), destRs.getString("IdInSource"), id);

        success &= equals("Distribution gazetteer_id ", srcRs.getString("gazetteer_id"), destRs.getString("AreaERMSGazetteerId"), id);

        success &= equals("Distribution area name ", srcRs.getString("gu_name"), destRs.getString("AreaName"), id);

        success &= equals("Distribution area name ", srcRs.getString("note"), destRs.getString("Notes"), id);

        //TODO

        return success;

    }

        ResultSet srcRs = source.getResultSet("SELECT v.*, ISNULL([639_3],[639_2]) iso, l.LanName, tu.id tuId "

                + " ORDER BY CAST(tu.id as nvarchar(20)), ISNULL([639_3],[639_2]), v.vername  ");

        ResultSet destRs = destination.getResultSet("SELECT cn.*, t.IdInSource, l.ISO639_2, l.ISO639_3 "

                + " FROM CommonName cn INNER JOIN Taxon t ON t.TaxonId = cn.TaxonFk LEFT JOIN Language l ON l.LanguageId = cn.LanguageFk "

                + " ORDER BY t.IdInSource, ISNULL("+preferredISO639+", "+alternativeISO639+"), cn.CommonName");

    boolean prefer639_3 = true;

    String preferredISO639 = prefer639_3? "ISO639_3":"ISO639_2";

    String alternativeISO639 = prefer639_3? "ISO639_2":"ISO639_3";

        success &= equals("Common name languageID ", srcRs.getString("iso"), getLanguageIso(destRs), id);

        success = equals("CommonName LanguageCache ", normalizeLang(srcRs.getString("LanName")), destRs.getString("LanguageCache"), id);

    private String normalizeLang(String string) {

        if ("Norwegian Nynorsk".equals(string)){

            return "Nynorsk (Norwegian)";

        }else if ("Norwegian Bokmål".equals(string)){

            return "Bokmål  (Norwegian)";

        }else if ("Spanish".equals(string)){

            return "Spanish, Castillian";

        }else if ("Modern Greek (1453-)".equals(string)){

            return "Greek";

        }else if ("Hebrew".equals(string)){

            return "Israel (Hebrew)";

        }else if ("Malay (individual language)".equals(string)){

            return "Malay";

        }

        return string;

    }

    private String getLanguageIso(ResultSet destRs) throws SQLException {

        String result = destRs.getString(preferredISO639);

        if (result == null){

            result = destRs.getString(alternativeISO639);

        }

        return result;

    }