mssql_script21.py 2 KB
import pyodbc

hil_sql = """
    create table interface_report
    (
       id bigint identity primary key,
       source nvarchar(64) not null,
       target nvarchar(64) not null,
       body nvarchar(max),
       response nvarchar(max),
       status bit default 1 not null,
       retry_times tinyint default 0 not null,
       duration smallint not null,
       create_time datetime not null
    );
    
    create table hil_compare_report_new
    (
       id bigint identity primary key,
       application_id nvarchar(64) not null,
       is_se bit default 1 not null,
       is_auto bit default 0 not null,
       is_pass bit default 0 not null,
       full_result nvarchar(max),
       field_result nvarchar(max),
       start_time datetime not null,
       end_time datetime not null,
    );
    
    create index hil_compare_report_new_start_time_index
        on hil_compare_report_new (start_time);
        
    create index hil_compare_report_new_application_id_index
        on hil_compare_report_new (application_id);
"""

afc_sql = """
    create table afc_compare_report_new
    (
       id bigint identity primary key,
       application_id nvarchar(64) not null,
       is_se bit default 1 not null,
       is_auto bit default 0 not null,
       is_pass bit default 0 not null,
       full_result nvarchar(max),
       field_result nvarchar(max),
       start_time datetime not null,
       end_time datetime not null,
    );
    
    create index afc_compare_report_new_start_time_index
        on afc_compare_report_new (start_time);
        
    create index afc_compare_report_new_application_id_index
        on afc_compare_report_new (application_id);
"""

hil_cnxn = pyodbc.connect('DRIVER={ODBC Driver 17 for SQL Server};', autocommit=True)

hil_cursor = hil_cnxn.cursor()
hil_cursor.execute(hil_sql)

hil_cursor.close()
hil_cnxn.close()

afc_cnxn = pyodbc.connect('DRIVER={ODBC Driver 17 for SQL Server};', autocommit=True)

afc_cursor = afc_cnxn.cursor()
afc_cursor.execute(afc_sql)

afc_cursor.close()
afc_cnxn.close()