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