diff --git a/src/FACT_jobs.jl b/src/FACT_jobs.jl index 3dcc197168baee86a95bc974edd802ceee5cb687..0fa9b0ae70f642418fbb3a23ebe28b6c817d926a 100644 --- a/src/FACT_jobs.jl +++ b/src/FACT_jobs.jl @@ -135,7 +135,7 @@ function eu_lfs(conn::MySQL.Connection, selection::Dict) # iterate over geo objects for id in geo_id # prepare query - query = "SELECT Nace as industry, ((EmpTh_Q1+EmpTh_Q2+EmpTh_Q3+EmpTh_Q4)/4)*1000 as jobs FROM LFS WHERE Year = $year AND GeoID = '$id';" + query = "SELECT Nace as industry, ((COALESCE(EmpTh_Q1, 0) + COALESCE(EmpTh_Q2, 0) + COALESCE(EmpTh_Q3, 0) + COALESCE(EmpTh_Q4, 0)) / (CASE WHEN EmpTh_Q1 IS NOT NULL THEN 1 ELSE 0 END + CASE WHEN EmpTh_Q2 IS NOT NULL THEN 1 ELSE 0 END + CASE WHEN EmpTh_Q3 IS NOT NULL THEN 1 ELSE 0 END + CASE WHEN EmpTh_Q4 IS NOT NULL THEN 1 ELSE 0 END)) * 1000 as jobs FROM LFS WHERE Year = $year AND GeoID = '$id';" # execute result = query_connection(conn, query) if !("industry" in names(result))