Subversion Repositories SmartDukaan

import java.io.BufferedReader;

import java.io.DataInputStream;

import java.io.FileInputStream;

import java.io.InputStreamReader;

import java.util.TreeMap;

		ContentMigrator contentmigrator = new ContentMigrator(sourceDbPath, destinationDbPath);

		contentmigrator.makeEntitiesObject();

	private boolean makeEntitiesObject() throws Exception{

		//DefinitionsContainer sourceDefs = new DefinitionsContainer(sourceDbPath);

		//DefinitionsContainer destinationDefs = new DefinitionsContainer(destinationDbPath);

		EntityContainer sourceEnts = new EntityContainer(sourceDbPath);

		//EntityContainer destinationEnts = new EntityContainer(destinationDbPath);

	/*

		Map<Long, List<Entity>> catEntities = sourceEnts.getEntitiesbyCategory();

		Map<Long, Entity> entities = sourceEnts.getEntities();

		for(Long catId: catEntities.keySet()){

			List<Entity> ents = catEntities.get(catId);

			for(Entity entity: ents){

				entities.put(entity.getID(), entity);

				System.out.println(entity.getID() + ":"  + entity.getCategoryID() + ":"+  entity.getBrand() + " "+ entity.getModelName() + " " + entity.getModelNumber());

			}

		}

		*/

		Map<Long, List<Entity>> catEntities = new TreeMap<Long, List<Entity>>();

		Map<Long, Entity> entities = new TreeMap<Long, Entity>();

	    FileInputStream fstream = new FileInputStream("/home/rajveer/Desktop/1");

	    DataInputStream in = new DataInputStream(fstream);

	    BufferedReader br = new BufferedReader(new InputStreamReader(in));

	    String strLine;

	    while ((strLine = br.readLine()) != null)   {

	    	long entityID = Long.parseLong(strLine);

	    	String entityDBFile = sourceDbPath + "entities" + File.separator + entityID +"/entity.ser";

	    	System.out.println (entityDBFile);

	    	Entity entity =  (Entity)DBUtils.read(entityDBFile);

	    	entities.put(entityID, entity);

	    	List<Entity> catent = catEntities.get(entity.getCategoryID());

	    	if(catent == null){

	    		catent = new ArrayList<Entity>();

	    	}

	    	catent.add(entity);

	    	catEntities.put(entity.getCategoryID(), catent);

	    }

	    in.close();

		String entitiesDBFile = sourceDbPath + "entities" + File.separator + "entities.ser";

		String entitiesbycategoryDBFile = sourceDbPath + "entities" + File.separator + "entitiesbycategory.ser";

		DBUtils.delete(entitiesDBFile);

		DBUtils.store(entities, entitiesDBFile);

		// Remove existing

		DBUtils.delete(entitiesbycategoryDBFile);

		DBUtils.store(catEntities, entitiesbycategoryDBFile);

		return false;

	}