# Proceed only if connection succeeded
if (!is.null(conn)) {
print("Database connection successful.")
# Load Core tables
ep_skills_df_clean <- dbReadTable(conn, "ep_skills")
onet_skills_df_clean <- dbReadTable(conn, "onet_skills")
tech_skills_df_clean <- dbReadTable(conn, "tech_skills")
soc_industry_project_df_clean <- dbReadTable(conn, "soc_industry_project")
soc_industry_project_change_df_clean <- dbReadTable(conn, "soc_industry_project_change")
# Load Link tables
soc_onet_soc_lnk <- dbReadTable(conn, "soc_onet_soc_lnk")
soc_industry_lnk <- dbReadTable(conn, "soc_industry_lnk")
# Load Reference tables
commodity_ref <- dbReadTable(conn, "commodity_ref")
skills_element_ref <- dbReadTable(conn, "skills_element_ref")
soc_ref <- dbReadTable(conn, "soc_ref")
skills_category_ref <- dbReadTable(conn, "skills_category_ref")
industry_ref <- dbReadTable(conn, "industry_ref")
# Optionally, print a sample from one table for verification
print(head(ep_skills_df_clean))
# Disconnect when done
dbDisconnect(conn)
} else {
stop("Database connection failed. Check credentials and try again.")
}