Data Source Connection with RESTful Web Services



After reading this Article, You should have an Understanding of –

  • Restful Web Services in AEM.
  • Swagger Implementation of Services ( YAML/JSON file).
  • Creation of Data Source with YMAL File.
  • Form Data Model Creation Using Restful Service Data Source
  • Adaptive Form Creation Using Form Data Model.


We found many cases in AEM Form development where we used a Restfull web service to store and retrieve form data. We can use it to create a data source with the help of a swagger specification. This method helps us to use restful web services as an end point within or outside of AEM. So in this post, we will create a data source and a form data model with the help of restful web services and, using that form data model, we will create an adaptive form.

Hence, without any further delay, let’s get started:-

Restful Web Services in AEM

RESTful Web Services are basically REST Architecture based Web Services. In the REST architecture, everything is a resource. RESTful web services are light-weight, highly scalable, maintainable and are very commonly used to create APIs for web-based applications. We can use Swagger to create REST-based APIs with the help of the Swagger Specification. It is a set of open-source tools.

For this Article we will use AEM Servlet as Restful we services there we will implement doGet() and doPost() Methods to fetch and insert Scholar data from database. You are free to choose different Rest Web Services as per your needs for data source connection.

					package com.adobe.learning.core.servlets;

import org.json.JSONArray;
import org.json.JSONException;
import org.json.JSONObject;
import org.osgi.framework.Constants;
import org.osgi.service.component.annotations.Component;
import org.osgi.service.component.annotations.Reference;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;

import javax.servlet.Servlet;
import javax.sql.DataSource;
import java.sql.*;
import java.util.Map;

@Component(service = Servlet.class, property = {Constants.SERVICE_DESCRIPTION + "=AEM Scholar Servlet for Data Source and FDM",
        ServletResolverConstants.SLING_SERVLET_PATHS + "=/bin/aemScholarServlet"})
public class AEMScholarServlet extends SlingAllMethodsServlet {

    private static final long serialVersionUID = 1L;
    protected static final Logger LOGGER = LoggerFactory.getLogger(AEMScholarServlet.class);

    DataSource dataSource;

