Transforming Flight Data with DataWeave

mule-xml.json (Mule XML)

{
	// Place your snippets for mule-xml here. Each snippet is defined under a snippet name and has a prefix, body and
	// description. The prefix is what is used to trigger the snippet and the body will be expanded and inserted. Possible variables are:
	// $1, $2 for tab stops, $0 for the final cursor position, and ${1:label}, ${2:another} for placeholders. Placeholders with the
	// same ids are connected.
	// Example:
	// "Print to console": {
	// 	"prefix": "log",
	// 	"body": [
	// 		"console.log('$1');",
	// 		"$2"
	// 	],
	// 	"description": "Log output to console"
	// }
}

{
  "Transform Message": {
    "prefix": "muledx:transform-message",
    "body": [
      "<ee:transform doc:name=\"${1:Transform Message}\" doc:id=\"$RANDOM_HEX-$RANDOM_HEX\">",
      "  <ee:message>",
      "    <ee:set-payload>",
      "      <![CDATA[${2:DataWeave}]]>",
      "    </ee:set-payload>",
      "  </ee:message>",
      "</ee:transform>"
    ]
  },
  "Mule Flow": {
    "prefix": "muledx:flow",
    "body": [
      "<flow name=\"${1:$TM_FILENAME_BASE-Flow}\" doc:id=\"$RANDOM_HEX-$RANDOM_HEX\">",
        "",
      "</flow>"
  ]
  },
  "HTTP Listener Config": {
    "prefix": "muledx:http-listener-config",
    "body": [
      "<http:listener-config name=\"${1:httpListenerConfig}\" doc:name=\"${2:Listener Config}\" doc:id=\"$RANDOM_HEX-$RANDOM_HEX\">",
      "  <http:listener-connection host=\"${3:Host}\" port=\"${4:Port}\"/>",
      "</http:listener-config>"
    ]
  },
  "HTTP Listener": {
    "prefix": "muledx:http-listener",
    "body": [
      "<http:listener path=\"/${1:path}\" config-ref=\"${2:httpListenerConfig}\" doc:name=\"${3:Listener}\" doc:id=\"$RANDOM_HEX-$RANDOM_HEX\"/>"
    ]
  },
  "Set Payload": {
    "prefix": "muledx:set-payload",
    "body": [
      "<set-payload value=\"${1:#[payload]}\" doc:name=\"${2:Set Payload}\" doc:id=\"$RANDOM_HEX-$RANDOM_HEX\"/>"
    ]
  },
  "Set Variable": {
    "prefix": "muledx:set-variable",
    "body": [
      "<set-variable variableName=\"${1:name}\" value=\"${2:#[payload]}\" doc:name=\"${3:Set Variable}\" doc:id=\"$RANDOM_HEX-$RANDOM_HEX\"/>"
    ]
  },
  "Logger": {
    "prefix": "muledx:logger",
    "body": [
      "<logger level=\"INFO\" message=\"${1:#[payload]}\" doc:name=\"${2:Logger}\" doc:id=\"$RANDOM_HEX-$RANDOM_HEX\"/>"
    ]
  },
  "Database Config - MySQL": {
    "prefix": "muledx:db-config-mysql",
    "body": [
      "<db:config name=\"${1:DatabaseConfig}\" doc:name=\"${2:mySQL DB}\" doc:id=\"$RANDOM_HEX-$RANDOM_HEX\">",
      "  <db:my-sql-connection host=\"${3:Host}\" port=\"${4:Port}\" user=\"${5:Username}\" password=\"${6:Password}\" database=\"${7:DatabaseName}\" />",
      "</db:config>"
    ]
  },
  "Database Select": {
    "prefix": "muledx:db-select",
    "body": [
      "<db:select config-ref=\"${1:DatabaseConfigRef}\" doc:name=\"${2:Select}\" doc:id=\"$RANDOM_HEX-$RANDOM_HEX\">",
      "  <db:sql>",
      "    <![CDATA[${3:SQL}]]>",
      "  </db:sql>",
      "</db:select>"
    ]
  }
}

