kettle 正则表达式 获取文件名

#include "stdioh"

#include "stdlibh"

#include "stringh"

struct PCB {

char NAME[10]; /进程名/

int ROUND; /进程轮转时间片/

int REACHTIME; /进程到达时间/

int CPUTIME; /进程占用CPU时间/

int COUNT; /计数器/

int NEEDTIME; /进程完成还要的CPU时间/

char STATE; /进程的状态/

struct PCB NEXT; /链指针/

};

struct LINK { /PCB的链结构/

struct PCB RUN; /当前运行进程指针/

struct PCB READY; /就绪队列头指针/

struct PCB TAIL; /就绪队列尾指针/

struct PCB FINISH; /完成队列头指针/

};

void INIT(LINK ); /对PCB的链结构初始化/

void INSERT(LINK ); /将执行了一个单位时间片数且还未完成的进程的PCB插到就绪队列的队尾/

void FIRSTIN(LINK ); /将就绪队列中的第一个进程投入运行/

void PRINT(LINK ); /打印每执行一个时间片后的所有进程的状态/

void PR(PCB ); /打印一个进程的状态/

int CREATE(LINK ,int); /创建新的进程/

void ROUNDSCH(LINK ); /按时间片轮转法调度进程/

void main() {

LINK pcbs;

int i;

INIT(&pcbs);

i=0;

printf("创建5个进程\n\n");

while(i<5) {

if(CREATE(&pcbs,i+1)==1) {

printf("进程已创建\n\n");

i++;

}

else

printf("进程创建失败\n\n");

}

FIRSTIN(&pcbs);

ROUNDSCH(&pcbs);

}

void ROUNDSCH(LINK p) {

PCB pcb;

while(p->RUN!=NULL) {

pcb=(PCB )malloc(sizeof(PCB));

strcpy(pcb->NAME,p->RUN->NAME);

pcb->ROUND=p->RUN->ROUND;

pcb->REACHTIME=p->RUN->REACHTIME;

pcb->CPUTIME=p->RUN->CPUTIME;

pcb->COUNT=p->RUN->COUNT;

pcb->NEEDTIME=p->RUN->NEEDTIME;

pcb->STATE=p->RUN->STATE;

pcb->NEXT=p->RUN->NEXT;

pcb->CPUTIME++;

pcb->NEEDTIME--;

pcb->COUNT++;

if(pcb->NEEDTIME==0) {

pcb->NEXT=p->FINISH->NEXT;

p->FINISH->NEXT=pcb;

pcb->STATE='F';

p->RUN=NULL;

if(p->READY!=p->TAIL)

FIRSTIN(p);

}

else {

p->RUN=pcb;

if(pcb->COUNT==pcb->ROUND) {

pcb->COUNT=0;

if(p->READY!=p->TAIL) {

pcb->STATE='W';

INSERT(p);

FIRSTIN(p);

}

}

}

PRINT(p);

}

}

void INIT(LINK p) {

p->RUN=NULL;

p->TAIL=p->READY=(PCB )malloc(sizeof(PCB));

p->READY->NEXT=NULL;

p->FINISH=(PCB )malloc(sizeof(PCB));

p->FINISH->NEXT=NULL;

}

int CREATE(LINK p,int n) {

PCB pcb,q;

pcb=(PCB )malloc(sizeof(PCB));

flushall();

printf("请输入第%d个进程的名称：\n",n);

gets(pcb->NAME);

printf("请输入第%d个进程的轮转时间片数：\n",n);

scanf("%d",&(pcb->ROUND));

printf("请输入第%d个进程的到达时间：\n",n);

scanf("%d",&(pcb->REACHTIME));

pcb->CPUTIME=0;

pcb->COUNT=0;

printf("请输入第%d个进程需运行的时间片数：\n",n);

scanf("%d",&(pcb->NEEDTIME));

pcb->STATE='W';

pcb->NEXT=NULL;

if(strcmp(pcb->NAME,"")==0||pcb->ROUND<=0||pcb->NEEDTIME<=0) /输入错误/

return 0;

q=p->READY;

while(q->NEXT!=NULL&&q->NEXT->REACHTIME<=pcb->REACHTIME)

q=q->NEXT;

pcb->NEXT=q->NEXT;

q->NEXT=pcb;

if(pcb->NEXT==NULL)

p->TAIL=pcb;

return 1;

}

