iTunes Import into DB

[duhit Choudhary]

package com.iremote.itunes;


import java.util.List;
import java.util.LinkedList;
import java.sql.Connection;
import java.sql.DriverManager;
import java.sql.ResultSet;
import java.sql.Statement;
import org.apache.log4j.Logger;
import org.apache.log4j.PropertyConfigurator;

public class DBReader {
	Logger log = Logger.getLogger(XmlReader.class);
	List<String> idList = new LinkedList<String>();
	
	public List<String> getAllTrackIdFromDB()
	{
		log.info("started");
		
		//TODO configure url 
		String connectionURL = "jdbc:mysql://localhost:3306/mymovie?useUnicode=yes&characterEncoding=UTF-8";
                  //machine name, port number, database name
		String user = "root"; String pass="duhit";
        Connection connection = null;
        Statement statement = null;
        ResultSet resultSet = null;
        //TODO include tv shows and videos section
        String queryString =" SELECT track_id FROM track WHERE track_id !=0 "+
        					" UNION "+
        					" SELECT track_id FROM movie WHERE track_id!=0 ";
        log.info("entering try");
        try 
        {
        	Class.forName("com.mysql.jdbc.Driver");
            
        	connection = DriverManager.getConnection(connectionURL, user, pass);
        	
        	statement = connection.createStatement(ResultSet.TYPE_FORWARD_ONLY, ResultSet.CONCUR_READ_ONLY);
        	
        	resultSet = statement.executeQuery(queryString);
			
			while(resultSet.next())
			{
				//TODO column name. might break if the column is renamed
				idList.add(resultSet.getString("track_id"));
			}
			
        }
        catch (Exception e) 
        {
			log.error("exception in db access",e);
		}    
       
       //System.out.println("--------"+idList);
	
		return idList;
	}
	public static void main(String[] args) {
		PropertyConfigurator.configure("E:\\lib\\Log4J.properties");
		DBReader reader = new DBReader();
		reader.getAllTrackIdFromDB();
	}
}

package com.iremote.itunes;

import java.sql.ResultSet;
import java.sql.SQLException;
import java.sql.Statement;
import java.util.List;
import java.util.Map;
import java.util.Vector;

public class ReaderThread extends Thread {
	String QueryString = null;
	Statement statement = null;
	ResultSet rs = null;
	int affectedRows = 0;
	
	@SuppressWarnings({ "unchecked", "unused" })
	public void run()
	{
		
		DBReader dbReaderObj = new DBReader();
		List<String> trackIdFromDb= dbReaderObj.getAllTrackIdFromDB();
		
		XmlReader xmlReaderObj = new XmlReader();
		Map<String, Track> trackIdFromXml = xmlReaderObj.getTracksFromXml("C:/Users/pbsl/Documents/itunes.xml");
		Vector<String>[] trackIdOfXml = (Vector<String>[]) trackIdFromXml.keySet().toArray();
		
		while(true)
		{
		
		  for(String trackIdDb : trackIdFromDb)
		  {
			if(trackIdFromXml.containsKey(trackIdDb))
			{
				System.out.println("Track_Id is already in the database.... No change in xml");
				QueryString = "UPDATE user_subcategorizes_track SET subcat_id = "
                                 + "(SELECT subcat_id FROM track_subcategory WHERE `name` = 'ResultSet.getArtist()' 
                               AND parent_cat = (SELECT cat_id FROM track_category WHERE `name` = 'Artist'))" + " WHERE track_id = trackIdDb";
				try
				{
					affectedRows = statement.executeUpdate(QueryString);
					rs = statement.executeQuery(QueryString);
					rs.close();
				}catch (SQLException e) {
					e.printStackTrace();
				}
			}
			else
			{
				QueryString = "INSERT INTO track(track_id)VALUES(trackIdXml)";
				try
				{
					affectedRows = statement.executeUpdate(QueryString);
					rs = statement.executeQuery(QueryString);
					rs.close();
				}catch (SQLException e) {
					e.printStackTrace();
				}
			}
			if(trackIdDb.contains((CharSequence) trackIdFromXml))
			{
				System.out.println("Track_Id is already in the xml.... No change in database");
			}
			else
			{
				QueryString =  "DELETE track_id FROM track Where track_id = trackIdFromXml";
				try
				{
					int affectedRows = statement.executeUpdate(QueryString);
					rs = statement.executeQuery(QueryString);
					rs.close();
				}catch (SQLException e) {
					e.printStackTrace();
				}
			}
		  }

		}
	}
	
	public static void main(String[] args)
	{
		ReaderThread readerThreadObj = new ReaderThread();
		readerThreadObj.start();
	}
}

