Skip to content
Merged
Show file tree
Hide file tree
Changes from all commits
Commits
File filter

Filter by extension

Filter by extension

Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
2 changes: 0 additions & 2 deletions models/br_me_rais/br_me_rais__dicionario.sql
Original file line number Diff line number Diff line change
@@ -1,6 +1,4 @@
{{ config(alias="dicionario", schema="br_me_rais") }}


select
safe_cast(id_tabela as string) id_tabela,
safe_cast(nome_coluna as string) nome_coluna,
Expand Down
233 changes: 221 additions & 12 deletions models/br_me_rais/br_me_rais__microdados_vinculos.sql
Original file line number Diff line number Diff line change
Expand Up @@ -12,21 +12,82 @@
cluster_by=["sigla_uf", "id_municipio"],
)
}}

select
safe_cast(ano as int64) ano,
safe_cast(sigla_uf as string) sigla_uf,
safe_cast(regexp_replace(id_municipio, r'\.0$', '') as string) id_municipio,
safe_cast(tipo_vinculo as string) tipo_vinculo,
safe_cast(vinculo_ativo_3112 as string) vinculo_ativo_3112,
safe_cast(tipo_admissao as string) tipo_admissao,
case
when tipo_admissao = '00'
then '0'
when tipo_admissao = '01'
then '1'
when tipo_admissao = '02'
then '2'
when tipo_admissao = '03'
then '3'
when tipo_admissao = '04'
then '4'
when tipo_admissao = '05'
then '5'
when tipo_admissao = '06'
then '6'
else tipo_admissao
end as tipo_admissao,
safe_cast(mes_admissao as int64) mes_admissao,
safe_cast(mes_desligamento as int64) mes_desligamento,
safe_cast(motivo_desligamento as string) motivo_desligamento,
case
when motivo_desligamento = '00' then '0' else motivo_desligamento
end as motivo_desligamento,
safe_cast(causa_desligamento_1 as string) causa_desligamento_1,
safe_cast(causa_desligamento_2 as string) causa_desligamento_2,
safe_cast(causa_desligamento_3 as string) causa_desligamento_3,
safe_cast(faixa_tempo_emprego as string) faixa_tempo_emprego,
safe_cast(faixa_horas_contratadas as string) faixa_horas_contratadas,
case
when faixa_tempo_emprego = '00'
then '0'
when faixa_tempo_emprego = '01'
then '1'
when faixa_tempo_emprego = '02'
then '2'
when faixa_tempo_emprego = '03'
then '3'
when faixa_tempo_emprego = '04'
then '4'
when faixa_tempo_emprego = '05'
then '5'
when faixa_tempo_emprego = '06'
then '6'
when faixa_tempo_emprego = '07'
then '7'
when faixa_tempo_emprego = '08'
then '8'
else faixa_tempo_emprego
end as faixa_tempo_emprego,
case
when faixa_horas_contratadas = '00'
then '0'
when faixa_horas_contratadas = '01'
then '1'
when faixa_horas_contratadas = '02'
then '2'
when faixa_horas_contratadas = '03'
then '3'
when faixa_horas_contratadas = '04'
then '4'
when faixa_horas_contratadas = '05'
then '5'
when faixa_horas_contratadas = '06'
then '6'
when faixa_horas_contratadas = '07'
then '7'
when faixa_horas_contratadas = '08'
then '8'
when faixa_horas_contratadas = '09'
then '9'
else faixa_horas_contratadas
end as faixa_horas_contratadas,
round(safe_cast(tempo_emprego as float64), 2) tempo_emprego,
safe_cast(quantidade_horas_contratadas as int64) quantidade_horas_contratadas,
safe_cast(id_municipio_trabalho as string) id_municipio_trabalho,
Expand All @@ -36,12 +97,56 @@ select
safe_cast(
indicador_trabalho_intermitente as string
) indicador_trabalho_intermitente,
safe_cast(faixa_remuneracao_media_sm as string) faixa_remuneracao_media_sm,
case
when faixa_remuneracao_media_sm = '00'
then '0'
when faixa_remuneracao_media_sm = '01'
then '1'
when faixa_remuneracao_media_sm = '02'
then '2'
when faixa_remuneracao_media_sm = '03'
then '3'
when faixa_remuneracao_media_sm = '04'
then '4'
when faixa_remuneracao_media_sm = '05'
then '5'
when faixa_remuneracao_media_sm = '06'
then '6'
when faixa_remuneracao_media_sm = '07'
then '7'
when faixa_remuneracao_media_sm = '08'
then '8'
when faixa_remuneracao_media_sm = '09'
then '9'
else faixa_remuneracao_media_sm
end as faixa_remuneracao_media_sm,
round(
safe_cast(valor_remuneracao_media_sm as float64), 2
) valor_remuneracao_media_sm,
safe_cast(valor_remuneracao_media as float64) valor_remuneracao_media,
safe_cast(faixa_remuneracao_dezembro_sm as string) faixa_remuneracao_dezembro_sm,
case
when faixa_remuneracao_dezembro_sm = '00'
then '0'
when faixa_remuneracao_dezembro_sm = '01'
then '1'
when faixa_remuneracao_dezembro_sm = '02'
then '2'
when faixa_remuneracao_dezembro_sm = '03'
then '3'
when faixa_remuneracao_dezembro_sm = '04'
then '4'
when faixa_remuneracao_dezembro_sm = '05'
then '5'
when faixa_remuneracao_dezembro_sm = '06'
then '6'
when faixa_remuneracao_dezembro_sm = '07'
then '7'
when faixa_remuneracao_dezembro_sm = '08'
then '8'
when faixa_remuneracao_dezembro_sm = '09'
then '9'
else faixa_remuneracao_dezembro_sm
end as faixa_remuneracao_dezembro_sm,
round(
safe_cast(valor_remuneracao_dezembro_sm as float64), 2
) valor_remuneracao_dezembro_sm,
Expand Down Expand Up @@ -70,17 +175,121 @@ select
safe_cast(cnae_1 as string) cnae_1,
safe_cast(cnae_2 as string) cnae_2,
safe_cast(cnae_2_subclasse as string) cnae_2_subclasse,
safe_cast(faixa_etaria as string) faixa_etaria,
case
when faixa_etaria = '00'
then '0'
when faixa_etaria = '01'
then '1'
when faixa_etaria = '02'
then '2'
when faixa_etaria = '03'
then '3'
when faixa_etaria = '04'
then '4'
when faixa_etaria = '05'
then '5'
when faixa_etaria = '06'
then '6'
when faixa_etaria = '07'
then '7'
when faixa_etaria = '08'
then '8'
else faixa_etaria
end as faixa_etaria,
safe_cast(idade as int64) idade,
safe_cast(grau_instrucao_1985_2005 as string) grau_instrucao_1985_2005,
safe_cast(grau_instrucao_apos_2005 as string) grau_instrucao_apos_2005,
case
when grau_instrucao_apos_2005 = '00'
then '0'
when grau_instrucao_apos_2005 = '01'
then '1'
when grau_instrucao_apos_2005 = '02'
then '2'
when grau_instrucao_apos_2005 = '03'
then '3'
when grau_instrucao_apos_2005 = '04'
then '4'
when grau_instrucao_apos_2005 = '05'
then '5'
when grau_instrucao_apos_2005 = '06'
then '6'
when grau_instrucao_apos_2005 = '07'
then '7'
when grau_instrucao_apos_2005 = '08'
then '8'
when grau_instrucao_apos_2005 = '09'
then '9'
else grau_instrucao_apos_2005
end as grau_instrucao_apos_2005,
safe_cast(nacionalidade as string) nacionalidade,
safe_cast(sexo as string) sexo,
safe_cast(raca_cor as string) raca_cor,
case when sexo = '01' then '1' when sexo = '02' then '2' else sexo end sexo,
case
when raca_cor = '00'
then '0'
when raca_cor = '01'
then '1'
when raca_cor = '02'
then '2'
when raca_cor = '03'
then '3'
when raca_cor = '04'
then '4'
when raca_cor = '05'
then '5'
when raca_cor = '06'
then '6'
when raca_cor = '07'
then '7'
when raca_cor = '08'
then '8'
when raca_cor = '09'
then '9'
else raca_cor
end as raca_cor,
safe_cast(indicador_portador_deficiencia as string) indicador_portador_deficiencia,
safe_cast(tipo_deficiencia as string) tipo_deficiencia,
case
when tipo_deficiencia = '00'
then '0'
when tipo_deficiencia = '01'
then '1'
when tipo_deficiencia = '02'
then '2'
when tipo_deficiencia = '03'
then '3'
when tipo_deficiencia = '04'
then '4'
when tipo_deficiencia = '05'
then '5'
when tipo_deficiencia = '06'
then '6'
when tipo_deficiencia = '07'
then '7'
when tipo_deficiencia = '08'
then '8'
else tipo_deficiencia
end as tipo_deficiencia,
safe_cast(ano_chegada_brasil as int64) ano_chegada_brasil,
safe_cast(tamanho_estabelecimento as string) tamanho_estabelecimento,
case
when tamanho_estabelecimento = '01'
then '1'
when tamanho_estabelecimento = '02'
then '2'
when tamanho_estabelecimento = '03'
then '3'
when tamanho_estabelecimento = '04'
then '4'
when tamanho_estabelecimento = '05'
then '5'
when tamanho_estabelecimento = '06'
then '6'
when tamanho_estabelecimento = '07'
then '7'
when tamanho_estabelecimento = '08'
then '8'
when tamanho_estabelecimento = '09'
then '9'
else tamanho_estabelecimento
end as tamanho_estabelecimento,
case
when tipo_estabelecimento in ('Não', 'Não Indentificado')
then 'Não identificado'
Expand Down
Loading