First Commit

.gitignore

@@ -0,0 +1,4 @@
+.Rproj.user
+.Rhistory
+.RData
+.Ruserdata

lahman_etl.R

@@ -0,0 +1,58 @@
+require(DBI)
+require(readr)
+require(dplyr)
+
+
+tables <- c('AllstarFull',
+'Appearances',
+'AwardsManagers',
+'AwardsPlayers',
+'AwardsShareManagers',
+'AwardsSharePlayers',
+'Batting',
+'BattingPost',
+'CollegePlaying',
+'Fielding',
+'FieldingOF',
+'FieldingOFsplit',
+'FieldingPost',
+'HallOfFame',
+'HomeGames',
+'Managers',
+'ManagersHalf',
+'Parks',
+'People',
+'Pitching',
+'PitchingPost',
+'Salaries',
+'Schools',
+'SeriesPost',
+'Teams',
+'TeamsFranchises',
+'TeamsHalf')
+
+foo<-dbConnect(MySQL(), host="localhost", dbname="lahman",user="root",port=3306)
+
+y=Sys.time()
+for (t in tables) {
+  print(t)
+  if (t != "AwardsSharePlayers"){
+  a <- read_csv(paste0("https://github.com/chadwickbureau/baseballdatabank/raw/master/core/",
+                       t,
+                      ".csv"))
+  } else {
+    a <- read_csv(paste0("https://github.com/chadwickbureau/baseballdatabank/raw/master/core/",
+                         t,
+                         ".csv"),col_names = c("awardID","yearID","lgID","playerID",
+                                               "pointsWon","pointsMax","votesFirst"),
+                  skip=1,
+                  col_types = "ciccdid")
+  }
+
+  dbSendQuery(foo, paste0("drop table if exists ",t,";"))
+  dbWriteTable(foo, name=t, value=a %>% as.data.frame(a))
+
+}
+Sys.time()-y
+
+dbDisconnect(foo)

lahman_etl.Rproj

@@ -0,0 +1,13 @@
+Version: 1.0
+
+RestoreWorkspace: Default
+SaveWorkspace: Default
+AlwaysSaveHistory: Default
+
+EnableCodeIndexing: Yes
+UseSpacesForTab: Yes
+NumSpacesForTab: 2
+Encoding: UTF-8
+
+RnwWeave: Sweave
+LaTeX: pdfLaTeX