kettle 迁移数据

导航

var totalCount = parseInt(parent_job.getVariable("TOTAL_COUNT"));

var pageSize = parseInt(parent_job.getVariable("PAGE_SIZE"));

var totalPage = parent_job.getVariable("TATAL_PAGE");

var currPage = parent_job.getVariable("CURR_PAGE");

if( totalPage == null || totalPage == undefined || totalPage == "")
{
totalPage = totalCount / pageSize;
if (totalCount % pageSize > 0) ++totalPage;// 如果有1001条，每页100条的话，应该分为1001/100 + 1页
parent_job.setVariable("TOTAL_PAGE",totalPage);
}
else
{
totalPage = parseInt(totalPage);
}

if( currPage == null || currPage == undefined || currPage == "")
{
currPage = 1;
}
else
{
currPage = parseInt(currPage);
}

if (currPage > totalPage )
{
false;
}
else
{
var start = (currPage - 1) * pageSize;
parent_job.setVariable("START_ROW",start);
parent_job.setVariable("CURR_PAGE",currPage + 1);

true;
}