table_attrs text,
primary key (queue_name, table_name),
- foreign key (queue_name) references pgq_node.node_info (queue_name),
+ foreign key (queue_name)
+ references pgq_node.node_info (queue_name)
+ on delete cascade,
check (dropped_ddl is null or merge_state = 'in-copy')
);
last_value int8 not null,
primary key (queue_name, seq_name),
- foreign key (queue_name) references pgq_node.node_info (queue_name)
+ foreign key (queue_name)
+ references pgq_node.node_info (queue_name)
+ on delete cascade
);
execute_file text not null,
execute_time timestamptz not null default now(),
execute_sql text not null,
- primary key (queue_name, execute_file)
+ primary key (queue_name, execute_file),
+ foreign key (queue_name)
+ references pgq_node.node_info (queue_name)
+ on delete cascade
);