中文字幕av专区_日韩电影在线播放_精品国产精品久久一区免费式_av在线免费观看网站

溫馨提示×

溫馨提示×

您好,登錄后才能下訂單哦!

密碼登錄×
登錄注冊×
其他方式登錄
點擊 登錄注冊 即表示同意《億速云用戶服務條款》

MySQL NDB如何進行批量更新100萬行數據

發布時間:2021-10-25 15:58:03 來源:億速云 閱讀:1100 作者:柒染 欄目:MySQL數據庫

本篇文章為大家展示了MySQL NDB如何進行批量更新100萬行數據,內容簡明扼要并且容易理解,絕對能使你眼前一亮,通過這篇文章的詳細介紹希望你能有所收獲。

生產NDB數據庫中的一張800多萬行的大表需要更新部分字段,為減少對數據庫性能的影響,編寫了一個存儲過程來實現:
1. 導出這張表的主鍵字段,數據量有100多萬條
select MSISDN from TEST where LastAccessTimeStamp=0
into outfile '/tmp/TEST_out.txt' fields terminated by ',' ;

2. 在其中一個SQL節點,創建兩張臨時表
--創建第一張臨時表,用于和生產數據庫的源表主鍵進行關聯,以更新部分字段
create table tmp_Subscribers_01(id int not null auto_increment primary key,MSISDN char(20)) engine=innodb;
--向第一張臨時表導入之前的導出數據
load data infile '/tmp/Subscribers_out.txt' into table tmp_Subscribers_01 fields terminated by ',' (MSISDN);
--創建第二張臨時表,用于記錄數據更新的進度
create table tmp_Subscribers_02(id int, MSISDN char(20),cdate datetime) engine=innodb;

3. 編寫數據更新的存儲過程
drop procedure proc_Subscribers_update;
delimiter $$
create procedure proc_Subscribers_update(IN v_fetch_cnt INT, IN v_sleep_secs INT)
begin
DECLARE v_count INT;
DECLARE v_times INT DEFAULT 1;
DECLARE v_max_value INT;
  /*compute the times that the loop runs*/
  select ceil(count(MSISDN)/v_fetch_cnt) into v_count from tmp_Subscribers_01;
  /*compute the maximum rows that have been already updated*/
  WHILE v_times < v_count DO
    select ifnull(max(id),0) into v_max_value from tmp_Subscribers_02;
    if v_max_value < v_fetch_cnt * v_count then
      SET v_times = 1 + floor(v_max_value/v_fetch_cnt);
      update TEST s,tmp_Subscribers_01 t set s.LastAccessTimeStamp=1420066800
      where s.MSISDN=t.MSISDN and t.id > v_max_value and t.id <= v_fetch_cnt * v_times;
      /*record the processing rows*/
      insert into tmp_Subscribers_02 select id, MSISDN, now() from tmp_Subscribers_01 where id = v_fetch_cnt * v_times;
      select concat('The job',' has already updated ', v_fetch_cnt * v_times, ' rows..') as Info;
      select sleep(v_sleep_secs);
    end if;
    commit;
  END WHILE;
  select concat('The job',' is ','finished!') as Info;
  commit;
end$$
delimiter ;

--執行存儲過程
--其中第一個傳入參數為每次更新的行數,第二個參數為每次更新后的休眠時間
call proc_Subscribers_update(10000, 2);

上述內容就是MySQL NDB如何進行批量更新100萬行數據,你們學到知識或技能了嗎?如果還想學到更多技能或者豐富自己的知識儲備,歡迎關注億速云行業資訊頻道。

向AI問一下細節

免責聲明:本站發布的內容(圖片、視頻和文字)以原創、轉載和分享為主,文章觀點不代表本網站立場,如果涉及侵權請聯系站長郵箱:is@yisu.com進行舉報,并提供相關證據,一經查實,將立刻刪除涉嫌侵權內容。

AI

泾川县| 永宁县| 山西省| 桃源县| 杭锦后旗| 沧州市| 北京市| 峨边| 宜宾县| 新丰县| 武邑县| 万盛区| 新绛县| 雷山县| 翁牛特旗| 玉龙| 吐鲁番市| 明光市| 牟定县| 达拉特旗| 准格尔旗| 额济纳旗| 磐安县| 湖南省| 梁平县| 茂名市| 佛冈县| 内黄县| 山东省| 淮滨县| 拜泉县| 西贡区| 玛多县| 盐亭县| 普陀区| 秦皇岛市| 锦屏县| 义马市| 宝鸡市| 长岛县| 台南市|