MySQL¶

MySQL is the world's most popular open-source relational database management system, known for its reliability, performance, and ease of use. It supports SQL querying and is widely used for web applications, data warehousing, and enterprise systems.

Why Integrate MySQL with EasyTask?¶

MySQL is the world's most popular open-source relational database trusted by organizations worldwide for its reliability, performance, and ease of use. By integrating MySQL with EasyTask, you can leverage scheduled tasks to perform CRUD operations, manage tables, and execute SQL queries as part of automated data pipelines. EasyTask enables you to create tables, insert and query data, manage databases, and execute complex SQL operations — all triggered on configurable schedules. This integration is ideal for building ETL workflows, automating reporting pipelines, and scheduling routine database maintenance tasks without manual intervention.

Integration Server Vault details¶

Required secrets in Vault¶

JSON

{
  "secret": {
    "database": "xyz_database",
    "host": "xxx.xxx.xxx.xxx",
    "password": "*******",
    "user": "xyz"
  }
}

MySQL JSON Format¶

An MySQL instance can be created as below by passing the vault_path_key:

TableJSON

Field	Type	Description	Required
is_credentials	object	Credentials for authentication	Yes
is_credentials.userid	string	User ID for authentication	Yes
is_credentials.passwd	string	Password for authentication	Yes
integrations	array	List of integration objects	Yes
integration	string	Type of integration (must be "mysql")	Yes
uuid	string	Unique identifier for the integration instance	Yes
init	object	Initialization parameters	Yes
init.vault_path_key	string	Path to the vault containing MySQL credentials	Yes
action	array	List of actions to be performed (empty in this example)	Yes

{
  "is_credentials": {
    "userid": "test",
    "passwd": "test123"
  },
  "integrations": [
    {
      "integration": "mysql",
      "uuid": "ae0e8ba9-423a-410e-bba5-e1933ff868c5",
      "init": {
        "vault_path_key": "mysql/server1"
      },
      "action": []
    }
  ]
}

Example cURL Commands¶

Sample Usage of MySQL¶

Input CommandOutput

curl -X POST http://localhost:8008/run-integration \
-H "Content-Type: application/json" \
-d'
{
  "is_credentials": {
      "userid": "test",
      "passwd": "test123",
  },
  "integrations": [
      {
          "integration": "mysql",
          "uuid": "ae0e8ba9-423a-410e-bba5-e1933ff868c5",
          "init": {
              "vault_path_key": "mysql/server1"
          },
          "action": [
              {
                  "insert_data": {
                      "table_name": "my_table1",
                      "records": [
                          [
                              1,
                              "jake",
                              "forest"
                          ],
                          [
                              2,
                              "wave",
                              "forest"
                          ],
                          [
                              3,
                              "jayant",
                              "khanna"
                          ]
                      ]
                  }
              }
          ]
      }
  ]
}'

{
    {
      "insert_data": null
    }
}

Functions¶

`create_table`¶

Create a MySQL table:

This function creates a new table in MySQL with specified columns and their types.

Input ParametersOutputJSON

Input Parameter	Type	Description	Mandatory
table_name	string	Name of the table to be created	Yes
cols	object	Dictionary of column names and their types	Yes

Output Parameter	Type	Description
user	string	The username of the user who performed the action
integration	string	The type of integration used (mysql)
uuid	string	Unique identifier for the integration instance
init	object	Initialization parameters, including vault path key
error	boolean	Indicates whether an error occurred during the operation
action	array	List of actions performed, with their results

{
  "is_credentials": {
    "userid": "test",
    "passwd": "test123"
  },
  "integrations": [
    {
      "integration": "mysql",
      "uuid": "ae0e8ba9-423a-410e-bba5-e1933ff868c5",
      "init": {
        "vault_path_key": "mysql/server1"
      },
      "action": [
        {
          "create_table": {
            "table_name": "my_table1",
            "cols": {
              "sno": "int",
              "fname": "varchar(50)",
              "lname": "varchar(50)"
            }
          }
        }
      ]
    }
  ]
}

`insert_data`¶

Inserting into MySQL table:

This function inserts records into a specified MySQL table.

