EDIT

/**

* Copyright (C) 2007 EDIT

* http://www.e-taxonomy.eu

* The contents of this file are subject to the Mozilla Public License Version 1.1

* See LICENSE.TXT at the top of this package for the full license terms.

*/

	private static int modCount = 5000;

	private static final String pluralString = "occurrence sources";

	private static final String dbTableName = "emOccurrenceSource";  //??

	private Map<String, Integer> sourceNumberRefIdMap;

	private Set<String> unfoundReferences = new HashSet<String>();

	public BerlinModelOccurrenceSourceImport(){

		super(dbTableName, pluralString);

	}

	@Override

	protected String getIdQuery(BerlinModelImportState state) {

		String result = "SELECT occurrenceSourceId FROM " + getTableName();

	@Override

	protected String getRecordQuery(BerlinModelImportConfigurator config) {

             "";

		return strQuery;

	}

	@Override

	protected void doInvoke(BerlinModelImportState state) {

		unfoundReferences = new HashSet<String>();

		try {

			sourceNumberRefIdMap = makeSourceNumberReferenceIdMap(state);

		} catch (SQLException e) {

		super.doInvoke(state);

		sourceNumberRefIdMap = null;

		if (unfoundReferences.size()>0){

			logger.warn("Not found references: " + unfound);

		}

		return;

		boolean success = true;

		ResultSet rs = partitioner.getResultSet();

		Map<String, Reference> refMap = partitioner.getObjectMap(BerlinModelReferenceImport.REFERENCE_NAMESPACE);

		Set<DescriptionElementBase> objectsToSave = new HashSet<DescriptionElementBase>();

		try {

			int i = 0;

			//for each reference

            while (rs.next()){

                if ((i++ % modCount) == 0 && i!= 1 ){ logger.info("occurrence sources handled: " + (i-1));}

                Integer occurrenceSourceId = rs.getInt("OccurrenceSourceId");

                Integer occurrenceFk =nullSafeInt(rs, "OccurrenceFk");

    			String sourceNumber = rs.getString("SourceNumber");

    			String oldName = rs.getString("OldName");

    			Integer oldNameFk = nullSafeInt(rs, "OldNameFk");

    			Distribution distribution = (Distribution)state.getRelatedObject(BerlinModelOccurrenceImport.NAMESPACE, String.valueOf(occurrenceFk));

    			if (distribution == null){

    				//distribution = duplicateMap.get(occurrenceFk);

    			}

    			if (distribution != null){

    				Integer refId = sourceNumberRefIdMap.get(sourceNumber);

    				if (ref != null){

    					DescriptionElementSource originalSource = DescriptionElementSource.NewInstance(OriginalSourceType.PrimaryTaxonomicSource);

    			}else{

    				logger.warn("distribution ("+occurrenceFk+") for occurrence source (" + occurrenceSourceId + ") could not be found." );

    			}

            }

			logger.info("Distributions to save: " + objectsToSave.size());

			return success;

		} catch (SQLException e) {

			logger.error("SQLException:" +  e);

		Class<?> cdmClass;

		Set<String> idSet;

		Map<Object, Map<String, ? extends CdmBase>> result = new HashMap<Object, Map<String, ? extends CdmBase>>();

		try{

			Set<String> occurrenceIdSet = new HashSet<String>();

			Set<String> referenceIdSet = new HashSet<String>();

				handleForeignKey(rs, nameIdSet, "oldNameFk");

				sourceNumberSet.add(CdmUtils.NzTrim(rs.getString("SourceNumber")));

			}

			sourceNumberSet.remove("");

			referenceIdSet = handleSourceNumber(rs, sourceNumberSet, result);

			//occurrence map

			nameSpace = BerlinModelOccurrenceImport.NAMESPACE;

			cdmClass = Distribution.class;

			idSet =nameIdSet;

			Map<String, TaxonNameBase> nameMap = (Map<String, TaxonNameBase>)getCommonService().getSourcedObjectsByIdInSource(cdmClass, idSet, nameSpace);

			result.put(nameSpace, nameMap);

			//reference map

			nameSpace = BerlinModelReferenceImport.REFERENCE_NAMESPACE;

			cdmClass = Reference.class;

	private Set<String> handleSourceNumber(ResultSet rs, Set<String> sourceNumberSet, Map<Object, Map<String, ? extends CdmBase>> result) {

		Map<String, Integer> sourceNumberReferenceIdMap = this.sourceNumberRefIdMap;

		Set<String> referenceIdSet = new HashSet<String>();

		for(String sourceNumber : sourceNumberSet){

			Integer refId = sourceNumberReferenceIdMap.get(sourceNumber);

		}

		return referenceIdSet;

	}

	/**

	 * @param state

	 * @param oldName

	 * Creates a map which maps source numbers on references

	 * @param state

	 * @return

	 */

	private Map<String, Integer> makeSourceNumberReferenceIdMap(BerlinModelImportState state) throws SQLException {

		Map<String, Integer> result = new HashMap<String, Integer>();

		Source source = state.getConfig().getSource();

						  " WHERE     (IdInSource IS NOT NULL) AND (IdInSource NOT LIKE '') ";

		ResultSet rs = source.getResultSet(strQuery) ;

		while (rs.next()){

			int refId = rs.getInt("RefId");

			}

		}

	}

}