仓库数据同步.ktr 31 KB

1234567891011121314151617181920212223242526272829303132333435363738394041424344454647484950515253545556575859606162636465666768697071727374757677787980818283848586878889909192939495969798991001011021031041051061071081091101111121131141151161171181191201211221231241251261271281291301311321331341351361371381391401411421431441451461471481491501511521531541551561571581591601611621631641651661671681691701711721731741751761771781791801811821831841851861871881891901911921931941951961971981992002012022032042052062072082092102112122132142152162172182192202212222232242252262272282292302312322332342352362372382392402412422432442452462472482492502512522532542552562572582592602612622632642652662672682692702712722732742752762772782792802812822832842852862872882892902912922932942952962972982993003013023033043053063073083093103113123133143153163173183193203213223233243253263273283293303313323333343353363373383393403413423433443453463473483493503513523533543553563573583593603613623633643653663673683693703713723733743753763773783793803813823833843853863873883893903913923933943953963973983994004014024034044054064074084094104114124134144154164174184194204214224234244254264274284294304314324334344354364374384394404414424434444454464474484494504514524534544554564574584594604614624634644654664674684694704714724734744754764774784794804814824834844854864874884894904914924934944954964974984995005015025035045055065075085095105115125135145155165175185195205215225235245255265275285295305315325335345355365375385395405415425435445455465475485495505515525535545555565575585595605615625635645655665675685695705715725735745755765775785795805815825835845855865875885895905915925935945955965975985996006016026036046056066076086096106116126136146156166176186196206216226236246256266276286296306316326336346356366376386396406416426436446456466476486496506516526536546556566576586596606616626636646656666676686696706716726736746756766776786796806816826836846856866876886896906916926936946956966976986997007017027037047057067077087097107117127137147157167177187197207217227237247257267277287297307317327337347357367377387397407417427437447457467477487497507517527537547557567577587597607617627637647657667677687697707717727737747757767777787797807817827837847857867877887897907917927937947957967977987998008018028038048058068078088098108118128138148158168178188198208218228238248258268278288298308318328338348358368378388398408418428438448458468478488498508518528538548558568578588598608618628638648658668678688698708718728738748758768778788798808818828838848858868878888898908918928938948958968978988999009019029039049059069079089099109119129139149159169179189199209219229239249259269279289299309319329339349359369379389399409419429439449459469479489499509519529539549559569579589599609619629639649659669679689699709719729739749759769779789799809819829839849859869879889899909919929939949959969979989991000100110021003100410051006100710081009101010111012101310141015101610171018101910201021102210231024102510261027102810291030103110321033103410351036103710381039104010411042104310441045104610471048104910501051105210531054105510561057105810591060106110621063106410651066106710681069107010711072107310741075107610771078107910801081108210831084108510861087108810891090109110921093109410951096109710981099110011011102110311041105
  1. <?xml version="1.0" encoding="UTF-8"?>
  2. <transformation>
  3. <info>
  4. <name>仓库数据同步</name>
  5. <description/>
  6. <extended_description/>
  7. <trans_version/>
  8. <trans_type>Normal</trans_type>
  9. <trans_status>0</trans_status>
  10. <directory>/</directory>
  11. <parameters>
  12. </parameters>
  13. <log>
  14. <trans-log-table>
  15. <connection/>
  16. <schema/>
  17. <table/>
  18. <size_limit_lines/>
  19. <interval/>
  20. <timeout_days/>
  21. <field>
  22. <id>ID_BATCH</id>
  23. <enabled>Y</enabled>
  24. <name>ID_BATCH</name>
  25. </field>
  26. <field>
  27. <id>CHANNEL_ID</id>
  28. <enabled>Y</enabled>
  29. <name>CHANNEL_ID</name>
  30. </field>
  31. <field>
  32. <id>TRANSNAME</id>
  33. <enabled>Y</enabled>
  34. <name>TRANSNAME</name>
  35. </field>
  36. <field>
  37. <id>STATUS</id>
  38. <enabled>Y</enabled>
  39. <name>STATUS</name>
  40. </field>
  41. <field>
  42. <id>LINES_READ</id>
  43. <enabled>Y</enabled>
  44. <name>LINES_READ</name>
  45. <subject/>
  46. </field>
  47. <field>
  48. <id>LINES_WRITTEN</id>
  49. <enabled>Y</enabled>
  50. <name>LINES_WRITTEN</name>
  51. <subject/>
  52. </field>
  53. <field>
  54. <id>LINES_UPDATED</id>
  55. <enabled>Y</enabled>
  56. <name>LINES_UPDATED</name>
  57. <subject/>
  58. </field>
  59. <field>
  60. <id>LINES_INPUT</id>
  61. <enabled>Y</enabled>
  62. <name>LINES_INPUT</name>
  63. <subject/>
  64. </field>
  65. <field>
  66. <id>LINES_OUTPUT</id>
  67. <enabled>Y</enabled>
  68. <name>LINES_OUTPUT</name>
  69. <subject/>
  70. </field>
  71. <field>
  72. <id>LINES_REJECTED</id>
  73. <enabled>Y</enabled>
  74. <name>LINES_REJECTED</name>
  75. <subject/>
  76. </field>
  77. <field>
  78. <id>ERRORS</id>
  79. <enabled>Y</enabled>
  80. <name>ERRORS</name>
  81. </field>
  82. <field>
  83. <id>STARTDATE</id>
  84. <enabled>Y</enabled>
  85. <name>STARTDATE</name>
  86. </field>
  87. <field>
  88. <id>ENDDATE</id>
  89. <enabled>Y</enabled>
  90. <name>ENDDATE</name>
  91. </field>
  92. <field>
  93. <id>LOGDATE</id>
  94. <enabled>Y</enabled>
  95. <name>LOGDATE</name>
  96. </field>
  97. <field>
  98. <id>DEPDATE</id>
  99. <enabled>Y</enabled>
  100. <name>DEPDATE</name>
  101. </field>
  102. <field>
  103. <id>REPLAYDATE</id>
  104. <enabled>Y</enabled>
  105. <name>REPLAYDATE</name>
  106. </field>
  107. <field>
  108. <id>LOG_FIELD</id>
  109. <enabled>Y</enabled>
  110. <name>LOG_FIELD</name>
  111. </field>
  112. <field>
  113. <id>EXECUTING_SERVER</id>
  114. <enabled>N</enabled>
  115. <name>EXECUTING_SERVER</name>
  116. </field>
  117. <field>
  118. <id>EXECUTING_USER</id>
  119. <enabled>N</enabled>
  120. <name>EXECUTING_USER</name>
  121. </field>
  122. <field>
  123. <id>CLIENT</id>
  124. <enabled>N</enabled>
  125. <name>CLIENT</name>
  126. </field>
  127. </trans-log-table>
  128. <perf-log-table>
  129. <connection/>
  130. <schema/>
  131. <table/>
  132. <interval/>
  133. <timeout_days/>
  134. <field>
  135. <id>ID_BATCH</id>
  136. <enabled>Y</enabled>
  137. <name>ID_BATCH</name>
  138. </field>
  139. <field>
  140. <id>SEQ_NR</id>
  141. <enabled>Y</enabled>
  142. <name>SEQ_NR</name>
  143. </field>
  144. <field>
  145. <id>LOGDATE</id>
  146. <enabled>Y</enabled>
  147. <name>LOGDATE</name>
  148. </field>
  149. <field>
  150. <id>TRANSNAME</id>
  151. <enabled>Y</enabled>
  152. <name>TRANSNAME</name>
  153. </field>
  154. <field>
  155. <id>STEPNAME</id>
  156. <enabled>Y</enabled>
  157. <name>STEPNAME</name>
  158. </field>
  159. <field>
  160. <id>STEP_COPY</id>
  161. <enabled>Y</enabled>
  162. <name>STEP_COPY</name>
  163. </field>
  164. <field>
  165. <id>LINES_READ</id>
  166. <enabled>Y</enabled>
  167. <name>LINES_READ</name>
  168. </field>
  169. <field>
  170. <id>LINES_WRITTEN</id>
  171. <enabled>Y</enabled>
  172. <name>LINES_WRITTEN</name>
  173. </field>
  174. <field>
  175. <id>LINES_UPDATED</id>
  176. <enabled>Y</enabled>
  177. <name>LINES_UPDATED</name>
  178. </field>
  179. <field>
  180. <id>LINES_INPUT</id>
  181. <enabled>Y</enabled>
  182. <name>LINES_INPUT</name>
  183. </field>
  184. <field>
  185. <id>LINES_OUTPUT</id>
  186. <enabled>Y</enabled>
  187. <name>LINES_OUTPUT</name>
  188. </field>
  189. <field>
  190. <id>LINES_REJECTED</id>
  191. <enabled>Y</enabled>
  192. <name>LINES_REJECTED</name>
  193. </field>
  194. <field>
  195. <id>ERRORS</id>
  196. <enabled>Y</enabled>
  197. <name>ERRORS</name>
  198. </field>
  199. <field>
  200. <id>INPUT_BUFFER_ROWS</id>
  201. <enabled>Y</enabled>
  202. <name>INPUT_BUFFER_ROWS</name>
  203. </field>
  204. <field>
  205. <id>OUTPUT_BUFFER_ROWS</id>
  206. <enabled>Y</enabled>
  207. <name>OUTPUT_BUFFER_ROWS</name>
  208. </field>
  209. </perf-log-table>
  210. <channel-log-table>
  211. <connection/>
  212. <schema/>
  213. <table/>
  214. <timeout_days/>
  215. <field>
  216. <id>ID_BATCH</id>
  217. <enabled>Y</enabled>
  218. <name>ID_BATCH</name>
  219. </field>
  220. <field>
  221. <id>CHANNEL_ID</id>
  222. <enabled>Y</enabled>
  223. <name>CHANNEL_ID</name>
  224. </field>
  225. <field>
  226. <id>LOG_DATE</id>
  227. <enabled>Y</enabled>
  228. <name>LOG_DATE</name>
  229. </field>
  230. <field>
  231. <id>LOGGING_OBJECT_TYPE</id>
  232. <enabled>Y</enabled>
  233. <name>LOGGING_OBJECT_TYPE</name>
  234. </field>
  235. <field>
  236. <id>OBJECT_NAME</id>
  237. <enabled>Y</enabled>
  238. <name>OBJECT_NAME</name>
  239. </field>
  240. <field>
  241. <id>OBJECT_COPY</id>
  242. <enabled>Y</enabled>
  243. <name>OBJECT_COPY</name>
  244. </field>
  245. <field>
  246. <id>REPOSITORY_DIRECTORY</id>
  247. <enabled>Y</enabled>
  248. <name>REPOSITORY_DIRECTORY</name>
  249. </field>
  250. <field>
  251. <id>FILENAME</id>
  252. <enabled>Y</enabled>
  253. <name>FILENAME</name>
  254. </field>
  255. <field>
  256. <id>OBJECT_ID</id>
  257. <enabled>Y</enabled>
  258. <name>OBJECT_ID</name>
  259. </field>
  260. <field>
  261. <id>OBJECT_REVISION</id>
  262. <enabled>Y</enabled>
  263. <name>OBJECT_REVISION</name>
  264. </field>
  265. <field>
  266. <id>PARENT_CHANNEL_ID</id>
  267. <enabled>Y</enabled>
  268. <name>PARENT_CHANNEL_ID</name>
  269. </field>
  270. <field>
  271. <id>ROOT_CHANNEL_ID</id>
  272. <enabled>Y</enabled>
  273. <name>ROOT_CHANNEL_ID</name>
  274. </field>
  275. </channel-log-table>
  276. <step-log-table>
  277. <connection/>
  278. <schema/>
  279. <table/>
  280. <timeout_days/>
  281. <field>
  282. <id>ID_BATCH</id>
  283. <enabled>Y</enabled>
  284. <name>ID_BATCH</name>
  285. </field>
  286. <field>
  287. <id>CHANNEL_ID</id>
  288. <enabled>Y</enabled>
  289. <name>CHANNEL_ID</name>
  290. </field>
  291. <field>
  292. <id>LOG_DATE</id>
  293. <enabled>Y</enabled>
  294. <name>LOG_DATE</name>
  295. </field>
  296. <field>
  297. <id>TRANSNAME</id>
  298. <enabled>Y</enabled>
  299. <name>TRANSNAME</name>
  300. </field>
  301. <field>
  302. <id>STEPNAME</id>
  303. <enabled>Y</enabled>
  304. <name>STEPNAME</name>
  305. </field>
  306. <field>
  307. <id>STEP_COPY</id>
  308. <enabled>Y</enabled>
  309. <name>STEP_COPY</name>
  310. </field>
  311. <field>
  312. <id>LINES_READ</id>
  313. <enabled>Y</enabled>
  314. <name>LINES_READ</name>
  315. </field>
  316. <field>
  317. <id>LINES_WRITTEN</id>
  318. <enabled>Y</enabled>
  319. <name>LINES_WRITTEN</name>
  320. </field>
  321. <field>
  322. <id>LINES_UPDATED</id>
  323. <enabled>Y</enabled>
  324. <name>LINES_UPDATED</name>
  325. </field>
  326. <field>
  327. <id>LINES_INPUT</id>
  328. <enabled>Y</enabled>
  329. <name>LINES_INPUT</name>
  330. </field>
  331. <field>
  332. <id>LINES_OUTPUT</id>
  333. <enabled>Y</enabled>
  334. <name>LINES_OUTPUT</name>
  335. </field>
  336. <field>
  337. <id>LINES_REJECTED</id>
  338. <enabled>Y</enabled>
  339. <name>LINES_REJECTED</name>
  340. </field>
  341. <field>
  342. <id>ERRORS</id>
  343. <enabled>Y</enabled>
  344. <name>ERRORS</name>
  345. </field>
  346. <field>
  347. <id>LOG_FIELD</id>
  348. <enabled>N</enabled>
  349. <name>LOG_FIELD</name>
  350. </field>
  351. </step-log-table>
  352. <metrics-log-table>
  353. <connection/>
  354. <schema/>
  355. <table/>
  356. <timeout_days/>
  357. <field>
  358. <id>ID_BATCH</id>
  359. <enabled>Y</enabled>
  360. <name>ID_BATCH</name>
  361. </field>
  362. <field>
  363. <id>CHANNEL_ID</id>
  364. <enabled>Y</enabled>
  365. <name>CHANNEL_ID</name>
  366. </field>
  367. <field>
  368. <id>LOG_DATE</id>
  369. <enabled>Y</enabled>
  370. <name>LOG_DATE</name>
  371. </field>
  372. <field>
  373. <id>METRICS_DATE</id>
  374. <enabled>Y</enabled>
  375. <name>METRICS_DATE</name>
  376. </field>
  377. <field>
  378. <id>METRICS_CODE</id>
  379. <enabled>Y</enabled>
  380. <name>METRICS_CODE</name>
  381. </field>
  382. <field>
  383. <id>METRICS_DESCRIPTION</id>
  384. <enabled>Y</enabled>
  385. <name>METRICS_DESCRIPTION</name>
  386. </field>
  387. <field>
  388. <id>METRICS_SUBJECT</id>
  389. <enabled>Y</enabled>
  390. <name>METRICS_SUBJECT</name>
  391. </field>
  392. <field>
  393. <id>METRICS_TYPE</id>
  394. <enabled>Y</enabled>
  395. <name>METRICS_TYPE</name>
  396. </field>
  397. <field>
  398. <id>METRICS_VALUE</id>
  399. <enabled>Y</enabled>
  400. <name>METRICS_VALUE</name>
  401. </field>
  402. </metrics-log-table>
  403. </log>
  404. <maxdate>
  405. <connection/>
  406. <table/>
  407. <field/>
  408. <offset>0.0</offset>
  409. <maxdiff>0.0</maxdiff>
  410. </maxdate>
  411. <size_rowset>10000</size_rowset>
  412. <sleep_time_empty>50</sleep_time_empty>
  413. <sleep_time_full>50</sleep_time_full>
  414. <unique_connections>N</unique_connections>
  415. <feedback_shown>Y</feedback_shown>
  416. <feedback_size>50000</feedback_size>
  417. <using_thread_priorities>Y</using_thread_priorities>
  418. <shared_objects_file/>
  419. <capture_step_performance>N</capture_step_performance>
  420. <step_performance_capturing_delay>1000</step_performance_capturing_delay>
  421. <step_performance_capturing_size_limit>100</step_performance_capturing_size_limit>
  422. <dependencies>
  423. </dependencies>
  424. <partitionschemas>
  425. </partitionschemas>
  426. <slaveservers>
  427. </slaveservers>
  428. <clusterschemas>
  429. </clusterschemas>
  430. <created_user>-</created_user>
  431. <created_date>2024/01/04 10:23:25.211</created_date>
  432. <modified_user>-</modified_user>
  433. <modified_date>2024/01/04 10:23:25.211</modified_date>
  434. <key_for_session_key>H4sIAAAAAAAAAAMAAAAAAAAAAAA=</key_for_session_key>
  435. <is_key_private>N</is_key_private>
  436. </info>
  437. <notepads>
  438. </notepads>
  439. <connection>
  440. <name>MOM</name>
  441. <server>192.168.1.134</server>
  442. <type>GENERIC</type>
  443. <access>Native</access>
  444. <database>cath_mom_001330</database>
  445. <port>3306</port>
  446. <username>${mysql_username}</username>
  447. <password>${mysql_password}</password>
  448. <servername/>
  449. <data_tablespace/>
  450. <index_tablespace/>
  451. <attributes>
  452. <attribute>
  453. <code>CUSTOM_DRIVER_CLASS</code>
  454. <attribute>${mysql_driverclassname}</attribute>
  455. </attribute>
  456. <attribute>
  457. <code>CUSTOM_URL</code>
  458. <attribute>${mysql_url}</attribute>
  459. </attribute>
  460. <attribute>
  461. <code>DATABASE_DIALECT_ID</code>
  462. <attribute>Generic database</attribute>
  463. </attribute>
  464. <attribute>
  465. <code>FORCE_IDENTIFIERS_TO_LOWERCASE</code>
  466. <attribute>N</attribute>
  467. </attribute>
  468. <attribute>
  469. <code>FORCE_IDENTIFIERS_TO_UPPERCASE</code>
  470. <attribute>N</attribute>
  471. </attribute>
  472. <attribute>
  473. <code>IS_CLUSTERED</code>
  474. <attribute>N</attribute>
  475. </attribute>
  476. <attribute>
  477. <code>PORT_NUMBER</code>
  478. <attribute>3306</attribute>
  479. </attribute>
  480. <attribute>
  481. <code>PRESERVE_RESERVED_WORD_CASE</code>
  482. <attribute>Y</attribute>
  483. </attribute>
  484. <attribute>
  485. <code>QUOTE_ALL_FIELDS</code>
  486. <attribute>N</attribute>
  487. </attribute>
  488. <attribute>
  489. <code>SUPPORTS_BOOLEAN_DATA_TYPE</code>
  490. <attribute>Y</attribute>
  491. </attribute>
  492. <attribute>
  493. <code>SUPPORTS_TIMESTAMP_DATA_TYPE</code>
  494. <attribute>Y</attribute>
  495. </attribute>
  496. <attribute>
  497. <code>USE_POOLING</code>
  498. <attribute>N</attribute>
  499. </attribute>
  500. </attributes>
  501. </connection>
  502. <connection>
  503. <name>U8</name>
  504. <server>192.168.1.102</server>
  505. <type>GENERIC</type>
  506. <access>Native</access>
  507. <database>UFDATA_818_2015</database>
  508. <port>1433</port>
  509. <username>${sqlserver_username}</username>
  510. <password>${sqlserver_password}</password>
  511. <servername/>
  512. <data_tablespace/>
  513. <index_tablespace/>
  514. <attributes>
  515. <attribute>
  516. <code>CUSTOM_DRIVER_CLASS</code>
  517. <attribute>${sqlserver_driverclassname}</attribute>
  518. </attribute>
  519. <attribute>
  520. <code>CUSTOM_URL</code>
  521. <attribute>${sqlserver_url}</attribute>
  522. </attribute>
  523. <attribute>
  524. <code>DATABASE_DIALECT_ID</code>
  525. <attribute>Generic database</attribute>
  526. </attribute>
  527. <attribute>
  528. <code>FORCE_IDENTIFIERS_TO_LOWERCASE</code>
  529. <attribute>N</attribute>
  530. </attribute>
  531. <attribute>
  532. <code>FORCE_IDENTIFIERS_TO_UPPERCASE</code>
  533. <attribute>N</attribute>
  534. </attribute>
  535. <attribute>
  536. <code>IS_CLUSTERED</code>
  537. <attribute>N</attribute>
  538. </attribute>
  539. <attribute>
  540. <code>PORT_NUMBER</code>
  541. <attribute>1433</attribute>
  542. </attribute>
  543. <attribute>
  544. <code>PRESERVE_RESERVED_WORD_CASE</code>
  545. <attribute>Y</attribute>
  546. </attribute>
  547. <attribute>
  548. <code>QUOTE_ALL_FIELDS</code>
  549. <attribute>N</attribute>
  550. </attribute>
  551. <attribute>
  552. <code>SUPPORTS_BOOLEAN_DATA_TYPE</code>
  553. <attribute>Y</attribute>
  554. </attribute>
  555. <attribute>
  556. <code>SUPPORTS_TIMESTAMP_DATA_TYPE</code>
  557. <attribute>Y</attribute>
  558. </attribute>
  559. <attribute>
  560. <code>USE_POOLING</code>
  561. <attribute>N</attribute>
  562. </attribute>
  563. </attributes>
  564. </connection>
  565. <order>
  566. <hop>
  567. <from>表输入</from>
  568. <to>插入 / 更新</to>
  569. <enabled>Y</enabled>
  570. </hop>
  571. <hop>
  572. <from>获取变量</from>
  573. <to>表输入</to>
  574. <enabled>Y</enabled>
  575. </hop>
  576. </order>
  577. <step>
  578. <name>插入 / 更新</name>
  579. <type>InsertUpdate</type>
  580. <description/>
  581. <distribute>Y</distribute>
  582. <custom_distribution/>
  583. <copies>1</copies>
  584. <partitioning>
  585. <method>none</method>
  586. <schema_name/>
  587. </partitioning>
  588. <connection>MOM</connection>
  589. <commit>1000</commit>
  590. <update_bypassed>N</update_bypassed>
  591. <lookup>
  592. <schema/>
  593. <table>base_warehouse</table>
  594. <key>
  595. <name>warehouse_code</name>
  596. <field>warehouse_code</field>
  597. <condition>=</condition>
  598. <name2/>
  599. </key>
  600. <value>
  601. <name>parent_id</name>
  602. <rename>parent_id</rename>
  603. <update>Y</update>
  604. </value>
  605. <value>
  606. <name>warehouse_code</name>
  607. <rename>warehouse_code</rename>
  608. <update>N</update>
  609. </value>
  610. <value>
  611. <name>warehouse_name</name>
  612. <rename>warehouse_name</rename>
  613. <update>Y</update>
  614. </value>
  615. <value>
  616. <name>warehouse_describe</name>
  617. <rename>warehouse_describe</rename>
  618. <update>Y</update>
  619. </value>
  620. <value>
  621. <name>status</name>
  622. <rename>status</rename>
  623. <update>Y</update>
  624. </value>
  625. <value>
  626. <name>inactive_time</name>
  627. <rename>inactive_time</rename>
  628. <update>Y</update>
  629. </value>
  630. <value>
  631. <name>create_by</name>
  632. <rename>sync_name</rename>
  633. <update>N</update>
  634. </value>
  635. <value>
  636. <name>create_id</name>
  637. <rename>sync_id</rename>
  638. <update>N</update>
  639. </value>
  640. <value>
  641. <name>create_time</name>
  642. <rename>sync_time</rename>
  643. <update>N</update>
  644. </value>
  645. <value>
  646. <name>update_by</name>
  647. <rename>sync_name</rename>
  648. <update>Y</update>
  649. </value>
  650. <value>
  651. <name>update_time</name>
  652. <rename>sync_time</rename>
  653. <update>Y</update>
  654. </value>
  655. </lookup>
  656. <attributes/>
  657. <cluster_schema/>
  658. <remotesteps>
  659. <input>
  660. </input>
  661. <output>
  662. </output>
  663. </remotesteps>
  664. <GUI>
  665. <xloc>448</xloc>
  666. <yloc>96</yloc>
  667. <draw>Y</draw>
  668. </GUI>
  669. </step>
  670. <step>
  671. <name>获取变量</name>
  672. <type>GetVariable</type>
  673. <description/>
  674. <distribute>Y</distribute>
  675. <custom_distribution/>
  676. <copies>1</copies>
  677. <partitioning>
  678. <method>none</method>
  679. <schema_name/>
  680. </partitioning>
  681. <fields>
  682. <field>
  683. <name>mysql_driverclassname</name>
  684. <variable>${mysql_driverclassname}</variable>
  685. <type>String</type>
  686. <format/>
  687. <currency/>
  688. <decimal/>
  689. <group/>
  690. <length>-1</length>
  691. <precision>-1</precision>
  692. <trim_type>none</trim_type>
  693. </field>
  694. <field>
  695. <name>mysql_password</name>
  696. <variable>${mysql_password}</variable>
  697. <type>String</type>
  698. <format/>
  699. <currency/>
  700. <decimal/>
  701. <group/>
  702. <length>-1</length>
  703. <precision>-1</precision>
  704. <trim_type>none</trim_type>
  705. </field>
  706. <field>
  707. <name>mysql_url</name>
  708. <variable>${mysql_url}</variable>
  709. <type>String</type>
  710. <format/>
  711. <currency/>
  712. <decimal/>
  713. <group/>
  714. <length>-1</length>
  715. <precision>-1</precision>
  716. <trim_type>none</trim_type>
  717. </field>
  718. <field>
  719. <name>mysql_username</name>
  720. <variable>${mysql_username}</variable>
  721. <type>String</type>
  722. <format/>
  723. <currency/>
  724. <decimal/>
  725. <group/>
  726. <length>-1</length>
  727. <precision>-1</precision>
  728. <trim_type>none</trim_type>
  729. </field>
  730. <field>
  731. <name>USER_ID</name>
  732. <variable>${userId}</variable>
  733. <type>String</type>
  734. <format/>
  735. <currency/>
  736. <decimal/>
  737. <group/>
  738. <length>-1</length>
  739. <precision>-1</precision>
  740. <trim_type>none</trim_type>
  741. </field>
  742. <field>
  743. <name>sqlserver_driverclassname</name>
  744. <variable>${sqlserver_driverclassname}</variable>
  745. <type>String</type>
  746. <format/>
  747. <currency/>
  748. <decimal/>
  749. <group/>
  750. <length>-1</length>
  751. <precision>-1</precision>
  752. <trim_type>none</trim_type>
  753. </field>
  754. <field>
  755. <name>sqlserver_password</name>
  756. <variable>${sqlserver_password}</variable>
  757. <type>String</type>
  758. <format/>
  759. <currency/>
  760. <decimal/>
  761. <group/>
  762. <length>-1</length>
  763. <precision>-1</precision>
  764. <trim_type>none</trim_type>
  765. </field>
  766. <field>
  767. <name>sqlserver_url</name>
  768. <variable>${sqlserver_url}</variable>
  769. <type>String</type>
  770. <format/>
  771. <currency/>
  772. <decimal/>
  773. <group/>
  774. <length>-1</length>
  775. <precision>-1</precision>
  776. <trim_type>none</trim_type>
  777. </field>
  778. <field>
  779. <name>sqlserver_username</name>
  780. <variable>${sqlserver_username}</variable>
  781. <type>String</type>
  782. <format/>
  783. <currency/>
  784. <decimal/>
  785. <group/>
  786. <length>-1</length>
  787. <precision>-1</precision>
  788. <trim_type>none</trim_type>
  789. </field>
  790. <field>
  791. <name>USER_NAME</name>
  792. <variable>${userName}</variable>
  793. <type>String</type>
  794. <format/>
  795. <currency/>
  796. <decimal/>
  797. <group/>
  798. <length>-1</length>
  799. <precision>-1</precision>
  800. <trim_type>none</trim_type>
  801. </field>
  802. </fields>
  803. <attributes/>
  804. <cluster_schema/>
  805. <remotesteps>
  806. <input>
  807. </input>
  808. <output>
  809. </output>
  810. </remotesteps>
  811. <GUI>
  812. <xloc>80</xloc>
  813. <yloc>96</yloc>
  814. <draw>Y</draw>
  815. </GUI>
  816. </step>
  817. <step>
  818. <name>表输入</name>
  819. <type>TableInput</type>
  820. <description/>
  821. <distribute>Y</distribute>
  822. <custom_distribution/>
  823. <copies>1</copies>
  824. <partitioning>
  825. <method>none</method>
  826. <schema_name/>
  827. </partitioning>
  828. <connection>U8</connection>
  829. <sql>DECLARE @USER_NAME VARCHAR(50),@USER_ID INT
  830. SET @USER_NAME = CASE '${USER_NAME}' WHEN '' THEN '管理员(kettle)' ELSE '${USER_NAME}' END
  831. SET @USER_ID = CASE 0${USER_ID} WHEN 0 THEN 1 ELSE 0${USER_ID} END
  832. SELECT
  833. 1 AS parent_id
  834. ,cWhCode AS warehouse_code
  835. ,cWhName AS warehouse_name
  836. ,NULL AS warehouse_describe
  837. ,1 AS is_location
  838. ,CASE ISNULL(dWhEndDate,'') WHEN '' THEN 0 ELSE 1 END AS status
  839. ,dWhEndDate AS inactive_time
  840. ,@USER_NAME AS sync_name
  841. ,@USER_ID AS sync_id
  842. ,GETDATE() AS sync_time
  843. FROM Warehouse
  844. </sql>
  845. <limit>0</limit>
  846. <lookup/>
  847. <execute_each_row>N</execute_each_row>
  848. <variables_active>Y</variables_active>
  849. <lazy_conversion_active>N</lazy_conversion_active>
  850. <cached_row_meta_active>N</cached_row_meta_active>
  851. <row-meta>
  852. <value-meta>
  853. <type>Integer</type>
  854. <storagetype>normal</storagetype>
  855. <name>parent_id</name>
  856. <length>9</length>
  857. <precision>0</precision>
  858. <origin>表输入</origin>
  859. <comments>parent_id</comments>
  860. <conversion_Mask>####0;-####0</conversion_Mask>
  861. <decimal_symbol>.</decimal_symbol>
  862. <grouping_symbol>,</grouping_symbol>
  863. <currency_symbol/>
  864. <trim_type>none</trim_type>
  865. <case_insensitive>N</case_insensitive>
  866. <collator_disabled>Y</collator_disabled>
  867. <collator_strength>0</collator_strength>
  868. <sort_descending>N</sort_descending>
  869. <output_padding>N</output_padding>
  870. <date_format_lenient>N</date_format_lenient>
  871. <date_format_locale>zh_CN</date_format_locale>
  872. <date_format_timezone>Asia/Shanghai</date_format_timezone>
  873. <lenient_string_to_number>N</lenient_string_to_number>
  874. </value-meta>
  875. <value-meta>
  876. <type>String</type>
  877. <storagetype>normal</storagetype>
  878. <name>warehouse_code</name>
  879. <length>10</length>
  880. <precision>-1</precision>
  881. <origin>表输入</origin>
  882. <comments>warehouse_code</comments>
  883. <conversion_Mask/>
  884. <decimal_symbol>.</decimal_symbol>
  885. <grouping_symbol>,</grouping_symbol>
  886. <currency_symbol/>
  887. <trim_type>none</trim_type>
  888. <case_insensitive>N</case_insensitive>
  889. <collator_disabled>Y</collator_disabled>
  890. <collator_strength>0</collator_strength>
  891. <sort_descending>N</sort_descending>
  892. <output_padding>N</output_padding>
  893. <date_format_lenient>N</date_format_lenient>
  894. <date_format_locale>zh_CN</date_format_locale>
  895. <date_format_timezone>Asia/Shanghai</date_format_timezone>
  896. <lenient_string_to_number>N</lenient_string_to_number>
  897. </value-meta>
  898. <value-meta>
  899. <type>String</type>
  900. <storagetype>normal</storagetype>
  901. <name>warehouse_name</name>
  902. <length>20</length>
  903. <precision>-1</precision>
  904. <origin>表输入</origin>
  905. <comments>warehouse_name</comments>
  906. <conversion_Mask/>
  907. <decimal_symbol>.</decimal_symbol>
  908. <grouping_symbol>,</grouping_symbol>
  909. <currency_symbol/>
  910. <trim_type>none</trim_type>
  911. <case_insensitive>N</case_insensitive>
  912. <collator_disabled>Y</collator_disabled>
  913. <collator_strength>0</collator_strength>
  914. <sort_descending>N</sort_descending>
  915. <output_padding>N</output_padding>
  916. <date_format_lenient>N</date_format_lenient>
  917. <date_format_locale>zh_CN</date_format_locale>
  918. <date_format_timezone>Asia/Shanghai</date_format_timezone>
  919. <lenient_string_to_number>N</lenient_string_to_number>
  920. </value-meta>
  921. <value-meta>
  922. <type>Integer</type>
  923. <storagetype>normal</storagetype>
  924. <name>warehouse_describe</name>
  925. <length>9</length>
  926. <precision>0</precision>
  927. <origin>表输入</origin>
  928. <comments>warehouse_describe</comments>
  929. <conversion_Mask>####0;-####0</conversion_Mask>
  930. <decimal_symbol>.</decimal_symbol>
  931. <grouping_symbol>,</grouping_symbol>
  932. <currency_symbol/>
  933. <trim_type>none</trim_type>
  934. <case_insensitive>N</case_insensitive>
  935. <collator_disabled>Y</collator_disabled>
  936. <collator_strength>0</collator_strength>
  937. <sort_descending>N</sort_descending>
  938. <output_padding>N</output_padding>
  939. <date_format_lenient>N</date_format_lenient>
  940. <date_format_locale>zh_CN</date_format_locale>
  941. <date_format_timezone>Asia/Shanghai</date_format_timezone>
  942. <lenient_string_to_number>N</lenient_string_to_number>
  943. </value-meta>
  944. <value-meta>
  945. <type>Integer</type>
  946. <storagetype>normal</storagetype>
  947. <name>is_location</name>
  948. <length>9</length>
  949. <precision>0</precision>
  950. <origin>表输入</origin>
  951. <comments>is_location</comments>
  952. <conversion_Mask>####0;-####0</conversion_Mask>
  953. <decimal_symbol>.</decimal_symbol>
  954. <grouping_symbol>,</grouping_symbol>
  955. <currency_symbol/>
  956. <trim_type>none</trim_type>
  957. <case_insensitive>N</case_insensitive>
  958. <collator_disabled>Y</collator_disabled>
  959. <collator_strength>0</collator_strength>
  960. <sort_descending>N</sort_descending>
  961. <output_padding>N</output_padding>
  962. <date_format_lenient>N</date_format_lenient>
  963. <date_format_locale>zh_CN</date_format_locale>
  964. <date_format_timezone>Asia/Shanghai</date_format_timezone>
  965. <lenient_string_to_number>N</lenient_string_to_number>
  966. </value-meta>
  967. <value-meta>
  968. <type>Integer</type>
  969. <storagetype>normal</storagetype>
  970. <name>status</name>
  971. <length>9</length>
  972. <precision>0</precision>
  973. <origin>表输入</origin>
  974. <comments>status</comments>
  975. <conversion_Mask>####0;-####0</conversion_Mask>
  976. <decimal_symbol>.</decimal_symbol>
  977. <grouping_symbol>,</grouping_symbol>
  978. <currency_symbol/>
  979. <trim_type>none</trim_type>
  980. <case_insensitive>N</case_insensitive>
  981. <collator_disabled>Y</collator_disabled>
  982. <collator_strength>0</collator_strength>
  983. <sort_descending>N</sort_descending>
  984. <output_padding>N</output_padding>
  985. <date_format_lenient>N</date_format_lenient>
  986. <date_format_locale>zh_CN</date_format_locale>
  987. <date_format_timezone>Asia/Shanghai</date_format_timezone>
  988. <lenient_string_to_number>N</lenient_string_to_number>
  989. </value-meta>
  990. <value-meta>
  991. <type>Timestamp</type>
  992. <storagetype>normal</storagetype>
  993. <name>inactive_time</name>
  994. <length>3</length>
  995. <precision>-1</precision>
  996. <origin>表输入</origin>
  997. <comments>inactive_time</comments>
  998. <conversion_Mask/>
  999. <decimal_symbol>.</decimal_symbol>
  1000. <grouping_symbol>,</grouping_symbol>
  1001. <currency_symbol/>
  1002. <trim_type>none</trim_type>
  1003. <case_insensitive>N</case_insensitive>
  1004. <collator_disabled>Y</collator_disabled>
  1005. <collator_strength>0</collator_strength>
  1006. <sort_descending>N</sort_descending>
  1007. <output_padding>N</output_padding>
  1008. <date_format_lenient>N</date_format_lenient>
  1009. <date_format_locale>zh_CN</date_format_locale>
  1010. <date_format_timezone>Asia/Shanghai</date_format_timezone>
  1011. <lenient_string_to_number>N</lenient_string_to_number>
  1012. </value-meta>
  1013. <value-meta>
  1014. <type>String</type>
  1015. <storagetype>normal</storagetype>
  1016. <name>sync_name</name>
  1017. <length>6</length>
  1018. <precision>-1</precision>
  1019. <origin>表输入</origin>
  1020. <comments>sync_name</comments>
  1021. <conversion_Mask/>
  1022. <decimal_symbol>.</decimal_symbol>
  1023. <grouping_symbol>,</grouping_symbol>
  1024. <currency_symbol/>
  1025. <trim_type>none</trim_type>
  1026. <case_insensitive>N</case_insensitive>
  1027. <collator_disabled>Y</collator_disabled>
  1028. <collator_strength>0</collator_strength>
  1029. <sort_descending>N</sort_descending>
  1030. <output_padding>N</output_padding>
  1031. <date_format_lenient>N</date_format_lenient>
  1032. <date_format_locale>zh_CN</date_format_locale>
  1033. <date_format_timezone>Asia/Shanghai</date_format_timezone>
  1034. <lenient_string_to_number>N</lenient_string_to_number>
  1035. </value-meta>
  1036. <value-meta>
  1037. <type>Integer</type>
  1038. <storagetype>normal</storagetype>
  1039. <name>sync_id</name>
  1040. <length>9</length>
  1041. <precision>0</precision>
  1042. <origin>表输入</origin>
  1043. <comments>sync_id</comments>
  1044. <conversion_Mask>####0;-####0</conversion_Mask>
  1045. <decimal_symbol>.</decimal_symbol>
  1046. <grouping_symbol>,</grouping_symbol>
  1047. <currency_symbol/>
  1048. <trim_type>none</trim_type>
  1049. <case_insensitive>N</case_insensitive>
  1050. <collator_disabled>Y</collator_disabled>
  1051. <collator_strength>0</collator_strength>
  1052. <sort_descending>N</sort_descending>
  1053. <output_padding>N</output_padding>
  1054. <date_format_lenient>N</date_format_lenient>
  1055. <date_format_locale>zh_CN</date_format_locale>
  1056. <date_format_timezone>Asia/Shanghai</date_format_timezone>
  1057. <lenient_string_to_number>N</lenient_string_to_number>
  1058. </value-meta>
  1059. <value-meta>
  1060. <type>Timestamp</type>
  1061. <storagetype>normal</storagetype>
  1062. <name>sync_time</name>
  1063. <length>3</length>
  1064. <precision>-1</precision>
  1065. <origin>表输入</origin>
  1066. <comments>sync_time</comments>
  1067. <conversion_Mask/>
  1068. <decimal_symbol>.</decimal_symbol>
  1069. <grouping_symbol>,</grouping_symbol>
  1070. <currency_symbol/>
  1071. <trim_type>none</trim_type>
  1072. <case_insensitive>N</case_insensitive>
  1073. <collator_disabled>Y</collator_disabled>
  1074. <collator_strength>0</collator_strength>
  1075. <sort_descending>N</sort_descending>
  1076. <output_padding>N</output_padding>
  1077. <date_format_lenient>N</date_format_lenient>
  1078. <date_format_locale>zh_CN</date_format_locale>
  1079. <date_format_timezone>Asia/Shanghai</date_format_timezone>
  1080. <lenient_string_to_number>N</lenient_string_to_number>
  1081. </value-meta>
  1082. </row-meta>
  1083. <attributes/>
  1084. <cluster_schema/>
  1085. <remotesteps>
  1086. <input>
  1087. </input>
  1088. <output>
  1089. </output>
  1090. </remotesteps>
  1091. <GUI>
  1092. <xloc>256</xloc>
  1093. <yloc>112</yloc>
  1094. <draw>Y</draw>
  1095. </GUI>
  1096. </step>
  1097. <step_error_handling>
  1098. </step_error_handling>
  1099. <slave-step-copy-partition-distribution>
  1100. </slave-step-copy-partition-distribution>
  1101. <slave_transformation>N</slave_transformation>
  1102. <attributes/>
  1103. </transformation>