core/src/main/java/com/orientechnologies/orient/core/db/tool/ODatabaseImport.java
private void processBrokenRids(Set<ORID> brokenRids) throws IOException, ParseException {
    if (exporterVersion >= 12) {
      listener.onMessage("Reading of set of RIDs of records which were detected as broken during database export\n");

      jsonReader.readNext(OJSONReader.BEGIN_COLLECTION);

      while (true) {
        jsonReader.readNext(OJSONReader.NEXT_IN_ARRAY);

        final ORecordId recordId = new ORecordId(jsonReader.getValue());
        brokenRids.add(recordId);

        if (jsonReader.lastChar() == ']')
          break;
      }
    }
    if (migrateLinks) {
      if (exporterVersion >= 12)
        listener.onMessage(
            brokenRids.size() + " were detected as broken during database export, links on those records will be removed from"
                + " result database");
      migrateLinksInImportedDocuments(brokenRids);
    }
  }
private void processBrokenRids(Set<ORID> brokenRids) throws IOException, ParseException {
    if (exporterVersion >= 12) {
      listener.onMessage("Reading of set of RIDs of records which were detected as broken during database export\n");

      jsonReader.readNext(OJSONReader.BEGIN_COLLECTION);

      while (true) {
        jsonReader.readNext(OJSONReader.NEXT_IN_ARRAY);

        final ORecordId recordId = new ORecordId(jsonReader.getValue());
        brokenRids.add(recordId);

        if (jsonReader.lastChar() == ']')
          break;
      }
    }
    if (migrateLinks) {
      if (exporterVersion >= 12)
        listener.onMessage(
            brokenRids.size() + " were detected as broken during database export, links on those records will be removed from"
                + " result database");
      migrateLinksInImportedDocuments(brokenRids);
    }
  }
private void processBrokenRids ( Set < ORID > brokenRids ) throws IOException , ParseException { if ( exporterVersion >= 12 ) { listener . onMessage ( "Reading of set of RIDs of records which were detected as broken during database export\n" ) ; jsonReader . readNext ( OJSONReader . BEGIN_COLLECTION ) ; while ( true ) { jsonReader . readNext ( OJSONReader . NEXT_IN_ARRAY ) ; final ORecordId recordId = new ORecordId ( jsonReader . getValue ( ) ) ; brokenRids . add ( recordId ) ; if ( jsonReader . lastChar ( ) == ' ' ) break ; } } if ( migrateLinks ) { if ( exporterVersion >= 12 ) listener . onMessage ( brokenRids . size ( ) + " were detected as broken during database export, links on those records will be removed from" + " result database" ) ; migrateLinksInImportedDocuments ( brokenRids ) ; } }
just read collection so import process can continue
just read collection so import process can continue