Input ParametersOutputJSON

Input Parameter	Type	Description	Mandatory
table_name	string	Name of the table to insert data into	Yes
records	array	2D list of records to be inserted	Yes

Output Parameter	Type	Description
user	string	The username of the user who performed the action
integration	string	The type of integration used (mysql)
uuid	string	Unique identifier for the integration instance
init	object	Initialization parameters, including vault path key
error	boolean	Indicates whether an error occurred during the operation
action	array	List of actions performed, with their results

{
  "is_credentials": {
    "userid": "test",
    "passwd": "test123"
  },
  "integrations": [
    {
      "integration": "mysql",
      "uuid": "ae0e8ba9-423a-410e-bba5-e1933ff868c5",
      "init": {
        "vault_path_key": "mysql/server1"
      },
      "action": [
        {
          "insert_data": {
            "table_name": "my_table1",
            "records": [
              [1, "jake", "forest"],
              [2, "wave", "forest"],
              [3, "jayant", "khanna"]
            ]
          }
        }
      ]
    }
  ]
}

`fetch_data`¶

Fetch data with filters from MySQL table:

This function retrieves data from a MySQL table based on specified filters.

Input ParametersOutputJSON

Input Parameter	Type	Description	Mandatory
tb_name	string	Name of the table to fetch data from	Yes
cols	object	Dictionary of column names and their filter values	Yes

Output Parameter	Type	Description
user	string	The username of the user who performed the action
integration	string	The type of integration used (mysql)
uuid	string	Unique identifier for the integration instance
init	object	Initialization parameters, including vault path key
error	boolean	Indicates whether an error occurred during the operation
action	array	List of actions performed, with their results

{
  "is_credentials": {
    "userid": "test",
    "passwd": "test123"
  },
  "integrations": [
    {
      "integration": "mysql",
      "uuid": "ae0e8ba9-423a-410e-bba5-e1933ff868c5",
      "init": {
        "vault_path_key": "mysql/server1"
      },
      "action": [
        {
          "fetch_data": {
            "tb_name": "my_table1",
            "cols": {
              "sno": 3,
              "fname": "jayant"
            }
          }
        }
      ]
    }
  ]
}

`del_data`¶

Deleting data in MySQL table:

This function deletes data from a MySQL table based on specified criteria.

Input ParametersOutputJSON

Input Parameter	Type	Description	Mandatory
table_name	string	Name of the table to delete data from	Yes
cols	object	Dictionary of column names and their filter values	Yes

Output Parameter	Type	Description
user	string	The username of the user who performed the action
integration	string	The type of integration used (mysql)
uuid	string	Unique identifier for the integration instance
init	object	Initialization parameters, including vault path key
error	boolean	Indicates whether an error occurred during the operation
action	array	List of actions performed, with their results

{
  "is_credentials": {
    "userid": "test",
    "passwd": "test123"
  },
  "integrations": [
    {
      "integration": "mysql",
      "uuid": "ae0e8ba9-423a-410e-bba5-e1933ff868c5",
      "init": {
        "vault_path_key": "mysql/server1"
      },
      "action": [
        {
          "del_data": {
            "table_name": "my_table1",
            "cols": {
              "sno": 3,
              "fname": "jayant"
            }
          }
        }
      ]
    }
  ]
}

`del_all_data`¶

Delete all records in MySQL table:

This function removes all data from a specified MySQL table.

Input ParametersOutputJSON

Input Parameter	Type	Description	Mandatory
table_name	string	Name of the table to delete all data from	Yes

Output Parameter	Type	Description
user	string	The username of the user who performed the action
integration	string	The type of integration used (mysql)
uuid	string	Unique identifier for the integration instance
init	object	Initialization parameters, including vault path key
error	boolean	Indicates whether an error occurred during the operation
action	array	List of actions performed, with their results

{
  "is_credentials": {
    "userid": "test",
    "passwd": "test123"
  },
  "integrations": [
    {
      "integration": "mysql",
      "uuid": "ae0e8ba9-423a-410e-bba5-e1933ff868c5",
      "init": {
        "vault_path_key": "mysql/server1"
      },
      "action": [
        {
          "del_all_data": {
            "table_name": "my_table1"
          }
        }
      ]
    }
  ]
}

