123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439440441442443444445446447448449450451452453454455456457458459460461462463464465466467468469470471472473474475476477478479480481482483484485486487488489490491492493494495496497498499500501502503504505506507508509510511512513514515516517518519520521522523524525526527528529530531532533534535536537538539540541542543544545546547548549550551552553554555556557558559560561562563564565566567568569570571572573574575576577578579580581582583584585586587588589590591592593594595596597598599600601602603604605606607608609610611612613614615616617618619620621622623624625626627628629630631632633634635636637638639640641642643644645646647648649650651652653654655656657658659660661662663664665666667668669670671672673674675676677678679680681682683684685686687688689690691692693694695696697698699700701702703704705706707708709710711712713714715716717718719720721722723724725726727728729730731732733734735736737738739740741742743744745746747748749750751752753754755756757758759760761762763764765766767768769770771772773774775776777778779780781782783784785786787788789790791792793794795796797798799800801802803804805806807808809810811812813814815816817818819820821822823824825826827828829830831832833834835836837838839840841842843844845846847848849850851852853854855856857858859860861862863864865866867868869870871872873874875876877878879880881882883884885886887888889890891892893894895896897898899900901902903904905906907908909910911912913914915916917918919920921922923924925926927928929930931932933934935936937938939940941942943944945946947948949950951952953954955956957958959960961962963964965966967968969970971972973974975976977978979980981982983984985986987988989990991992993994995996997998999100010011002100310041005100610071008100910101011101210131014101510161017101810191020102110221023102410251026102710281029103010311032103310341035103610371038103910401041104210431044104510461047104810491050105110521053105410551056105710581059106010611062106310641065106610671068106910701071107210731074107510761077107810791080108110821083108410851086108710881089109010911092109310941095109610971098109911001101110211031104110511061107110811091110111111121113111411151116111711181119112011211122112311241125112611271128112911301131113211331134113511361137113811391140114111421143114411451146114711481149115011511152115311541155115611571158115911601161116211631164116511661167116811691170117111721173117411751176117711781179118011811182118311841185118611871188118911901191119211931194119511961197119811991200120112021203120412051206120712081209121012111212121312141215121612171218121912201221122212231224122512261227 |
- <?xml version="1.0" encoding="UTF-8"?>
- <transformation>
- <info>
- <name>mem_memberbase_query_perday_page</name>
- <description/>
- <extended_description/>
- <trans_version/>
- <trans_type>Normal</trans_type>
- <trans_status>0</trans_status>
- <directory>/</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>2</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_user>
- <created_date>2019/05/26 19:55:18.893</created_date>
- <modified_user>-</modified_user>
- <modified_date>2019/05/26 19:55:18.893</modified_date>
- <key_for_session_key>H4sIAAAAAAAAAAMAAAAAAAAAAAA=</key_for_session_key>
- <is_key_private>N</is_key_private>
- </info>
- <notepads>
- </notepads>
- <connection>
- <name>mall</name>
- <server>192.168.50.32</server>
- <type>MSSQLNATIVE</type>
- <access>Native</access>
- <database>Mall</database>
- <port>1433</port>
- <username>sa</username>
- <password>Encrypted 2be98afc86aa7f297aa15a478c7d38f99</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>INITIAL_POOL_SIZE</code>
- <attribute>30</attribute>
- </attribute>
- <attribute>
- <code>IS_CLUSTERED</code>
- <attribute>N</attribute>
- </attribute>
- <attribute>
- <code>MAXIMUM_POOL_SIZE</code>
- <attribute>1000</attribute>
- </attribute>
- <attribute>
- <code>MSSQLUseIntegratedSecurity</code>
- <attribute>false</attribute>
- </attribute>
- <attribute>
- <code>MSSQL_DOUBLE_DECIMAL_SEPARATOR</code>
- <attribute>N</attribute>
- </attribute>
- <attribute>
- <code>PORT_NUMBER</code>
- <attribute>1433</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>Y</attribute>
- </attribute>
- </attributes>
- </connection>
- <order>
- <hop>
- <from>表输入</from>
- <to>Java 代码</to>
- <enabled>Y</enabled>
- </hop>
- <hop>
- <from>Java 代码</from>
- <to>Elasticsearch bulk insert 2</to>
- <enabled>Y</enabled>
- </hop>
- <hop>
- <from>表输入 2</from>
- <to>Java 代码</to>
- <enabled>Y</enabled>
- </hop>
- <hop>
- <from>表输入 3</from>
- <to>Java 代码</to>
- <enabled>Y</enabled>
- </hop>
- </order>
- <step>
- <name>Elasticsearch bulk insert 2</name>
- <type>ElasticSearchBulk</type>
- <description/>
- <distribute>Y</distribute>
- <custom_distribution/>
- <copies>1</copies>
- <partitioning>
- <method>none</method>
- <schema_name/>
- </partitioning>
- <general>
- <index>crm_memberbase_phoneid</index>
- <type>_doc</type>
- <batchSize>150</batchSize>
- <timeout>100</timeout>
- <timeoutUnit>SECONDS</timeoutUnit>
- <isJson>N</isJson>
- <idField>PhoneId</idField>
- <overwriteIfExists>N</overwriteIfExists>
- <useOutput>N</useOutput>
- <stopOnError>N</stopOnError>
- </general>
- <fields>
- <field>
- <columnName>HasOrder</columnName>
- <targetName>HasOrder</targetName>
- </field>
- <field>
- <columnName>MemDesc</columnName>
- <targetName>MemDesc</targetName>
- </field>
- <field>
- <columnName>MemEmail</columnName>
- <targetName>MemEmail</targetName>
- </field>
- <field>
- <columnName>MemPhone1</columnName>
- <targetName>MemPhone1</targetName>
- </field>
- <field>
- <columnName>MemPhone2</columnName>
- <targetName>MemPhone2</targetName>
- </field>
- <field>
- <columnName>MemPhone3</columnName>
- <targetName>MemPhone3</targetName>
- </field>
- <field>
- <columnName>MemUsualAddress</columnName>
- <targetName>MemUsualAddress</targetName>
- </field>
- <field>
- <columnName>MemUsualAreaCode</columnName>
- <targetName>MemUsualAreaCode</targetName>
- </field>
- <field>
- <columnName>MemUsualCityCode</columnName>
- <targetName>MemUsualCityCode</targetName>
- </field>
- <field>
- <columnName>MemUsualPhone</columnName>
- <targetName>MemUsualPhone</targetName>
- </field>
- <field>
- <columnName>MemUsualProvinceCode</columnName>
- <targetName>MemUsualProvinceCode</targetName>
- </field>
- <field>
- <columnName>MemberBirthday</columnName>
- <targetName>MemberBirthday</targetName>
- </field>
- <field>
- <columnName>MemberGender</columnName>
- <targetName>MemberGender</targetName>
- </field>
- <field>
- <columnName>MemberHeaPic</columnName>
- <targetName>MemberHeaPic</targetName>
- </field>
- <field>
- <columnName>MemberId</columnName>
- <targetName>MemberId</targetName>
- </field>
- <field>
- <columnName>MemberKey</columnName>
- <targetName>MemberKey</targetName>
- </field>
- <field>
- <columnName>MemberNickName</columnName>
- <targetName>MemberNickName</targetName>
- </field>
- <field>
- <columnName>OrdersCode</columnName>
- <targetName>OrdersCode</targetName>
- </field>
- <field>
- <columnName>OriginType</columnName>
- <targetName>OriginType</targetName>
- </field>
- <field>
- <columnName>PhoneId</columnName>
- <targetName>PhoneId</targetName>
- </field>
- <field>
- <columnName>RegisterDay</columnName>
- <targetName>RegisterDay</targetName>
- </field>
- <field>
- <columnName>RegisterMonth</columnName>
- <targetName>RegisterMonth</targetName>
- </field>
- <field>
- <columnName>RegisterTime</columnName>
- <targetName>RegisterTime</targetName>
- </field>
- <field>
- <columnName>RegisterYear</columnName>
- <targetName>RegisterYear</targetName>
- </field>
- <field>
- <columnName>order_join_field</columnName>
- <targetName>order_join_field</targetName>
- </field>
- </fields>
- <servers>
- <server>
- <address>192.168.50.34</address>
- <port>9300</port>
- </server>
- </servers>
- <settings>
- <setting>
- <name>cluster.name</name>
- <value>es</value>
- </setting>
- <setting>
- <name>custom.aliase.source</name>
- <value>mem_memberbase_phoneid</value>
- </setting>
- <setting>
- <name>custom.fields.HasOrder</name>
- <value>{"type":"boolean"}</value>
- </setting>
- <setting>
- <name>custom.fields.MemDesc</name>
- <value>{"type":"text","analyzer": "ik_smart",
- "search_analyzer":"ik_smart","index":true}</value>
- </setting>
- <setting>
- <name>custom.fields.MemberBirthday</name>
- <value>{"type":"date","format":"yyyy-MM-dd HH:mm:ss||yyyy-MM-dd||strict_date_optional_time||epoch_millis"}</value>
- </setting>
- <setting>
- <name>custom.fields.RegisterTime</name>
- <value>{"type":"date","format":"yyyy-MM-dd HH:mm:ss||yyyy-MM-dd||strict_date_optional_time||epoch_millis"}</value>
- </setting>
- <setting>
- <name>custom.index.number_of_replicas</name>
- <value>1</value>
- </setting>
- <setting>
- <name>custom.index.number_of_shards</name>
- <value>11</value>
- </setting>
- </settings>
- <attributes/>
- <cluster_schema/>
- <remotesteps>
- <input>
- </input>
- <output>
- </output>
- </remotesteps>
- <GUI>
- <xloc>464</xloc>
- <yloc>32</yloc>
- <draw>Y</draw>
- </GUI>
- </step>
- <step>
- <name>Java 代码</name>
- <type>UserDefinedJavaClass</type>
- <description/>
- <distribute>Y</distribute>
- <custom_distribution/>
- <copies>1</copies>
- <partitioning>
- <method>none</method>
- <schema_name/>
- </partitioning>
- <definitions>
- <definition>
- <class_type>TRANSFORM_CLASS</class_type>
- <class_name>Processor</class_name>
- <class_source>import java.sql.*;
- import org.pentaho.di.core.database.*;
- import org.apache.http.HttpHost;
- import org.elasticsearch.ElasticsearchException;
- import org.elasticsearch.action.get.GetRequest;
- import org.elasticsearch.action.get.GetResponse;
- import org.elasticsearch.client.RestHighLevelClient;
- import org.elasticsearch.client.RequestOptions;
- import org.elasticsearch.client.RestClient;
- import org.elasticsearch.common.Strings;
- import org.elasticsearch.rest.RestStatus;
- import org.elasticsearch.search.fetch.subphase.FetchSourceContext;
- import org.elasticsearch.action.update.UpdateRequest;
- import org.elasticsearch.action.update.UpdateResponse;
- import org.elasticsearch.common.xcontent.XContentBuilder;
- import org.elasticsearch.common.xcontent.XContentFactory;
- import org.elasticsearch.script.Script;
- import java.lang.reflect.InvocationTargetException;
- import java.lang.reflect.Method;
- import com.microsoft.sqlserver.jdbc.SQLServerException;
- Database database = null;
- PreparedStatement stat = null;
- PreparedStatement stat1 = null;
- RestHighLevelClient client = new RestHighLevelClient(
- RestClient.builder(
- new HttpHost[]{new HttpHost("192.168.50.34", 9200, "http")}));
- Integer index = 0;
- public boolean processRow(StepMetaInterface smi, StepDataInterface sdi) throws KettleException
- {
- //logBasic("start---");
- String type = getVariable("type");
- String indexs = getVariable("index");
- //if (indexs != null) index = Integer.parseInt(indexs);
- Object[] r = getRow();
- if (r == null) {
-
- try {
- if (stat!=null) {
- stat.close();
- }
-
- if (stat1!=null) {
- stat1.close();
- }
- if (database!=null) {
- database.disconnect();
- }
- if(client!=null){
- client.close();
- }
- }
- catch(Exception e) {
- throw new KettleException(e);
- }
- setOutputDone();
- return false;
- }
- synchronized(this) {
- r = createOutputRow(r, data.outputRowMeta.size());
- //获取数据库名和表名
- String dbName = "MemberSqlServer";//getInputRowMeta().getString(r, "conname", null );
- String tablename = "DataImport_membase";//getInputRowMeta().getString(r, "tablename", null );
- String idname = "MemberKey";//getInputRowMeta().getString(r, "idname", null );
- String idname1 = "MemPhone1";//getInputRowMeta().getString(r, "idname", null );
- String idname2 = "MemPhone2";//getInputRowMeta().getString(r, "idname", null );
- String idname3 = "MemPhone3";//getInputRowMeta().getString(r, "idname", null );
- String sourceidname = "PhoneId";//getInputRowMeta().getString(r, "sourceidname", null );
- String sourcetablename = "Orders";//getInputRowMeta().getString(r, "sourcetablename", null );
- if (dbName==null||tablename==null) {
- throw new KettleException("Unable to find field with name "+tablename+" in the input row.");
- }
- //logBasic("table---"+tablename);
- if(database == null){
- //数据库连接
- DatabaseMeta databaseMeta=null;
- try {
- databaseMeta = getTransMeta().findDatabase(dbName);
- if (databaseMeta==null) {
- logError("A connection with name "+dbName+" could not be found!");
- setErrors(1);
- return false;
- }
- database = new Database(getTrans(), databaseMeta);
- database.connect();
- //logBasic("success!");
- } catch(Exception e) {
- logError("Connecting to database "+dbName+" failed.", e);
- setErrors(1);
- return false;
- }
- }
- //查询表数据
- try {
- RowMetaInterface idxRowMeta =data.outputRowMeta;
-
- int i=0;
- r = createOutputRow(r, data.outputRowMeta.size());
-
- //int index = getInputRowMeta().size();
-
- // Add the index name
- //
- String Id = idxRowMeta.getString(r, idname, null);
- String Id1 = idxRowMeta.getString(r, idname1, null);
- String Id2 = idxRowMeta.getString(r, idname2, null);
- String Id3 = idxRowMeta.getString(r, idname3, null);
- // Add the column name
-
- String DataId = idxRowMeta.getString(r, sourceidname, null);
-
-
- /*String sqlSelect = "select Id from "+tablename + " where DataId = '"+ DataId +"'";
- ResultSet resultSet = null;
- resultSet = database.openQuery(sqlSelect);
- Object[] idxRow = database.getRow(resultSet);
- if (database!=null) {
- database.closeQuery(resultSet);
- resultSet = null;
- }
- //if(idxRow != null){
- // return true;
- //}
- */
-
- Thread.sleep(100);
- /*
- //logBasic("idxRow--Id"+Id);
- //logBasic("idxRow--sourcetablename"+sourcetablename);
- //logBasic("idxRow--DataId"+DataId);
-
-
- GetRequest getRequest = new GetRequest(
- "crm_memberbase_phoneid", // Index
- "_doc", // /Type
- DataId); // Document id
- getRequest.fetchSourceContext(new FetchSourceContext(false)); // 禁用 _source 字段
- getRequest.storedFields(new String[]{"_none_"}); // 禁止存储任何字段
- boolean exists = client.exists(getRequest,RequestOptions.DEFAULT);
- //client.close();
- if(exists ){
- return true;
- }
- */
- //if(!exists && idxRow == null){
- // return true;
- //}
-
- /*
- //3.获得预处理对象
- String sql="insert into "+tablename+" values (?,?,?,?);";//begin tran t2; commit tran t2
- //logBasic("idxRow--database"+ database);
- index = index + 1;
- if(stat == null)
- stat = database.prepareSQL(sql);
- //logBasic("idxRow--database"+ stat);
- //stat.addBatch(sql);
- //4.SQL语句占位符设置实际参数
- stat.setString(1, Id);//索引参数1代表着sql中的第一个?号,也就是我需要将条件sid所对应的sname数据更新为“儿童玩具测试”
- stat.setString(2, sourcetablename);//索引参数2代表着sql中的第二个?号,也就是条件是sid为3
- stat.setString(3, DataId);//索引参数2代表着sql中的第二个?号,也就是条件是sid为3
- stat.setString(4, "phone1");
- //stat.setInt(5, index);
-
- //5.执行SQL语句
- boolean line = stat.execute();
- //int[] line = stat.executeBatch();
- //System.out.println("更新记录数"+ line);
- //6.释放资源
- //stat.close();
- setVariable("index",String.valueOf(index));
- */
- //Integer pn = Integer.parseInt(Id);
- //Integer curpageNum = Integer.parseInt(Id) % pagesize;
- //if(pn > 0 && curpageNum == 0){
- // setVariable("page",String.valueOf(page));
- //}
- //logBasic("idxRow--getVariable"+getVariable("page"));
- //logBasic("idxRow--curpageNum"+curpageNum);
- //logBasic("idxRow--length"+i);
-
-
-
- }
- catch(SQLServerException e) {
- return true;
- }catch(Exception e) {
-
- throw new KettleException(e);
- }
- //释放连接
- //if (database!=null) {
- // database.disconnect();
- //}
- // Send the row on to the next step.
- }
- putRow(data.outputRowMeta, r);
- return true;
- }</class_source>
- </definition>
- </definitions>
- <fields>
- </fields>
- <clear_result_fields>N</clear_result_fields>
- <info_steps/>
- <target_steps/>
- <usage_parameters/>
- <attributes/>
- <cluster_schema/>
- <remotesteps>
- <input>
- </input>
- <output>
- </output>
- </remotesteps>
- <GUI>
- <xloc>352</xloc>
- <yloc>16</yloc>
- <draw>Y</draw>
- </GUI>
- </step>
- <step>
- <name>表输入</name>
- <type>TableInput</type>
- <description/>
- <distribute>Y</distribute>
- <custom_distribution/>
- <copies>1</copies>
- <partitioning>
- <method>none</method>
- <schema_name/>
- </partitioning>
- <connection>mall</connection>
- <sql>select
- --ROW_NUMBER() over (order by OrderTime asc ) as MemberKey,
- 1 as MemberKey,
- case when sex= ''then 1 else sex end as MemberGender,
- '' as MemberHeaPic,
- Consignee as MemberNickName,
- null as MemberBirthday,
- dbo.DesDecryptFixKey('123456','123456e10adc3949ba59abbe56e057f20f883e',AConsigneePhone1) as PhoneId,
- dbo.DesDecryptFixKey('123456','123456e10adc3949ba59abbe56e057f20f883e',AConsigneePhone1) as MemUsualPhone,--电话号码
- case when AConsigneePhone1= '' then ''
- ELSE dbo.DesDecryptFixKey('123456','123456e10adc3949ba59abbe56e057f20f883e',AConsigneePhone1) end as MemPhone1,--
- case when AConsigneePhone2= '' then ''
- ELSE dbo.DesDecryptFixKey('123456','123456e10adc3949ba59abbe56e057f20f883e',AConsigneePhone2) end as MemPhone2,--
- case when AConsigneePhone3= '' then ''
- ELSE dbo.DesDecryptFixKey('123456','123456e10adc3949ba59abbe56e057f20f883e',AConsigneePhone3) end as MemPhone3,--
-
- case when ADeliveryAddress= '' then ''
- ELSE dbo.DesDecryptFixKey('123456','123456e10adc3949ba59abbe56e057f20f883e',ADeliveryAddress) end as MemUsualAddress,
- OriginType,
-
- ( select CONVERT(varchar(100), min(b.OrderTime), 20) from orders b where b.AConsigneePhone1=a.AConsigneePhone1
- and b.OrderTime!='1800/01/01 00:00:00'
- group by b.AConsigneePhone1
- )
- as RegisterTime,
- case when b0.Level= 3 then a.RegionCode else null end as MemUsualAreaCode,
- case when b1.Level= 2 then b.ParentCode else b.AreaCode end as MemUsualCityCode,
- case when c1.Level= 1 then c.ParentCode else c.AreaCode end as MemUsualProvinceCode
- ,'true' as HasOrder
- ,convert(varchar,datepart(year,getdate())) as RegisterYear
- ,convert(varchar,datepart(month,getdate())) as RegisterMonth
- ,convert(varchar,datepart(day,getdate())) as RegisterDay
- ,BuyUserId as MemberId
- ,OrdersCode
- ,'' as MemEmail
- ,'' as MemDesc
- ,'Member' as order_join_field
- from orders a
- left join Areamap b0 on b0.MappingCode=a.RegionCode
- left join AreaRegion b on b.AreaCode=a.RegionCode left join Areamap b1 on b1.MappingCode=b.ParentCode
- left join AreaRegion c on c.AreaCode=b.ParentCode left join Areamap c1 on c1.MappingCode=c.ParentCode
- where 1=1 and (a.AConsigneePhone1!= '' and a.AConsigneePhone1 is not null)
- and OrderTime>'2019-05-01 00:22:10'
- --and datediff(day,DATEADD(d,0,DATEDIFF(d,0,getdate())-21),OrderTime )>0
- --and AConsigneePhone1 in (
- --'0423F752B2D2AD0B473550BFE5FEA0AE','EEB4AB98536F6545C6CFDB35F978DAA2','996518B300E7E45E451BC4244799FFC9','18AAFDA225E18079D96E4B555C6FA0B3','818DA68D37C2918969736CF2A237C4A9','81F4601D958BE83AAD8616100C79108F','6D7361DB47D1E2EEE496C87DF06A0EC8','4E86D0A542AC090BBC25A111DC0666A0','18AF11B2567BA9C7AD6245626BB31BC9','F27A57F07A32709CFE74B6E7FA786FD3','086A73009D0013EBB1C478CC7B0FD12F','D07995C56FAF6397D1DB98F76204EB52','0E24B79BA1581333B9F06D3676C0CA64','67EF37A11980D8413374E138472F805B','64E6CCD18DA5488A474B6818AC00931D','ECF0974FD1AB5E5DFE761ED131FAA3E3','2B8D52A56FC4C2C4236F7C8CD01292BE','8D3314F80A83EAF8175ABB3672CBD7CC','F262784DB9E9252176A4B60AF654A2EC','D459D762D9E70F33194721F3FC2486B2','277375616683F8898B53DA4BB6C00438','00F902BE87871C2ADA10433144CB9F26','8097B72D91A133AF69C14EC181F4AB22','B412BCFF3767351B83C32484CD02F9C1','FA5108C230E3086603F226714B9C9AF2','C5DD26477A9CAAB3F01651233C272653','353FFD94515CD446D0DD22F3FC2E597E','7CED8EDDC54963E3139F14BD6B0F8641','8FC52187EA6A110ACCD4CB39EB3C5818','2EC8ED672FFBDEEA180DA466B76B38AC','DD31E235A35AAED95AF888D435F3DC47','3089BDEB1302CCA3619A9F49569F7B48','A39C6623271ABDB9F7F590543FC8057E','C529CE9490E26DD701539043E97E4BF8','EA35ED41C5A518715634ABFADE13B418','AE3ACFB96CC4EAC7D078AC09A6800FDC','3871D053F065EFBEAD600F33C636CDED','706BA31B06FE76728E001BCD47FD20BA','874C74568946B69D7FFB8AB335B65C33','ABC5625667D92349F1D7C5508FB975A9','64D7ED72C3EFBC0FE84D60EA24732417','4A39414F3F8BD22193D171A8ACC85B2C','7BDD4F56B12A818A5C173A17B1A6FB61','582E44926B1FBE3F0829348753F5BE24','EEA9F999433FC0EFB14B8F2FF393A3D6','E0DA009E7C441E1CC67AD7C3BC9E5927','2D037E57BFFABDF351EA646E7172A83F','E88D865B9E0C23448707C48F097FAFFA','8C4CC92F44D318DE27ED1803CDE0719A','9C0244F33187F34EA2B4AA8837EE2407','25E56D031E41BAA2585561E863AE3240','D62B7285ABD69A325866666FE8B1A211','041F49A973274CD46D88340492610836','55CC616C6267F7FFE6476E476A683B5B','D5F8294754A75ADA7F342254BECD8A36','72FEDECEC3573A85F1EF1E6D9168459F','A03BA4E861E08C2BD79014AACEB3457B','4F6D0500A89FB68AF57685751BF9FDD5','BB7A4324E327A17AC89E15A7E33B97D1','934DCB5E2CEDBE2F1BE2DF38E6B6FD21','CEAA74AD1FDBDF008D9303E8FAC9E58C','1DAE4B4EAB277D5C936F30D343669E8C','1E30EC2DB596EEA3F4075345313AD115','BB1F3A29FB1A7103B8456C6CCB4976C0','2EA2E7DC32064F9D2EBF9169B3B8B591','15FC5E0B1A7EA452E7850A941510B300','34950773FE2BB7AC1D238EFD747587DA','6698177B8F7DAEBA75FC9C74C7801082','486F95FCFF8784742535C89EECE12800','148B9F9220250C2D1AF3F18E8F4A7EFC','B5533EB90812BEC93350A70270A03543','3752A63527286C9549A5CDF0865FFFC8','1E7C72D95C9B3FD402C6705744AB19D7','36AC5937A03787B184BDE307231E2C45','661A29270751F08C48FA6ECBAB098668','97A8506E3BC4B9775E84ABF24FA8B5DF','5FDAB53E2C22942E71310FB030F00B7D','4093D2E26F44CD9E40D77BEBCAEA0E93','436E378BF7F5A53056B5900B67B49F62','832308EE1C5342C61B7C7F93152B4F6E','DA59338AF9229DE962CD20389F105F2D','57CB937F384116AC307430E400A5AB44','26922708241922654E119401117B1B94','25A811E19CC2E073909566BCD9D41361','EA3CB0E0ACBAFD16F50DB15602306E34','9901F0F13917C8CCE0352270BF2D0CD3','A39307DE9F3FB0190B98C527724F3B82','B8EDBB84091CC49A9AAFD251FCBDE7AF','4696EB55E911B7C24FFE7C3E65440072','3FCD315847A2F51E431857223432325E','201BD119927B3E06E39C05E75B3D9226','22B469D36AE35B57066305D87EFF8EA5','8B5F0F92E9E4B056B81D03519B7444C0','DEB97DEDBD570BEB7582F0E2AA03CC39','BD15992218632192AD7AFC515D9362FE','FC453359CA5378B600B36DA52F211251','663F850B4278422E5F8297179D1A576F','8696585F2EF20708D6EF342E294B8C1D','A395D12AF277D10EDAD439AC9AB08BCB','B7B2CD4DAA5DD09750ACD284D1992AA8','1779A33F6DA916B374FD714ABAE3FC18','3D28AC24BFC99A1550C75A4723FD46ECDE3E1974C7C408D872C1ABB463746192','0497493705B32E10CA97AD6C18710732','F270173F75C5DE0115062743D2EB7162','4FB7249A845C037D135FAFAA4F4C8035','E680E60C7BEE8A4E543E5641C5E7C802','3926C52407492CD87D7B957850C3EA3A','DB1EE0E9AB2D3E69E7C1522F169784DF','753BAF2406D831F3669E2D3A9D1D7F50','32D4F9F5ABAED2D54B6AFD9A5DDA3603','A92B24983AFF869AFCCB72BE4272FA20','B12D34376DA5676FB1188F1FB79D0E68','6EE25308B2AC781C3C1A728583DE2B27','39F4EAF971B477340CC238BD3129FA4A','631CEA72973147B759FDFFDFCF729558','6FF9FFCB9AB44C82C0ACCAD494549864','C40E83730FC4F81A33DA4A18DBD68A3B','6542F359BABB789F5CCE77325C609E8A','C69BDD440A2E1C55D21502DF8A66427A','1A819713BCF646541CBECC1887F5BF12','7245A7DDB91FC534BC2D0A4124DC115A','3466B4251F2B5B0EDED1A930405A9347','7B5A2B66DE344621B40882E1130CB0A2','E44DE94ECC5AF45103D2816BD557DACF','20DA5D3F0ED8B8361953876CAA7E618F','86896C4B29FC01CB20929AD02D1694C1','02E84A91CCCADD6BD315F6B1D86238C8','C0690FCB609433CC5338542019815072','FC8CC4CF43F997D0857C686CBA19BB78','8B79072AD66767252167F927A72A2ECB','E7BA3AFE24E5C46B2880B20EDF9F2814','D089136B015BFE0D6962C30A76B30397','DB167261B3048798706EB6FBCC2FC39A','F2C5ABD1FA6998E84B268718E2ECDE4E','3140AEE561B1B02B86D1149D871257DE','E787B20F2FA0441C3A337E9A8969A782','115DBE25E8A5CD08A28969A70E854034','61CB07B4C8D9C00FEC1BBA23DEC7894B','D4DBC7436582AD61B2F8709123D7B174','1613E515EE8D065C24001A8D4465FCA7','4F716E96C278C161AC984D5EE50CB9E9','1EE556430825950A2E9DDC81E4CE0857','A3AF63C59E2E37F4C4D3E5C8310F56D9','81A7D2CFC350FC946081CE1053844D8D','86B385A605CD471360C8BC118D7471E5','84AA28BB7153C39A4BFF0FF2E6CC9396','6D127E26B0280C66FFA70D4125371B7E','1674EC0D2026A13632CA672F2040D2A9','AAE4878B1960C904D8A19CF5221042E4','AF08B36889547EECD36D10CF20536279','4B7A89350213C12C0060B9AA8E06ECBE','7E907FEC97B8E10C4FEB77E2C92BE994','E93FE4F8AC12512BFF7E1307C18D483D','936CACC27696E6FED3CD47ED7C92E21C','30F64AD746EAE514D67A6B6C4CDECDBD','A065ADA7618F0560C2FCDB3A5703F4ED','F56F2D8477E79C9314B8E6CFBB516991','951C82B57831ADA7E30B34433B3D8648','9066B9B45E07E8DEC530DC808C73E8C9','1ED0B0E1EDF5D297C630D328AD7A323B','2EDCEB4B3369B08B3C67B66CBAD40116','3DA87AD9C4CD2B40EAC8EC27FCCF9408','9D7D1E92D68B24CB23B1BFD72C869B76','801FD14FB8F87640ED9C33193E30D983','D59E92E2F73A76DAE4D113FEC840BDE5','27EE2BB311B4209EBCF45A7E63D4028D','BFD94D45219AE8BFDFCC4C00E38B1CEE','6ABEDE3C15D40A8BB41B24170DFC765E','A0D798043917CA269ED76ADA26A20044','58F13DBC5CF59EEC90F19E70EBF8F4BC','7FB75D08E52EC0D379BC922749EC85EC','7F5097158F2882EA71A7B797B9718F08','312B3D5FC9B8B700424D6CAEDFD91E7E','E8722AED71CC6DD5A33DC9585BA80344','B9CC021D61995349476F46E8FFEB4E0D','B25FFAD1DDC8542A7CAAD0331C405C71','B1A1343DDDE78FE613C0C5A158F7C1C4','A53ADC4B9F1AC8618CBEA77BAACAC7F3','6C18608EC7A8BA88D0496A00CF711156','C767C3E9506F6E69ABEDD3A4F0E659F1','7F0A22B95B9A68B30D17DB07B1061EA1','CE1B88A69B7438D2231A74BACE309F12','E23CE33E9A39B32A1AACFB22BF943DE6','5ED3C490D43C210CC71A6A9AD75AA07C','66E793FF38F70C25D4E2F71CD2C15FA8','19A1E6D9411368BB808576246338172A','3D85B4F59411D2C1966451D7D169C4B4','3ADAF372B66AEB24E812BD0DFA40BDDC','1B1461AF3520DBB94F365BCF6C58DBEC','C9F14AF81CAB0766E5F385F76D9CC8E5','24C83A54492F7F92BC929E9CE2522161','4C6533B63414F3AB134C0F54C93FFC79','B672DD905B7337D7C8C165CC0B7F6282','EC2DC1B7285B63E95B7A9A1A586E00B5','D9D6F7CC155A3F01AF074AC32762E962','43E7A04E0260628DB2D923E6F2809F80','163F326D62390FE832C7DC7D31DFD0FE','7EF0F9855D9E5A2239672ED9D6CBD465','2F48FD445A7FB33D8CB9775D5B729B46','FEB6FD71EB9DA705687446BCF2380BF7','41663401F7E0096AE11E4760623CECC2','2032C9EADC95D3E915471052077A89CF','E3C6C365F30B112008CAE9DCBAEEC4C4','148B579D9F2C0E088431AE5A9C17F5FB','FECDCD7495FC501B706592B6C8FF92CE','3826222895D2DC548898560312666719','C60E8FD859276624C59BD9D8D7AEA56E','94D09FC7877AD3E0E476A3D43E9F90D6','BFBA3FA0B1114FB852432D5F953D77BB','183BC8E3D3452C2613D8BDF8F6E77BC5','D551CE55697416308D33E2F665FED2D426C9591C5C08933B15CC3D501B3B46E2','B1DC9AF9C1B2183A21F97E9DD119028D','8F25B71D6B9DED5107C600E5D4A4CCA8','6A1A3DC59F2B5CBFDF2038EAE704806B','16CB35A6A919B6A12B323928580277C4','D6EBD67E8BEEC2B442D475B0E753409E','9A3C1601FE78A76C13C97910A9E49FA6','4FB68069901C08B0502E5364965664CB','16559DC7CF7F430E4546740DFD4BB0F3','9FE33A926F39766B494E7D8299132455','7CB5B2BC8DA9E8FE6611E4A271D3069D','04262222623544E24457A3DB49F7287F','C2834F63C479220F76B7C3699839C3B3','0EC038F7C7F940DD23A391B69BD4D2CC','4C0CFBAE9095C1172A796DDC1C6EB0CB','50336EF5A905804B0FDA6CB5A30E2B1A','193BC933DECCFE1C5D2B4EA7FCCD4CFF','3D3A9F44184661254DA89F187B4B5EA6','29F066003D11A658D7E14335572D7E79','183BEC6770471275ABA7F1DF641A4A36','F5891A19FEE5EDA105702FDA96B0F9F2','F2D8152E78EA863E83521BB5BB165D28','B73728233E8311694FFA0357AC436874'
- --)
-
- order by OrderTime asc
- offset ((${mem_membase_page1}-1)*${mem_membase_pagesize1}) rows fetch NEXT (${mem_membase_pagesize1}) rows only
- --offset ((${page}-1)*${pagesize}) rows fetch NEXT (${pagesize}) rows only 60000
- --offset 25650 rows --fetch NEXT 10 rows only
- </sql>
- <limit>0</limit>
- <lookup/>
- <execute_each_row>N</execute_each_row>
- <variables_active>Y</variables_active>
- <lazy_conversion_active>N</lazy_conversion_active>
- <attributes/>
- <cluster_schema/>
- <remotesteps>
- <input>
- </input>
- <output>
- </output>
- </remotesteps>
- <GUI>
- <xloc>176</xloc>
- <yloc>32</yloc>
- <draw>Y</draw>
- </GUI>
- </step>
- <step>
- <name>表输入 2</name>
- <type>TableInput</type>
- <description/>
- <distribute>Y</distribute>
- <custom_distribution/>
- <copies>1</copies>
- <partitioning>
- <method>none</method>
- <schema_name/>
- </partitioning>
- <connection>mall</connection>
- <sql>select --ROW_NUMBER() over (order by OrderTime asc ) as MemberKey,
- 1 as MemberKey,
- case when sex= ''then 1 else sex end as MemberGender,
- '' as MemberHeaPic,
- Consignee as MemberNickName,
- null as MemberBirthday,
- dbo.DesDecryptFixKey('123456','123456e10adc3949ba59abbe56e057f20f883e',AConsigneePhone2) as PhoneId,
- dbo.DesDecryptFixKey('123456','123456e10adc3949ba59abbe56e057f20f883e',AConsigneePhone2) as MemUsualPhone,--电话号码
- case when AConsigneePhone1= '' then ''
- ELSE dbo.DesDecryptFixKey('123456','123456e10adc3949ba59abbe56e057f20f883e',AConsigneePhone1) end as MemPhone1,--
- case when AConsigneePhone2= '' then ''
- ELSE dbo.DesDecryptFixKey('123456','123456e10adc3949ba59abbe56e057f20f883e',AConsigneePhone2) end as MemPhone2,--
- case when AConsigneePhone3= '' then ''
- ELSE dbo.DesDecryptFixKey('123456','123456e10adc3949ba59abbe56e057f20f883e',AConsigneePhone3) end as MemPhone3,--
-
- case when ADeliveryAddress= '' then ''
- ELSE dbo.DesDecryptFixKey('123456','123456e10adc3949ba59abbe56e057f20f883e',ADeliveryAddress) end as MemUsualAddress,
- OriginType,
-
- ( select CONVERT(varchar(100), min(b.OrderTime), 20) from orders b where b.AConsigneePhone2=a.AConsigneePhone2
- and b.OrderTime!='1800/01/01 00:00:00'
- group by b.AConsigneePhone2
- )
- as RegisterTime,
- case when b0.Level= 3 then a.RegionCode else null end as MemUsualAreaCode,
- case when b1.Level= 2 then b.ParentCode else b.AreaCode end as MemUsualCityCode,
- case when c1.Level= 1 then c.ParentCode else c.AreaCode end as MemUsualProvinceCode
- ,'true' as HasOrder
- ,convert(varchar,datepart(year,getdate())) as RegisterYear
- ,convert(varchar,datepart(month,getdate())) as RegisterMonth
- ,convert(varchar,datepart(day,getdate())) as RegisterDay
- ,BuyUserId as MemberId
- ,OrdersCode
- ,'' as MemEmail
- ,'' as MemDesc
- ,'Member' as order_join_field
- from orders a
- left join Areamap b0 on b0.MappingCode=a.RegionCode
- left join AreaRegion b on b.AreaCode=a.RegionCode left join Areamap b1 on b1.MappingCode=b.ParentCode
- left join AreaRegion c on c.AreaCode=b.ParentCode left join Areamap c1 on c1.MappingCode=c.ParentCode
- where 1=1 and (a.AConsigneePhone2!= '' and a.AConsigneePhone2 is not null)
- and OrderTime>'2019-05-01 00:22:10'
- --and datediff(day,DATEADD(d,0,DATEDIFF(d,0,getdate())-21),OrderTime )>0
- --and a.AConsigneePhone2='642E18F7DA186FA6B34D9054C9B8F5A2'--mall.dbo.DesEncryptFixKey('123456','123456e10adc3949ba59abbe56e057f20f883e','15962631520')
- --and AConsigneePhone2 in (
- --'0423F752B2D2AD0B473550BFE5FEA0AE','EEB4AB98536F6545C6CFDB35F978DAA2','996518B300E7E45E451BC4244799FFC9','18AAFDA225E18079D96E4B555C6FA0B3','818DA68D37C2918969736CF2A237C4A9','81F4601D958BE83AAD8616100C79108F','6D7361DB47D1E2EEE496C87DF06A0EC8','4E86D0A542AC090BBC25A111DC0666A0','18AF11B2567BA9C7AD6245626BB31BC9','F27A57F07A32709CFE74B6E7FA786FD3','086A73009D0013EBB1C478CC7B0FD12F','D07995C56FAF6397D1DB98F76204EB52','0E24B79BA1581333B9F06D3676C0CA64','67EF37A11980D8413374E138472F805B','64E6CCD18DA5488A474B6818AC00931D','ECF0974FD1AB5E5DFE761ED131FAA3E3','2B8D52A56FC4C2C4236F7C8CD01292BE','8D3314F80A83EAF8175ABB3672CBD7CC','F262784DB9E9252176A4B60AF654A2EC','D459D762D9E70F33194721F3FC2486B2','277375616683F8898B53DA4BB6C00438','00F902BE87871C2ADA10433144CB9F26','8097B72D91A133AF69C14EC181F4AB22','B412BCFF3767351B83C32484CD02F9C1','FA5108C230E3086603F226714B9C9AF2','C5DD26477A9CAAB3F01651233C272653','353FFD94515CD446D0DD22F3FC2E597E','7CED8EDDC54963E3139F14BD6B0F8641','8FC52187EA6A110ACCD4CB39EB3C5818','2EC8ED672FFBDEEA180DA466B76B38AC','DD31E235A35AAED95AF888D435F3DC47','3089BDEB1302CCA3619A9F49569F7B48','A39C6623271ABDB9F7F590543FC8057E','C529CE9490E26DD701539043E97E4BF8','EA35ED41C5A518715634ABFADE13B418','AE3ACFB96CC4EAC7D078AC09A6800FDC','3871D053F065EFBEAD600F33C636CDED','706BA31B06FE76728E001BCD47FD20BA','874C74568946B69D7FFB8AB335B65C33','ABC5625667D92349F1D7C5508FB975A9','64D7ED72C3EFBC0FE84D60EA24732417','4A39414F3F8BD22193D171A8ACC85B2C','7BDD4F56B12A818A5C173A17B1A6FB61','582E44926B1FBE3F0829348753F5BE24','EEA9F999433FC0EFB14B8F2FF393A3D6','E0DA009E7C441E1CC67AD7C3BC9E5927','2D037E57BFFABDF351EA646E7172A83F','E88D865B9E0C23448707C48F097FAFFA','8C4CC92F44D318DE27ED1803CDE0719A','9C0244F33187F34EA2B4AA8837EE2407','25E56D031E41BAA2585561E863AE3240','D62B7285ABD69A325866666FE8B1A211','041F49A973274CD46D88340492610836','55CC616C6267F7FFE6476E476A683B5B','D5F8294754A75ADA7F342254BECD8A36','72FEDECEC3573A85F1EF1E6D9168459F','A03BA4E861E08C2BD79014AACEB3457B','4F6D0500A89FB68AF57685751BF9FDD5','BB7A4324E327A17AC89E15A7E33B97D1','934DCB5E2CEDBE2F1BE2DF38E6B6FD21','CEAA74AD1FDBDF008D9303E8FAC9E58C','1DAE4B4EAB277D5C936F30D343669E8C','1E30EC2DB596EEA3F4075345313AD115','BB1F3A29FB1A7103B8456C6CCB4976C0','2EA2E7DC32064F9D2EBF9169B3B8B591','15FC5E0B1A7EA452E7850A941510B300','34950773FE2BB7AC1D238EFD747587DA','6698177B8F7DAEBA75FC9C74C7801082','486F95FCFF8784742535C89EECE12800','148B9F9220250C2D1AF3F18E8F4A7EFC','B5533EB90812BEC93350A70270A03543','3752A63527286C9549A5CDF0865FFFC8','1E7C72D95C9B3FD402C6705744AB19D7','36AC5937A03787B184BDE307231E2C45','661A29270751F08C48FA6ECBAB098668','97A8506E3BC4B9775E84ABF24FA8B5DF','5FDAB53E2C22942E71310FB030F00B7D','4093D2E26F44CD9E40D77BEBCAEA0E93','436E378BF7F5A53056B5900B67B49F62','832308EE1C5342C61B7C7F93152B4F6E','DA59338AF9229DE962CD20389F105F2D','57CB937F384116AC307430E400A5AB44','26922708241922654E119401117B1B94','25A811E19CC2E073909566BCD9D41361','EA3CB0E0ACBAFD16F50DB15602306E34','9901F0F13917C8CCE0352270BF2D0CD3','A39307DE9F3FB0190B98C527724F3B82','B8EDBB84091CC49A9AAFD251FCBDE7AF','4696EB55E911B7C24FFE7C3E65440072','3FCD315847A2F51E431857223432325E','201BD119927B3E06E39C05E75B3D9226','22B469D36AE35B57066305D87EFF8EA5','8B5F0F92E9E4B056B81D03519B7444C0','DEB97DEDBD570BEB7582F0E2AA03CC39','BD15992218632192AD7AFC515D9362FE','FC453359CA5378B600B36DA52F211251','663F850B4278422E5F8297179D1A576F','8696585F2EF20708D6EF342E294B8C1D','A395D12AF277D10EDAD439AC9AB08BCB','B7B2CD4DAA5DD09750ACD284D1992AA8','1779A33F6DA916B374FD714ABAE3FC18','3D28AC24BFC99A1550C75A4723FD46ECDE3E1974C7C408D872C1ABB463746192','0497493705B32E10CA97AD6C18710732','F270173F75C5DE0115062743D2EB7162','4FB7249A845C037D135FAFAA4F4C8035','E680E60C7BEE8A4E543E5641C5E7C802','3926C52407492CD87D7B957850C3EA3A','DB1EE0E9AB2D3E69E7C1522F169784DF','753BAF2406D831F3669E2D3A9D1D7F50','32D4F9F5ABAED2D54B6AFD9A5DDA3603','A92B24983AFF869AFCCB72BE4272FA20','B12D34376DA5676FB1188F1FB79D0E68','6EE25308B2AC781C3C1A728583DE2B27','39F4EAF971B477340CC238BD3129FA4A','631CEA72973147B759FDFFDFCF729558','6FF9FFCB9AB44C82C0ACCAD494549864','C40E83730FC4F81A33DA4A18DBD68A3B','6542F359BABB789F5CCE77325C609E8A','C69BDD440A2E1C55D21502DF8A66427A','1A819713BCF646541CBECC1887F5BF12','7245A7DDB91FC534BC2D0A4124DC115A','3466B4251F2B5B0EDED1A930405A9347','7B5A2B66DE344621B40882E1130CB0A2','E44DE94ECC5AF45103D2816BD557DACF','20DA5D3F0ED8B8361953876CAA7E618F','86896C4B29FC01CB20929AD02D1694C1','02E84A91CCCADD6BD315F6B1D86238C8','C0690FCB609433CC5338542019815072','FC8CC4CF43F997D0857C686CBA19BB78','8B79072AD66767252167F927A72A2ECB','E7BA3AFE24E5C46B2880B20EDF9F2814','D089136B015BFE0D6962C30A76B30397','DB167261B3048798706EB6FBCC2FC39A','F2C5ABD1FA6998E84B268718E2ECDE4E','3140AEE561B1B02B86D1149D871257DE','E787B20F2FA0441C3A337E9A8969A782','115DBE25E8A5CD08A28969A70E854034','61CB07B4C8D9C00FEC1BBA23DEC7894B','D4DBC7436582AD61B2F8709123D7B174','1613E515EE8D065C24001A8D4465FCA7','4F716E96C278C161AC984D5EE50CB9E9','1EE556430825950A2E9DDC81E4CE0857','A3AF63C59E2E37F4C4D3E5C8310F56D9','81A7D2CFC350FC946081CE1053844D8D','86B385A605CD471360C8BC118D7471E5','84AA28BB7153C39A4BFF0FF2E6CC9396','6D127E26B0280C66FFA70D4125371B7E','1674EC0D2026A13632CA672F2040D2A9','AAE4878B1960C904D8A19CF5221042E4','AF08B36889547EECD36D10CF20536279','4B7A89350213C12C0060B9AA8E06ECBE','7E907FEC97B8E10C4FEB77E2C92BE994','E93FE4F8AC12512BFF7E1307C18D483D','936CACC27696E6FED3CD47ED7C92E21C','30F64AD746EAE514D67A6B6C4CDECDBD','A065ADA7618F0560C2FCDB3A5703F4ED','F56F2D8477E79C9314B8E6CFBB516991','951C82B57831ADA7E30B34433B3D8648','9066B9B45E07E8DEC530DC808C73E8C9','1ED0B0E1EDF5D297C630D328AD7A323B','2EDCEB4B3369B08B3C67B66CBAD40116','3DA87AD9C4CD2B40EAC8EC27FCCF9408','9D7D1E92D68B24CB23B1BFD72C869B76','801FD14FB8F87640ED9C33193E30D983','D59E92E2F73A76DAE4D113FEC840BDE5','27EE2BB311B4209EBCF45A7E63D4028D','BFD94D45219AE8BFDFCC4C00E38B1CEE','6ABEDE3C15D40A8BB41B24170DFC765E','A0D798043917CA269ED76ADA26A20044','58F13DBC5CF59EEC90F19E70EBF8F4BC','7FB75D08E52EC0D379BC922749EC85EC','7F5097158F2882EA71A7B797B9718F08','312B3D5FC9B8B700424D6CAEDFD91E7E','E8722AED71CC6DD5A33DC9585BA80344','B9CC021D61995349476F46E8FFEB4E0D','B25FFAD1DDC8542A7CAAD0331C405C71','B1A1343DDDE78FE613C0C5A158F7C1C4','A53ADC4B9F1AC8618CBEA77BAACAC7F3','6C18608EC7A8BA88D0496A00CF711156','C767C3E9506F6E69ABEDD3A4F0E659F1','7F0A22B95B9A68B30D17DB07B1061EA1','CE1B88A69B7438D2231A74BACE309F12','E23CE33E9A39B32A1AACFB22BF943DE6','5ED3C490D43C210CC71A6A9AD75AA07C','66E793FF38F70C25D4E2F71CD2C15FA8','19A1E6D9411368BB808576246338172A','3D85B4F59411D2C1966451D7D169C4B4','3ADAF372B66AEB24E812BD0DFA40BDDC','1B1461AF3520DBB94F365BCF6C58DBEC','C9F14AF81CAB0766E5F385F76D9CC8E5','24C83A54492F7F92BC929E9CE2522161','4C6533B63414F3AB134C0F54C93FFC79','B672DD905B7337D7C8C165CC0B7F6282','EC2DC1B7285B63E95B7A9A1A586E00B5','D9D6F7CC155A3F01AF074AC32762E962','43E7A04E0260628DB2D923E6F2809F80','163F326D62390FE832C7DC7D31DFD0FE','7EF0F9855D9E5A2239672ED9D6CBD465','2F48FD445A7FB33D8CB9775D5B729B46','FEB6FD71EB9DA705687446BCF2380BF7','41663401F7E0096AE11E4760623CECC2','2032C9EADC95D3E915471052077A89CF','E3C6C365F30B112008CAE9DCBAEEC4C4','148B579D9F2C0E088431AE5A9C17F5FB','FECDCD7495FC501B706592B6C8FF92CE','3826222895D2DC548898560312666719','C60E8FD859276624C59BD9D8D7AEA56E','94D09FC7877AD3E0E476A3D43E9F90D6','BFBA3FA0B1114FB852432D5F953D77BB','183BC8E3D3452C2613D8BDF8F6E77BC5','D551CE55697416308D33E2F665FED2D426C9591C5C08933B15CC3D501B3B46E2','B1DC9AF9C1B2183A21F97E9DD119028D','8F25B71D6B9DED5107C600E5D4A4CCA8','6A1A3DC59F2B5CBFDF2038EAE704806B','16CB35A6A919B6A12B323928580277C4','D6EBD67E8BEEC2B442D475B0E753409E','9A3C1601FE78A76C13C97910A9E49FA6','4FB68069901C08B0502E5364965664CB','16559DC7CF7F430E4546740DFD4BB0F3','9FE33A926F39766B494E7D8299132455','7CB5B2BC8DA9E8FE6611E4A271D3069D','04262222623544E24457A3DB49F7287F','C2834F63C479220F76B7C3699839C3B3','0EC038F7C7F940DD23A391B69BD4D2CC','4C0CFBAE9095C1172A796DDC1C6EB0CB','50336EF5A905804B0FDA6CB5A30E2B1A','193BC933DECCFE1C5D2B4EA7FCCD4CFF','3D3A9F44184661254DA89F187B4B5EA6','29F066003D11A658D7E14335572D7E79','183BEC6770471275ABA7F1DF641A4A36','F5891A19FEE5EDA105702FDA96B0F9F2','F2D8152E78EA863E83521BB5BB165D28','B73728233E8311694FFA0357AC436874'
- --)
- order by OrderTime asc
- offset ((${mem_membase_page2}-1)*${mem_membase_pagesize2}) rows fetch NEXT (${mem_membase_pagesize2}) rows only
- --offset ((${page}-1)*${pagesize}) rows fetch NEXT (${pagesize}) rows only 1680000
- --offset 23700 rows --fetch NEXT 10 rows only</sql>
- <limit>0</limit>
- <lookup/>
- <execute_each_row>N</execute_each_row>
- <variables_active>Y</variables_active>
- <lazy_conversion_active>N</lazy_conversion_active>
- <attributes/>
- <cluster_schema/>
- <remotesteps>
- <input>
- </input>
- <output>
- </output>
- </remotesteps>
- <GUI>
- <xloc>144</xloc>
- <yloc>96</yloc>
- <draw>Y</draw>
- </GUI>
- </step>
- <step>
- <name>表输入 3</name>
- <type>TableInput</type>
- <description/>
- <distribute>Y</distribute>
- <custom_distribution/>
- <copies>1</copies>
- <partitioning>
- <method>none</method>
- <schema_name/>
- </partitioning>
- <connection>mall</connection>
- <sql>select --ROW_NUMBER() over (order by OrderTime asc ) as MemberKey,
- 1 as MemberKey,
- case when sex= ''then 1 else sex end as MemberGender,
- '' as MemberHeaPic,
- Consignee as MemberNickName,
- null as MemberBirthday,
- dbo.DesDecryptFixKey('123456','123456e10adc3949ba59abbe56e057f20f883e',AConsigneePhone3) as PhoneId,
- dbo.DesDecryptFixKey('123456','123456e10adc3949ba59abbe56e057f20f883e',AConsigneePhone3) as MemUsualPhone,--电话号码
- case when AConsigneePhone1= '' then ''
- ELSE dbo.DesDecryptFixKey('123456','123456e10adc3949ba59abbe56e057f20f883e',AConsigneePhone1) end as MemPhone1,--
- case when AConsigneePhone2= '' then ''
- ELSE dbo.DesDecryptFixKey('123456','123456e10adc3949ba59abbe56e057f20f883e',AConsigneePhone2) end as MemPhone2,--
- case when AConsigneePhone3= '' then ''
- ELSE dbo.DesDecryptFixKey('123456','123456e10adc3949ba59abbe56e057f20f883e',AConsigneePhone3) end as MemPhone3,--
-
- case when ADeliveryAddress= '' then ''
- ELSE dbo.DesDecryptFixKey('123456','123456e10adc3949ba59abbe56e057f20f883e',ADeliveryAddress) end as MemUsualAddress,
- OriginType,
-
- ( select CONVERT(varchar(100), min(b.OrderTime), 20) from orders b where b.AConsigneePhone3=a.AConsigneePhone3
- and b.OrderTime!='1800/01/01 00:00:00'
- group by b.AConsigneePhone3
- )
- as RegisterTime,
- case when b0.Level= 3 then a.RegionCode else null end as MemUsualAreaCode,
- case when b1.Level= 2 then b.ParentCode else b.AreaCode end as MemUsualCityCode,
- case when c1.Level= 1 then c.ParentCode else c.AreaCode end as MemUsualProvinceCode
- ,'true' as HasOrder
- ,convert(varchar,datepart(year,getdate())) as RegisterYear
- ,convert(varchar,datepart(month,getdate())) as RegisterMonth
- ,convert(varchar,datepart(day,getdate())) as RegisterDay
- ,BuyUserId as MemberId
- ,OrdersCode
- ,'' as MemEmail
- ,'' as MemDesc
- ,'Member' as order_join_field
- from orders a
- left join Areamap b0 on b0.MappingCode=a.RegionCode
- left join AreaRegion b on b.AreaCode=a.RegionCode left join Areamap b1 on b1.MappingCode=b.ParentCode
- left join AreaRegion c on c.AreaCode=b.ParentCode left join Areamap c1 on c1.MappingCode=c.ParentCode
- where 1=1 and (a.AConsigneePhone3!= '' and a.AConsigneePhone3 is not null)
- and OrderTime>'2019-05-01 00:22:10'
- --and datediff(day,DATEADD(d,0,DATEDIFF(d,0,getdate())-21),OrderTime )>0
- --and AConsigneePhone3 in (
- --'0423F752B2D2AD0B473550BFE5FEA0AE','EEB4AB98536F6545C6CFDB35F978DAA2','996518B300E7E45E451BC4244799FFC9','18AAFDA225E18079D96E4B555C6FA0B3','818DA68D37C2918969736CF2A237C4A9','81F4601D958BE83AAD8616100C79108F','6D7361DB47D1E2EEE496C87DF06A0EC8','4E86D0A542AC090BBC25A111DC0666A0','18AF11B2567BA9C7AD6245626BB31BC9','F27A57F07A32709CFE74B6E7FA786FD3','086A73009D0013EBB1C478CC7B0FD12F','D07995C56FAF6397D1DB98F76204EB52','0E24B79BA1581333B9F06D3676C0CA64','67EF37A11980D8413374E138472F805B','64E6CCD18DA5488A474B6818AC00931D','ECF0974FD1AB5E5DFE761ED131FAA3E3','2B8D52A56FC4C2C4236F7C8CD01292BE','8D3314F80A83EAF8175ABB3672CBD7CC','F262784DB9E9252176A4B60AF654A2EC','D459D762D9E70F33194721F3FC2486B2','277375616683F8898B53DA4BB6C00438','00F902BE87871C2ADA10433144CB9F26','8097B72D91A133AF69C14EC181F4AB22','B412BCFF3767351B83C32484CD02F9C1','FA5108C230E3086603F226714B9C9AF2','C5DD26477A9CAAB3F01651233C272653','353FFD94515CD446D0DD22F3FC2E597E','7CED8EDDC54963E3139F14BD6B0F8641','8FC52187EA6A110ACCD4CB39EB3C5818','2EC8ED672FFBDEEA180DA466B76B38AC','DD31E235A35AAED95AF888D435F3DC47','3089BDEB1302CCA3619A9F49569F7B48','A39C6623271ABDB9F7F590543FC8057E','C529CE9490E26DD701539043E97E4BF8','EA35ED41C5A518715634ABFADE13B418','AE3ACFB96CC4EAC7D078AC09A6800FDC','3871D053F065EFBEAD600F33C636CDED','706BA31B06FE76728E001BCD47FD20BA','874C74568946B69D7FFB8AB335B65C33','ABC5625667D92349F1D7C5508FB975A9','64D7ED72C3EFBC0FE84D60EA24732417','4A39414F3F8BD22193D171A8ACC85B2C','7BDD4F56B12A818A5C173A17B1A6FB61','582E44926B1FBE3F0829348753F5BE24','EEA9F999433FC0EFB14B8F2FF393A3D6','E0DA009E7C441E1CC67AD7C3BC9E5927','2D037E57BFFABDF351EA646E7172A83F','E88D865B9E0C23448707C48F097FAFFA','8C4CC92F44D318DE27ED1803CDE0719A','9C0244F33187F34EA2B4AA8837EE2407','25E56D031E41BAA2585561E863AE3240','D62B7285ABD69A325866666FE8B1A211','041F49A973274CD46D88340492610836','55CC616C6267F7FFE6476E476A683B5B','D5F8294754A75ADA7F342254BECD8A36','72FEDECEC3573A85F1EF1E6D9168459F','A03BA4E861E08C2BD79014AACEB3457B','4F6D0500A89FB68AF57685751BF9FDD5','BB7A4324E327A17AC89E15A7E33B97D1','934DCB5E2CEDBE2F1BE2DF38E6B6FD21','CEAA74AD1FDBDF008D9303E8FAC9E58C','1DAE4B4EAB277D5C936F30D343669E8C','1E30EC2DB596EEA3F4075345313AD115','BB1F3A29FB1A7103B8456C6CCB4976C0','2EA2E7DC32064F9D2EBF9169B3B8B591','15FC5E0B1A7EA452E7850A941510B300','34950773FE2BB7AC1D238EFD747587DA','6698177B8F7DAEBA75FC9C74C7801082','486F95FCFF8784742535C89EECE12800','148B9F9220250C2D1AF3F18E8F4A7EFC','B5533EB90812BEC93350A70270A03543','3752A63527286C9549A5CDF0865FFFC8','1E7C72D95C9B3FD402C6705744AB19D7','36AC5937A03787B184BDE307231E2C45','661A29270751F08C48FA6ECBAB098668','97A8506E3BC4B9775E84ABF24FA8B5DF','5FDAB53E2C22942E71310FB030F00B7D','4093D2E26F44CD9E40D77BEBCAEA0E93','436E378BF7F5A53056B5900B67B49F62','832308EE1C5342C61B7C7F93152B4F6E','DA59338AF9229DE962CD20389F105F2D','57CB937F384116AC307430E400A5AB44','26922708241922654E119401117B1B94','25A811E19CC2E073909566BCD9D41361','EA3CB0E0ACBAFD16F50DB15602306E34','9901F0F13917C8CCE0352270BF2D0CD3','A39307DE9F3FB0190B98C527724F3B82','B8EDBB84091CC49A9AAFD251FCBDE7AF','4696EB55E911B7C24FFE7C3E65440072','3FCD315847A2F51E431857223432325E','201BD119927B3E06E39C05E75B3D9226','22B469D36AE35B57066305D87EFF8EA5','8B5F0F92E9E4B056B81D03519B7444C0','DEB97DEDBD570BEB7582F0E2AA03CC39','BD15992218632192AD7AFC515D9362FE','FC453359CA5378B600B36DA52F211251','663F850B4278422E5F8297179D1A576F','8696585F2EF20708D6EF342E294B8C1D','A395D12AF277D10EDAD439AC9AB08BCB','B7B2CD4DAA5DD09750ACD284D1992AA8','1779A33F6DA916B374FD714ABAE3FC18','3D28AC24BFC99A1550C75A4723FD46ECDE3E1974C7C408D872C1ABB463746192','0497493705B32E10CA97AD6C18710732','F270173F75C5DE0115062743D2EB7162','4FB7249A845C037D135FAFAA4F4C8035','E680E60C7BEE8A4E543E5641C5E7C802','3926C52407492CD87D7B957850C3EA3A','DB1EE0E9AB2D3E69E7C1522F169784DF','753BAF2406D831F3669E2D3A9D1D7F50','32D4F9F5ABAED2D54B6AFD9A5DDA3603','A92B24983AFF869AFCCB72BE4272FA20','B12D34376DA5676FB1188F1FB79D0E68','6EE25308B2AC781C3C1A728583DE2B27','39F4EAF971B477340CC238BD3129FA4A','631CEA72973147B759FDFFDFCF729558','6FF9FFCB9AB44C82C0ACCAD494549864','C40E83730FC4F81A33DA4A18DBD68A3B','6542F359BABB789F5CCE77325C609E8A','C69BDD440A2E1C55D21502DF8A66427A','1A819713BCF646541CBECC1887F5BF12','7245A7DDB91FC534BC2D0A4124DC115A','3466B4251F2B5B0EDED1A930405A9347','7B5A2B66DE344621B40882E1130CB0A2','E44DE94ECC5AF45103D2816BD557DACF','20DA5D3F0ED8B8361953876CAA7E618F','86896C4B29FC01CB20929AD02D1694C1','02E84A91CCCADD6BD315F6B1D86238C8','C0690FCB609433CC5338542019815072','FC8CC4CF43F997D0857C686CBA19BB78','8B79072AD66767252167F927A72A2ECB','E7BA3AFE24E5C46B2880B20EDF9F2814','D089136B015BFE0D6962C30A76B30397','DB167261B3048798706EB6FBCC2FC39A','F2C5ABD1FA6998E84B268718E2ECDE4E','3140AEE561B1B02B86D1149D871257DE','E787B20F2FA0441C3A337E9A8969A782','115DBE25E8A5CD08A28969A70E854034','61CB07B4C8D9C00FEC1BBA23DEC7894B','D4DBC7436582AD61B2F8709123D7B174','1613E515EE8D065C24001A8D4465FCA7','4F716E96C278C161AC984D5EE50CB9E9','1EE556430825950A2E9DDC81E4CE0857','A3AF63C59E2E37F4C4D3E5C8310F56D9','81A7D2CFC350FC946081CE1053844D8D','86B385A605CD471360C8BC118D7471E5','84AA28BB7153C39A4BFF0FF2E6CC9396','6D127E26B0280C66FFA70D4125371B7E','1674EC0D2026A13632CA672F2040D2A9','AAE4878B1960C904D8A19CF5221042E4','AF08B36889547EECD36D10CF20536279','4B7A89350213C12C0060B9AA8E06ECBE','7E907FEC97B8E10C4FEB77E2C92BE994','E93FE4F8AC12512BFF7E1307C18D483D','936CACC27696E6FED3CD47ED7C92E21C','30F64AD746EAE514D67A6B6C4CDECDBD','A065ADA7618F0560C2FCDB3A5703F4ED','F56F2D8477E79C9314B8E6CFBB516991','951C82B57831ADA7E30B34433B3D8648','9066B9B45E07E8DEC530DC808C73E8C9','1ED0B0E1EDF5D297C630D328AD7A323B','2EDCEB4B3369B08B3C67B66CBAD40116','3DA87AD9C4CD2B40EAC8EC27FCCF9408','9D7D1E92D68B24CB23B1BFD72C869B76','801FD14FB8F87640ED9C33193E30D983','D59E92E2F73A76DAE4D113FEC840BDE5','27EE2BB311B4209EBCF45A7E63D4028D','BFD94D45219AE8BFDFCC4C00E38B1CEE','6ABEDE3C15D40A8BB41B24170DFC765E','A0D798043917CA269ED76ADA26A20044','58F13DBC5CF59EEC90F19E70EBF8F4BC','7FB75D08E52EC0D379BC922749EC85EC','7F5097158F2882EA71A7B797B9718F08','312B3D5FC9B8B700424D6CAEDFD91E7E','E8722AED71CC6DD5A33DC9585BA80344','B9CC021D61995349476F46E8FFEB4E0D','B25FFAD1DDC8542A7CAAD0331C405C71','B1A1343DDDE78FE613C0C5A158F7C1C4','A53ADC4B9F1AC8618CBEA77BAACAC7F3','6C18608EC7A8BA88D0496A00CF711156','C767C3E9506F6E69ABEDD3A4F0E659F1','7F0A22B95B9A68B30D17DB07B1061EA1','CE1B88A69B7438D2231A74BACE309F12','E23CE33E9A39B32A1AACFB22BF943DE6','5ED3C490D43C210CC71A6A9AD75AA07C','66E793FF38F70C25D4E2F71CD2C15FA8','19A1E6D9411368BB808576246338172A','3D85B4F59411D2C1966451D7D169C4B4','3ADAF372B66AEB24E812BD0DFA40BDDC','1B1461AF3520DBB94F365BCF6C58DBEC','C9F14AF81CAB0766E5F385F76D9CC8E5','24C83A54492F7F92BC929E9CE2522161','4C6533B63414F3AB134C0F54C93FFC79','B672DD905B7337D7C8C165CC0B7F6282','EC2DC1B7285B63E95B7A9A1A586E00B5','D9D6F7CC155A3F01AF074AC32762E962','43E7A04E0260628DB2D923E6F2809F80','163F326D62390FE832C7DC7D31DFD0FE','7EF0F9855D9E5A2239672ED9D6CBD465','2F48FD445A7FB33D8CB9775D5B729B46','FEB6FD71EB9DA705687446BCF2380BF7','41663401F7E0096AE11E4760623CECC2','2032C9EADC95D3E915471052077A89CF','E3C6C365F30B112008CAE9DCBAEEC4C4','148B579D9F2C0E088431AE5A9C17F5FB','FECDCD7495FC501B706592B6C8FF92CE','3826222895D2DC548898560312666719','C60E8FD859276624C59BD9D8D7AEA56E','94D09FC7877AD3E0E476A3D43E9F90D6','BFBA3FA0B1114FB852432D5F953D77BB','183BC8E3D3452C2613D8BDF8F6E77BC5','D551CE55697416308D33E2F665FED2D426C9591C5C08933B15CC3D501B3B46E2','B1DC9AF9C1B2183A21F97E9DD119028D','8F25B71D6B9DED5107C600E5D4A4CCA8','6A1A3DC59F2B5CBFDF2038EAE704806B','16CB35A6A919B6A12B323928580277C4','D6EBD67E8BEEC2B442D475B0E753409E','9A3C1601FE78A76C13C97910A9E49FA6','4FB68069901C08B0502E5364965664CB','16559DC7CF7F430E4546740DFD4BB0F3','9FE33A926F39766B494E7D8299132455','7CB5B2BC8DA9E8FE6611E4A271D3069D','04262222623544E24457A3DB49F7287F','C2834F63C479220F76B7C3699839C3B3','0EC038F7C7F940DD23A391B69BD4D2CC','4C0CFBAE9095C1172A796DDC1C6EB0CB','50336EF5A905804B0FDA6CB5A30E2B1A','193BC933DECCFE1C5D2B4EA7FCCD4CFF','3D3A9F44184661254DA89F187B4B5EA6','29F066003D11A658D7E14335572D7E79','183BEC6770471275ABA7F1DF641A4A36','F5891A19FEE5EDA105702FDA96B0F9F2','F2D8152E78EA863E83521BB5BB165D28','B73728233E8311694FFA0357AC436874'
- --)
- order by OrderTime asc
- offset ((${mem_membase_page3}-1)*${mem_membase_pagesize3}) rows fetch NEXT (${mem_membase_pagesize3}) rows only
- --offset ((${page}-1)*${pagesize}) rows fetch NEXT (${pagesize}) rows only 200000
- --offset 8750 rows --fetch NEXT 10 rows only</sql>
- <limit>0</limit>
- <lookup/>
- <execute_each_row>N</execute_each_row>
- <variables_active>Y</variables_active>
- <lazy_conversion_active>N</lazy_conversion_active>
- <attributes/>
- <cluster_schema/>
- <remotesteps>
- <input>
- </input>
- <output>
- </output>
- </remotesteps>
- <GUI>
- <xloc>176</xloc>
- <yloc>176</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>
|