|
|
@ -94,32 +94,34 @@ def scrap_sde(url, usuario, senha=None): |
|
|
|
def tenta_correcao(): |
|
|
|
from sapl.legacy.migracao_dados import ocorrencias |
|
|
|
|
|
|
|
gravar_marco("producao", pula_se_ja_existe=True) |
|
|
|
gravar_marco("producao") |
|
|
|
migrar_dados() |
|
|
|
assert "fk" not in ocorrencias, "AINDA EXISTEM FKS ORFAS" |
|
|
|
gravar_marco() |
|
|
|
from IPython import get_ipython |
|
|
|
import git |
|
|
|
|
|
|
|
sigla = NOME_BANCO_LEGADO[-3:] |
|
|
|
|
|
|
|
print(f"cd ~/migracao_sapl/repos/sapl_cm_{sigla}") |
|
|
|
get_ipython().run_line_magic( |
|
|
|
"cd", f"~/migracao_sapl/repos/sapl_cm_{sigla}" |
|
|
|
) |
|
|
|
get_ipython().system( |
|
|
|
"diff -rq producao dados | grep -v 'Only in dados' | grep -v 'Files producao/sequences.yaml and dados/sequences.yaml differ'" # noqa |
|
|
|
) |
|
|
|
get_ipython().system( |
|
|
|
"vimdiff producao/sequences.yaml dados/sequences.yaml" |
|
|
|
) |
|
|
|
from IPython import get_ipython |
|
|
|
|
|
|
|
ajustes = Path( |
|
|
|
f"/home/mazza/work/consulta_sapls/ajustes_pre_migracao/{sigla}.sql" |
|
|
|
).read_file() |
|
|
|
assert ajustes.count("RESSUSCITADOS") == 1 |
|
|
|
consulta_sapl = git.Repo(f"/home/mazza/work/consulta_sapls") |
|
|
|
consulta_sapl.git.add( |
|
|
|
f"/home/mazza/work/consulta_sapls/ajustes_pre_migracao/{sigla}.sql" |
|
|
|
) |
|
|
|
consulta_sapl.index.commit(f"Ajusta {sigla} (p migração corretiva)") |
|
|
|
ip = get_ipython() |
|
|
|
if ip: |
|
|
|
print(f"cd ~/migracao_sapl/repos/sapl_cm_{sigla}") |
|
|
|
ip.run_line_magic("cd", f"~/migracao_sapl/repos/sapl_cm_{sigla}") |
|
|
|
ip.system( |
|
|
|
"diff -rq producao dados | grep -v 'Only in dados' | grep -v 'Files producao/sequences.yaml and dados/sequences.yaml differ'" # noqa |
|
|
|
) |
|
|
|
ip.system("vimdiff producao/sequences.yaml dados/sequences.yaml") |
|
|
|
|
|
|
|
ajustes = Path( |
|
|
|
f"/home/mazza/work/consulta_sapls/ajustes_pre_migracao/{sigla}.sql" |
|
|
|
).read_file() |
|
|
|
assert ajustes.count("RESSUSCITADOS") <= 1 |
|
|
|
consulta_sapl = git.Repo(f"/home/mazza/work/consulta_sapls") |
|
|
|
consulta_sapl.git.add( |
|
|
|
f"/home/mazza/work/consulta_sapls/ajustes_pre_migracao/{sigla}.sql" |
|
|
|
) |
|
|
|
if consulta_sapl.git.diff("--cached"): |
|
|
|
consulta_sapl.index.commit( |
|
|
|
f"Ajusta {sigla} (p migração corretiva)" |
|
|
|
) |
|
|
|