|
|
|
@@ -19,13 +19,13 @@ tvepisodes |
|
|
|
|
|
|
|
tvseries %>% |
|
|
|
inner_join(episodes, by = c("tconst" = "parentTconst")) %>% |
|
|
|
select(-tconst, seriesTitle = primaryTitle, tconst = tconst.y, season = seasonNumber, episode = episodeNumber) %>% |
|
|
|
select(id = tconst, seriesTitle = primaryTitle, eptconst = tconst.y, season = seasonNumber, episode = episodeNumber, startYear) %>% |
|
|
|
filter(season != "\\N") %>% |
|
|
|
inner_join(ratings) %>% |
|
|
|
inner_join(tvepisodes) %>% |
|
|
|
select(-tconst, episodeTitle = primaryTitle) %>% |
|
|
|
inner_join(ratings, by = c("eptconst" = "tconst")) %>% |
|
|
|
inner_join(tvepisodes, by = c("eptconst" = "tconst")) %>% |
|
|
|
select(-eptconst, episodeTitle = primaryTitle) %>% |
|
|
|
arrange(seriesTitle, season, episode) -> |
|
|
|
final |
|
|
|
|
|
|
|
final %>% |
|
|
|
dbWriteTable(conn = imdb, name = "imdb", value = .) |
|
|
|
dbWriteTable(conn = imdb, name = "imdb", value = ., overwrite = T) |
