| |
|
RSS Feed - WebSphere MQ Support
|
RSS Feed - Message Broker Support
|
  |
|
| Warehouse Node: strange behaviour? |
« View previous topic :: View next topic » |
| Author |
Message
|
| PieterV |
 Posted: Tue Apr 11, 2006 12:07 am Post subject: Warehouse Node: strange behaviour? |
 |
|
Disciple
Joined: 04 Jan 2006
Posts: 164
Location: Belgium
|
Hello,
i have a simple flow: MQInput -> Warehouse -> MQOutput.
The warehouse node writes the message and the timestamp to an Oracle database using JDBC.
But what goes wrong is that he writes it in 2 records, the first time he writes the message (as blob) and the timestamp is empty, the second time the timestamp is good but the message is empty.
The mapping:
| Code: |
<?xml version="1.0" encoding="UTF-8"?>
<mfmap:MappingRoutineCollection xmi:version="2.0" xmlns:xmi="http://www.omg.org/XMI" xmlns:mfmap="mfmap.xmi" xmi:id="MappingRoutineCollection_1" nodeSchema="">
<routines xmi:id="MappingRoutine_1" name="WareHouse_Warehouse" type="warehouse">
<outputResources xmi:type="mfmap:OutputRDBResource" xmi:id="OutputRDBResource_1" uri="IT2D_IT2D_WBIMBBR_WAREHOUSE.tblxmi#WAREHOUSE" nameInMappings="WAREHOUSE" schemaName="WBIMBBR" tableName="WAREHOUSE">
<referencedSymbols xmi:id="BuilderSymbol_1" uri="tblxmi:WBIMBBR#WAREHOUSE"/>
<referencedSymbols xmi:id="BuilderSymbol_2" uri="tblxmi:WBIMBBR#WAREHOUSE.TIMESTAMP"/>
<referencedSymbols xmi:id="BuilderSymbol_3" uri="tblxmi:WBIMBBR#WAREHOUSE.MESSAGE"/>
<mappings xmi:id="TransformMapping_1">
<helper xmi:id="TransformMappingHelper_1">
<statement xmi:type="mfmap:InsertStatement" xmi:id="InsertStatement_1">
<assignments xmi:id="TableAssignment_1" expression="BITSTREAM(MsgRoot)">
<target xmi:id="TransformMappingItem_1" parentPath="WAREHOUSE" name="MESSAGE" esqlPath=""#T".MESSAGE"/>
</assignments>
</statement>
</helper>
</mappings>
<mappings xmi:id="TransformMapping_2">
<helper xmi:id="TransformMappingHelper_2">
<statement xmi:type="mfmap:InsertStatement" xmi:id="InsertStatement_2">
<assignments xmi:id="TableAssignment_2" expression="CURRENT_TIMESTAMP">
<target xmi:id="TransformMappingItem_2" parentPath="WAREHOUSE" name="TIMESTAMP" esqlPath=""#T".TIMESTAMP"/>
</assignments>
</statement>
</helper>
</mappings>
</outputResources>
<inputResources xmi:type="mfmap:InputMessageResource" xmi:id="InputMessageResource_1" uri="RailEasySet/wbimbrec2.mxsd#/msg_WBIMB_BLOB_RECORD;XSDElementDeclaration=2/$MRMessage" nameInMappings="msg_WBIMB_BLOB_RECORD" messageName="msg_WBIMB_BLOB_RECORD" messageType="WBIMB_BLOB_RECORD" parserDomain="MRM">
<referencedSymbols xmi:id="BuilderSymbol_4" uri="mset:message#{}msg_WBIMB_BLOB_RECORD"/>
<referencedSymbols xmi:id="BuilderSymbol_5" uri="mset:complexType#{}WBIMB_BLOB_RECORD"/>
</inputResources>
</routines>
</mfmap:MappingRoutineCollection>
|
i've pasted it as xml cause it says more than the graphical design.
The usertrace contains no errors:
| Code: |
2006-04-11 09:52:33.546364 35 UserTrace BIP2632I: Message received and propagated to 'out' terminal of MQ input node 'WareHouse.MQIn
put'.
2006-04-11 09:52:33.546620 35 UserTrace BIP6060I: Parser type 'Properties' created on behalf of node 'WareHouse.MQInput' to handle p
ortion of incoming message of length 0 bytes beginning at offset '0'.
2006-04-11 09:52:33.546742 35 UserTrace BIP6061I: Parser type 'MQMD' created on behalf of node 'WareHouse.MQInput' to handle portion
of incoming message of length '364' bytes beginning at offset '0'. Parser type selected based on value 'MQHMD' from previous parser.
2006-04-11 09:52:33.547176 35 UserTrace BIP6061I: Parser type 'MRM' created on behalf of node 'WareHouse.MQInput' to handle portion
of incoming message of length '1892' bytes beginning at offset '364'. Parser type selected based on value 'MRM' from previous parser.
2006-04-11 09:52:33.547310 35 UserTrace BIP2537I: Node 'WareHouse.Warehouse': Executing statement 'BEGIN ... END;' at (.IBM_WBIMB_Wa
reHouse_Warehouse.Main, 1.40).
2006-04-11 09:52:33.547444 35 UserTrace BIP2537I: Node 'WareHouse.Warehouse': Executing statement 'DECLARE s_msg_WBIMB_BLOB_RECORD R
EFERENCE TO Root.MRM;' at (.IBM_WBIMB_WareHouse_Warehouse.Main, 2.2).
2006-04-11 09:52:33.547588 35 UserTrace BIP2537I: Node 'WareHouse.Warehouse': Executing statement 'DECLARE MsgRoot REFERENCE TO Root
;' at (.IBM_WBIMB_WareHouse_Warehouse.Main, 4.2).
2006-04-11 09:52:33.547684 35 UserTrace BIP2537I: Node 'WareHouse.Warehouse': Executing statement 'WareHouse_Warehouse(MsgRoot, s_ms
g_WBIMB_BLOB_RECORD);' at (.IBM_WBIMB_WareHouse_Warehouse.Main, 5.2).
2006-04-11 09:52:33.547794 35 UserTrace BIP2538I: Node 'WareHouse.Warehouse': Evaluating expression 'WareHouse_Warehouse(MsgRoot, s_
msg_WBIMB_BLOB_RECORD)' at (.IBM_WBIMB_WareHouse_Warehouse.Main, 5.26).
2006-04-11 09:52:33.570812 35 UserTrace BIP2537I: Node 'WareHouse.Warehouse': Executing statement 'BEGIN ... END;' at (.WareHouse_Wa
rehouse, 4.1).
2006-04-11 09:52:33.570908 35 UserTrace BIP2537I: Node 'WareHouse.Warehouse': Executing statement 'DATABASE(INSERT INTO WAREHOUSE(ME
SSAGE) VALUES (?), BITSTREAM(MsgRoot));' at (.WareHouse_Warehouse, 7.1).
2006-04-11 09:52:33.571060 35 UserTrace BIP2538I: Node 'WareHouse.Warehouse': Evaluating expression 'BITSTREAM(MsgRoot)' at (.WareHo
use_Warehouse, 7.50).
2006-04-11 09:52:33.573492 35 UserTrace BIP2540I: Node 'WareHouse.Warehouse': Finished evaluating expression 'BITSTREAM(MsgRoot)' at
(.WareHouse_Warehouse, 7.50). The result was 'X'4d4420200000[...]04040''.
2006-04-11 09:52:33.575644 35 UserTrace BIP2544I: Node 'WareHouse.Warehouse': Executing database SQL statement 'INSERT INTO WAREHOUS
E(MESSAGE) VALUES (?)' derived from (.WareHouse_Warehouse, 7.1); expressions 'BITSTREAM(MsgRoot)'; resulting parameter values ''X'4d4420200000[...]04040''.
2006-04-11 09:52:33.607288 35 UserTrace BIP2537I: Node 'WareHouse.Warehouse': Executing statement 'DATABASE(INSERT INTO WAREHOUSE(TI
MESTAMP) VALUES (?), CURRENT_TIMESTAMP);' at (.WareHouse_Warehouse, 10.1).
2006-04-11 09:52:33.607372 35 UserTrace BIP2538I: Node 'WareHouse.Warehouse': Evaluating expression 'CURRENT_TIMESTAMP' at (.WareHou
se_Warehouse, 10.52).
2006-04-11 09:52:33.607696 35 UserTrace BIP2540I: Node 'WareHouse.Warehouse': Finished evaluating expression 'CURRENT_TIMESTAMP' at
(.WareHouse_Warehouse, 10.52). The result was 'TIMESTAMP '2006-04-11 09:52:33.546482''.
2006-04-11 09:52:33.607824 35 UserTrace BIP2544I: Node 'WareHouse.Warehouse': Executing database SQL statement 'INSERT INTO WAREHOUS
E(TIMESTAMP) VALUES (?)' derived from (.WareHouse_Warehouse, 10.1); expressions 'CURRENT_TIMESTAMP'; resulting parameter values 'TIMESTAMP '20
06-04-11 09:52:33.546482''.
2006-04-11 09:52:33.609860 35 UserTrace BIP2537I: Node 'WareHouse.Warehouse': Executing statement 'RETURN TRUE;' at (.IBM_WBIMB_Ware
House_Warehouse.Main, 7.2).
2006-04-11 09:52:33.609988 35 UserTrace BIP4184I: Message propagated to 'out' terminal of database node 'WareHouse.Warehouse'.
2006-04-11 09:52:33.610904 35 UserTrace BIP2638I: The MQ output node 'WareHouse.MQOutput' attempted to write a message to queue 'TES
TOUT' connected to queue manager ''. The MQCC was '0' and the MQRC was '0'.
2006-04-11 09:52:33.610960 35 UserTrace BIP2622I: Message successfully output by output node 'WareHouse.MQOutput' to queue 'TESTOUT'
on queue manager ''.
|
You see that there are 2 insert statements, shoudnt this be one statement?
Pieter |
|
| Back to top |
|
 |
|
|
|
| |
|
Page 1 of 1 |
|
You cannot post new topics in this forum
You cannot reply to topics in this forum
You cannot edit your posts in this forum
You cannot delete your posts in this forum
You cannot vote in polls in this forum
|
|
|
|
