Skip to content

Commit

Permalink
Better error logging and handling
Browse files Browse the repository at this point in the history
  • Loading branch information
t3eHawk committed Dec 11, 2022
1 parent 037aec4 commit 7af8ba5
Show file tree
Hide file tree
Showing 6 changed files with 245 additions and 252 deletions.
96 changes: 49 additions & 47 deletions db/oracle.sql
Original file line number Diff line number Diff line change
Expand Up @@ -55,19 +55,19 @@ create table pd_run_history (
start_date date,
end_date date,
status varchar2(1 char),
server varchar2(25 char),
user varchar2(25 char),
server_name varchar2(25 char),
user_name varchar2(25 char),
pid number(*, 0),
trigger_id number(*, 0),
error_list clob,
rerun_id number(*, 0),
rerun_seqno number(*, 0),
rerun_times number(*, 0),
rerun_now varchar2(1 char),
rerun_done varchar2(1 char),
trigger_id number(*, 0),
data_dump blob,
file_log varchar2(25 char),
text_log clob,
text_error clob,
data_dump blob,
updated date,
constraint pd_run_history_pk primary key (id)
);
Expand Down Expand Up @@ -95,20 +95,21 @@ end;
/

create table pd_task_history (
id number(*, 0),
job_id number(*, 0),
run_id number(*, 0),
task_name varchar2(30 char),
task_date date,
start_date date,
end_date date,
status varchar2(1 char),
records_read number(*, 0),
records_written number(*, 0),
records_error number(*, 0),
result_value number(*, 0),
result_long varchar2(4000 char),
updated date,
id number(*, 0),
job_id number(*, 0),
run_id number(*, 0),
task_name varchar2(30 char),
task_date date,
start_date date,
end_date date,
status varchar2(1 char),
records_read number(*, 0),
records_written number(*, 0),
records_processed number(*, 0),
records_error number(*, 0),
result_value number(*, 0),
result_long varchar2(4000 char),
updated date,
constraint pd_task_history_pk primary key (id)
);

Expand All @@ -126,25 +127,26 @@ end;
/

create table pd_step_history (
id number(*, 0),
job_id number(*, 0),
run_id number(*, 0),
task_id number(*, 0),
step_name varchar2(30 char),
step_type varchar2(3 char),
step_a varchar2(30 char),
step_b varchar2(30 char),
step_c varchar2(30 char),
step_date date,
start_date date,
end_date date,
status varchar2(1 char),
records_read number(*, 0),
records_written number(*, 0),
records_error number(*, 0),
result_value number(*, 0),
result_long varchar2(4000 char),
updated date,
id number(*, 0),
job_id number(*, 0),
run_id number(*, 0),
task_id number(*, 0),
step_name varchar2(30 char),
step_type varchar2(3 char),
step_a varchar2(30 char),
step_b varchar2(30 char),
step_c varchar2(30 char),
step_date date,
start_date date,
end_date date,
status varchar2(1 char),
records_read number(*, 0),
records_written number(*, 0),
records_processed number(*, 0),
records_error number(*, 0),
result_value number(*, 0),
result_long varchar2(4000 char),
updated date,
constraint pd_step_history_pk primary key (id)
);

Expand Down Expand Up @@ -223,15 +225,15 @@ end;
/

create table pd_components (
id varchar2(100 char),
server varchar2(100 char),
user varchar2(100 char),
pid number(*, 0),
url varchar2(100 char),
debug char(1 char),
start_date date,
stop_date date,
status varchar2(1 char),
id varchar2(100 char),
server_name varchar2(100 char),
user_name varchar2(100 char),
pid number(*, 0),
url varchar2(100 char),
debug char(1 char),
start_date date,
stop_date date,
status varchar2(1 char),
constraint pd_components_pk primary key (id)
);

Expand Down
96 changes: 49 additions & 47 deletions db/sqlite.sql
Original file line number Diff line number Diff line change
Expand Up @@ -41,19 +41,19 @@ create table pd_run_history (
start_date text,
end_date text,
status text,
server text,
user text,
server_name text,
user_name text,
pid integer,
trigger_id integer,
error_list text,
rerun_id integer,
rerun_seqno integer,
rerun_times integer,
rerun_now text,
rerun_done text,
trigger_id integer,
data_dump blob,
file_log text,
text_log text,
text_error text,
data_dump blob,
updated text
);

Expand All @@ -67,42 +67,44 @@ create index pd_run_history_status_ix
on pd_run_history (status);

create table pd_task_history (
id integer primary key autoincrement,
job_id integer,
run_id integer,
task_name text,
task_date text,
start_date text,
end_date text,
status text,
records_read integer,
records_written integer,
records_error integer,
result_value integer,
result_long integer,
updated text
id integer primary key autoincrement,
job_id integer,
run_id integer,
task_name text,
task_date text,
start_date text,
end_date text,
status text,
records_read integer,
records_written integer,
records_processed integer,
records_error integer,
result_value integer,
result_long text,
updated text
);

create table pd_step_history (
id integer primary key autoincrement,
job_id integer,
run_id integer,
task_id integer,
step_name text,
step_type text,
step_a text,
step_b text,
step_c text,
step_date text,
start_date text,
end_date text,
status text,
records_read integer,
records_written integer,
records_error integer,
result_value integer,
result_long text,
updated text
id integer primary key autoincrement,
job_id integer,
run_id integer,
task_id integer,
step_name text,
step_type text,
step_a text,
step_b text,
step_c text,
step_date text,
start_date text,
end_date text,
status text,
records_read integer,
records_written integer,
records_processed integer,
records_error integer,
result_value integer,
result_long text,
updated text
);

create table pd_file_log (
Expand Down Expand Up @@ -139,15 +141,15 @@ create table pd_sql_log (
);

create table pd_components (
id text primary key,
server text,
user text,
pid integer,
url text,
debug text,
start_date text,
stop_date text,
status text
id text primary key,
server_name text,
user_name text,
pid integer,
url text,
debug text,
start_date text,
stop_date text,
status text
);

insert into pd_components (id) values ('SCHEDULER');
Expand Down
Loading

0 comments on commit 7af8ba5

Please sign in to comment.