分库SQL脚本初始化存储过程

-- 选择其中一个数据库，创建存储过程 proc_update_schema_or_data，这里需要注意替换SCHEMA_NAME的条件。
CREATE PROCEDURE `proc_update_schema_or_data`(IN update_sql LONGTEXT)
BEGIN
		DECLARE _done  INT DEFAULT false;
        DECLARE dbx VARCHAR(128);              
		DECLARE cur_schema CURSOR FOR 
			SELECT SCHEMA_NAME FROM information_schema.SCHEMATA WHERE SCHEMA_NAME like 'db_%' ;
		DECLARE CONTINUE HANDLER FOR NOT found SET _done=true;
	  
		OPEN cur_schema;
		  db_loop:LOOP -- 声明循环开始
			FETCH cur_schema INTO dbx;
			-- 先判断done，这个时候done的值还是之前的循环的值，因此就会导致循环一次
			IF _done THEN LEAVE db_loop; 
			END IF;
			
			SET @full_sql = REPLACE(update_sql, '@db', CONCAT('`', dbx, '`'));
			-- SELECT @full_sql;
			PREPARE stmt_sql from @full_sql;
			EXECUTE stmt_sql;
			DEALLOCATE PREPARE stmt_sql;
		
			END LOOP db_loop;     
		CLOSE cur_schema;
	
END

-- 执行存储过程
CALL proc_update_schema_or_data('ALTER TABLE @db.`driver` DROP COLUMN `ver`;');