当前位置: 代码迷 >> PB >> 用pb killer 看到 pipeline 的代码如下,请教怎么建这个pineline
  详细解决方案

用pb killer 看到 pipeline 的代码如下,请教怎么建这个pineline

热度:449   发布时间:2016-04-29 09:11:20.0
用pb killer 看到 pipeline 的代码如下,请问如何建这个pineline
PIPELINE(source_connect=aaa,destination_connect=aaa,type=update,commit=0,errors=0,keyname="gjd_main")
SOURCE(name="gjd_main",COLUMN(type=char,name="list_no",dbtype="char(19)",key=yes,nulls_allowed=no)
 COLUMN(type=char,name="cli_no",dbtype="char(4)",nulls_allowed=no)
 COLUMN(type=datetime,name="local_time",dbtype="datetime",nulls_allowed=no)
 COLUMN(type=datetime,name="remote_time",dbtype="datetime",nulls_allowed=no)
 COLUMN(type=long,name="belong_to",dbtype="int",nulls_allowed=no)
 COLUMN(type=long,name="now_status",dbtype="int",nulls_allowed=no))
RETRIEVE(statement="PBSELECT( VERSION(400) TABLE(NAME=~"gjd_main~" ) COLUMN(NAME=~"gjd_main.list_no~") COLUMN(NAME=~"gjd_main.cli_no~") COLUMN(NAME=~"gjd_main.local_time~") COLUMN(NAME=~"gjd_main.remote_time~") COLUMN(NAME=~"gjd_main.belong_to~") COLUMN(NAME=~"gjd_main.now_status~")WHERE( EXP1 =~"gjd_main.list_no~" OP =~"in~" EXP2 =~":s_list_no~" ) ) ARG(NAME = ~"s_list_no~" TYPE = stringlist)",arguments((s_list_no,String array)))
DESTINATION(name="gjd_main",COLUMN(type=char,name="list_no",dbtype="char(19)",key=yes,nulls_allowed=no,initial_value="spaces")
 COLUMN(type=char,name="cli_no",dbtype="char(4)",nulls_allowed=no,initial_value="spaces")
 COLUMN(type=datetime,name="local_time",dbtype="datetime",nulls_allowed=no,initial_value="today")
 COLUMN(type=datetime,name="remote_time",dbtype="datetime",nulls_allowed=no,initial_value="today")
 COLUMN(type=long,name="belong_to",dbtype="int",nulls_allowed=no,initial_value="none")
 COLUMN(type=long,name="now_status",dbtype="int",nulls_allowed=no,initial_value="none"))

------解决方案--------------------
在以上内容的前面加上一行:
$PBExportHeader$p_p.srp
然后将该内容保存为p_p.srp,再导入到pbl中

或者随便新建一个Database → Data Pipeline,然后对新建的pipline进行edit source, 用你发的内容替换原内容再保存
------解决方案--------------------
补充一点,你的PB数据库连接也得有aaa这个连接。

SQL code
source_connect=aaa,destination_connect=aaa
  相关解决方案