From 8124239d736eb91081d904d62820db0c1d46823a Mon Sep 17 00:00:00 2001 From: bnuxuliang <shendianqishi@126.com> Date: Mon, 26 Oct 2020 19:43:11 +0800 Subject: [PATCH] 111 --- intelligent_test/union_yuejuan_test/transfer/core.kjb | 1087 +++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++ intelligent_test/union_yuejuan_test/transfer/monitor_exam.ktr | 535 +++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++ 2 files changed, 1622 insertions(+) create mode 100644 intelligent_test/union_yuejuan_test/transfer/core.kjb create mode 100644 intelligent_test/union_yuejuan_test/transfer/monitor_exam.ktr diff --git a/intelligent_test/union_yuejuan_test/transfer/core.kjb b/intelligent_test/union_yuejuan_test/transfer/core.kjb new file mode 100644 index 0000000..7795094 --- /dev/null +++ b/intelligent_test/union_yuejuan_test/transfer/core.kjb @@ -0,0 +1,1087 @@ +<job> + <name>core</name> + <description /> + <extended_description /> + <job_version /> + <job_status>0</job_status> + <directory>/intelligent_test/union_yuejuan_test/transfer</directory> + <created_user>admin</created_user> + <created_date>2020/01/04 14:21:41.533</created_date> + <modified_user>admin</modified_user> + <modified_date>2020/09/18 17:08:10.910</modified_date> + <parameters> + </parameters> + <slaveservers> + </slaveservers> + <job-log-table> + <connection /> + <schema /> + <table /> + <size_limit_lines /> + <interval /> + <timeout_days /> + <field> + <id>ID_JOB</id> + <enabled>Y</enabled> + <name>ID_JOB</name> + </field> + <field> + <id>CHANNEL_ID</id> + <enabled>Y</enabled> + <name>CHANNEL_ID</name> + </field> + <field> + <id>JOBNAME</id> + <enabled>Y</enabled> + <name>JOBNAME</name> + </field> + <field> + <id>STATUS</id> + <enabled>Y</enabled> + <name>STATUS</name> + </field> + <field> + <id>LINES_READ</id> + <enabled>Y</enabled> + <name>LINES_READ</name> + </field> + <field> + <id>LINES_WRITTEN</id> + <enabled>Y</enabled> + <name>LINES_WRITTEN</name> + </field> + <field> + <id>LINES_UPDATED</id> + <enabled>Y</enabled> + <name>LINES_UPDATED</name> + </field> + <field> + <id>LINES_INPUT</id> + <enabled>Y</enabled> + <name>LINES_INPUT</name> + </field> + <field> + <id>LINES_OUTPUT</id> + <enabled>Y</enabled> + <name>LINES_OUTPUT</name> + </field> + <field> + <id>LINES_REJECTED</id> + <enabled>Y</enabled> + <name>LINES_REJECTED</name> + </field> + <field> + <id>ERRORS</id> + <enabled>Y</enabled> + <name>ERRORS</name> + </field> + <field> + <id>STARTDATE</id> + <enabled>Y</enabled> + <name>STARTDATE</name> + </field> + <field> + <id>ENDDATE</id> + <enabled>Y</enabled> + <name>ENDDATE</name> + </field> + <field> + <id>LOGDATE</id> + <enabled>Y</enabled> + <name>LOGDATE</name> + </field> + <field> + <id>DEPDATE</id> + <enabled>Y</enabled> + <name>DEPDATE</name> + </field> + <field> + <id>REPLAYDATE</id> + <enabled>Y</enabled> + <name>REPLAYDATE</name> + </field> + <field> + <id>LOG_FIELD</id> + <enabled>Y</enabled> + <name>LOG_FIELD</name> + </field> + <field> + <id>EXECUTING_SERVER</id> + <enabled>N</enabled> + <name>EXECUTING_SERVER</name> + </field> + <field> + <id>EXECUTING_USER</id> + <enabled>N</enabled> + <name>EXECUTING_USER</name> + </field> + <field> + <id>START_JOB_ENTRY</id> + <enabled>N</enabled> + <name>START_JOB_ENTRY</name> + </field> + <field> + <id>CLIENT</id> + <enabled>N</enabled> + <name>CLIENT</name> + </field> + </job-log-table> + <jobentry-log-table> + <connection /> + <schema /> + <table /> + <timeout_days /> + <field> + <id>ID_BATCH</id> + <enabled>Y</enabled> + <name>ID_BATCH</name> + </field> + <field> + <id>CHANNEL_ID</id> + <enabled>Y</enabled> + <name>CHANNEL_ID</name> + </field> + <field> + <id>LOG_DATE</id> + <enabled>Y</enabled> + <name>LOG_DATE</name> + </field> + <field> + <id>JOBNAME</id> + <enabled>Y</enabled> + <name>TRANSNAME</name> + </field> + <field> + <id>JOBENTRYNAME</id> + <enabled>Y</enabled> + <name>STEPNAME</name> + </field> + <field> + <id>LINES_READ</id> + <enabled>Y</enabled> + <name>LINES_READ</name> + </field> + <field> + <id>LINES_WRITTEN</id> + <enabled>Y</enabled> + <name>LINES_WRITTEN</name> + </field> + <field> + <id>LINES_UPDATED</id> + <enabled>Y</enabled> + <name>LINES_UPDATED</name> + </field> + <field> + <id>LINES_INPUT</id> + <enabled>Y</enabled> + <name>LINES_INPUT</name> + </field> + <field> + <id>LINES_OUTPUT</id> + <enabled>Y</enabled> + <name>LINES_OUTPUT</name> + </field> + <field> + <id>LINES_REJECTED</id> + <enabled>Y</enabled> + <name>LINES_REJECTED</name> + </field> + <field> + <id>ERRORS</id> + <enabled>Y</enabled> + <name>ERRORS</name> + </field> + <field> + <id>RESULT</id> + <enabled>Y</enabled> + <name>RESULT</name> + </field> + <field> + <id>NR_RESULT_ROWS</id> + <enabled>Y</enabled> + <name>NR_RESULT_ROWS</name> + </field> + <field> + <id>NR_RESULT_FILES</id> + <enabled>Y</enabled> + <name>NR_RESULT_FILES</name> + </field> + <field> + <id>LOG_FIELD</id> + <enabled>N</enabled> + <name>LOG_FIELD</name> + </field> + <field> + <id>COPY_NR</id> + <enabled>N</enabled> + <name>COPY_NR</name> + </field> + </jobentry-log-table> + <channel-log-table> + <connection /> + <schema /> + <table /> + <timeout_days /> + <field> + <id>ID_BATCH</id> + <enabled>Y</enabled> + <name>ID_BATCH</name> + </field> + <field> + <id>CHANNEL_ID</id> + <enabled>Y</enabled> + <name>CHANNEL_ID</name> + </field> + <field> + <id>LOG_DATE</id> + <enabled>Y</enabled> + <name>LOG_DATE</name> + </field> + <field> + <id>LOGGING_OBJECT_TYPE</id> + <enabled>Y</enabled> + <name>LOGGING_OBJECT_TYPE</name> + </field> + <field> + <id>OBJECT_NAME</id> + <enabled>Y</enabled> + <name>OBJECT_NAME</name> + </field> + <field> + <id>OBJECT_COPY</id> + <enabled>Y</enabled> + <name>OBJECT_COPY</name> + </field> + <field> + <id>REPOSITORY_DIRECTORY</id> + <enabled>Y</enabled> + <name>REPOSITORY_DIRECTORY</name> + </field> + <field> + <id>FILENAME</id> + <enabled>Y</enabled> + <name>FILENAME</name> + </field> + <field> + <id>OBJECT_ID</id> + <enabled>Y</enabled> + <name>OBJECT_ID</name> + </field> + <field> + <id>OBJECT_REVISION</id> + <enabled>Y</enabled> + <name>OBJECT_REVISION</name> + </field> + <field> + <id>PARENT_CHANNEL_ID</id> + <enabled>Y</enabled> + <name>PARENT_CHANNEL_ID</name> + </field> + <field> + <id>ROOT_CHANNEL_ID</id> + <enabled>Y</enabled> + <name>ROOT_CHANNEL_ID</name> + </field> + </channel-log-table> + <pass_batchid>N</pass_batchid> + <shared_objects_file /> + <entries> + <entry> + <name>write_log_success (3)</name> + <description /> + <type>TRANS</type> + <attributes /> + <specification_method>rep_name</specification_method> + <trans_object_id /> + <filename /> + <transname>write_log_success</transname> + <directory>/intelligent_test/union_yuejuan_test/transfer/total_control</directory> + <arg_from_previous>N</arg_from_previous> + <params_from_previous>N</params_from_previous> + <exec_per_row>N</exec_per_row> + <clear_rows>N</clear_rows> + <clear_files>N</clear_files> + <set_logfile>N</set_logfile> + <logfile /> + <logext /> + <add_date>N</add_date> + <add_time>N</add_time> + <loglevel>Basic</loglevel> + <cluster>N</cluster> + <slave_server_name /> + <set_append_logfile>N</set_append_logfile> + <wait_until_finished>Y</wait_until_finished> + <follow_abort_remote>N</follow_abort_remote> + <create_parent_folder>N</create_parent_folder> + <logging_remote_work>N</logging_remote_work> + <run_configuration /> + <parameters> + <pass_all_parameters>Y</pass_all_parameters> + </parameters> + <parallel>N</parallel> + <draw>Y</draw> + <nr>0</nr> + <xloc>768</xloc> + <yloc>304</yloc> + <attributes_kjc /> + </entry> + <entry> + <name>write_log_unsuccess (2)</name> + <description /> + <type>TRANS</type> + <attributes /> + <specification_method>rep_name</specification_method> + <trans_object_id /> + <filename /> + <transname>write_log_unsuccess</transname> + <directory>/intelligent_test/union_yuejuan_test/transfer/total_control</directory> + <arg_from_previous>N</arg_from_previous> + <params_from_previous>N</params_from_previous> + <exec_per_row>N</exec_per_row> + <clear_rows>N</clear_rows> + <clear_files>N</clear_files> + <set_logfile>N</set_logfile> + <logfile /> + <logext /> + <add_date>N</add_date> + <add_time>N</add_time> + <loglevel>Basic</loglevel> + <cluster>N</cluster> + <slave_server_name /> + <set_append_logfile>N</set_append_logfile> + <wait_until_finished>Y</wait_until_finished> + <follow_abort_remote>N</follow_abort_remote> + <create_parent_folder>N</create_parent_folder> + <logging_remote_work>N</logging_remote_work> + <run_configuration /> + <parameters> + <pass_all_parameters>Y</pass_all_parameters> + </parameters> + <parallel>N</parallel> + <draw>Y</draw> + <nr>0</nr> + <xloc>640</xloc> + <yloc>192</yloc> + <attributes_kjc /> + </entry> + <entry> + <name>roll_back</name> + <description /> + <type>JOB</type> + <attributes /> + <specification_method>filename</specification_method> + <job_object_id /> + <filename /> + <jobname>roll_back</jobname> + <directory>/intelligent_test/union_yuejuan_test/transfer/roll_back</directory> + <arg_from_previous>N</arg_from_previous> + <params_from_previous>N</params_from_previous> + <exec_per_row>N</exec_per_row> + <set_logfile>N</set_logfile> + <logfile /> + <logext /> + <add_date>N</add_date> + <add_time>N</add_time> + <loglevel>Nothing</loglevel> + <slave_server_name /> + <wait_until_finished>Y</wait_until_finished> + <follow_abort_remote>N</follow_abort_remote> + <expand_remote_job>N</expand_remote_job> + <create_parent_folder>N</create_parent_folder> + <pass_export>N</pass_export> + <run_configuration /> + <parameters> + <pass_all_parameters>Y</pass_all_parameters> + </parameters> + <set_append_logfile>N</set_append_logfile> + <parallel>N</parallel> + <draw>Y</draw> + <nr>0</nr> + <xloc>768</xloc> + <yloc>192</yloc> + <attributes_kjc /> + </entry> + <entry> + <name>fundamental</name> + <description /> + <type>JOB</type> + <attributes /> + <specification_method>filename</specification_method> + <job_object_id /> + <filename /> + <jobname>fundamental</jobname> + <directory>/intelligent_test/union_yuejuan_test/transfer/fundamental</directory> + <arg_from_previous>N</arg_from_previous> + <params_from_previous>N</params_from_previous> + <exec_per_row>N</exec_per_row> + <set_logfile>N</set_logfile> + <logfile /> + <logext /> + <add_date>N</add_date> + <add_time>N</add_time> + <loglevel>Nothing</loglevel> + <slave_server_name /> + <wait_until_finished>Y</wait_until_finished> + <follow_abort_remote>N</follow_abort_remote> + <expand_remote_job>N</expand_remote_job> + <create_parent_folder>N</create_parent_folder> + <pass_export>N</pass_export> + <run_configuration /> + <parameters> + <pass_all_parameters>Y</pass_all_parameters> + </parameters> + <set_append_logfile>N</set_append_logfile> + <parallel>N</parallel> + <draw>Y</draw> + <nr>0</nr> + <xloc>496</xloc> + <yloc>304</yloc> + <attributes_kjc /> + </entry> + <entry> + <name>Set variables</name> + <description /> + <type>SET_VARIABLES</type> + <attributes /> + <replacevars>Y</replacevars> + <filename /> + <file_variable_type>ROOT_JOB</file_variable_type> + <fields> + <field> + <variable_name>stage</variable_name> + <variable_value>start</variable_value> + <variable_type>ROOT_JOB</variable_type> + </field> + </fields> + <parallel>N</parallel> + <draw>Y</draw> + <nr>0</nr> + <xloc>128</xloc> + <yloc>32</yloc> + <attributes_kjc /> + </entry> + <entry> + <name>START</name> + <description /> + <type>SPECIAL</type> + <attributes /> + <start>Y</start> + <dummy>N</dummy> + <repeat>N</repeat> + <schedulerType>0</schedulerType> + <intervalSeconds>0</intervalSeconds> + <intervalMinutes>60</intervalMinutes> + <hour>12</hour> + <minutes>0</minutes> + <weekDay>1</weekDay> + <DayOfMonth>1</DayOfMonth> + <parallel>N</parallel> + <draw>Y</draw> + <nr>0</nr> + <xloc>16</xloc> + <yloc>32</yloc> + <attributes_kjc /> + </entry> + <entry> + <name>Simple evaluation</name> + <description /> + <type>SIMPLE_EVAL</type> + <attributes /> + <valuetype>variable</valuetype> + <fieldname /> + <variablename>is_run</variablename> + <fieldtype>number</fieldtype> + <mask /> + <comparevalue>1</comparevalue> + <minvalue /> + <maxvalue /> + <successcondition>equal</successcondition> + <successnumbercondition>equal</successnumbercondition> + <successbooleancondition>false</successbooleancondition> + <successwhenvarset>N</successwhenvarset> + <parallel>N</parallel> + <draw>Y</draw> + <nr>0</nr> + <xloc>384</xloc> + <yloc>32</yloc> + <attributes_kjc /> + </entry> + <entry> + <name>Success</name> + <description /> + <type>SUCCESS</type> + <attributes /> + <parallel>N</parallel> + <draw>Y</draw> + <nr>0</nr> + <xloc>384</xloc> + <yloc>112</yloc> + <attributes_kjc /> + </entry> + <entry> + <name>source_stage</name> + <description /> + <type>SET_VARIABLES</type> + <attributes /> + <replacevars>Y</replacevars> + <filename /> + <file_variable_type>ROOT_JOB</file_variable_type> + <fields> + <field> + <variable_name>stage</variable_name> + <variable_value>source</variable_value> + <variable_type>ROOT_JOB</variable_type> + </field> + </fields> + <parallel>N</parallel> + <draw>Y</draw> + <nr>0</nr> + <xloc>512</xloc> + <yloc>32</yloc> + <attributes_kjc /> + </entry> + <entry> + <name>write_log_success</name> + <description /> + <type>TRANS</type> + <attributes /> + <specification_method>rep_name</specification_method> + <trans_object_id /> + <filename /> + <transname>write_log_success</transname> + <directory>/intelligent_test/union_yuejuan_test/transfer/total_control</directory> + <arg_from_previous>N</arg_from_previous> + <params_from_previous>N</params_from_previous> + <exec_per_row>N</exec_per_row> + <clear_rows>N</clear_rows> + <clear_files>N</clear_files> + <set_logfile>N</set_logfile> + <logfile /> + <logext /> + <add_date>N</add_date> + <add_time>N</add_time> + <loglevel>Basic</loglevel> + <cluster>N</cluster> + <slave_server_name /> + <set_append_logfile>N</set_append_logfile> + <wait_until_finished>Y</wait_until_finished> + <follow_abort_remote>N</follow_abort_remote> + <create_parent_folder>N</create_parent_folder> + <logging_remote_work>N</logging_remote_work> + <run_configuration /> + <parameters> + <pass_all_parameters>Y</pass_all_parameters> + </parameters> + <parallel>N</parallel> + <draw>Y</draw> + <nr>0</nr> + <xloc>768</xloc> + <yloc>32</yloc> + <attributes_kjc /> + </entry> + <entry> + <name>write_log_unsuccess</name> + <description /> + <type>TRANS</type> + <attributes /> + <specification_method>rep_name</specification_method> + <trans_object_id /> + <filename /> + <transname>write_log_unsuccess</transname> + <directory>/intelligent_test/union_yuejuan_test/transfer/total_control</directory> + <arg_from_previous>N</arg_from_previous> + <params_from_previous>N</params_from_previous> + <exec_per_row>N</exec_per_row> + <clear_rows>N</clear_rows> + <clear_files>N</clear_files> + <set_logfile>N</set_logfile> + <logfile /> + <logext /> + <add_date>N</add_date> + <add_time>N</add_time> + <loglevel>Basic</loglevel> + <cluster>N</cluster> + <slave_server_name /> + <set_append_logfile>N</set_append_logfile> + <wait_until_finished>Y</wait_until_finished> + <follow_abort_remote>N</follow_abort_remote> + <create_parent_folder>N</create_parent_folder> + <logging_remote_work>N</logging_remote_work> + <run_configuration /> + <parameters> + <pass_all_parameters>Y</pass_all_parameters> + </parameters> + <parallel>N</parallel> + <draw>Y</draw> + <nr>0</nr> + <xloc>640</xloc> + <yloc>112</yloc> + <attributes_kjc /> + </entry> + <entry> + <name>write_log_unsuccess (3)</name> + <description /> + <type>TRANS</type> + <attributes /> + <specification_method>rep_name</specification_method> + <trans_object_id /> + <filename /> + <transname>write_log_unsuccess</transname> + <directory>/intelligent_test/union_yuejuan_test/transfer/total_control</directory> + <arg_from_previous>N</arg_from_previous> + <params_from_previous>N</params_from_previous> + <exec_per_row>N</exec_per_row> + <clear_rows>N</clear_rows> + <clear_files>N</clear_files> + <set_logfile>N</set_logfile> + <logfile /> + <logext /> + <add_date>N</add_date> + <add_time>N</add_time> + <loglevel>Basic</loglevel> + <cluster>N</cluster> + <slave_server_name /> + <set_append_logfile>N</set_append_logfile> + <wait_until_finished>Y</wait_until_finished> + <follow_abort_remote>N</follow_abort_remote> + <create_parent_folder>N</create_parent_folder> + <logging_remote_work>N</logging_remote_work> + <run_configuration /> + <parameters> + <pass_all_parameters>Y</pass_all_parameters> + </parameters> + <parallel>N</parallel> + <draw>Y</draw> + <nr>0</nr> + <xloc>496</xloc> + <yloc>208</yloc> + <attributes_kjc /> + </entry> + <entry> + <name>write_log_success (2)</name> + <description /> + <type>TRANS</type> + <attributes /> + <specification_method>rep_name</specification_method> + <trans_object_id /> + <filename /> + <transname>write_log_success</transname> + <directory>/intelligent_test/union_yuejuan_test/transfer/total_control</directory> + <arg_from_previous>N</arg_from_previous> + <params_from_previous>N</params_from_previous> + <exec_per_row>N</exec_per_row> + <clear_rows>N</clear_rows> + <clear_files>N</clear_files> + <set_logfile>N</set_logfile> + <logfile /> + <logext /> + <add_date>N</add_date> + <add_time>N</add_time> + <loglevel>Basic</loglevel> + <cluster>N</cluster> + <slave_server_name /> + <set_append_logfile>N</set_append_logfile> + <wait_until_finished>Y</wait_until_finished> + <follow_abort_remote>N</follow_abort_remote> + <create_parent_folder>N</create_parent_folder> + <logging_remote_work>N</logging_remote_work> + <run_configuration /> + <parameters> + <pass_all_parameters>Y</pass_all_parameters> + </parameters> + <parallel>N</parallel> + <draw>Y</draw> + <nr>0</nr> + <xloc>368</xloc> + <yloc>304</yloc> + <attributes_kjc /> + </entry> + <entry> + <name>fundamental_stage</name> + <description /> + <type>SET_VARIABLES</type> + <attributes /> + <replacevars>Y</replacevars> + <filename /> + <file_variable_type>ROOT_JOB</file_variable_type> + <fields> + <field> + <variable_name>stage</variable_name> + <variable_value>fundamental</variable_value> + <variable_type>ROOT_JOB</variable_type> + </field> + </fields> + <parallel>N</parallel> + <draw>Y</draw> + <nr>0</nr> + <xloc>640</xloc> + <yloc>304</yloc> + <attributes_kjc /> + </entry> + <entry> + <name>update_state</name> + <description /> + <type>TRANS</type> + <attributes /> + <specification_method>rep_name</specification_method> + <trans_object_id /> + <filename /> + <transname>update_state</transname> + <directory>/intelligent_test/union_yuejuan_test/transfer/total_control</directory> + <arg_from_previous>N</arg_from_previous> + <params_from_previous>N</params_from_previous> + <exec_per_row>N</exec_per_row> + <clear_rows>N</clear_rows> + <clear_files>N</clear_files> + <set_logfile>N</set_logfile> + <logfile /> + <logext /> + <add_date>N</add_date> + <add_time>N</add_time> + <loglevel>Basic</loglevel> + <cluster>N</cluster> + <slave_server_name /> + <set_append_logfile>N</set_append_logfile> + <wait_until_finished>Y</wait_until_finished> + <follow_abort_remote>N</follow_abort_remote> + <create_parent_folder>N</create_parent_folder> + <logging_remote_work>N</logging_remote_work> + <run_configuration /> + <parameters> + <pass_all_parameters>Y</pass_all_parameters> + </parameters> + <parallel>N</parallel> + <draw>Y</draw> + <nr>0</nr> + <xloc>208</xloc> + <yloc>304</yloc> + <attributes_kjc /> + </entry> + <entry> + <name>stage_roll_back</name> + <description /> + <type>SET_VARIABLES</type> + <attributes /> + <replacevars>Y</replacevars> + <filename /> + <file_variable_type>ROOT_JOB</file_variable_type> + <fields> + <field> + <variable_name>stage</variable_name> + <variable_value>roll_back</variable_value> + <variable_type>ROOT_JOB</variable_type> + </field> + </fields> + <parallel>N</parallel> + <draw>Y</draw> + <nr>0</nr> + <xloc>768</xloc> + <yloc>112</yloc> + <attributes_kjc /> + </entry> + <entry> + <name>set_variable</name> + <description /> + <type>JOB</type> + <attributes /> + <specification_method>filename</specification_method> + <job_object_id /> + <filename /> + <jobname>set_variable</jobname> + <directory>/intelligent_test/union_yuejuan_test/transfer/total_control</directory> + <arg_from_previous>N</arg_from_previous> + <params_from_previous>N</params_from_previous> + <exec_per_row>N</exec_per_row> + <set_logfile>N</set_logfile> + <logfile /> + <logext /> + <add_date>N</add_date> + <add_time>N</add_time> + <loglevel>Nothing</loglevel> + <slave_server_name /> + <wait_until_finished>Y</wait_until_finished> + <follow_abort_remote>N</follow_abort_remote> + <expand_remote_job>N</expand_remote_job> + <create_parent_folder>N</create_parent_folder> + <pass_export>N</pass_export> + <run_configuration /> + <parameters> + <pass_all_parameters>Y</pass_all_parameters> + </parameters> + <set_append_logfile>N</set_append_logfile> + <parallel>N</parallel> + <draw>Y</draw> + <nr>0</nr> + <xloc>256</xloc> + <yloc>32</yloc> + <attributes_kjc /> + </entry> + <entry> + <name>Shell</name> + <description /> + <type>SHELL</type> + <attributes /> + <filename>/home/jty_dw/etl_total/job/intelligent/union_yuejuan/union_yuejuan_transfer_test.sh</filename> + <work_directory /> + <arg_from_previous>N</arg_from_previous> + <exec_per_row>N</exec_per_row> + <set_logfile>N</set_logfile> + <logfile /> + <set_append_logfile>N</set_append_logfile> + <logext /> + <add_date>N</add_date> + <add_time>N</add_time> + <insertScript>N</insertScript> + <script /> + <loglevel>Basic</loglevel> + <parallel>N</parallel> + <draw>Y</draw> + <nr>0</nr> + <xloc>640</xloc> + <yloc>32</yloc> + <attributes_kjc /> + </entry> + <entry> + <name>Success 2</name> + <description /> + <type>SUCCESS</type> + <attributes /> + <parallel>N</parallel> + <draw>Y</draw> + <nr>0</nr> + <xloc>80</xloc> + <yloc>432</yloc> + <attributes_kjc /> + </entry> + <entry> + <name>monitor_exam</name> + <description /> + <type>TRANS</type> + <attributes /> + <specification_method>rep_name</specification_method> + <trans_object_id /> + <filename /> + <transname>monitor_exam</transname> + <directory>/intelligent_test/union_yuejuan_test/transfer</directory> + <arg_from_previous>N</arg_from_previous> + <params_from_previous>N</params_from_previous> + <exec_per_row>N</exec_per_row> + <clear_rows>N</clear_rows> + <clear_files>N</clear_files> + <set_logfile>N</set_logfile> + <logfile /> + <logext /> + <add_date>N</add_date> + <add_time>N</add_time> + <loglevel>Basic</loglevel> + <cluster>N</cluster> + <slave_server_name /> + <set_append_logfile>N</set_append_logfile> + <wait_until_finished>Y</wait_until_finished> + <follow_abort_remote>N</follow_abort_remote> + <create_parent_folder>N</create_parent_folder> + <logging_remote_work>N</logging_remote_work> + <run_configuration>Pentaho local</run_configuration> + <parameters> + <pass_all_parameters>Y</pass_all_parameters> + </parameters> + <parallel>N</parallel> + <draw>Y</draw> + <nr>0</nr> + <xloc>80</xloc> + <yloc>304</yloc> + <attributes_kjc /> + </entry> + </entries> + <hops> + <hop> + <from>fundamental_stage</from> + <to>fundamental</to> + <from_nr>0</from_nr> + <to_nr>0</to_nr> + <enabled>Y</enabled> + <evaluation>Y</evaluation> + <unconditional>N</unconditional> + </hop> + <hop> + <from>fundamental</from> + <to>write_log_unsuccess (3)</to> + <from_nr>0</from_nr> + <to_nr>0</to_nr> + <enabled>Y</enabled> + <evaluation>N</evaluation> + <unconditional>N</unconditional> + </hop> + <hop> + <from>START</from> + <to>Set variables</to> + <from_nr>0</from_nr> + <to_nr>0</to_nr> + <enabled>Y</enabled> + <evaluation>Y</evaluation> + <unconditional>Y</unconditional> + </hop> + <hop> + <from>Simple evaluation</from> + <to>Success</to> + <from_nr>0</from_nr> + <to_nr>0</to_nr> + <enabled>Y</enabled> + <evaluation>N</evaluation> + <unconditional>N</unconditional> + </hop> + <hop> + <from>write_log_success</from> + <to>stage_roll_back</to> + <from_nr>0</from_nr> + <to_nr>0</to_nr> + <enabled>Y</enabled> + <evaluation>Y</evaluation> + <unconditional>N</unconditional> + </hop> + <hop> + <from>write_log_success (3)</from> + <to>fundamental_stage</to> + <from_nr>0</from_nr> + <to_nr>0</to_nr> + <enabled>Y</enabled> + <evaluation>Y</evaluation> + <unconditional>N</unconditional> + </hop> + <hop> + <from>stage_roll_back</from> + <to>roll_back</to> + <from_nr>0</from_nr> + <to_nr>0</to_nr> + <enabled>Y</enabled> + <evaluation>Y</evaluation> + <unconditional>N</unconditional> + </hop> + <hop> + <from>roll_back</from> + <to>write_log_success (3)</to> + <from_nr>0</from_nr> + <to_nr>0</to_nr> + <enabled>Y</enabled> + <evaluation>Y</evaluation> + <unconditional>N</unconditional> + </hop> + <hop> + <from>fundamental</from> + <to>write_log_success (2)</to> + <from_nr>0</from_nr> + <to_nr>0</to_nr> + <enabled>Y</enabled> + <evaluation>Y</evaluation> + <unconditional>N</unconditional> + </hop> + <hop> + <from>roll_back</from> + <to>write_log_unsuccess (2)</to> + <from_nr>0</from_nr> + <to_nr>0</to_nr> + <enabled>Y</enabled> + <evaluation>N</evaluation> + <unconditional>N</unconditional> + </hop> + <hop> + <from>Simple evaluation</from> + <to>source_stage</to> + <from_nr>0</from_nr> + <to_nr>0</to_nr> + <enabled>Y</enabled> + <evaluation>Y</evaluation> + <unconditional>N</unconditional> + </hop> + <hop> + <from>Set variables</from> + <to>set_variable</to> + <from_nr>0</from_nr> + <to_nr>0</to_nr> + <enabled>Y</enabled> + <evaluation>Y</evaluation> + <unconditional>N</unconditional> + </hop> + <hop> + <from>set_variable</from> + <to>Simple evaluation</to> + <from_nr>0</from_nr> + <to_nr>0</to_nr> + <enabled>Y</enabled> + <evaluation>Y</evaluation> + <unconditional>N</unconditional> + </hop> + <hop> + <from>write_log_success (2)</from> + <to>update_state</to> + <from_nr>0</from_nr> + <to_nr>0</to_nr> + <enabled>Y</enabled> + <evaluation>Y</evaluation> + <unconditional>N</unconditional> + </hop> + <hop> + <from>source_stage</from> + <to>Shell</to> + <from_nr>0</from_nr> + <to_nr>0</to_nr> + <enabled>Y</enabled> + <evaluation>Y</evaluation> + <unconditional>N</unconditional> + </hop> + <hop> + <from>Shell</from> + <to>write_log_success</to> + <from_nr>0</from_nr> + <to_nr>0</to_nr> + <enabled>Y</enabled> + <evaluation>Y</evaluation> + <unconditional>N</unconditional> + </hop> + <hop> + <from>Shell</from> + <to>write_log_unsuccess</to> + <from_nr>0</from_nr> + <to_nr>0</to_nr> + <enabled>Y</enabled> + <evaluation>N</evaluation> + <unconditional>N</unconditional> + </hop> + <hop> + <from>update_state</from> + <to>monitor_exam</to> + <from_nr>0</from_nr> + <to_nr>0</to_nr> + <enabled>Y</enabled> + <evaluation>Y</evaluation> + <unconditional>N</unconditional> + </hop> + <hop> + <from>monitor_exam</from> + <to>Success 2</to> + <from_nr>0</from_nr> + <to_nr>0</to_nr> + <enabled>Y</enabled> + <evaluation>Y</evaluation> + <unconditional>N</unconditional> + </hop> + </hops> + <notepads> + </notepads> + <attributes> + <group> + <name>METASTORE.pentaho</name> + <attribute> + <key>Default Run Configuration</key> + <value>{"namespace":"pentaho","id":"Default Run Configuration","name":"Default Run Configuration","description":"Defines a default run configuration","metaStoreName":null}</value> + </attribute> + </group> + <group> + <name>{"_":"Embedded MetaStore Elements","namespace":"pentaho","type":"Default Run Configuration"}</name> + <attribute> + <key>Pentaho local</key> + <value>{"children":[{"children":[],"id":"server","value":null},{"children":[],"id":"clustered","value":"N"},{"children":[],"id":"name","value":"Pentaho local"},{"children":[],"id":"description","value":null},{"children":[],"id":"pentaho","value":"N"},{"children":[],"id":"readOnly","value":"Y"},{"children":[],"id":"sendResources","value":"N"},{"children":[],"id":"logRemoteExecutionLocally","value":"N"},{"children":[],"id":"remote","value":"N"},{"children":[],"id":"local","value":"Y"},{"children":[],"id":"showTransformations","value":"N"}],"id":"Pentaho local","value":null,"name":"Pentaho local","owner":null,"ownerPermissionsList":[]}</value> + </attribute> + </group> + </attributes> +</job> diff --git a/intelligent_test/union_yuejuan_test/transfer/monitor_exam.ktr b/intelligent_test/union_yuejuan_test/transfer/monitor_exam.ktr new file mode 100644 index 0000000..3bc843e --- /dev/null +++ b/intelligent_test/union_yuejuan_test/transfer/monitor_exam.ktr @@ -0,0 +1,535 @@ +<transformation> + <info> + <name>monitor_exam</name> + <description /> + <extended_description /> + <trans_version /> + <trans_type>Normal</trans_type> + <directory>/intelligent_test/union_yuejuan_test/transfer</directory> + <parameters> + </parameters> + <log> + <trans-log-table> + <connection /> + <schema /> + <table /> + <size_limit_lines /> + <interval /> + <timeout_days /> + <field> + <id>ID_BATCH</id> + <enabled>Y</enabled> + <name>ID_BATCH</name> + </field> + <field> + <id>CHANNEL_ID</id> + <enabled>Y</enabled> + <name>CHANNEL_ID</name> + </field> + <field> + <id>TRANSNAME</id> + <enabled>Y</enabled> + <name>TRANSNAME</name> + </field> + <field> + <id>STATUS</id> + <enabled>Y</enabled> + <name>STATUS</name> + </field> + <field> + <id>LINES_READ</id> + <enabled>Y</enabled> + <name>LINES_READ</name> + <subject /> + </field> + <field> + <id>LINES_WRITTEN</id> + <enabled>Y</enabled> + <name>LINES_WRITTEN</name> + <subject /> + </field> + <field> + <id>LINES_UPDATED</id> + <enabled>Y</enabled> + <name>LINES_UPDATED</name> + <subject /> + </field> + <field> + <id>LINES_INPUT</id> + <enabled>Y</enabled> + <name>LINES_INPUT</name> + <subject /> + </field> + <field> + <id>LINES_OUTPUT</id> + <enabled>Y</enabled> + <name>LINES_OUTPUT</name> + <subject /> + </field> + <field> + <id>LINES_REJECTED</id> + <enabled>Y</enabled> + <name>LINES_REJECTED</name> + <subject /> + </field> + <field> + <id>ERRORS</id> + <enabled>Y</enabled> + <name>ERRORS</name> + </field> + <field> + <id>STARTDATE</id> + <enabled>Y</enabled> + <name>STARTDATE</name> + </field> + <field> + <id>ENDDATE</id> + <enabled>Y</enabled> + <name>ENDDATE</name> + </field> + <field> + <id>LOGDATE</id> + <enabled>Y</enabled> + <name>LOGDATE</name> + </field> + <field> + <id>DEPDATE</id> + <enabled>Y</enabled> + <name>DEPDATE</name> + </field> + <field> + <id>REPLAYDATE</id> + <enabled>Y</enabled> + <name>REPLAYDATE</name> + </field> + <field> + <id>LOG_FIELD</id> + <enabled>Y</enabled> + <name>LOG_FIELD</name> + </field> + <field> + <id>EXECUTING_SERVER</id> + <enabled>N</enabled> + <name>EXECUTING_SERVER</name> + </field> + <field> + <id>EXECUTING_USER</id> + <enabled>N</enabled> + <name>EXECUTING_USER</name> + </field> + <field> + <id>CLIENT</id> + <enabled>N</enabled> + <name>CLIENT</name> + </field> + </trans-log-table> + <perf-log-table> + <connection /> + <schema /> + <table /> + <interval /> + <timeout_days /> + <field> + <id>ID_BATCH</id> + <enabled>Y</enabled> + <name>ID_BATCH</name> + </field> + <field> + <id>SEQ_NR</id> + <enabled>Y</enabled> + <name>SEQ_NR</name> + </field> + <field> + <id>LOGDATE</id> + <enabled>Y</enabled> + <name>LOGDATE</name> + </field> + <field> + <id>TRANSNAME</id> + <enabled>Y</enabled> + <name>TRANSNAME</name> + </field> + <field> + <id>STEPNAME</id> + <enabled>Y</enabled> + <name>STEPNAME</name> + </field> + <field> + <id>STEP_COPY</id> + <enabled>Y</enabled> + <name>STEP_COPY</name> + </field> + <field> + <id>LINES_READ</id> + <enabled>Y</enabled> + <name>LINES_READ</name> + </field> + <field> + <id>LINES_WRITTEN</id> + <enabled>Y</enabled> + <name>LINES_WRITTEN</name> + </field> + <field> + <id>LINES_UPDATED</id> + <enabled>Y</enabled> + <name>LINES_UPDATED</name> + </field> + <field> + <id>LINES_INPUT</id> + <enabled>Y</enabled> + <name>LINES_INPUT</name> + </field> + <field> + <id>LINES_OUTPUT</id> + <enabled>Y</enabled> + <name>LINES_OUTPUT</name> + </field> + <field> + <id>LINES_REJECTED</id> + <enabled>Y</enabled> + <name>LINES_REJECTED</name> + </field> + <field> + <id>ERRORS</id> + <enabled>Y</enabled> + <name>ERRORS</name> + </field> + <field> + <id>INPUT_BUFFER_ROWS</id> + <enabled>Y</enabled> + <name>INPUT_BUFFER_ROWS</name> + </field> + <field> + <id>OUTPUT_BUFFER_ROWS</id> + <enabled>Y</enabled> + <name>OUTPUT_BUFFER_ROWS</name> + </field> + </perf-log-table> + <channel-log-table> + <connection /> + <schema /> + <table /> + <timeout_days /> + <field> + <id>ID_BATCH</id> + <enabled>Y</enabled> + <name>ID_BATCH</name> + </field> + <field> + <id>CHANNEL_ID</id> + <enabled>Y</enabled> + <name>CHANNEL_ID</name> + </field> + <field> + <id>LOG_DATE</id> + <enabled>Y</enabled> + <name>LOG_DATE</name> + </field> + <field> + <id>LOGGING_OBJECT_TYPE</id> + <enabled>Y</enabled> + <name>LOGGING_OBJECT_TYPE</name> + </field> + <field> + <id>OBJECT_NAME</id> + <enabled>Y</enabled> + <name>OBJECT_NAME</name> + </field> + <field> + <id>OBJECT_COPY</id> + <enabled>Y</enabled> + <name>OBJECT_COPY</name> + </field> + <field> + <id>REPOSITORY_DIRECTORY</id> + <enabled>Y</enabled> + <name>REPOSITORY_DIRECTORY</name> + </field> + <field> + <id>FILENAME</id> + <enabled>Y</enabled> + <name>FILENAME</name> + </field> + <field> + <id>OBJECT_ID</id> + <enabled>Y</enabled> + <name>OBJECT_ID</name> + </field> + <field> + <id>OBJECT_REVISION</id> + <enabled>Y</enabled> + <name>OBJECT_REVISION</name> + </field> + <field> + <id>PARENT_CHANNEL_ID</id> + <enabled>Y</enabled> + <name>PARENT_CHANNEL_ID</name> + </field> + <field> + <id>ROOT_CHANNEL_ID</id> + <enabled>Y</enabled> + <name>ROOT_CHANNEL_ID</name> + </field> + </channel-log-table> + <step-log-table> + <connection /> + <schema /> + <table /> + <timeout_days /> + <field> + <id>ID_BATCH</id> + <enabled>Y</enabled> + <name>ID_BATCH</name> + </field> + <field> + <id>CHANNEL_ID</id> + <enabled>Y</enabled> + <name>CHANNEL_ID</name> + </field> + <field> + <id>LOG_DATE</id> + <enabled>Y</enabled> + <name>LOG_DATE</name> + </field> + <field> + <id>TRANSNAME</id> + <enabled>Y</enabled> + <name>TRANSNAME</name> + </field> + <field> + <id>STEPNAME</id> + <enabled>Y</enabled> + <name>STEPNAME</name> + </field> + <field> + <id>STEP_COPY</id> + <enabled>Y</enabled> + <name>STEP_COPY</name> + </field> + <field> + <id>LINES_READ</id> + <enabled>Y</enabled> + <name>LINES_READ</name> + </field> + <field> + <id>LINES_WRITTEN</id> + <enabled>Y</enabled> + <name>LINES_WRITTEN</name> + </field> + <field> + <id>LINES_UPDATED</id> + <enabled>Y</enabled> + <name>LINES_UPDATED</name> + </field> + <field> + <id>LINES_INPUT</id> + <enabled>Y</enabled> + <name>LINES_INPUT</name> + </field> + <field> + <id>LINES_OUTPUT</id> + <enabled>Y</enabled> + <name>LINES_OUTPUT</name> + </field> + <field> + <id>LINES_REJECTED</id> + <enabled>Y</enabled> + <name>LINES_REJECTED</name> + </field> + <field> + <id>ERRORS</id> + <enabled>Y</enabled> + <name>ERRORS</name> + </field> + <field> + <id>LOG_FIELD</id> + <enabled>N</enabled> + <name>LOG_FIELD</name> + </field> + </step-log-table> + <metrics-log-table> + <connection /> + <schema /> + <table /> + <timeout_days /> + <field> + <id>ID_BATCH</id> + <enabled>Y</enabled> + <name>ID_BATCH</name> + </field> + <field> + <id>CHANNEL_ID</id> + <enabled>Y</enabled> + <name>CHANNEL_ID</name> + </field> + <field> + <id>LOG_DATE</id> + <enabled>Y</enabled> + <name>LOG_DATE</name> + </field> + <field> + <id>METRICS_DATE</id> + <enabled>Y</enabled> + <name>METRICS_DATE</name> + </field> + <field> + <id>METRICS_CODE</id> + <enabled>Y</enabled> + <name>METRICS_CODE</name> + </field> + <field> + <id>METRICS_DESCRIPTION</id> + <enabled>Y</enabled> + <name>METRICS_DESCRIPTION</name> + </field> + <field> + <id>METRICS_SUBJECT</id> + <enabled>Y</enabled> + <name>METRICS_SUBJECT</name> + </field> + <field> + <id>METRICS_TYPE</id> + <enabled>Y</enabled> + <name>METRICS_TYPE</name> + </field> + <field> + <id>METRICS_VALUE</id> + <enabled>Y</enabled> + <name>METRICS_VALUE</name> + </field> + </metrics-log-table> + </log> + <maxdate> + <connection /> + <table /> + <field /> + <offset>0.0</offset> + <maxdiff>0.0</maxdiff> + </maxdate> + <size_rowset>10000</size_rowset> + <sleep_time_empty>50</sleep_time_empty> + <sleep_time_full>50</sleep_time_full> + <unique_connections>N</unique_connections> + <feedback_shown>Y</feedback_shown> + <feedback_size>50000</feedback_size> + <using_thread_priorities>Y</using_thread_priorities> + <shared_objects_file /> + <capture_step_performance>N</capture_step_performance> + <step_performance_capturing_delay>1000</step_performance_capturing_delay> + <step_performance_capturing_size_limit>100</step_performance_capturing_size_limit> + <dependencies> + </dependencies> + <partitionschemas> + </partitionschemas> + <slaveservers> + </slaveservers> + <clusterschemas> + </clusterschemas> + <created_user /> + <created_date>2020/10/23 12:46:09.658</created_date> + <modified_user>admin</modified_user> + <modified_date>2020/09/18 17:02:51.136</modified_date> + <key_for_session_key>H4sIAAAAAAAAAAMAAAAAAAAAAAA=</key_for_session_key> + <is_key_private>N</is_key_private> + </info> + <notepads> + </notepads> + <connection> + <name>intelligent_monitor_test_greenplum</name> + <server>59.52.24.124</server> + <type>POSTGRESQL</type> + <access>Native</access> + <database>intelligent_monitor_test</database> + <port>5432</port> + <username>yuejuan</username> + <password>Encrypted 2be98afc86ade8781a10caf7efe98bbc3</password> + <servername /> + <data_tablespace /> + <index_tablespace /> + <attributes> + <attribute> + <code>FORCE_IDENTIFIERS_TO_LOWERCASE</code> + <attribute>N</attribute> + </attribute> + <attribute> + <code>FORCE_IDENTIFIERS_TO_UPPERCASE</code> + <attribute>N</attribute> + </attribute> + <attribute> + <code>IS_CLUSTERED</code> + <attribute>N</attribute> + </attribute> + <attribute> + <code>PORT_NUMBER</code> + <attribute>5432</attribute> + </attribute> + <attribute> + <code>PRESERVE_RESERVED_WORD_CASE</code> + <attribute>Y</attribute> + </attribute> + <attribute> + <code>QUOTE_ALL_FIELDS</code> + <attribute>N</attribute> + </attribute> + <attribute> + <code>SUPPORTS_BOOLEAN_DATA_TYPE</code> + <attribute>Y</attribute> + </attribute> + <attribute> + <code>SUPPORTS_TIMESTAMP_DATA_TYPE</code> + <attribute>Y</attribute> + </attribute> + <attribute> + <code>USE_POOLING</code> + <attribute>N</attribute> + </attribute> + </attributes> + </connection> + <order> + </order> + <step> + <name>monitor_exam</name> + <type>ExecSQL</type> + <description /> + <distribute>Y</distribute> + <custom_distribution /> + <copies>1</copies> + <partitioning> + <method>none</method> + <schema_name /> + </partitioning> + <connection>intelligent_monitor_test_greenplum</connection> + <execute_each_row>N</execute_each_row> + <single_statement>Y</single_statement> + <replace_variables>Y</replace_variables> + <quoteString>N</quoteString> + <sql>insert into yuejuan_data_screen.gp_monitor_exam (exam_id,source_type,etl_date) +values (${exam_id},3,current_date)</sql> + <set_params>N</set_params> + <insert_field /> + <update_field /> + <delete_field /> + <read_field /> + <arguments> + </arguments> + <attributes /> + <cluster_schema /> + <remotesteps> + <input> + </input> + <output> + </output> + </remotesteps> + <GUI> + <xloc>202</xloc> + <yloc>112</yloc> + <draw>Y</draw> + </GUI> + </step> + <step_error_handling> + </step_error_handling> + <slave-step-copy-partition-distribution> + </slave-step-copy-partition-distribution> + <slave_transformation>N</slave_transformation> + <attributes /> +</transformation> -- libgit2 0.26.0