自定义datastage阶段

今天药忘吃喽~ 2022-08-18 03:21 142阅读 0赞

1.  新建两个表定义，用于阶段的输入（InTableDef）输出（OutTableDef）。

![Center][]

（1）.InTableDef的定义如下（输入字段为：inID）：

![Center 1][]

![Center 2][]

（2）.OutTableDef的定义如下(输出字段为vaild)：

![Center 3][]

![Center 4][]

1.  创建一个新的buildstage

![Center 5][]

1.  编辑阶段常规属性（命名阶段的名称为ID\_VER）：

![Center 6][]

1.  编辑阶段构建\->接口\->输入属性（表名为：选择我们刚刚新建的表定义）

![Center 7][]

1.  编辑阶段构建\->接口\->输出属性（表名为：选择我们刚刚新建的表定义）

![Center 8][]

1.  编辑阶段构建\->接口\->传输属性

![Center 9][]

1.  编辑阶段构建\->逻辑\->定义属性（也可以在 每条记录 里面直接定义）

![Center 10][]

1.  编辑阶段构建\->逻辑\->每条记录属性（在这里编写功能代码，这里是身份证有效性的验证代码，来源IBM官网）

![Center 11][]

源代码：来源IBM官网

APT\_StringaddressNumber\[\] =\{"11","22","35","44","53","12","23","36","45","54","13","31","37","46","61","14","32","41","50","62","15","33","42","51","63","21","34","43","52","64","65","71","81","82","91"\};

intiWeight\[\]=\{7, 9, 10, 5, 8, 4, 2, 1, 6, 3, 7, 9, 10, 5, 8, 4, 2\};

staticchar sVerCode\[\]="10X98765432";

boolbResult;

bResult=true;

boolb\_IsLeapYear=false;

int Days\[12\]=\{31, 28, 31, 30, 31, 30, 31, 31, 30, 31, 30, 31\};

inti,length;

intiYear;

intiMonth;

intiDay;

APT\_StringID;

APT\_StringIdtemp;

intiS = 0;

intiY;

ID= InRec.inID;

ID.trimWhitespace();

length= ID.length();

//lengthverify

if(length!= 15 && length != 18)

bResult= false;

else

//provinceverify

for(i = 0; i<= 34; i++)

if(ID.substring(0,2) == addressNumber\[i\])

break;

elseif (i == 34)

bResult= false;

if(bResult)

//Year,Month,Dayverify

intiYear = atoi(ID.substring(6, 4).data());

intiMonth = atoi(ID.substring(10, 2).data());

intiDay = atoi(ID.substring(12, 2).data());

if(iMonth<1|| iMonth>12)

bResult= false;

else

if(iYear%4== 0)

b\_IsLeapYear= true;

if(!(iYear%100==0 && iYear%400==0)) b\_IsLeapYear=false;

if(b\_IsLeapYear)

Days\[1\]=29;

else

Days\[1\]=28;

if(iDay<0 || iDay>Days\[iMonth-1\])

bResult= false;

else

//verifycheck code

if(ID.length()!= 17)

for(i=0;i<17;i++)

iS+= (int)(ID\[i\]-'0') \* iWeight\[i\];

intiY = iS%11;

if(sVerCode\[iY\]!= ID\[17\])

bResult = false;

if(bResult)

vaild= "TRUE";

else

vaild= "FALSE";

1.  编写完成后，点击下方的生成后，会弹出日志反馈是否成功，不成功继续调试。
2.  实例验证stage的正确性：

![Center 12][]

输出结果：

1.  源表：511\*\*为正确的身份证

![Center 13][]

2.文件，记录了错误的身份证号的那条记录

![Center 14][]

1.  目标表，结果是和源表一样的：

![Center 15][]

注意事项：1.自定义的stageID\_VER的输入为inID，所以DSLink1的输出字段必须定义为inID

2.filter的属性编辑：

![Center 16][]

3.OutputLink的确定是在“链接排序”里边。

![Center 17][]

[Center]: /images/20220731/a2cd41ff9d3a484182ef95d9fe8a4d3b.png
[Center 1]: /images/20220731/5be3eda464d34f82bece868864580918.png
[Center 2]: /images/20220731/4b6c1a0a8d104024a4c5e552a8f1429c.png
[Center 3]: /images/20220731/06a18c5e7b9840a8b216f0b683a9ea61.png
[Center 4]: /images/20220731/778afc6341d848ff8056e86a748b9dd3.png
[Center 5]: /images/20220731/bd49961e4736475187fa20572d30dc6d.png
[Center 6]: /images/20220731/54a80a0c1a3148e4a4283f72603c52d9.png
[Center 7]: /images/20220731/f06864d8016c484896ecd9f3cf6936de.png
[Center 8]: /images/20220731/6a77939bbba14a54bffc0ff06738a6fc.png
[Center 9]: /images/20220731/b7e2d48237d748449d36b1dd73188b4f.png
[Center 10]: /images/20220731/338f9c7b7ed24408bded8678c801aa1f.png
[Center 11]: /images/20220731/8f6b1bbaa3574fd480d10bdea39f2b1b.png
[Center 12]: /images/20220731/14743248c5e246f79100f3bdf37a8e56.png
[Center 13]: /images/20220731/39e417b94cb046b2bd8d6f34c8951ced.png
[Center 14]: /images/20220731/95b3e9e2695d4a83b5f4a1d719516c4b.png
[Center 15]: /images/20220731/6a34ae7052194519aa24d263054ec66a.png
[Center 16]: /images/20220731/52c575a2274f440d818eb73ce25ebb9d.png
[Center 17]: /images/20220731/beed03fa961a4037b9926ac96996ad1f.png