`drop_table`¶

Dropping MySQL table:

This function removes a specified table from the MySQL database.

Input ParametersOutputJSON

Input Parameter	Type	Description	Mandatory
table_name	string	Name of the table to be dropped	Yes

Output Parameter	Type	Description
user	string	The username of the user who performed the action
integration	string	The type of integration used (mysql)
uuid	string	Unique identifier for the integration instance
init	object	Initialization parameters, including vault path key
error	boolean	Indicates whether an error occurred during the operation
action	array	List of actions performed, with their results

{
  "is_credentials": {
    "userid": "test",
    "passwd": "test123"
  },
  "integrations": [
    {
      "integration": "mysql",
      "uuid": "ae0e8ba9-423a-410e-bba5-e1933ff868c5",
      "init": {
        "vault_path_key": "mysql/server1"
      },
      "action": [
        {
          "drop_table": {
            "table_name": "my_table3"
          }
        }
      ]
    }
  ]
}

`create_database`¶

Create Database:

This function creates a new MySQL database.

Input ParametersOutputJSON

Input Parameter	Type	Description	Mandatory
db_name	string	Name of the database to be created	Yes

Output Parameter	Type	Description
user	string	The username of the user who performed the action
integration	string	The type of integration used (mysql)
uuid	string	Unique identifier for the integration instance
init	object	Initialization parameters, including vault path key
error	boolean	Indicates whether an error occurred during the operation
action	array	List of actions performed, with their results

{
  "is_credentials": {
    "userid": "test",
    "passwd": "test123"
  },
  "integrations": [
    {
      "integration": "mysql",
      "uuid": "ae0e8ba9-423a-410e-bba5-e1933ff868c5",
      "init": {
        "vault_path_key": "mysql/server1"
      },
      "action": [
        {
          "create_database": {
            "db_name": "database"
          }
        }
      ]
    }
  ]
}

`delete_database`¶

Delete Database:

This function deletes a specified MySQL database.

Input ParametersOutputJSON

Input Parameter	Type	Description	Mandatory
db_name	string	Name of the database to be deleted	Yes

Output Parameter	Type	Description
user	string	The username of the user who performed the action
integration	string	The type of integration used (mysql)
uuid	string	Unique identifier for the integration instance
init	object	Initialization parameters, including vault path key
error	boolean	Indicates whether an error occurred during the operation
action	array	List of actions performed, with their results

{
  "is_credentials": {
    "userid": "test",
    "passwd": "test123"
  },
  "integrations": [
    {
      "integration": "mysql",
      "uuid": "ae0e8ba9-423a-410e-bba5-e1933ff868c5",
      "init": {
        "vault_path_key": "mysql/server1"
      },
      "action": [
        {
          "delete_database": {
            "db_name": "database"
          }
        }
      ]
    }
  ]
}

`connect_to_database`¶

Connect to Database:

This function establishes a connection to a specified MySQL database.

Input ParametersOutputJSON

Input Parameter	Type	Description	Mandatory
db_name	string	Name of the database to connect to	Yes

Output Parameter	Type	Description
user	string	The username of the user who performed the action
integration	string	The type of integration used (mysql)
uuid	string	Unique identifier for the integration instance
init	object	Initialization parameters, including vault path key
error	boolean	Indicates whether an error occurred during the operation
action	array	List of actions performed, with their results

{
  "is_credentials": {
    "userid": "test",
    "passwd": "test123"
  },
  "integrations": [
    {
      "integration": "mysql",
      "uuid": "ae0e8ba9-423a-410e-bba5-e1933ff868c5",
      "init": {
        "vault_path_key": "mysql/server1"
      },
      "action": [
        {
          "connect_to_database": {
            "db_name": "database"
          }
        }
      ]
    }
  ]
}

`rollback`¶

Rollback:

This function performs a rollback operation on the current MySQL transaction.

Input ParametersOutputJSON

Input Parameter	Type	Description	Mandatory
None	-	No parameters required	-

