关键：系统对象Pipeline
　　首先打开Pipe画板，定义源数据库、源表、目标数据库、目标表，然后取名存盘，在本例中Pipe名为Pipe_sample。
　　打开User Object画板，定义一个用户对象，该对象继承自系统对象Pipeline，并在该对象中定义如下实例变量：
STATICTEXT READ
STATICTEXT WRITTEN
STATICTEXT ERROR
　　这三个变量用来记录数据管道执行时读入的行数，写入的行数，发生错误的行数。
　　在该用户对象的Pipemeter事件中写入如下语句：
READ.TEXT=STRING（ROWSREAD）
WRITTEN.TEXT=STRING（ROWSWRITTEN）
ERROR.TEXT=STRING（ROWSINERROR）
　　然后取名存盘，在本例中取名为U_Pipe_Sample。
　　打开窗口画板，创建一个窗口，在该窗口中放置一个数据窗口对象和三个静态文本对象，分别名为DW_1，ST_READ，ST_WRITTEN，ST_ERROR，这个数据窗口用来记录管道执行过程中发生的错误信息，不要为该数据窗口对象指定数据窗口。
　　在该窗口中定义如下实例变量：
Transaction I_SRC，I_DST
U_Pipe_Sample I_PIPE
　　在窗口的Open事件中写入如下语句：
i_src=create transaction
i_src.dbms=odbc
i_src.dbparm="Connectstring=DSN=数据库名;uid=用户名;pwd=口令"

connect using i_src;
If i_src.sqlcode $#@60;$#@62; 0 then
Messagebox("源数据库连接错误",i_src.sqlerrtext)
Return
End If

i_dst=create transaction
i_dst.dbms=odbc
i_dst.dbparm="Connectstring=DSN=数据库名;uid=用户名;pwd=口令"

connect using i_dst;
If i_dst.sqlcode $#@60;$#@62; 0 then
Messagebox("目标数据库连接错误",i_dst.sqlerrtext)
Return
End If
　　在窗口中放置一个按钮用来运行数据管道，在此按钮的Clicked事件中写入如下语句：
i_pipe=create u_pipe_sample
i_pipe.read=st_read
i_pipe.written=st_written
i_pipe.error=st_error
i_pipe.dataobject="Pipe_Sample"

//execute pipe
i_pipe.start(i_src,i_dst,dw_1)