refactor: refactor columnsReturned to seperate select for postgres co…

…mpatability
wearefrank · Sep 27, 2023 · 1f602f2 · 1f602f2
1 parent a6402b5
commit 1f602f2
Show file tree

Hide file tree

Showing 2 changed files with 37 additions and 5 deletions.
diff --git a/...ns/Documenten API - 1.1.0/configuration_documenten_enkelvoudiginformatieobject_create.xml b/...ns/Documenten API - 1.1.0/configuration_documenten_enkelvoudiginformatieobject_create.xml
@@ -64,15 +64,31 @@
                 <Forward name="error" path="InternalServerError"/>
             </XsltPipe>
 
-			<SenderPipe name="InsertZgwEnkelvoudigInformatieObjectSender">
+			<SenderPipe
+				name="InsertZgwEnkelvoudigInformatieObjectSender"
+				storeResultInSessionKey="pk"
+				>
                 <FixedQuerySender
 					name="InsertZgwEnkelvoudigInformatieObjectFixedQuerySender"
                     query="INSERT INTO ENKELVOUDIGINFORMATIEOBJECT (DATA, FILE) VALUES (?{data}, ?{file})" 
                     queryType="OTHER"
-					columnsReturned="PK,ID,DATA,FILE"
+					scalar="true"
                     />
                     <Param name="data" />
 					<Param name="file" sessionKey="orginalMessageXml" xpathExpression="//inhoud" />
+                <Forward name="success" path="SelectZgwEnkelvoudigInformatieObjectSender" />
+                <Forward name="exception" path="InternalServerError" />
+            </SenderPipe>
+
+			<SenderPipe
+				name="SelectZgwEnkelvoudigInformatieObjectSender"
+				>
+                <FixedQuerySender
+					name="SelectZgwEnkelvoudigInformatieObjectFixedQuerySender"
+                    query="SELECT PK,ID,DATA FROM ENKELVOUDIGINFORMATIEOBJECT WHERE PK = ?{pk}" 
+                    queryType="SELECT"
+                    />
+                    <Param name="pk" sessionKey="pk"/>
                 <Forward name="success" path="StoreSubstitutionVars" />
                 <Forward name="exception" path="InternalServerError" />
             </SenderPipe>

diff --git a/...main/configurations/Zaken API - 1.2.0/configuration_zaken_zaakinformatieobject_create.xml b/...main/configurations/Zaken API - 1.2.0/configuration_zaken_zaakinformatieobject_create.xml
@@ -59,14 +59,30 @@
                 <Forward name="error" path="InternalServerError"/>
             </XsltPipe>
 
-			<SenderPipe name="InsertZgwZaakInformatieObjectSender">
+			<SenderPipe
+				name="InsertZgwZaakInformatieObjectSender"
+				storeResultInSessionKey="pk"
+				>
                 <FixedQuerySender
 					name="InsertZgwZaakInformatieObjectFixedQuerySender"
-                    query="INSERT INTO ZAAKINFORMATIEOBJECT (DATA) VALUES (?{data})" 
+                    query="INSERT INTO ZAAKINFORMATIEOBJECT (DATA) VALUES (?{data})"
+					scalar="true"
                     queryType="OTHER"
-					columnsReturned="PK,ID,DATA"
                     />
                     <Param name="data" />
+                <Forward name="success" path="SelectZgwZaakInformatieObjectSender" />
+                <Forward name="exception" path="InternalServerError" />
+            </SenderPipe>
+
+			<SenderPipe
+				name="SelectZgwZaakInformatieObjectSender"
+				>
+                <FixedQuerySender
+					name="SelectZgwZaakInformatieObjectFixedQuerySender"
+                    query="SELECT * FROM ZAAKINFORMATIEOBJECT WHERE PK = ?{pk}" 
+                    queryType="SELECT"
+                    />
+                    <Param name="pk" sessionKey="pk" />
                 <Forward name="success" path="StoreSubstitutionVars" />
                 <Forward name="exception" path="InternalServerError" />
             </SenderPipe>