用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語句步驟，使用參數傳遞上步驟的值