add arangodb integration

2021-01-28 21:42:40 +08:00 · 2021-01-28 21:42:40 +08:00 · 7a6e677b89
parent 497c87ce00
commit 7a6e677b89
5 changed files with 115 additions and 0 deletions
--- a/packages/builder/src/components/backend/DatasourceNavigator/icons/ArangoDB.svelte
+++ b/packages/builder/src/components/backend/DatasourceNavigator/icons/ArangoDB.svelte
@ -0,0 +1,22 @@
+<script>
+  export let width = "100"
+  export let height = "100"
+</script>
+
+
+<svg version="1.1" xmlns="http://www.w3.org/2000/svg" xmlns:xlink="http://www.w3.org/1999/xlink" x="0px" y="0px" {width} {height} viewBox="0 0 2900 2000" >
+<g id="layer101">
+ <path fill="#5b350f" d="M735 1983 c-137 -19 -322 -95 -431 -175 -138 -103 -250 -315 -284 -542 -24 -161 22 -298 129 -382 123 -97 318 -180 577 -243 l130 -32 29 -67 c41 -94 135 -231 199 -289 292 -267 732 -319 1094 -128 148 79 224 151 418 400 137 176 173 242 228 414 41 130 70 301 70 416 0 236 -146 421 -382 484 -206 56 -392 19 -733 -144 -96 -47 -181 -85 -189 -85 -7 0 -61 46 -119 103 -163 159 -283 231 -433 261 -71 15 -229 19 -303 9z"/>
+ </g>
+<g id="layer102">
+ <path fill="#406f23" d="M735 1983 c-137 -19 -322 -95 -431 -175 -138 -103 -250 -315 -284 -542 -24 -161 22 -298 129 -382 123 -97 318 -180 577 -243 l130 -32 29 -67 c41 -94 135 -231 199 -289 292 -267 732 -319 1094 -128 148 79 224 151 418 400 137 176 173 242 228 414 41 130 70 301 70 416 0 236 -146 421 -382 484 -206 56 -392 19 -733 -144 -96 -47 -181 -85 -189 -85 -7 0 -61 46 -119 103 -163 159 -283 231 -433 261 -71 15 -229 19 -303 9z m460 -643 c163 -51 296 -150 329 -246 23 -69 20 -93 -20 -174 -51 -100 -126 -173 -238 -230 l-89 -45 -131 0 c-151 0 -222 18 -323 84 -138 89 -243 264 -243 406 0 62 12 76 120 134 160 85 229 102 405 96 87 -2 139 -9 190 -25z"/>
+ </g>
+<g id="layer103">
+ <path fill="#c6d821" d="M2215 1789 c-27 -4 -68 -15 -90 -23 -42 -15 -264 -116 -397 -180 l-77 -38 78 -102 c102 -134 144 -208 175 -305 37 -116 49 -200 44 -309 -7 -157 -46 -218 -175 -278 -94 -44 -178 -56 -313 -43 -108 10 -401 53 -479 70 -24 5 -45 8 -47 6 -2 -2 20 -44 49 -92 67 -115 176 -225 281 -284 87 -49 235 -103 335 -121 91 -16 253 -14 346 5 175 37 269 95 419 264 307 347 422 563 457 859 18 148 9 247 -29 325 -88 179 -340 286 -577 246z"/>
+ <path fill="#c6d821" d="M549 1680 c-272 -34 -426 -142 -495 -346 -22 -68 -26 -91 -22 -164 6 -115 32 -173 112 -248 70 -65 236 -153 370 -196 241 -79 722 -172 985 -192 180 -14 343 55 404 170 34 64 30 168 -11 271 -88 223 -245 373 -568 542 -222 116 -379 161 -584 168 -69 2 -155 0 -191 -5z m646 -340 c163 -51 296 -150 329 -246 23 -69 20 -93 -20 -174 -50 -100 -126 -173 -235 -229 -84 -42 -90 -44 -200 -48 -190 -8 -312 37 -434 161 -98 99 -155 221 -155 331 0 62 12 76 120 134 160 85 229 102 405 96 87 -2 139 -9 190 -25z"/>
+ </g>
+<g id="layer104">
+ <path fill="#f6f654" d="M2190 1721 c-57 -19 -469 -184 -494 -198 -12 -7 -5 -21 34 -72 28 -35 71 -96 97 -137 l46 -74 69 0 c38 0 83 -6 102 -14 52 -22 105 -75 139 -140 28 -55 32 -70 32 -147 0 -84 -2 -90 -48 -183 -96 -187 -234 -296 -376 -296 -44 0 -80 7 -110 20 -28 13 -65 20 -105 20 -72 0 -264 22 -426 49 -63 10 -117 17 -118 15 -10 -8 59 -113 110 -169 106 -115 238 -183 448 -231 155 -35 313 -29 447 17 78 27 210 117 279 191 82 89 277 353 336 456 92 159 137 344 125 513 -9 117 -37 189 -101 258 -109 116 -332 172 -486 122z"/>
+ <path fill="#f6f654" d="M490 1624 c-153 -33 -275 -125 -339 -257 -54 -109 -59 -201 -17 -301 32 -76 164 -189 288 -245 51 -23 260 -91 281 -91 3 0 -21 25 -54 56 -94 91 -150 193 -170 313 -14 90 1 111 123 172 161 81 195 91 343 96 111 5 143 2 215 -16 221 -55 380 -192 380 -327 0 -52 -46 -143 -106 -212 -75 -85 -233 -170 -323 -173 -25 -1 -25 -1 4 -10 140 -43 411 -62 527 -38 142 30 238 125 238 234 0 88 -58 230 -139 337 -105 139 -431 343 -676 423 -161 52 -429 71 -575 39z"/>
+ </g>
+</svg>
--- a/packages/builder/src/components/backend/DatasourceNavigator/icons/index.js
+++ b/packages/builder/src/components/backend/DatasourceNavigator/icons/index.js
@ -7,6 +7,7 @@ import S3 from "./S3.svelte"
 import Airtable from "./Airtable.svelte"
 import SqlServer from "./SQLServer.svelte"
 import MySQL from "./MySQL.svelte"
