---
title: Write to Databases with Integration Topics
slug: manufacturing-connect-edge-v1/write-to-databases-with-integration-topics
docTags: 
createdAt: 2024-02-02T21:26:46.425Z
---

You can create Flows to send data to a database through integration topics. 

# Before You Begin

Make sure you follow the preferable database integration in the [Integration Guides](docId\:cfrig27AmQr8cOMDx5p0Q). For this tutorial, we will use the [MySQL Integration Guide](docId\:lmmC1EQngVF2FlaDijja0).

# Step 1: Add a Device

Follow the steps to [Connect a Device](docId\:RFVIJdxz7DBAd8mwbismA) and configure the following parameters:

- **Device Type**: Simulator
- **Driver Name**: Generator
- **Enable Alias Topics**: Select the checkbox. 

# Step 2: Add Tags

After connecting the device, [Add Tags](docId\:iOaNZd2AwqnkuppgeE3Eh) to the device.

## Tag 1: tag1

- **Name**: Select **S - Random value generator**
- **Value Type:** Select **float64**
- **Polling Interval**: Enter **5**
- **Tag Name**: Enter **tag1**
- **Min\_value**: Enter **10**
- **Max\_value**: Enter **50**

# Step 3: Add a Database Integration Topic

**To add a database integration topic:**

1. In Manufacturing Connect Edge, navigate to **Integration**. 
2. Click a **database integration **tile. Make sure the tile has a *Connected *status.
   ::Image[]{src="https://api.archbee.com/api/optimize/SSUUxKZUk9bFTEPNn_6Zo/IDfZzh8YMyo6cqeCJKhLe_image.png" size="40" width="315" height="313" position="center" caption="Database integration tile" showCaption="true"}
3. Click **Topics**. 
4. Click **Add a new subscription** icon. 
   The *Data Integration dialog* box appears. 
   - **Data Direction: **Select **Local to Remote - Outbound**.
   - **Local Data Topic:** Click the **Search **icon, and then select the device and alias topic for the tag you previously created.
   - Toggle **Enable** to enable the topic.
     ::Image[]{src="https://api.archbee.com/api/optimize/SSUUxKZUk9bFTEPNn_6Zo/3fXkcMw7IjzKJaS1-JPeC_image.png" size="80" width="1920" height="522" position="center" caption="Integration > Topics pane" showCaption="true"}
5. Click **Yes**.
   ::Image[]{src="https://api.archbee.com/api/optimize/SSUUxKZUk9bFTEPNn_6Zo/ysOZ2VmVsjHvwqvCsine0_image.png" size="80" width="937" height="540" position="center" caption="Edit data integration dialog box" showCaption="true"}

:::hint{type="info"}
**Note:** Modifying topics restarts the connector.
:::

# Step 4: Create Flow

**To create the flow:**

1. Navigate to the **Flows Manager **and create a new flow. 
   See [Create a Flow](docId:-oL2gwhtG2gkdJLBR6cai) learn more.
2. Drag the **Inject**, **Function**,** **and **DataHub Publish **nodes to the canvas and wire them together.
3. Drag the **DataHub Subscribe **and **Debug **nodes to the canvas and wire them together.
   ::Image[]{src="https://api.archbee.com/api/optimize/SSUUxKZUk9bFTEPNn_6Zo/12GYDgUk5fD3sbCt9FSn__flow-22339x203.png" size="50" width="339" height="203" position="center" caption="Flows canvas " showCaption="true"}
4. Double-click the **Function **node. 
   - In the **On Message** tab, input the code below, ensuring to update the variables *obj.name*, *obj.num*, and *msg.subjectInput* to match your topic and database. 
     `var obj = {}; // Create an empty JSON object.
     `
     `obj.name ="test_table"; // Write the name of your database integration remote data topic in the quotation marks.
     `
     `obj.num = 99000; // Change num to be one of the names of your columns or change 99000 to a value that you want to insert into the database.
     `
     `msg.payload = JSON.stringify(obj); // Puts the JSON object into the message payload.
     `
     `msg.subjectInput = "test_table"; // Write the name of your database integration remote data topic in the quotation marks.
     `
     `return msg;`
   - Click **Done**.
5. Double-click the **Datahub Publish **node. 
   - **Datahub:** Configure the *Datahub Publish *connection if needed. See [Configure Connector Nodes](docId:-oL2gwhtG2gkdJLBR6cai) to learn more. 
   - **Topic: **Enter your topic name.
   - Click **Done**.
6. Double-click the **Datahub Subscribe** node. 
   - **Datahub:** Configure the *Datahub Subscribe *connection if needed. See [Configure Connector Nodes](docId:-oL2gwhtG2gkdJLBR6cai) to learn more. 
   - **Topic: **Enter your topic name.
   - Click **Done**.
7. Click **Deploy**.
8. Expand the message window beneath the flow.
   ![](https://api.archbee.com/api/optimize/SSUUxKZUk9bFTEPNn_6Zo/Zy8ybHzr9L7Zr34GsUSZH_image.png "Flow canvas message window")
9. Click the **Inject node button** to insert rows into the database.  
10. Click the **Debug **icon to view the data output.
    ![](https://api.archbee.com/api/optimize/SSUUxKZUk9bFTEPNn_6Zo/sEDZRZpwbEVgyqOTnG7vO_image.png "Flows canvas debug tab ")

# Step 5: Verify the Results in Database

You can query the database to confirm that the integration topic inserted the data properly. See [Make Queries in the Container Terminal](docId\:lmmC1EQngVF2FlaDijja0) to learn more. 

![](https://api.archbee.com/api/optimize/SSUUxKZUk9bFTEPNn_6Zo/m6AZRMyGHOOkeIqUfnlWI_image.png "Output of custom query on test_table")