     * Get Method to fetch scholar details with ID
     * @param request  Fetch ID from request parameters.
     * @param response Write JSON Response of Data.
    protected void doGet(SlingHttpServletRequest request, SlingHttpServletResponse response) {
        try {
            int id = Integer.parseInt(request.getParameter("id"));
            JSONArray jsonArrayData = getSingleScholarData(id);

        } catch (IOException e) {
            LOGGER.error("Error in response writing :{}", e.getMessage());

     * Post Method to update scholar data in MYSQL Database.
     * @param request  Fetch all Form parameter to insert.
     * @param response Response as true after successful insertion.
    protected void doPost(SlingHttpServletRequest request, SlingHttpServletResponse response) {"### Inside doPost");
        Connection connection = getConnection();
        try (PreparedStatement preparedStatement = connection.prepareStatement("INSERT INTO AEM_SQL.SCHOLAR (ID, NAME, DOB, GENDER, GRADE) VALUES (?, ?, ?, ?, ?)")) {

            Map<String, String[]> allParameter = request.getParameterMap();
            Map.Entry<String, String[]> paramEntry = allParameter.entrySet().iterator().next();
            String allValues = paramEntry.getKey();
            JSONObject jsonObject = new JSONObject(allValues);

            preparedStatement.setInt(1, jsonObject.getInt("id"));
            preparedStatement.setString(2, jsonObject.getString("name"));
            preparedStatement.setString(3, jsonObject.getString("dob"));
            preparedStatement.setString(4, jsonObject.getString("gender"));
            preparedStatement.setString(5, jsonObject.getString("grade"));

        } catch (IOException | SQLException | JSONException e) {
            LOGGER.error("Error in response writing :{}", e.getMessage());

     * Return JSON Array Data for specific ID
     * @return Return all JSON Array Data
     * @param id Take input as ID
    public JSONArray getSingleScholarData(int id) {
        LOGGER.debug("### Inside my getData of aem_sql.scholar");
        JSONArray jsonArray = new JSONArray();
        Connection connection = getConnection();
        try (PreparedStatement preparedStatement = connection.prepareStatement("SELECT * FROM AEM_SQL.SCHOLAR WHERE ID = ?")) {
            preparedStatement.setInt(1, id);
            ResultSet resultSet = preparedStatement.executeQuery();
            jsonArray = getJsonData(resultSet);
        } catch (SQLException | JSONException e) {
            LOGGER.error("SQL Exception Occurred :{}", e.getMessage());
        return jsonArray;

     * Getting the connection to Data Source MYSQL.
     * @return the connection object.
    public Connection getConnection() {
        LOGGER.debug("### Getting Connection :");
        Connection connection = null;
        try {
            connection = dataSource.getConnection();
            LOGGER.debug("Got connection");
        } catch (Exception e) {
            LOGGER.debug("Not able to get connection {}", e.getMessage());
        return connection;

     *  Fetch data in form of JSON Array from resultSet.
     * @param resultSet Take result of executed query.
     * @return Data in form of JSON Array.
     * @throws SQLException Throw SQL Exception.
     * @throws JSONException Throw JSON Exception.
    public JSONArray getJsonData(ResultSet resultSet) throws SQLException, JSONException {
        JSONArray jsonArray = new JSONArray();
        ResultSetMetaData resultSetMetaData = resultSet.getMetaData();
        while ( {
            int numColumns = resultSetMetaData.getColumnCount();
            JSONObject jsonObject = new JSONObject();
            eachRowData(numColumns, resultSet, resultSetMetaData, jsonObject);
        return jsonArray;

     * Fetch SQL data for all Column and Put in JSON Object.
     * @param numColumns Column in SQL Table.
     * @param resultSet Result of Executed Query.
     * @param resultSetMetaData ResultSet Metadata
     * @param jsonObject New Json Object
     * @throws SQLException Throw SQL Exception
     * @throws JSONException Throw JSON Exception
    public void eachRowData(int numColumns, ResultSet resultSet, ResultSetMetaData resultSetMetaData, JSONObject jsonObject) throws SQLException, JSONException {
        for (int i = 1; i < numColumns + 1; i++) {
            String column_name = resultSetMetaData.getColumnName(i);
            if (resultSetMetaData.getColumnType(i) == Types.ARRAY) {
                jsonObject.put(column_name, resultSet.getArray(column_name));
            } else if (resultSetMetaData.getColumnType(i) == Types.BOOLEAN) {
                jsonObject.put(column_name, resultSet.getBoolean(column_name));
            } else if (resultSetMetaData.getColumnType(i) == Types.DOUBLE) {
                jsonObject.put(column_name, resultSet.getDouble(column_name));
            } else if (resultSetMetaData.getColumnType(i) == Types.FLOAT) {
                jsonObject.put(column_name, resultSet.getFloat(column_name));
            } else if (resultSetMetaData.getColumnType(i) == Types.INTEGER) {
                jsonObject.put(column_name, resultSet.getInt(column_name));
            } else if (resultSetMetaData.getColumnType(i) == Types.NVARCHAR) {
                jsonObject.put(column_name, resultSet.getNString(column_name));
            } else if (resultSetMetaData.getColumnType(i) == Types.VARCHAR) {
                jsonObject.put(column_name, resultSet.getString(column_name));
            } else if (resultSetMetaData.getColumnType(i) == Types.SMALLINT) {
                jsonObject.put(column_name, resultSet.getInt(column_name));
            } else if (resultSetMetaData.getColumnType(i) == Types.DATE) {
                jsonObject.put(column_name, resultSet.getDate(column_name));
            } else if (resultSetMetaData.getColumnType(i) == Types.TIMESTAMP) {
                jsonObject.put(column_name, resultSet.getTimestamp(column_name));
            } else {
                jsonObject.put(column_name, resultSet.getObject(column_name));

  • In this class, We are using DataSource Object that provide connection to MYSQL. You can refer  – Data Source Connection with MYSQL (Relational Databases) for more details on MYSQL and DataSurce.
  • Create scholar database table(id, name dob, gender and grade) to store new scholar details.

Swagger Implementation of Services ( YAML/JSON file)

  • Swagger is a set of open source tools for documenting REST-based APIs. 
  • Simplify API development for users, teams, and enterprises with the Swagger open source and professional toolset.
  • Swagger offers a tool called the Swagger Editor which helps us design our APIs based on the OpenAPI specification. 

Swagger Specification for

  • Navigate to Swagger Editor
  • Modify the content as per Restful web service for GET and POST Services.


					swagger: '2.0'
  description: AEM Scholar SQL Swagger API
  version: 1.0.0
  title: AEM Scholar Swagger API
  - http
  - application/json
  - application/json
host: 'localhost:4502'
      summary: Fetch Scholar Data with ID
        - application/x-www-form-urlencoded
        - application/json
        - in: query
          name: id
          type: integer
          required: true
          description: All Scholar Details
            type: array
              $ref: '#/definitions/Scholar'
          description: Invalid Input
      summary: Add New Scholar
      operationId: addNewScholar
        - application/x-www-form-urlencoded
        - application/json
      - in: "body"
        name: "body"
        description: "Add New Scholar in MYSQL Database"
        required: true
          $ref: "#/definitions/Scholar"
          description: Scholar Details Added to MYSQL
          description: Invalid Input
    type: object
        type: integer
        type: string
        type: string
        type: string
        type: string
AEM Swagger Editor
Swagger Editor

Creation of Data Source with YMAL File

  • Cloud Configurations should be checked for folder in Configuration Browser( Tools –> General –> Configuration Browser). If not checked edit Configuration Properties.
  • Now, Navigate to Data Sources(Tools –> Cloud Services –> Data Sources) – http://localhost:4502/libs/fd/fdm/gui/components/admin/fdmcloudservice/fdm.html/conf
  • Select folder and click on create.
  • Give proper title and select service type as Restful web service, Click on next.
  • Browse ScholarSwagger.ymal file and select Basic Authentication.
  • Fill username and password and Click on create.
  • That’s it, Data Source with Restful web services created successfully.
Cloud Configuration
Configuration Properties
Scholar Data Source I
Scholar Data Source I
Scholar Data Source II
Scholar Data Source I

Form Data Model Creation Using Restful Service Data Source

  • Navigate to Form Data Integration – http://localhost:4502/aem/forms.html/content/dam/formsanddocuments-fdm
  • Click on Create and select Form Data Model.
  • Give Proper FDM Title, Select Data Source Configuration Folder and Click on Next.
  • Select Restful Service (e.g. Scholar Data Source) and create it.
  • Edit the Form Data Model, Select scholar data and service in Model.
  • Select the Model and click on edit properties to configure default read and write service and save it.
  • Select the service and click on edit properties to configure all required field and save the model.
  • Select the service and click on Test Service. It should successfully fetch and insert data in table.
Scholar FDM I
FDM with Scholar Data
Scholar FDM II
Testing POST Service
Scholar FDM III
Testing GET Service

Adaptive Form Using Form Data Model

  • Navigate to Adaptive form folder and start form creation using blank template.
  • Select the Form Data Model (Scholar FDM) and create the form.
  • Now Edit the form and drag Scholar in root panel.
  • Add submit button in the form.
  • Edit form container to configure submission.
  • Select Submit Action as “Submit Using Form Data Model” and Data Model as “Scholar FDM”
  • Save all the change and Navigate to Preview Mode.
  • Fill all data and submit the form, that’s all and data should successfully save in MYSQL Database
Scholar Form I
Scholar Forms
Scholar Form II
Submit Action
Scholar Form III
Form Submission


  • So in this post, we have covered the Data Source Creation with the help of Restful Web Services and using that Data Source we can create Form Data Model, Adaptive Form etc.
  •  I hope you enjoyed this post. Your suggestions and feedback are always welcome.

1 Comment

Leave a Reply

Your email address will not be published.