diff --git a/src/aquarius/Aquarius.ts b/src/aquarius/Aquarius.ts
index bc213a4..2e14c4b 100644
--- a/src/aquarius/Aquarius.ts
+++ b/src/aquarius/Aquarius.ts
@@ -36,7 +36,7 @@ export default class Aquarius {
     public async queryMetadata(query): Promise<any[]> {
 
         const result = await AquariusConnectorProvider.getConnector().post(
-            this.url + "/api/v1/aquarius/assets/metadata/query",
+            this.url + "/api/v1/aquarius/assets/ddo/query",
             JSON.stringify(query))
             .then((response: any) => {
                 if (response.ok) {
@@ -45,7 +45,25 @@ export default class Aquarius {
                 Logger.log("Failed: ", response.status, response.statusText)
             })
             .catch((error) => {
-                Logger.error("Error fetching querying metdata: ", error)
+                Logger.error("Error fetching querying metadata: ", error)
+            })
+
+        return result
+    }
+
+    public async queryMetadataByText(query): Promise<any[]> {
+
+        const result = await AquariusConnectorProvider.getConnector().get(
+            this.url + "/api/v1/aquarius/assets/ddo/query",
+            JSON.stringify(query))
+            .then((response: any) => {
+                if (response.ok) {
+                    return response.json()
+                }
+                Logger.log("Failed: ", response.status, response.statusText)
+            })
+            .catch((error) => {
+                Logger.error("Error fetching querying metadata: ", error)
             })
 
         return result
diff --git a/src/aquarius/AquariusConnector.ts b/src/aquarius/AquariusConnector.ts
index 247799d..243bd23 100644
--- a/src/aquarius/AquariusConnector.ts
+++ b/src/aquarius/AquariusConnector.ts
@@ -1,4 +1,5 @@
 import fetch from "node-fetch"
+import { URL } from "url"
 
 export default class AquariusConnector {
 
@@ -11,4 +12,18 @@ export default class AquariusConnector {
             },
         })
     }
+
+    public get(url, payload) {
+        const fullUrl = new URL(url)
+        for (const key of Object.keys(payload)) {
+          fullUrl.searchParams.append(key, payload[key])
+        }
+        return fetch(fullUrl, {
+            method: "GET",
+            body: null,
+            headers: {
+                "Content-type": "application/json",
+            },
+        })
+    }
 }