Output Parameter	Type	Description
user	string	The username of the user who performed the action
integration	string	The type of integration used (mysql)
uuid	string	Unique identifier for the integration instance
init	object	Initialization parameters, including vault path key
error	boolean	Indicates whether an error occurred during the operation
action	array	List of actions performed, with their results

{
  "is_credentials": {
    "userid": "test",
    "passwd": "test123"
  },
  "integrations": [
    {
      "integration": "mysql",
      "uuid": "ae0e8ba9-423a-410e-bba5-e1933ff868c5",
      "init": {
        "vault_path_key": "mysql/server1"
      },
      "action": [
        {
          "rollback": {}
        }
      ]
    }
  ]
}

`get_current_database`¶

Get Current Database:

This function retrieves the name of the currently connected MySQL database.

Input ParametersOutputJSON

Input Parameter	Type	Description	Mandatory
None	-	No parameters required	-

Output Parameter	Type	Description
user	string	The username of the user who performed the action
integration	string	The type of integration used (mysql)
uuid	string	Unique identifier for the integration instance
init	object	Initialization parameters, including vault path key
error	boolean	Indicates whether an error occurred during the operation
action	array	List of actions performed, with their results

{
  "is_credentials": {
    "userid": "test",
    "passwd": "test123"
  },
  "integrations": [
    {
      "integration": "mysql",
      "uuid": "ae0e8ba9-423a-410e-bba5-e1933ff868c5",
      "init": {
        "vault_path_key": "mysql/server1"
      },
      "action": [
        {
          "get_current_database": {}
        }
      ]
    }
  ]
}

`get_all_databases`¶

Get All Databases:

This function retrieves information about all databases in the MySQL instance.

Input ParametersOutputJSON

Input Parameter	Type	Description	Mandatory
None	-	No parameters required	-

Output Parameter	Type	Description
user	string	The username of the user who performed the action
integration	string	The type of integration used (mysql)
uuid	string	Unique identifier for the integration instance
init	object	Initialization parameters, including vault path key
error	boolean	Indicates whether an error occurred during the operation
action	array	List of actions performed, with their results

{
  "is_credentials": {
    "userid": "test",
    "passwd": "test123"
  },
  "integrations": [
    {
      "integration": "mysql",
      "uuid": "ae0e8ba9-423a-410e-bba5-e1933ff868c5",
      "init": {
        "vault_path_key": "mysql/server1"
      },
      "action": [
        {
          "get_all_databases": {}
        }
      ]
    }
  ]
}

FAQ¶

What MySQL operations does EasyTask support?¶

EasyTask supports a comprehensive set of MySQL operations including creating and dropping tables, inserting data, fetching data with filters, deleting specific or all records, creating and deleting databases, connecting to databases, performing rollbacks, and retrieving database information.

How do I automate SQL operations with scheduled tasks?¶

Configure your MySQL integration in EasyTask by providing your vault credentials, then define actions (such as create_table, insert_data, fetch_data, etc.) within a scheduled task. EasyTask will execute these operations automatically at the specified intervals, enabling hands-free database automation.

Can I create and manage databases with EasyTask?¶

Yes. EasyTask provides dedicated functions for database management, including create_database, delete_database, connect_to_database, get_current_database, and get_all_databases. You can fully automate database lifecycle management through scheduled workflows.

MySQL¶

Why Integrate MySQL with EasyTask?¶

Integration Server Vault details¶

Required secrets in Vault¶

MySQL JSON Format¶

Example cURL Commands¶

Sample Usage of MySQL¶

Functions¶

create_table¶

insert_data¶

fetch_data¶

del_data¶

del_all_data¶

drop_table¶

create_database¶

delete_database¶

connect_to_database¶

rollback¶

get_current_database¶

get_all_databases¶

FAQ¶

What MySQL operations does EasyTask support?¶

How do I automate SQL operations with scheduled tasks?¶

Can I create and manage databases with EasyTask?¶

Next Steps¶

`create_table`¶

`insert_data`¶

`fetch_data`¶

`del_data`¶

`del_all_data`¶

`drop_table`¶

`create_database`¶

`delete_database`¶

`connect_to_database`¶

`rollback`¶

`get_current_database`¶

`get_all_databases`¶