Connect to AWS Athena Database in a Mule Application With Generic Database

This would be a short tutorial on connecting from MuleSoft to AWS Athena Database. We will use Generic Database Driver.

 Please read through the following resources for further information before getting started, just in case. 

• Introduction to MuleSoft Anypoint Studio
• Introduction to building API using MuleSoft
• MuleSoft Database Connector
• MuleSoft Database Connector: Configuring a generic connection
• Connect Amazon Athena with JDBC

We will get started and go through each process step by step. Let's assume that we have the following information before getting started:

• Athena S3 Output Location:
• AWS Region:
• UserName:
• Password:

Get Started

We will start by creating a Project in Anypoint MuleSoft Platform. If you want to understand how to do this, please check my blog on Introduction to Building API Using MuleSoft. 

Once we have created the application, the first step is to update our POM with the necessary JAR. I was not able to find a MAVEN Repository having the necessary JAR Files available to be used. However, I was able to get the JAR files.

The JAR files can be available for download here in my GitHub space.

Alternatively, you can download the JAR file from the AWS Documentation Connect Amazon Athena with JDBC.

In my case, I am using version 2.1.0.1000, the JDBC driver with AWS SDK.

Once the corresponding JAR is downloaded, we need to upload the same to the artifactory that we use. In my case, I will simply upload this to my Maven Repository using the following command.

mvn install:install-file \
   -Dfile= \
   -DgroupId= \
   -DartifactId= \
   -Dversion= \
   -Dpackaging= \
   -DgeneratePom=true

In my case:

mvn install:install-file   -Dfile= -DgroupId=aws.athena -DartifactId=AthenaJDBC42 -Dversion=2.1.0.1000 

I would overwrite the pom file that I have downloaded from the GitLab.

Set Up My Application POM File

Once completed, we must update my POM File at 2 places:

• Add the dependency to the AthenaJDBC42 JAR.

	aws.athena
    AthenaJDBC42
    2.1.0.1000

• Add the shared library configuration.

	org.mule.tools.maven
    mule-maven-plugin
    ${mule.maven.plugin.version}
    true
    
		
			
				aws.athena
				AthenaJDBC42
			                              
		
		mule-application
	

Starting the Code

Here is an example of the code used. We will head back to the actual XML and start by creating a flow consisting of the following, in order:

• HTTP Listener
• Logger
• Database Select
• Logger
• Map to convert the output to JSON

• The Flow should look something like this.

Here is the code that I have in my XML:

Testing My Application

Finally, I will run my application in MuleSoft. 

Once the application is deployed, up and kicking, we can call the API from Postman:

Conclusion

This blog explains the steps required to configure the Mule application to use generic database configuration to connect to Amazon Athena using the AWS Athena JDBC Driver. Please let me know your thoughts. The idea was to connect to the database. Of course, we should have proper error handling, HTTPs security, etc., in the application.