package com.iremote.itunes;

public class Track {
	
	private int isUrl;
	private int trackId;
	private String album;
	private String artist;
	private String fileFormat;
	private int runTime;
	private String genre;
	private String location;
	private String title;
	
	String getAlbum() {
		return album;
	}
	void setAlbum(String album) {
		this.album = album;
	}
	String getArtist() {
		return artist;
	}
	void setArtist(String artist) {
		this.artist = artist;
	}
	String getFileFormat() {
		return fileFormat;
	}
	void setFileFormat(String fileFormat) {
		this.fileFormat = fileFormat;
	}
	String getGenre() {
		return genre;
	}
	void setGenre(String genre) {
		this.genre = genre;
	}
	String getLocation() {
		return location;
	}
	void setLocation(String location) {
		this.location = location;
	}
	String getTitle() {
		return title;
	}
	void setTitle(String title) {
		this.title = title;
	}
	 public int getTrackId() {
		return trackId;
	}
	public void setTrackId(int trackId) {
		this.trackId = trackId;
	}
	
	public String toString()
	{
		return "id:"+getTrackId()+"     title: "+getTitle()+ "    isUrl: "+ getIsUrl()+"\n";
	}
	public int getIsUrl() {
		return isUrl;
	}
	public void setIsUrl(int isUrl) {
		this.isUrl = isUrl;
	}
	public int getRunTime() {
		return runTime;
	}
	public void setRunTime(int runTime) {
		this.runTime = runTime;
	}
}

package com.iremote.itunes;

import java.util.HashMap;
import java.util.List;
import java.util.Map;
import org.apache.commons.configuration.ConfigurationException;
import org.apache.commons.configuration.HierarchicalConfiguration;
import org.apache.commons.configuration.XMLConfiguration;
import org.apache.log4j.Logger;
import org.apache.log4j.PropertyConfigurator;

public class XmlReader {
	Logger log = Logger.getLogger(XmlReader.class);
    Track obj = new Track();
    Map<String,Track> trackMap = null;
    String isUrl,  title, fileFormat, location, artist, genre, album, trackId,runTime;
	
    Track track = new Track();
    
    @SuppressWarnings("unchecked")
	public Map<String, Track> getTracksFromXml(String path)
    {
        try
        {
        	XMLConfiguration config;
        	//TODO configure url
        	if(path==null||"".equals(path))
        		 config = new XMLConfiguration("C:/Users/pbsl/Documents/itunes.xml");
        	else
        		config = new XMLConfiguration("C:/Users/pbsl/Documents/itunes.xml");
	       
	        List<HierarchicalConfiguration> fields = config.configurationsAt("Tracks.Track");
	        trackMap = new HashMap<String, Track>(fields.size());
	        
	        for(HierarchicalConfiguration sub : fields)
	        {
	             
	            isUrl = sub.getString("Track-Type"); 
	            fileFormat = sub.getString("Kind");
	            title = sub.getString("Name");
	            location = sub.getString("Location");
	            artist = sub.getString("Artist");
	            trackId = sub.getString("Track-ID");
	            runTime = sub.getString("Total-Time");
	            genre = sub.getString("Genre");
	            album = sub.getString("Album");
	         

	            if(isUrl.equalsIgnoreCase("file"))
	            	track.setIsUrl(0);
	            else
	            	track.setIsUrl(1);
	          
	            track.setFileFormat(fileFormat);
	            track.setTitle(title);
	            track.setLocation(location);
	            track.setArtist(artist);
		        track.setTrackId(Integer.parseInt(trackId));  
		        if (runTime==null)
		        	track.setRunTime(0);   
		        else  
		        	track.setRunTime(Integer.parseInt(runTime));
		        
		        track.setGenre(genre);
		        track.setAlbum(album);
	            
	            trackMap.put(trackId,track);
            }
        }
        catch (ConfigurationException e)
        {
           log.error(e.getMessage());
        	e.printStackTrace();
        }
        catch(Exception ex)
        {
        	log.error(ex.getMessage());
        	ex.printStackTrace();
        }
        
        return trackMap;
    }
    
