用kettle从mysql中使用存储过程读取数据写入到sqlserver数据库

Posted 漂泊雪狼的博客

tags:

篇首语:本文由小常识网(cha138.com)小编为大家整理,主要介绍了用kettle从mysql中使用存储过程读取数据写入到sqlserver数据库相关的知识,希望对你有一定的参考价值。

1、mysql存储过程,可以实现动态表读取,满足较为复杂的业务逻辑

DROP PROCEDURE if exists p_get_car_trace;

delimiter //
CREATE PROCEDURE p_get_car_trace()
begin

declare var_sql varchar(800);
declare var_tabe_name varchar(50);
set var_tabe_name = \'geom1\';
set var_sql = concat_ws(\' \', \'select id,AsText(geo) geo from \', var_tabe_name);
set @sql = var_sql;
PREPARE s1 from @sql; 
EXECUTE s1; 
deallocate prepare s1;

end //
delimiter ;

2、sql server存储过程,使用执行sql语句的脚步步骤,实现数据的逐行调用

create proc p_ins_test
(@id int,
@geo nvarchar(max)
)
as
begin
insert into t_test(id,geo)
values(@id,@geo);
end

3、抽取过程流程图:

表输入:

 

 执行sql语句步骤,使用参数传递上步骤的值

 

以上是关于用kettle从mysql中使用存储过程读取数据写入到sqlserver数据库的主要内容,如果未能解决你的问题,请参考以下文章

请问如何从数据库中读取一个存储过程并把查询结果生成一个xml文件(c#)

kettle庖丁解牛第28篇之oracle数据迁移到mysql库

kettle从oracle向mysql迁移大数据量时报错,求教

kettle中mongodb查询语句怎么写

怎么写存储过程,向数据库中批量插入数据?

实战使用 Kettle 工具将 mysql 数据增量导入到 MongoDB 中