void FIRSTIN(LINK p) {

PCB q;

q=p->READY->NEXT;

p->READY->NEXT=q->NEXT;

q->NEXT=NULL;

if(p->READY->NEXT==NULL)

p->TAIL=p->READY;

q->STATE='R';

p->RUN=q;

}

void INSERT(LINK p) {

PCB pcb;

pcb=(PCB )malloc(sizeof(PCB));

strcpy(pcb->NAME,p->RUN->NAME);

pcb->ROUND=p->RUN->ROUND;

pcb->REACHTIME=p->RUN->REACHTIME;

pcb->CPUTIME=p->RUN->CPUTIME;

pcb->COUNT=p->RUN->COUNT;

pcb->NEEDTIME=p->RUN->NEEDTIME;

pcb->STATE=p->RUN->STATE;

pcb->NEXT=p->RUN->NEXT;

p->TAIL->NEXT=pcb;

p->TAIL=pcb;

p->RUN=NULL;

pcb->STATE='W';

}

void PRINT(LINK p) {

PCB pcb;

printf("执行一个时间片后的所有进程的状态：\n\n");

if(p->RUN!=NULL)

PR(p->RUN);

if(p->READY!=p->TAIL) {

pcb=p->READY->NEXT;

while(pcb!=NULL) {

PR(pcb);

pcb=pcb->NEXT;

}

}

pcb=p->FINISH->NEXT;

while(pcb!=NULL) {

PR(pcb);

pcb=pcb->NEXT;

}

}

void PR(PCB p) {

printf("进程名：%s\n",p->NAME);

printf("进程轮转时间片：%d\n",p->ROUND);

printf("进程到达时间：%d\n",p->REACHTIME);

printf("进程占用CPU时间：%d\n",p->CPUTIME);

printf("计数器：%d\n",p->COUNT);

printf("进程完成还要的CPU时间：%d\n",p->NEEDTIME);

printf("进程的状态：%c\n\n",p->STATE);

}

1选择文本文件输入

2先浏览选着自己用到的文本，点击添加，选中的文件会到“选中的文件”框里边图中的“1”就是我选中的文件之后点击“字段”在下边有个“获取字段 ” 点击它会出现你导出时候的字段名称，下边有“预览记录”可以查看里边的记录

向左转|向右转

我知道两种办法 ，毕竟是新手，各位大侠刀下留人

一：直接用sql 进行替换，

但是这样有问题，就是目标自己有值得时候，就不进行替换的

二：直接用脚本替换，不管哪种情况都会替换成功

三：还可以使用值映射。。直接映射成新的值就可以

kettle中要做到判断字段为1时抽取数据，为0时不抽取怎么做

你可以直接用表输入控件,在里面把a,b,c三张表的关联关系写好,select那3个字段,这样是最简单的,否则就是通过控件实现关联关系

打开kettle，定义数据源

1

kettle中定义两个数据源，其中“DS_ERP”是来源数据库，“DS_ODS”是用于同步的数据库

END

新建转换，用于同步某一张表

1

新建一个转换（执行SQL脚本--->>表输入--->>表输出）

执行SQL脚本：删除DS_ODS库中已经存在的数据

表输入：查询DS_ERP库中的数据

表输出：将“表输入”中的结果输出到DS_ODS库中

2

执行SQL脚本：删除DS_ODS库中已经存在的数据

${qy_table_name}：这个是参数，指同步的表名

3

表输入：查询DS_ERP库中的数据

${qy_table_name}：这个是参数，指同步的表名

4

表输出：将“表输入”中的结果输出到DS_ODS库中

${qy_table_name}：这个是参数，指同步的表名

END

新建转换，用于获取需要同步的表名

1

新建一个转换（文本文件输入--->>复制结果到记录）

文本文件输入：通过读取指定txt文件，获取所有要同步的表。（这里也可以通过其他方式获取，例如通过sql查询数据库系统表）

2

指定txt文件路径

3

定义txt文件中的字段名，同上一步中定义的参数名

4

txt中定义需要同步的表，每行一张表名

END

新建任务，实现批量同步

新建任务，调用前面的转换

其中，同步表的转换需要设置循环执行，并将获取到的表名传递到转换内部

以上就是关于kettle 正则表达式 获取文件名全部的内容，包括:kettle 正则表达式 获取文件名、kettle 从文本文件输入是，怎么拆分字段、Kettle使用教程 二 给表字段设置默认值等相关内容解答，如果想了解更多相关内容，可以关注我们，你们的支持是我们更新的动力！