+import ArangoDB from "./ArangoDB.svelte"

 export default {
  POSTGRES: Postgres,
@ -18,4 +19,5 @@ export default {
  S3: S3,
  AIRTABLE: Airtable,
  MYSQL: MySQL,
+  ARANGODB: ArangoDB,
 }
--- a/packages/server/package.json
+++ b/packages/server/package.json
@ -56,6 +56,7 @@
    "@sendgrid/mail": "^7.1.1",
    "@sentry/node": "^5.19.2",
    "airtable": "^0.10.1",
+    "arangojs": "^7.2.0",
    "aws-sdk": "^2.767.0",
    "bcryptjs": "^2.4.3",
    "chmodr": "^1.2.0",
--- a/packages/server/src/integrations/arangodb.js
+++ b/packages/server/src/integrations/arangodb.js
@ -0,0 +1,87 @@
+const arangojs = require("arangojs")
+const { FIELD_TYPES, QUERY_TYPES } = require("./Integration")
+// const arangodb = arangojs.Database
+const aql = arangojs.aql
+
+const SCHEMA = {
+    docs: "https://github.com/arangodb/arangojs",
+    datasource: {
+        url: {
+            type: FIELD_TYPES.STRING,
+            default: "http://localhost:8529",
+            required: true,
+        },
+        username: {
+            type: FIELD_TYPES.STRING,
+            default: "root",
+            required: true,
+        },
+        password: {
+            type: FIELD_TYPES.PASSWORD,
+            required: true,
+        },
+        databaseName: {
+            type: FIELD_TYPES.STRING,
+            default: "_system",
+            required: true,
+        },
+        collection: {
+            type: FIELD_TYPES.STRING,
+            required: true,
+        },
+    },
+    query: {
+        read: {
+            type: QUERY_TYPES.SQL,
+        },
+        create: {
+            type: QUERY_TYPES.JSON,
+        },
+    },
+}
+
+class ArangoDBIntegration {
+    constructor(config) {
+        config.auth = {
+            username: config.username,
+            password: config.password,
+        }
+        
+        this.config = config
+        this.client = arangojs.arangojs(config)
+    }
+
+    async read(query) {
+        try {
+            const result = await this.client.query(query.sql)
+            let rl = []
+            await result.forEach((r)=> rl.push(r))
+            return rl
+        } catch (err) {
+            console.error("Error querying arangodb",err.message)
+            throw err
+        } finally {
+            this.client.close()
+        }
+    }
+
+    async create(query) {
+        const clc = this.client.collection(this.config.collection)
+        try {
+            const result = await this.client.query(aql`INSERT ${query.json} INTO ${clc} LET n = NEW RETURN NEW`)
+            let rl = []
+            await result.forEach((r)=> rl.push(r))
+            return rl
+        } catch (err) {
+            console.error("Error querying arangodb",err.message)
+            throw err
+        } finally {
+            this.client.close()
+        }
+    }
+}
+
+module.exports = {
+  schema: SCHEMA,
+  integration: ArangoDBIntegration,
+}
--- a/packages/server/src/integrations/index.js
+++ b/packages/server/src/integrations/index.js
@ -7,6 +7,7 @@ const sqlServer = require("./microsoftSqlServer")
 const s3 = require("./s3")
 const airtable = require("./airtable")
 const mysql = require("./mysql")
+const arangodb = require("./arangodb")

 const DEFINITIONS = {
  POSTGRES: postgres.schema,
@ -18,6 +19,7 @@ const DEFINITIONS = {
  S3: s3.schema,
  AIRTABLE: airtable.schema,
  MYSQL: mysql.schema,
+  ARANGODB: arangodb.schema,
 }

 const INTEGRATIONS = {
@ -30,6 +32,7 @@ const INTEGRATIONS = {
  SQL_SERVER: sqlServer.integration,
  AIRTABLE: airtable.integration,
  MYSQL: mysql.integration,
+  ARANGODB:　arangodb.integration,
 }

 module.exports = {