MuleSoft Connector for Spark SQL

Build 21.0.7930

Parameterized Queries

You can use Dataweave to build parameterized queries and dynamic queries. The following sections provide more information on executing and configuring the parameters in the standard visual editor and in the XML directly.

Configuring Parameterized Queries

In the SQL query box, enter the query you want to use with the parameterized values prefixed with the ':' character. For example:

SELECT * FROM Customers WHERE Country = :Country

In the Input Parameters box, set the key value pair for the parameter and value via a DataWeave script:

output application/json
---
{
  "Country": payload
}

XML Editor

The XML below corresponds to the same parameterized query demonstrated above:

<cdata-sparksql:select config-ref="CData_SparkSQL_Configuration" query="SELECT * FROM Customers WHERE Country = :Country" doc:name="CData SparkSQL"/>
<cdata-sparksql:input-parameters ><![CDATA[#[output application/json --- { "Country": payload }]]]></cdata-sparksql:input-parameters>

Copyright (c) 2021 CData Software, Inc. - All rights reserved.
Build 21.0.7930