mysql存储过程 实现全量同步数据并自动创建表
Posted 健康平安的活着
tags:
篇首语:本文由小常识网(cha138.com)小编为大家整理,主要介绍了mysql存储过程 实现全量同步数据并自动创建表相关的知识,希望对你有一定的参考价值。
一 存储过程
老规矩,话不多说,上代码!
1.存储过程
drop PROCEDURE if EXISTS p_create_table;
CREATE PROCEDURE p_create_table (
IN pa_table_name VARCHAR (30) # 表名
)
BEGIN
DECLARE n int(10);
set @currMonth=MONTH(CURDATE());
set @a=@currMonth;
if @a=1 or @a=2 or @a=3 then set n=123;
elseif @a=4 or @a=5 or @a=6 then set n=456;
elseif @a=7 or @a=8 or @a=9 then set n=789;
else set n=101112;
end if;
set @tName=concat(pa_table_name,'_',n); # 利用concat拼接字符串函数,将复制表的sql赋值到变量sql_create_table
select @tName;
set @sql_create_table = concat('CREATE TABLE ',@tName," SELECT * FROM iip_acc_warn_information WHERE 1=1;");
# 预处理建表
PREPARE sql_create_table FROM @sql_create_table;
# 执行sql
EXECUTE sql_create_table;
END
2.调用
CALL p_create_table ("iip_acc_warn_information")
3.效果
查看数量
以上是关于mysql存储过程 实现全量同步数据并自动创建表的主要内容,如果未能解决你的问题,请参考以下文章
通过Logstash全量和增量同步Mysql一对多关系到Elasticsearch
Flink 实战系列Flink CDC 实时同步 Mysql 全量加增量数据到 Hudi