检测数据库迁移准确性

游戏运营中经常遇到数据库迁移的情况。比如：合服前的库迁移。为了节省成本整合库迁移。甚至换云服务商引起的库迁移。其实运维本身有责任和义务保证迁移过程中库数据的准确性和完整性。因为对服务器而言。数据实在是太重要。批量迁移过程中总担忧出问题。数据会不会丢失。如何减少这种意外发生。如何做到双重保障？这样心里更加有把握。

双重保障思路是：迁移前批量执行库中每个表的条数输出到文本中。等运维迁移后。再批量执行库中每个表的条数输出到文本中。然后使用Beyond Compare 对比工具。因为输出顺序一致。文本前后完全相同。安全性大大提高。也可以简单的方式输出每个库表的总条数。相同也可以保证准确性。

Shell脚本：CheckDbWork.sh

#!/bin/bash

myvar=0
while [ $myvar -le 19 ]
do
echo $myvar
mysql -uadmin -p'Pa$$w0' -h17.31.25.133 -P 3306 -Dtafang_s$(($myvar+6000)) <CheckDbWorkSql.sql
myvar=$(( $myvar + 1 ))
done

myvar=20
while [ $myvar -le 39 ]
do
echo $myvar
mysql -uadmin -p'Pa$$w0' -h17.31.25.134 -P 3306 -Dtafang_s$(($myvar+6000)) <CheckDbWorkSql.sql
myvar=$(( $myvar + 1 ))
done

Mysql脚本：CheckDbWork.sql

SET CHARACTER_SET_CLIENT=utf8;
SET CHARACTER_SET_CONNECTION=utf8;

DELIMITER $$

DROP PROCEDURE IF EXISTS `CheckDbWorkSql`$$

CREATE PROCEDURE `CheckDbWorkSql`()
BEGIN
    DECLARE i INT DEFAULT 0;
    DECLARE tempCount INT DEFAULT 0;

    DECLARE dbSql VARCHAR(512) DEFAULT '';
    DECLARE dbNameSql VARCHAR(512) DEFAULT '';
    DECLARE checkDbSql VARCHAR(512) DEFAULT '';

    DECLARE tableName VARCHAR(128) DEFAULT '';
    DECLARE checkSrceSql VARCHAR(1024) DEFAULT '';
    DECLARE runSrceSql VARCHAR(1024) DEFAULT '';
    DECLARE calTableSql VARCHAR(1024) DEFAULT '';

    DECLARE tempAllCount INT DEFAULT 0;
    DECLARE tempTableCount INT DEFAULT 0;

    -- 获取当前数据库
    prepare stmt from "SELECT database() INTO @dbSql";
    EXECUTE stmt;

    -- 循环导入数据
    SET @checkSql=CONCAT("SELECT COUNT(1) into @tempCount FROM information_schema.TABLES WHERE TABLE_SCHEMA = '",@dbSql,"'");
    prepare stmt from @checkSql;
    EXECUTE stmt;

    SET @checkSrceSql=CONCAT("SELECT table_name into @tableName FROM information_schema.TABLES WHERE TABLE_SCHEMA = '",@dbSql,"' LIMIT [##],1");
    WHILE i < @tempCount DO
        SET @runSrceSql=REPLACE(@checkSrceSql,'[##]',i);
        prepare stmt from @runSrceSql;
        EXECUTE stmt;

        SET @calTableSql=CONCAT("SELECT COUNT(1) into @tempTableCount FROM ",@tableName);
        prepare stmt from @calTableSql;
        EXECUTE stmt;
        SET i=i+1;
        SET tempAllCount=tempAllCount+@tempTableCount;
        -- SELECT @tempTableCount;
    END WHILE;

    SELECT @dbSql,tempAllCount;

END$$

DELIMITER $$

CALL CheckDbWorkSql();