Added management of missing data in all employment data queries

src/FACT_jobs.jl

@@ -139,9 +139,9 @@ function eu_lfs(conn::MySQL.Connection, selection::Dict)
         # execute
         result = query_connection(conn, query)
         if !("industry" in names(result))
-            println("No data returned for query with GeoID = $id and Year = $year.")
+           println("No data returned for query with GeoID = $id and Year = $year.")
            # Initialize `result` with the expected columns but no rows
-           #result = DataFrame(industry = String[], jobs = Float64[], geo_id = String[], agg_level = Int[])
+           result = DataFrame(industry = String[], jobs = Float64[], geo_id = String[], agg_level = Int[])
         end
         # add geo_id col
         result[!, :geo_id] = fill(id, nrow(result))
@@ -178,6 +178,11 @@ function eu_sbs(conn::MySQL.Connection, selection::Dict)
             query = "SELECT Nace as industry, Employment as jobs FROM SBS WHERE Year = "*string(year)*" AND GeoID = '"*id*"';"
             # execute
             result = query_connection(conn, query)
+            if !("industry" in names(result))
+               println("No data returned for query with GeoID = $id and Year = $year.")
+               # Initialize `result` with the expected columns but no rows
+               result = DataFrame(industry = String[], jobs = Float64[], geo_id = String[], agg_level = Int[])
+            end
             # add geo_id col
             result[!, :geo_id] = fill(id, nrow(result))
             # add agg level
@@ -213,6 +218,11 @@ function eu_rea(conn::MySQL.Connection, selection::Dict)
         query = "SELECT Nace as industry, EmpTh*1000 as jobs FROM REA WHERE Year = "*string(year)*" AND GeoID = '"*id*"';"
         # execute
         result = query_connection(conn, query)
+        if !("industry" in names(result))
+            println("No data returned for query with GeoID = $id and Year = $year.")
+            # Initialize `result` with the expected columns but no rows
+            result = DataFrame(industry = String[], jobs = Float64[], geo_id = String[], agg_level = Int[])
+        end
         # add geo_id col
         result[!, :geo_id] = fill(id, nrow(result))
         # add agg level