用Mysql存储过程迁移数据-MySQL-Tutorial-php.cn

用Mysql存储过程迁移数据

WBOY

Freigeben： 2016-06-07 15:40:22

Original

1223 Leute haben es durchsucht

今天有一个需求是迁移tag的数据，之前写的存储过程到现在都忘记了，从新再写一个，并在这里纪录一下，防止自己下次还忘记首先是修改一下Mysql的配置大家可以看下这是我们老大的测试结果 SET GLOBAL max_allowed_packet=1024*1024*1024;SET GLOBAL key_buf

今天有一个需求是迁移tag的数据，之前写的存储过程到现在都忘记了，从新再写一个，并在这里纪录一下，防止自己下次还忘记

首先是修改一下Mysql的配置

大家可以看下

这是我们老大的测试结果

<code>SET GLOBAL max_allowed_packet=1024*1024*1024;
SET GLOBAL key_buffer_size=1024*1024*1024;
SET GLOBAL tmp_table_size = 512*1024*1024;

SET SESSION myisam_sort_buffer_size = 512*1024*1024;
SET SESSION read_buffer_size = 128*1024*1024;
SET GLOBAL myisam_max_sort_file_size = 100*1024*1024*1024;</code>

Nach dem Login kopieren

下面选择数据库

<code>use db_database;</code>

Nach dem Login kopieren

如果有存储过程，先删除存储过程，（官方的中文翻译叫存储程序，感觉诡异）

<code>drop procedure 存储过程名称;</code>

Nach dem Login kopieren

好了，下面重头戏,把delimiter 改成 // 为开始和结束，并创建存储过程

<code>delimiter //
CREATE PROCEDURE 存储过程的名称();
BEGIN</code>

Nach dem Login kopieren

好了下面我们来定义变量，这个大家都能看懂吧！

<code>DECLARE rid INT;
DECLARE rtags VARCHAR(225);
DECLARE lasttime datetime;
DECLARE firsttime datetime;
DECLARE done, duplicate, expcount INT DEFAULT 0;</code>

Nach dem Login kopieren

下面这个比较特殊，是定义游标（或者叫指针，但是官网上面叫光标），这个需求要获取id，来操作后面得数据

<code>DECLARE cur CURSOR FOR SELECT
id
FROM 表名
ORDER BY id ASC;</code>

Nach dem Login kopieren

然后设置各种状态下的设置的变量的值

Mysql各种状态都在这里了

当sql错误状态是02000的时候 done这个变量为1

<code>DECLARE CONTINUE HANDLER FOR SQLSTATE '02000' SET done = 1;</code>

Nach dem Login kopieren

同上

<code>DECLARE CONTINUE HANDLER FOR SQLSTATE '23000' SET duplicate = 1;</code>

Nach dem Login kopieren

设置变量

<code>SET lasttime = now();
SET firsttime = now();</code>

Nach dem Login kopieren

下面我们来遍历游标

打开游标

<code>OPEN cur;</code>

Nach dem Login kopieren

遍历

<code>REPEAT
FETCH cur INTO rid;

if not done then

SET duplicate = 0;
UPDATE 另一张表
SET keywords = 数据是啥
WHERE id = rid;</code>

Nach dem Login kopieren

好了，上面就是写你的sql，下面是100条的时候，打印出来执行时间和条数

<code>SET expcount = expcount + 1;
IF expcount % 100 = 0 then
  SELECT expcount,now() - lasttime;
  SET lasttime = now();
END IF;</code>

Nach dem Login kopieren

直到没有数据，遍历结束

<code>end if;

UNTIL done END REPEAT;</code>

Nach dem Login kopieren

关闭游标

<code>CLOSE cur;</code>

Nach dem Login kopieren

最后结束存储过程

<code>END;
//
delimiter ;</code>

Nach dem Login kopieren

以上就是做的存储过程的数据迁移的部分，这个写的比较简单，不过以后有复杂的可以直接修改修改就可以用了！