<ee:transform doc:name="" doc:id="51fed3-afee8c">
  <ee:message>
    <ee:set-payload>
      <![CDATA[]]>
    </ee:set-payload>
  </ee:message>
</ee:transform>

<ee:transform doc:name="Transform Message" doc:id="423214-fac9c4">
...

<ee:transform doc:name="Transform Message" doc:id="51fed3-afee8c">
  <ee:message>
    <ee:set-payload>
      <![CDATA[
      %dw 2.0
      output application/json
      ---
      payload
      ]]>
    </ee:set-payload>
  </ee:message>
</ee:transform>

[
  {
    "planeType": "Boeing 787",
    "code2": "0001",
    "takeOffDate": "2016-01-20T00:00:00",
    "code1": "rree",
    "fromAirport": "MUA",
    "price": 541,
    "seatsAvailable": 0,
    "toAirport": "LAX",
    "ID": 1,
    "airlineName": "American Airlines",
    "totalSeats": 200
  },
    ...
]

Cannot get connection for URL jdbc:mysql://mudb.learn.mulesoft.com:3306/ :
Communications link failure.

<ee:transform doc:name="Transform Message" doc:id="51fed3-afee8c">
  <ee:message>
    <ee:set-payload>
      <![CDATA[
      %dw 2.0
      output application/json
      ---
      payload map ( payload01 , indexOfPayload01 ) -> {
        ID: payload01.ID,
        code: (payload01.code1 default "") ++ (payload01.code2 default ""),
        price: payload01.price default 0,
        departureDate: payload01.takeOffDate as String default "",
        origin: payload01.fromAirport default "",
        destination: payload01.toAirport default "",
        emptySeats: payload01.seatsAvailable default 0,
        plane: {
          "type": payload01.planeType default "",
          totalSeats: payload01.totalSeats default 0
        }
      }
      ]]>
    </ee:set-payload>
  </ee:message>
</ee:transform>

<http:listener-config name="inbound-request" doc:name="HTTP Config">
    <http:listener-connection host="0.0.0.0" port="8081" />
</http:listener-config>

<db:config name="Database_Config" doc:name="mySQL DB">
    <db:my-sql-connection host="mudb.learn.mulesoft.com" port="3306"
        user="mule" password="mule" database="training" />
</db:config>

<flow name="getFlights">
    <http:listener path="flights" config-ref="inbound-request" doc:name="HTTP /flights" />
    <db:select doc:name="Query Flights" config-ref="Database_Config" >
        <db:sql>
            <![CDATA[Select * FROM american]]>
        </db:sql>
    </db:select>

    <ee:transform doc:name="Transform Message">
        <ee:message >
            <ee:set-payload >
            <![CDATA[
            %dw 2.0
            output application/json
            ---
            payload map ( payload01 , indexOfPayload01 ) -> {
              ID: payload01.ID,
              code: (payload01.code1 default "") ++ (payload01.code2 default ""),
              price: payload01.price default 0,
              departureDate: payload01.takeOffDate as String default "",
              origin: payload01.fromAirport default "",
              destination: payload01.toAirport default "",
              emptySeats: payload01.seatsAvailable default 0,
              plane: {
                "type": payload01.planeType default "",
                totalSeats: payload01.totalSeats default 0
              }
            }
            ]]>
            </ee:set-payload>
        </ee:message>
    </ee:transform>
</flow>

[
    {
        "ID": 1,
        "code": "rree0001",
        "price": 541,
        "departureDate": "2016-01-20T00:00:00",
        "origin": "MUA",
        "destination": "LAX",
        "emptySeats": 0,
        "plane": {
            "type": "Boeing 787",
            "totalSeats": 200
        }
    },
    ...