2011-01-06 3 views
0

Я создал хранимую процедуру для удаления данных из нескольких таблиц. моя работа потока следующим образомхранимая процедура + mysql вопрос

Я использую MySQL 5.0 и работает на Linux

зависимостей таблицы следующим образом

таблицы C в зависимости от таблицы В таблицу В зависимости от таблице А,

Я хочу для удаления записи в таблице A и удаления всех связанных записей в таблицах B и C

1 - удалить все данные из таблиц подробностей (C) (с хранимой процедурой sp_delete_from_C)

2 - удалить данные, относящиеся к немедленной дочерней таблицы (B) (с хранимой процедурой sp_delete_from_B)

3 - удаление основной таблицы (A) (с хранимой процедурой sp_delete_from_A)

Я написал следующую процедуру

CREATE PROCEDURE sp_A_rollback(IN aId INT UNSIGNED) 
READS SQL DATA 
BEGIN 
DECLARE b_id INT DEFAULT 0; 

DECLARE cur_1 CURSOR FOR SELECT id FROM b where a_id=aId; 

OPEN cur_1; 
read_loop: LOOP 
    FETCH cur_1 INTO a_id; 
    CALL sp_delete_from_C(b_id); 
END LOOP; 
CLOSE cur_1; 

CALL sp_delete_from_B(aId); 
CALL sp_delete_from_A(aId); 


END // 

Мой вопрос,

Если я запустить эти процедуры индивидуально работает

, но если вы запустите sp_A_rollback, то выполните только «sp_delete_from_C»

У меня нет идеи, почему он не вызывает другие 2 sps. Я новичок в хранимых процедурах mysql. пожалуйста, может кто-то помочь мне

заранее спасибо

Sameera

ответ

2

Я понятия не имею, почему вы используете курсоры - все, что вам нужно что-то вроде следующего:

drop procedure if exists cascade_delete_tableA; 
delimiter # 

create procedure cascade_delete_tableA 
(
in p_id int unsigned 
) 
begin 

delete from tableC where a_id = p_id; 
delete from tableB where a_id = p_id; 
delete from tableA where id = p_id; 

end# 

delimiter ; 

звонка хранимую процедуру из вашего кода приложения, завернутого в транзакцию.

EDIT

Вы должны использовать объединение, чтобы удалить строки из вашего tableC. Вот более подробный пример для изучения http://pastie.org/1435521. Кроме того, ваш цикл курсора не извлекается в правильную переменную, поэтому он не работает в текущей форме. Я бы порекомендовал вам изучить следующее ...

-- TABLES 

drop table if exists customers; 
create table customers 
(
cust_id smallint unsigned not null auto_increment primary key, 
name varchar(255) not null 
) 
engine=innodb; 

drop table if exists orders; 
create table orders 
(
order_id int unsigned not null auto_increment primary key, 
cust_id smallint unsigned not null 
) 
engine=innodb; 

drop table if exists order_items; 
create table order_items 
(
order_id int unsigned not null, 
prod_id smallint unsigned not null, 
primary key (order_id, prod_id) 
) 
engine=innodb; 

-- STORED PROCS 

drop procedure if exists cascade_delete_customer; 
delimiter # 

create procedure cascade_delete_customer 
(
in p_cust_id smallint unsigned 
) 
begin 

declare rows int unsigned default 0; 

-- delete order items 

delete oi from order_items oi 
inner join orders o on o.order_id = oi.order_id and o.cust_id = p_cust_id; 

set rows = row_count(); 

-- delete orders 

delete from orders where cust_id = p_cust_id; 

set rows = rows + row_count(); 

-- delete customer 

delete from customers where cust_id = p_cust_id; 

select rows + row_count() as rows; 

end# 

delimiter ; 

-- TEST DATA 

insert into customers (name) values ('c1'),('c2'),('c3'),('c4'); 

insert into orders (cust_id) values (1),(2),(3),(1),(1),(3),(2),(4); 

insert into order_items (order_id, prod_id) values 
(1,1),(1,2),(1,3), 
(2,5), 
(3,2),(3,5),(3,8), 
(4,1),(4,4), 
(5,2),(5,7), 
(6,4),(6,8),(6,9), 
(7,5), 
(8,3),(8,4),(8,5),(8,6); 

-- TESTING 

/* 

select * from customers where cust_id = 1; 

select * from orders where cust_id = 1; 

select * from order_items oi 
inner join orders o on oi.order_id = o.order_id and o.cust_id = 1; 

call cascade_delete_customer(1); 

*/ 
+0

Hi f00, спасибо за ответ. Я использую курсоры здесь, потому что для удаления из таблицы C у меня есть только ключ таблицы B. Так как мне нужен цикл, я использую курсор. и в реальном renario я должен использовать другие хранимые процедуры вместо прямых операторов удаления (потому что есть некоторые логики, и эти процедуры уже реализованы). поэтому я должен вызвать другие sps внутри этого SP. любые мысли, еще раз спасибо за ответ – sameera207

+0

, см. раздел EDIT в моем ответе выше :) –

Смежные вопросы