TruncateTables.ktr 15 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439440441442443444445446447448449450451452453454455456457458459460461462463464465466467468469470471472473474475476477478479480481482483484485486487488489490491492493494495496497498499500501502503504505506507508509510511512513514515516517518519520521522523524525526527528529530531532533534535536537538539540541542543544545546547548549550551552553554555556557558559560561562563564565566567568569570571572573574575576577578579580581582583584585586587588589590
  1. <transformation>
  2. <info>
  3. <name>TruncateTables</name>
  4. <description/>
  5. <extended_description/>
  6. <trans_version/>
  7. <trans_type>Normal</trans_type>
  8. <directory>/0_Import/DATEV</directory>
  9. <parameters>
  10. </parameters>
  11. <log>
  12. <trans-log-table>
  13. <connection/>
  14. <schema/>
  15. <table/>
  16. <size_limit_lines/>
  17. <interval/>
  18. <timeout_days/>
  19. <field>
  20. <id>ID_BATCH</id>
  21. <enabled>Y</enabled>
  22. <name>ID_BATCH</name>
  23. </field>
  24. <field>
  25. <id>CHANNEL_ID</id>
  26. <enabled>Y</enabled>
  27. <name>CHANNEL_ID</name>
  28. </field>
  29. <field>
  30. <id>TRANSNAME</id>
  31. <enabled>Y</enabled>
  32. <name>TRANSNAME</name>
  33. </field>
  34. <field>
  35. <id>STATUS</id>
  36. <enabled>Y</enabled>
  37. <name>STATUS</name>
  38. </field>
  39. <field>
  40. <id>LINES_READ</id>
  41. <enabled>Y</enabled>
  42. <name>LINES_READ</name>
  43. <subject/>
  44. </field>
  45. <field>
  46. <id>LINES_WRITTEN</id>
  47. <enabled>Y</enabled>
  48. <name>LINES_WRITTEN</name>
  49. <subject/>
  50. </field>
  51. <field>
  52. <id>LINES_UPDATED</id>
  53. <enabled>Y</enabled>
  54. <name>LINES_UPDATED</name>
  55. <subject/>
  56. </field>
  57. <field>
  58. <id>LINES_INPUT</id>
  59. <enabled>Y</enabled>
  60. <name>LINES_INPUT</name>
  61. <subject/>
  62. </field>
  63. <field>
  64. <id>LINES_OUTPUT</id>
  65. <enabled>Y</enabled>
  66. <name>LINES_OUTPUT</name>
  67. <subject/>
  68. </field>
  69. <field>
  70. <id>LINES_REJECTED</id>
  71. <enabled>Y</enabled>
  72. <name>LINES_REJECTED</name>
  73. <subject/>
  74. </field>
  75. <field>
  76. <id>ERRORS</id>
  77. <enabled>Y</enabled>
  78. <name>ERRORS</name>
  79. </field>
  80. <field>
  81. <id>STARTDATE</id>
  82. <enabled>Y</enabled>
  83. <name>STARTDATE</name>
  84. </field>
  85. <field>
  86. <id>ENDDATE</id>
  87. <enabled>Y</enabled>
  88. <name>ENDDATE</name>
  89. </field>
  90. <field>
  91. <id>LOGDATE</id>
  92. <enabled>Y</enabled>
  93. <name>LOGDATE</name>
  94. </field>
  95. <field>
  96. <id>DEPDATE</id>
  97. <enabled>Y</enabled>
  98. <name>DEPDATE</name>
  99. </field>
  100. <field>
  101. <id>REPLAYDATE</id>
  102. <enabled>Y</enabled>
  103. <name>REPLAYDATE</name>
  104. </field>
  105. <field>
  106. <id>LOG_FIELD</id>
  107. <enabled>Y</enabled>
  108. <name>LOG_FIELD</name>
  109. </field>
  110. <field>
  111. <id>EXECUTING_SERVER</id>
  112. <enabled>N</enabled>
  113. <name>EXECUTING_SERVER</name>
  114. </field>
  115. <field>
  116. <id>EXECUTING_USER</id>
  117. <enabled>N</enabled>
  118. <name>EXECUTING_USER</name>
  119. </field>
  120. <field>
  121. <id>CLIENT</id>
  122. <enabled>N</enabled>
  123. <name>CLIENT</name>
  124. </field>
  125. </trans-log-table>
  126. <perf-log-table>
  127. <connection/>
  128. <schema/>
  129. <table/>
  130. <interval/>
  131. <timeout_days/>
  132. <field>
  133. <id>ID_BATCH</id>
  134. <enabled>Y</enabled>
  135. <name>ID_BATCH</name>
  136. </field>
  137. <field>
  138. <id>SEQ_NR</id>
  139. <enabled>Y</enabled>
  140. <name>SEQ_NR</name>
  141. </field>
  142. <field>
  143. <id>LOGDATE</id>
  144. <enabled>Y</enabled>
  145. <name>LOGDATE</name>
  146. </field>
  147. <field>
  148. <id>TRANSNAME</id>
  149. <enabled>Y</enabled>
  150. <name>TRANSNAME</name>
  151. </field>
  152. <field>
  153. <id>STEPNAME</id>
  154. <enabled>Y</enabled>
  155. <name>STEPNAME</name>
  156. </field>
  157. <field>
  158. <id>STEP_COPY</id>
  159. <enabled>Y</enabled>
  160. <name>STEP_COPY</name>
  161. </field>
  162. <field>
  163. <id>LINES_READ</id>
  164. <enabled>Y</enabled>
  165. <name>LINES_READ</name>
  166. </field>
  167. <field>
  168. <id>LINES_WRITTEN</id>
  169. <enabled>Y</enabled>
  170. <name>LINES_WRITTEN</name>
  171. </field>
  172. <field>
  173. <id>LINES_UPDATED</id>
  174. <enabled>Y</enabled>
  175. <name>LINES_UPDATED</name>
  176. </field>
  177. <field>
  178. <id>LINES_INPUT</id>
  179. <enabled>Y</enabled>
  180. <name>LINES_INPUT</name>
  181. </field>
  182. <field>
  183. <id>LINES_OUTPUT</id>
  184. <enabled>Y</enabled>
  185. <name>LINES_OUTPUT</name>
  186. </field>
  187. <field>
  188. <id>LINES_REJECTED</id>
  189. <enabled>Y</enabled>
  190. <name>LINES_REJECTED</name>
  191. </field>
  192. <field>
  193. <id>ERRORS</id>
  194. <enabled>Y</enabled>
  195. <name>ERRORS</name>
  196. </field>
  197. <field>
  198. <id>INPUT_BUFFER_ROWS</id>
  199. <enabled>Y</enabled>
  200. <name>INPUT_BUFFER_ROWS</name>
  201. </field>
  202. <field>
  203. <id>OUTPUT_BUFFER_ROWS</id>
  204. <enabled>Y</enabled>
  205. <name>OUTPUT_BUFFER_ROWS</name>
  206. </field>
  207. </perf-log-table>
  208. <channel-log-table>
  209. <connection/>
  210. <schema/>
  211. <table/>
  212. <timeout_days/>
  213. <field>
  214. <id>ID_BATCH</id>
  215. <enabled>Y</enabled>
  216. <name>ID_BATCH</name>
  217. </field>
  218. <field>
  219. <id>CHANNEL_ID</id>
  220. <enabled>Y</enabled>
  221. <name>CHANNEL_ID</name>
  222. </field>
  223. <field>
  224. <id>LOG_DATE</id>
  225. <enabled>Y</enabled>
  226. <name>LOG_DATE</name>
  227. </field>
  228. <field>
  229. <id>LOGGING_OBJECT_TYPE</id>
  230. <enabled>Y</enabled>
  231. <name>LOGGING_OBJECT_TYPE</name>
  232. </field>
  233. <field>
  234. <id>OBJECT_NAME</id>
  235. <enabled>Y</enabled>
  236. <name>OBJECT_NAME</name>
  237. </field>
  238. <field>
  239. <id>OBJECT_COPY</id>
  240. <enabled>Y</enabled>
  241. <name>OBJECT_COPY</name>
  242. </field>
  243. <field>
  244. <id>REPOSITORY_DIRECTORY</id>
  245. <enabled>Y</enabled>
  246. <name>REPOSITORY_DIRECTORY</name>
  247. </field>
  248. <field>
  249. <id>FILENAME</id>
  250. <enabled>Y</enabled>
  251. <name>FILENAME</name>
  252. </field>
  253. <field>
  254. <id>OBJECT_ID</id>
  255. <enabled>Y</enabled>
  256. <name>OBJECT_ID</name>
  257. </field>
  258. <field>
  259. <id>OBJECT_REVISION</id>
  260. <enabled>Y</enabled>
  261. <name>OBJECT_REVISION</name>
  262. </field>
  263. <field>
  264. <id>PARENT_CHANNEL_ID</id>
  265. <enabled>Y</enabled>
  266. <name>PARENT_CHANNEL_ID</name>
  267. </field>
  268. <field>
  269. <id>ROOT_CHANNEL_ID</id>
  270. <enabled>Y</enabled>
  271. <name>ROOT_CHANNEL_ID</name>
  272. </field>
  273. </channel-log-table>
  274. <step-log-table>
  275. <connection/>
  276. <schema/>
  277. <table/>
  278. <timeout_days/>
  279. <field>
  280. <id>ID_BATCH</id>
  281. <enabled>Y</enabled>
  282. <name>ID_BATCH</name>
  283. </field>
  284. <field>
  285. <id>CHANNEL_ID</id>
  286. <enabled>Y</enabled>
  287. <name>CHANNEL_ID</name>
  288. </field>
  289. <field>
  290. <id>LOG_DATE</id>
  291. <enabled>Y</enabled>
  292. <name>LOG_DATE</name>
  293. </field>
  294. <field>
  295. <id>TRANSNAME</id>
  296. <enabled>Y</enabled>
  297. <name>TRANSNAME</name>
  298. </field>
  299. <field>
  300. <id>STEPNAME</id>
  301. <enabled>Y</enabled>
  302. <name>STEPNAME</name>
  303. </field>
  304. <field>
  305. <id>STEP_COPY</id>
  306. <enabled>Y</enabled>
  307. <name>STEP_COPY</name>
  308. </field>
  309. <field>
  310. <id>LINES_READ</id>
  311. <enabled>Y</enabled>
  312. <name>LINES_READ</name>
  313. </field>
  314. <field>
  315. <id>LINES_WRITTEN</id>
  316. <enabled>Y</enabled>
  317. <name>LINES_WRITTEN</name>
  318. </field>
  319. <field>
  320. <id>LINES_UPDATED</id>
  321. <enabled>Y</enabled>
  322. <name>LINES_UPDATED</name>
  323. </field>
  324. <field>
  325. <id>LINES_INPUT</id>
  326. <enabled>Y</enabled>
  327. <name>LINES_INPUT</name>
  328. </field>
  329. <field>
  330. <id>LINES_OUTPUT</id>
  331. <enabled>Y</enabled>
  332. <name>LINES_OUTPUT</name>
  333. </field>
  334. <field>
  335. <id>LINES_REJECTED</id>
  336. <enabled>Y</enabled>
  337. <name>LINES_REJECTED</name>
  338. </field>
  339. <field>
  340. <id>ERRORS</id>
  341. <enabled>Y</enabled>
  342. <name>ERRORS</name>
  343. </field>
  344. <field>
  345. <id>LOG_FIELD</id>
  346. <enabled>N</enabled>
  347. <name>LOG_FIELD</name>
  348. </field>
  349. </step-log-table>
  350. <metrics-log-table>
  351. <connection/>
  352. <schema/>
  353. <table/>
  354. <timeout_days/>
  355. <field>
  356. <id>ID_BATCH</id>
  357. <enabled>Y</enabled>
  358. <name>ID_BATCH</name>
  359. </field>
  360. <field>
  361. <id>CHANNEL_ID</id>
  362. <enabled>Y</enabled>
  363. <name>CHANNEL_ID</name>
  364. </field>
  365. <field>
  366. <id>LOG_DATE</id>
  367. <enabled>Y</enabled>
  368. <name>LOG_DATE</name>
  369. </field>
  370. <field>
  371. <id>METRICS_DATE</id>
  372. <enabled>Y</enabled>
  373. <name>METRICS_DATE</name>
  374. </field>
  375. <field>
  376. <id>METRICS_CODE</id>
  377. <enabled>Y</enabled>
  378. <name>METRICS_CODE</name>
  379. </field>
  380. <field>
  381. <id>METRICS_DESCRIPTION</id>
  382. <enabled>Y</enabled>
  383. <name>METRICS_DESCRIPTION</name>
  384. </field>
  385. <field>
  386. <id>METRICS_SUBJECT</id>
  387. <enabled>Y</enabled>
  388. <name>METRICS_SUBJECT</name>
  389. </field>
  390. <field>
  391. <id>METRICS_TYPE</id>
  392. <enabled>Y</enabled>
  393. <name>METRICS_TYPE</name>
  394. </field>
  395. <field>
  396. <id>METRICS_VALUE</id>
  397. <enabled>Y</enabled>
  398. <name>METRICS_VALUE</name>
  399. </field>
  400. </metrics-log-table>
  401. </log>
  402. <maxdate>
  403. <connection/>
  404. <table/>
  405. <field/>
  406. <offset>0.0</offset>
  407. <maxdiff>0.0</maxdiff>
  408. </maxdate>
  409. <size_rowset>10000</size_rowset>
  410. <sleep_time_empty>50</sleep_time_empty>
  411. <sleep_time_full>50</sleep_time_full>
  412. <unique_connections>N</unique_connections>
  413. <feedback_shown>Y</feedback_shown>
  414. <feedback_size>50000</feedback_size>
  415. <using_thread_priorities>Y</using_thread_priorities>
  416. <shared_objects_file/>
  417. <capture_step_performance>N</capture_step_performance>
  418. <step_performance_capturing_delay>1000</step_performance_capturing_delay>
  419. <step_performance_capturing_size_limit>100</step_performance_capturing_size_limit>
  420. <dependencies>
  421. </dependencies>
  422. <partitionschemas>
  423. </partitionschemas>
  424. <slaveservers>
  425. </slaveservers>
  426. <clusterschemas>
  427. </clusterschemas>
  428. <created_user>-</created_user>
  429. <created_date>2025/01/30 15:30:21.392</created_date>
  430. <modified_user>-</modified_user>
  431. <modified_date>2025/01/30 15:37:55.779</modified_date>
  432. <key_for_session_key/>
  433. <is_key_private>N</is_key_private>
  434. </info>
  435. <notepads>
  436. </notepads>
  437. <connection>
  438. <name>DATEV</name>
  439. <server>192.168.2.43</server>
  440. <type>MSSQL</type>
  441. <access>Native</access>
  442. <database>DATEV</database>
  443. <port>1433</port>
  444. <username>sa</username>
  445. <password>Encrypted 2be98afc86aa7f2a9ad1fbb238ec3fe99</password>
  446. <servername/>
  447. <data_tablespace/>
  448. <index_tablespace/>
  449. <attributes>
  450. <attribute>
  451. <code>EXTRA_OPTION_MSSQL.instance</code>
  452. <attribute>GLOBALCUBE</attribute>
  453. </attribute>
  454. <attribute>
  455. <code>FORCE_IDENTIFIERS_TO_LOWERCASE</code>
  456. <attribute>N</attribute>
  457. </attribute>
  458. <attribute>
  459. <code>FORCE_IDENTIFIERS_TO_UPPERCASE</code>
  460. <attribute>N</attribute>
  461. </attribute>
  462. <attribute>
  463. <code>IS_CLUSTERED</code>
  464. <attribute>N</attribute>
  465. </attribute>
  466. <attribute>
  467. <code>MSSQL_DOUBLE_DECIMAL_SEPARATOR</code>
  468. <attribute>N</attribute>
  469. </attribute>
  470. <attribute>
  471. <code>PORT_NUMBER</code>
  472. <attribute>1433</attribute>
  473. </attribute>
  474. <attribute>
  475. <code>PRESERVE_RESERVED_WORD_CASE</code>
  476. <attribute>Y</attribute>
  477. </attribute>
  478. <attribute>
  479. <code>QUOTE_ALL_FIELDS</code>
  480. <attribute>N</attribute>
  481. </attribute>
  482. <attribute>
  483. <code>SUPPORTS_BOOLEAN_DATA_TYPE</code>
  484. <attribute>Y</attribute>
  485. </attribute>
  486. <attribute>
  487. <code>SUPPORTS_TIMESTAMP_DATA_TYPE</code>
  488. <attribute>Y</attribute>
  489. </attribute>
  490. <attribute>
  491. <code>USE_POOLING</code>
  492. <attribute>N</attribute>
  493. </attribute>
  494. </attributes>
  495. </connection>
  496. <order>
  497. <hop>
  498. <from>Get table names</from>
  499. <to>Truncate table</to>
  500. <enabled>Y</enabled>
  501. </hop>
  502. </order>
  503. <step>
  504. <name>Get table names</name>
  505. <type>GetTableNames</type>
  506. <description/>
  507. <distribute>Y</distribute>
  508. <custom_distribution/>
  509. <copies>1</copies>
  510. <partitioning>
  511. <method>none</method>
  512. <schema_name/>
  513. </partitioning>
  514. <connection>DATEV</connection>
  515. <schemaname>import</schemaname>
  516. <tablenamefieldname>tablename</tablenamefieldname>
  517. <objecttypefieldname>type</objecttypefieldname>
  518. <issystemobjectfieldname>is system</issystemobjectfieldname>
  519. <sqlcreationfieldname/>
  520. <includeCatalog>N</includeCatalog>
  521. <includeSchema>N</includeSchema>
  522. <includeTable>Y</includeTable>
  523. <includeView>N</includeView>
  524. <includeProcedure>N</includeProcedure>
  525. <includeSynonym>N</includeSynonym>
  526. <addSchemaInOutput>N</addSchemaInOutput>
  527. <dynamicSchema>N</dynamicSchema>
  528. <schemaNameField/>
  529. <attributes/>
  530. <cluster_schema/>
  531. <remotesteps>
  532. <input>
  533. </input>
  534. <output>
  535. </output>
  536. </remotesteps>
  537. <GUI>
  538. <xloc>192</xloc>
  539. <yloc>128</yloc>
  540. <draw>Y</draw>
  541. </GUI>
  542. </step>
  543. <step>
  544. <name>Truncate table</name>
  545. <type>ExecSQL</type>
  546. <description/>
  547. <distribute>Y</distribute>
  548. <custom_distribution/>
  549. <copies>1</copies>
  550. <partitioning>
  551. <method>none</method>
  552. <schema_name/>
  553. </partitioning>
  554. <connection>DATEV</connection>
  555. <execute_each_row>Y</execute_each_row>
  556. <single_statement>N</single_statement>
  557. <replace_variables>Y</replace_variables>
  558. <quoteString>N</quoteString>
  559. <sql>TRUNCATE TABLE import.${tablename};</sql>
  560. <set_params>N</set_params>
  561. <insert_field/>
  562. <update_field/>
  563. <delete_field/>
  564. <read_field/>
  565. <arguments>
  566. <argument>
  567. <name>tablename</name>
  568. </argument>
  569. </arguments>
  570. <attributes/>
  571. <cluster_schema/>
  572. <remotesteps>
  573. <input>
  574. </input>
  575. <output>
  576. </output>
  577. </remotesteps>
  578. <GUI>
  579. <xloc>384</xloc>
  580. <yloc>128</yloc>
  581. <draw>Y</draw>
  582. </GUI>
  583. </step>
  584. <step_error_handling>
  585. </step_error_handling>
  586. <slave-step-copy-partition-distribution>
  587. </slave-step-copy-partition-distribution>
  588. <slave_transformation>N</slave_transformation>
  589. <attributes/>
  590. </transformation>