Так как таблицы и связи между ними заранее не известны то, чтобы удалить все связанные данные придется создавать динамические запросы. Для этого можно воспользоваться описанием связей foreign key
- primary key
получив его из information_schema.
SqlFiddle что-то ругается на пример в отличии от SSMS так что выкладываю пример здесь.
Для начала создадим несколько таблиц и наполним их данными:
create table TableOne
(
id int primary key
);
create table TableTwo
(
id int primary key,
tableOne_id int foreign key references TableOne(id)
);
create table TableThree
(
id int primary key,
tableTwo_id int foreign key references TableTwo(id)
);
create table TableFour
(
id int,
tableThree_id int foreign key references TableThree(id)
);
create table TableFive
(
id int,
tableOne_id int foreign key references TableOne(id)
)
insert into TableOne (id) values(1);
insert into TableOne (id) values(2);
insert into TableTwo (id, tableOne_id) values(1, 1);
insert into TableTwo (id, tableOne_id) values(2, 1);
insert into TableThree (id, tableTwo_id) values(3, 1);
insert into TableThree (id, tableTwo_id) values(4, 1);
insert into TableFour (id, tableThree_id) values(5, 3);
insert into TableFour (id, tableThree_id) values(6, 3);
insert into TableFive (id, tableOne_id) values(1, 2);
insert into TableFive (id, tableOne_id) values(2, 2);
Теперь создадим процедуру, которая внутри себя будет использовать рекурсивный запрос к метаданным для получения динамического запроса на удаления связанных строк:
CREATE PROCEDURE clear_table @table_name VARCHAR(max)
AS
BEGIN
DECLARE @DROP_QUERY varchar(max);
DECLARE QUERY_CURSOR CURSOR
LOCAL STATIC READ_ONLY FORWARD_ONLY
FOR
with fk (query, deleteQuery, master_table, detail_table, master_column_name, detail_column_name, ord)
as
(
select
cast('select * from ' + ctu.TABLE_NAME + ' where ' + dccu.COLUMN_NAME + ' in (select ' + mccu.COLUMN_NAME + ' from ' + mccu.TABLE_NAME + ')'as varchar(max)) as query,
cast('delete from ' + ctu.TABLE_NAME + ' where ' + dccu.COLUMN_NAME + ' in (select ' + mccu.COLUMN_NAME + ' from ' + mccu.TABLE_NAME + ')' as varchar(max)) deleteQuery,
mccu.TABLE_NAME master_table,
ctu.TABLE_NAME detail_table,
mccu.COLUMN_NAME master_column_name,
dccu.COLUMN_NAME detail_column_name,
1 ord
from INFORMATION_SCHEMA.CONSTRAINT_COLUMN_USAGE mccu
join INFORMATION_SCHEMA.REFERENTIAL_CONSTRAINTS rc on rc.UNIQUE_CONSTRAINT_NAME = mccu.CONSTRAINT_NAME
join INFORMATION_SCHEMA.CONSTRAINT_COLUMN_USAGE dccu on dccu.CONSTRAINT_NAME = rc.CONSTRAINT_NAME
join INFORMATION_SCHEMA.CONSTRAINT_TABLE_USAGE ctu on ctu.constraint_name = rc.CONSTRAINT_NAME
where mccu.table_name = @table_name
union all
select
cast('select * from ' + ctu.TABLE_NAME + ' where ' + dccu.COLUMN_NAME + ' in (select ' + mccu.COLUMN_NAME + ' from (' + fk.query + ') s )'as varchar(max)) as query,
cast('delete from ' + ctu.TABLE_NAME + ' where ' + dccu.COLUMN_NAME + ' in (select ' + mccu.COLUMN_NAME + ' from (' + fk.query + ') s )' as varchar(max)) deleteQuery,
mccu.TABLE_NAME master_table,
ctu.table_name detail_table,
mccu.COLUMN_NAME master_column_name,
dccu.COLUMN_NAME detail_column_name,
fk.ord + 1
from INFORMATION_SCHEMA.CONSTRAINT_COLUMN_USAGE mccu
join INFORMATION_SCHEMA.REFERENTIAL_CONSTRAINTS rc on rc.UNIQUE_CONSTRAINT_NAME = mccu.CONSTRAINT_NAME
join INFORMATION_SCHEMA.CONSTRAINT_COLUMN_USAGE dccu on dccu.CONSTRAINT_NAME = rc.CONSTRAINT_NAME
join INFORMATION_SCHEMA.CONSTRAINT_TABLE_USAGE ctu on ctu.constraint_name = rc.CONSTRAINT_NAME
join fk on fk.detail_table = mccu.table_name
)
select deleteQuery
from
(
select deleteQuery, ord
from fk
union all
select 'delete from ' + @table_name deleteQuery, 0 ord
) s
order by ord desc
OPEN QUERY_CURSOR
FETCH NEXT FROM QUERY_CURSOR INTO @DROP_QUERY
WHILE @@FETCH_STATUS = 0
BEGIN
EXEC(@DROP_QUERY)
FETCH NEXT FROM QUERY_CURSOR INTO @DROP_QUERY
END
CLOSE QUERY_CURSOR
DEALLOCATE QUERY_CURSOR
END;
Теперь попробуем с помощью нее удалить все данные из таблицы TableOne
. Как видно из кода выше на таблицу TableOne
ссылаются таблицы TableTwo
и TableFive
, а на таблицу TableTwo
ссылается таблица TableThree
и т.п. Но, благодаря использованию процедуры все связанные данные будут удалены:
exec clear_table 'TableOne'
Чтобы посмотреть какие запросы на удаление генерируются в процедуре можно отдельно выполнить рекурсивный запрос и посмотреть на результат его работы. В нашем случае для таблицы TableOne
будут сгенерированны и последовательно выполнены следующие запросы:
delete from TableFour where tableThree_id in (select id from (select * from TableThree where tableTwo_id in (select id from (select * from TableTwo where tableOne_id in (select id from TableOne)) s )) s )
delete from TableThree where tableTwo_id in (select id from (select * from TableTwo where tableOne_id in (select id from TableOne)) s )
delete from TableTwo where tableOne_id in (select id from TableOne)
delete from TableFive where tableOne_id in (select id from TableOne)
delete from TableOne
UPDATE
Чтобы удалить данные только из той таблицы, имя которой нам передано в параметрах, нужно сначала удалить все foreign key
которые смотрят на ее primary key
, а затем уже стереть из нее данные.
Для этого можно воспользоваться той же метаинформацией и сгенерировать запросы на удаление foreign key
после чего уже удалить данные из самой таблицы:
CREATE PROCEDURE clear_table2 @table_name VARCHAR(max)
AS
BEGIN
DECLARE @DROP_QUERY varchar(max);
DECLARE QUERY_CURSOR CURSOR
LOCAL STATIC READ_ONLY FORWARD_ONLY
FOR
select 'alter table ' + ctu.table_name + ' drop constraint ' + rc.CONSTRAINT_NAME query
from INFORMATION_SCHEMA.CONSTRAINT_COLUMN_USAGE mccu
join INFORMATION_SCHEMA.REFERENTIAL_CONSTRAINTS rc on rc.UNIQUE_CONSTRAINT_NAME = mccu.CONSTRAINT_NAME
join INFORMATION_SCHEMA.CONSTRAINT_TABLE_USAGE ctu on ctu.constraint_name = rc.CONSTRAINT_NAME
where mccu.table_name = @table_name
union all
select 'delete from ' + @table_name query
OPEN QUERY_CURSOR
FETCH NEXT FROM QUERY_CURSOR INTO @DROP_QUERY
WHILE @@FETCH_STATUS = 0
BEGIN
EXEC(@DROP_QUERY)
FETCH NEXT FROM QUERY_CURSOR INTO @DROP_QUERY
END
CLOSE QUERY_CURSOR
DEALLOCATE QUERY_CURSOR
END;
Если вызвать ее с параметром TableOne
то она сгенерирует и выполнит следующие запросы (имя констрейнтов может отличаться):
alter table TableFive drop constraint FK__TableFive__table__004002F9
alter table TableTwo drop constraint FK__TableTwo__tableO__7993056A
delete from TableOne
UPDATE 2
Чтобы уже сильно не менять процедуру доработаем ее так, как есть, добавив возможность указывать фильтр влияющий на удаляемые данные. Для этого добавим к процедуре еще один параметр и немного модифицируем способ генерации запросов:
CREATE PROCEDURE clear_table3 @table_name VARCHAR(max), @predicate varchar(max)
AS
BEGIN
DECLARE @DROP_QUERY varchar(max);
DECLARE QUERY_CURSOR CURSOR
LOCAL STATIC READ_ONLY FORWARD_ONLY
FOR
with fk (query, deleteQuery, master_table, detail_table, master_column_name, detail_column_name, ord)
as
(
select
cast('select * from ' + ctu.TABLE_NAME + ' where ' + dccu.COLUMN_NAME + ' in (select ' + mccu.COLUMN_NAME + ' from ' + mccu.TABLE_NAME + ' ' + @predicate + ')'as varchar(max)) as query,
cast('delete from ' + ctu.TABLE_NAME + ' where ' + dccu.COLUMN_NAME + ' in (select ' + mccu.COLUMN_NAME + ' from ' + mccu.TABLE_NAME + ' ' + @predicate + ')' as varchar(max)) deleteQuery,
mccu.TABLE_NAME master_table,
ctu.TABLE_NAME detail_table,
mccu.COLUMN_NAME master_column_name,
dccu.COLUMN_NAME detail_column_name,
1 ord
from INFORMATION_SCHEMA.CONSTRAINT_COLUMN_USAGE mccu
join INFORMATION_SCHEMA.REFERENTIAL_CONSTRAINTS rc on rc.UNIQUE_CONSTRAINT_NAME = mccu.CONSTRAINT_NAME
join INFORMATION_SCHEMA.CONSTRAINT_COLUMN_USAGE dccu on dccu.CONSTRAINT_NAME = rc.CONSTRAINT_NAME
join INFORMATION_SCHEMA.CONSTRAINT_TABLE_USAGE ctu on ctu.constraint_name = rc.CONSTRAINT_NAME
where mccu.table_name = @table_name
union all
select
cast('select * from ' + ctu.TABLE_NAME + ' where ' + dccu.COLUMN_NAME + ' in (select ' + mccu.COLUMN_NAME + ' from (' + fk.query + ') s )'as varchar(max)) as query,
cast('delete from ' + ctu.TABLE_NAME + ' where ' + dccu.COLUMN_NAME + ' in (select ' + mccu.COLUMN_NAME + ' from (' + fk.query + ') s )' as varchar(max)) deleteQuery,
mccu.TABLE_NAME master_table,
ctu.table_name detail_table,
mccu.COLUMN_NAME master_column_name,
dccu.COLUMN_NAME detail_column_name,
fk.ord + 1
from INFORMATION_SCHEMA.CONSTRAINT_COLUMN_USAGE mccu
join INFORMATION_SCHEMA.REFERENTIAL_CONSTRAINTS rc on rc.UNIQUE_CONSTRAINT_NAME = mccu.CONSTRAINT_NAME
join INFORMATION_SCHEMA.CONSTRAINT_COLUMN_USAGE dccu on dccu.CONSTRAINT_NAME = rc.CONSTRAINT_NAME
join INFORMATION_SCHEMA.CONSTRAINT_TABLE_USAGE ctu on ctu.constraint_name = rc.CONSTRAINT_NAME
join fk on fk.detail_table = mccu.table_name
)
select deleteQuery
from
(
select deleteQuery, ord
from fk
union all
select 'delete from ' + @table_name + ' ' + @predicate deleteQuery, 0 ord
) s
order by ord desc
OPEN QUERY_CURSOR
FETCH NEXT FROM QUERY_CURSOR INTO @DROP_QUERY
WHILE @@FETCH_STATUS = 0
BEGIN
EXEC(@DROP_QUERY)
FETCH NEXT FROM QUERY_CURSOR INTO @DROP_QUERY
END
CLOSE QUERY_CURSOR
DEALLOCATE QUERY_CURSOR
END;
Если вызвать эту процедур, например, так:
exec clear_table3 'TableOne', 'where id != 1'
То сформируются такие запросы:
delete from TableFour where tableThree_id in (select id from (select * from TableThree where tableTwo_id in (select id from (select * from TableTwo where tableOne_id in (select id from TableOne where id != 1)) s )) s )
delete from TableThree where tableTwo_id in (select id from (select * from TableTwo where tableOne_id in (select id from TableOne where id != 1)) s )
delete from TableTwo where tableOne_id in (select id from TableOne where id != 1)
delete from TableFive where tableOne_id in (select id from TableOne where id != 1)
delete from TableOne where id != 1
Которые удалят только то, что нам нужно.