diff --git a/debit_notes_pdf_reader.py b/debit_notes_pdf_reader.py index de6cd33..8126095 100644 --- a/debit_notes_pdf_reader.py +++ b/debit_notes_pdf_reader.py @@ -376,6 +376,17 @@ def upsert_rows_sqlserver(rows: List[Dict[str, Any]], connection_string: str) -> has_cnpj_col = False try: + cur.execute( + "SELECT 1 FROM sys.columns " + "WHERE object_id = OBJECT_ID('dbo.TrfDocumento') AND name = 'CriadoEm'" + ) + if cur.fetchone() is None: + cur.execute( + "ALTER TABLE dbo.TrfDocumento " + "ADD CriadoEm DATETIME2 NOT NULL DEFAULT SYSUTCDATETIME()" + ) + cn.commit() + cur.execute( """ SELECT 1