|
@@ -26,28 +26,65 @@ public class DataParser {
|
|
|
while(in.hasNextLine()) {
|
|
while(in.hasNextLine()) {
|
|
|
msg = in.nextLine();
|
|
msg = in.nextLine();
|
|
|
if(msg.startsWith("New_Entity:")) {
|
|
if(msg.startsWith("New_Entity:")) {
|
|
|
- System.out.println(msg.substring(11));
|
|
|
|
|
switch(msg.substring(11)) {
|
|
switch(msg.substring(11)) {
|
|
|
case " \"movie_id\",\"movie_title\",\"movie_plot\",\"genre_name\",\"movie_released\",\"movie_imdbVotes\",\"movie_imdbRating\"":
|
|
case " \"movie_id\",\"movie_title\",\"movie_plot\",\"genre_name\",\"movie_released\",\"movie_imdbVotes\",\"movie_imdbRating\"":
|
|
|
readmode = mode.MOVIE;
|
|
readmode = mode.MOVIE;
|
|
|
break;
|
|
break;
|
|
|
|
|
+ case "\"actor_id\",\"actor_name\"":
|
|
|
|
|
+ readmode = mode.ACTOR;
|
|
|
|
|
+ break;
|
|
|
|
|
+ case "\"director_id\",\"director_name\"":
|
|
|
|
|
+ readmode = mode.DIRECTOR;
|
|
|
|
|
+ break;
|
|
|
|
|
+ case "\"actor_id\",\"movie_id\"":
|
|
|
|
|
+ readmode = mode.ACTING;
|
|
|
|
|
+ break;
|
|
|
|
|
+ case "\"director_id\",\"movie_id\"":
|
|
|
|
|
+ readmode = mode.DIRECTING;
|
|
|
|
|
+ break;
|
|
|
|
|
+ case "\"user_name\",\"rating\",\"movie_id\"":
|
|
|
|
|
+ readmode = mode.USER;
|
|
|
|
|
+ break;
|
|
|
default:
|
|
default:
|
|
|
readmode = mode.NONE;
|
|
readmode = mode.NONE;
|
|
|
}
|
|
}
|
|
|
}else {
|
|
}else {
|
|
|
String[] data = msg.split("\",\"");
|
|
String[] data = msg.split("\",\"");
|
|
|
|
|
+ for(int i = 0; i < data.length; i++) {
|
|
|
|
|
+ data[i] = data[i].replaceAll("\"", "");
|
|
|
|
|
+ }
|
|
|
switch(readmode) {
|
|
switch(readmode) {
|
|
|
case MOVIE:
|
|
case MOVIE:
|
|
|
- System.out.println(msg);
|
|
|
|
|
Movie m = new Movie();
|
|
Movie m = new Movie();
|
|
|
- m.setId(Integer.valueOf(data[0].replaceAll("\"", "")));
|
|
|
|
|
- m.setGenre(data[3].replaceAll("\"", ""));
|
|
|
|
|
- m.setPlot(data[2].replaceAll("\"", ""));
|
|
|
|
|
|
|
+ m.setId(Integer.valueOf(data[0]));
|
|
|
|
|
+ m.setGenre(data[3]);
|
|
|
|
|
+ m.setPlot(data[2]);
|
|
|
m.setTitle(data[1].replaceAll("\"", ""));
|
|
m.setTitle(data[1].replaceAll("\"", ""));
|
|
|
if(!data[6].replaceAll("\"", "").equals(""))
|
|
if(!data[6].replaceAll("\"", "").equals(""))
|
|
|
m.setRating(Float.valueOf(data[6].replaceAll("\"", "")));
|
|
m.setRating(Float.valueOf(data[6].replaceAll("\"", "")));
|
|
|
db.addMovie(m);
|
|
db.addMovie(m);
|
|
|
break;
|
|
break;
|
|
|
|
|
+ case ACTOR:
|
|
|
|
|
+ Actor a = new Actor();
|
|
|
|
|
+ a.setId(Integer.valueOf(data[0]));
|
|
|
|
|
+ a.setName(data[1].trim());
|
|
|
|
|
+ db.addActor(a);
|
|
|
|
|
+ break;
|
|
|
|
|
+ case DIRECTOR:
|
|
|
|
|
+ Director d = new Director();
|
|
|
|
|
+ d.setId(Integer.valueOf(data[0]));
|
|
|
|
|
+ d.setName(data[1]);
|
|
|
|
|
+ db.addDirector(d);
|
|
|
|
|
+ break;
|
|
|
|
|
+ case ACTING:
|
|
|
|
|
+ db.addActing(Integer.valueOf(data[0]), Integer.valueOf(data[1]));
|
|
|
|
|
+ break;
|
|
|
|
|
+ case DIRECTING:
|
|
|
|
|
+ db.addDirecting(Integer.valueOf(data[0]), Integer.valueOf(data[1]));
|
|
|
|
|
+ break;
|
|
|
|
|
+ case USER:
|
|
|
|
|
+ db.addUser(data[0], Float.valueOf(data[1]), Integer.valueOf(data[2]));
|
|
|
|
|
+ break;
|
|
|
default:
|
|
default:
|
|
|
|
|
|
|
|
}
|
|
}
|