    @SuppressWarnings("unused")
	public static void main(String as[])
    {
    	//TODO configure url
    	PropertyConfigurator.configure("E:\\lib\\Log4J.properties");
    	XmlReader xmlReader = new XmlReader();
    	Map<String, Track> tracks = xmlReader.getTracksFromXml("C:/Users/pbsl/Documents/itunes.xml");
    	
    	Logger.getLogger(XmlReader.class).info("--------------size");
    	
    }
}

I am working on a project module in which i have to insert all the changes or updates done in the xml file of all the song tracks into a database, through this program. but unfortunately when i tried to run this program then i am getting this error. kindly tell me how to overcome with it.
here is the error...

log4j:WARN No appenders could be found for logger (com.iremote.itunes.XmlReader).
log4j:WARN Please initialize the log4j system properly.
Exception in thread "Thread-0" java.lang.NoClassDefFoundError: org/apache/commons/collections/Predicate
at com.iremote.itunes.XmlReader.getTracksFromXml(XmlReader.java:30)
at com.iremote.itunes.ReaderThread.run(ReaderThread.java:24)
Caused by: java.lang.ClassNotFoundException: org.apache.commons.collections.Predicate
at java.net.URLClassLoader$1.run(Unknown Source)
at java.security.AccessController.doPrivileged(Native Method)
at java.net.URLClassLoader.findClass(Unknown Source)
at java.lang.ClassLoader.loadClass(Unknown Source)
at sun.misc.Launcher$AppClassLoader.loadClass(Unknown Source)
at java.lang.ClassLoader.loadClass(Unknown Source)
... 2 more

[Ulf Dittmer]

How are you adding the Apache Commons library to the classpath? That seems to be missing.

[duhit Choudhary]

Ulf Dittmer wrote:How are you adding the Apache Commons library to the classpath? That seems to be missing.

i think i have added all the files correctly...

[Maneesh Godbole]

duhit Choudhary wrote:

Ulf Dittmer wrote:How are you adding the Apache Commons library to the classpath? That seems to be missing.

i think i have added all the files correctly...

The error is telling you...not really

[duhit Choudhary]

thanks all.... now i added the required library successfully but now i am getting exception in class ReaderThread t line no. 25. here is the exception.....

log4j:WARN No appenders could be found for logger (com.iremote.itunes.XmlReader).
log4j:WARN Please initialize the log4j system properly.
Exception in thread "Thread-0" java.lang.ClassCastException: [Ljava.lang.Object; cannot be cast to [Ljava.util.Vector;
at com.iremote.itunes.ReaderThread.run(ReaderThread.java:25)

Is there any way by which I can resolve this ???

[Jesper de Jong]

The error message tells you exactly where this error happens: line 25 of ReaderThread.java.

It also tells you what the problem is: you're getting an array of objects (indicated by [Ljava.lang.Object;) and you're casting that to an array of vectors (indicated by [Ljava.util.Vector;).

The object that you're getting isn't an array of vectors, so you get a ClassCastException. Don't cast it to something that it isn't.