将数据复制到另一个数据库后删除

Question

我有一个存储过程，其内容如下：

-- --------------------------------------------------------------------------------
-- Routine DDL
-- Note: comments before and after the routine body will not be stored by the server
-- --------------------------------------------------------------------------------
DELIMITER $$

CREATE DEFINER=`MailMe`@`%` PROCEDURE `sp_archivev3`()
BEGIN

INSERT INTO 
     send.sgev3_archive(a_bi,
                        b_vc,
                        c_int,
                        d_int,
                        e_vc,
                        f_vc,
                        g_vc,
                        h_vc,
                        i_dt,
                        j_vc,
                        k_vc,
                        l_vc,
                        m_dt,
                        n_vch,
                        o_bit)
SELECT     a_bi,
           b_vc,
           c_int,
           d_int,
           e_vc,
           f_vc,
           g_vc,
           h_vc,
           i_dt,
           j_vc,
           k_vc,
           l_vc,
           m_dt,
           n_vch,
           o_bit

FROM   send.sgev3

WHERE m_dt BETWEEN  '2014-06-09' AND CURDATE();


END

因为，我的查询是将记录从send.sgev3 插入到send.sgev3_archive。我还想做一件事。在选择 send.sgev3 表中的记录并将其插入send.sgev3_archive 后，我想删除它们。我应该在上面的代码中的 SELECT 查询下面写 DELETE 查询吗？只是想确认一下，因为我不想弄乱我的真实数据并在不复制的情况下意外删除任何记录。请指教。

Answer 1

没错。包括一个DELETE 声明

DELETE FROM   send.sgev3
WHERE m_dt BETWEEN  '2014-06-09' AND CURDATE();

为了更确定INSERT 确实在DELETE 调用之前完成；将INSERT 和DELETE 包装在Transaction Block 中

START TRANSACTION;
INSERT INTO send.sgev3_archive ...
SELECT ... FROM send.sgev3
COMMIT;

您还可以使用exit handler in stored procedure 处理您的过程和ROLLBACK 整个事务中的错误情况。下面的帖子已经展示了一种方法。看看吧。

How can I use transactions in my MySQL stored procedure?

MySQL Rollback in transaction

编辑：

为什么需要交易？我不能像我一样继续前进吗 我的问题中提到了？

而不是向你解释原因；让我们给你看一个例子（很像你的场景）

假设您有一个名为parent 的表声明为

create table parent(id int not null auto_increment primary key,
`name` varchar(10),city varchar(10));

向其中插入一些记录

insert into parent(`name`,city) values('sfsdfd','sdfsdfdf'),('sfsdfd','sdfsdfdf'),('sfsdfd',null)

现在，您有另一个名为child 的表定义如下（注意最后一列有not null 约束）

create table child(id int not null auto_increment primary key,
`name` varchar(10),city varchar(10) not null) 

现在执行以下两个语句（您当前正在执行的操作）

insert into child(`name`,city) select * from parent;
delete from parent;

结果：INSERT 将因child 表中的not null 约束而失败，但delete 将成功。

为了避免这种确切的情况，您需要Transaction。因此，如果 INSERT 失败，您根本不会选择 delete。

关于如何在事务中处理此问题的伪代码

start transaction

insert into child(`name`,city) select * from parent;

if(ERROR)
rollback
exit from stored proc

else
commit
delete from parent;

旁注：exit from stored proc 可以使用LEAVE 实现