Advertisement
Not a member of Pastebin yet?
Sign Up,
it unlocks many cool features!
- <!DOCTYPE etl SYSTEM "http://scriptella.javaforge.com/dtd/etl.dtd">
- <etl>
- <!-- = = = = = = = = = = = = = = = = = = = -->
- <!-- = Load external properties = -->
- <!-- = = = = = = = = = = = = = = = = = = = -->
- <properties><include href="etl.properties"/></properties>
- <!-- = = = = = = = = = = = = = = = = = = = -->
- <!-- = Connections = -->
- <!-- = = = = = = = = = = = = = = = = = = = -->
- <connection id='log' driver='${driver_log}'/>
- <connection id='src' driver='${driver_src}' url='${url_src}' user='${user_src}' password='${pass_src}' classpath='lib/ojdbc6.jar'>
- //autocommit=true
- </connection>
- <connection id='csv' driver="${driver_csv}" url="source/SalesOrderDetail.csv">
- headers=off
- separator=\t
- </connection>
- <!-- = = = = = = = = = = = = = = = = = = = -->
- <!-- Job definition = -->
- <!-- = = = = = = = = = = = = = = = = = = = -->
- <script connection-id='src'>
- <onerror codes="955" retry='true'>
- DROP TABLE SRC_SalesOrderDetail;
- </onerror>
- CREATE TABLE SRC_SalesOrderDetail(
- SalesOrderID int,
- SalesOrderDetailID int,
- CarrierTrackingNumber varchar2(25),
- OrderQty smallint,
- ProductID int,
- SpecialOfferID int,
- UnitPrice decimal(16,4),
- UnitPriceDiscount decimal(16,4),
- LineTotal decimal(16,4),
- rowguid varchar2(64),
- ModifiedDate timestamp
- );
- </script>
- <query connection-id="csv">
- <script connection-id="src">
- INSERT INTO SRC_SalesOrderDetail
- VALUES (
- ?1,
- ?2,
- ?3,
- ?4,
- ?5,
- ?6,
- ?7,
- ?8,
- ?9,
- ?10,
- to_timestamp(?11,'yyyy-mm-dd hh24:mi:ss.ff')
- );
- </script>
- </query>
- <query connection-id='src'>
- SELECT count(1) AS result FROM SRC_SalesOrderDetail;
- <script connection-id='log'>
- [SalesOrderDetail] Loaded: ${result}
- </script>
- </query>
- </etl>
Advertisement
Add Comment
Please, Sign In to add comment
Advertisement