CodeMirror/budibase
1
0
Fork 0
mirror of synced 2024-10-03 10:36:59 +13:00
Code Issues Projects Releases Wiki Activity

dynamo integration

Browse source
This commit is contained in:
Martin McKeaveney 2021-01-15 13:24:36 +00:00
parent a7f9e2fb8f
commit 6d5dc7592e
2 changed files with 64 additions and 9 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

2
packages/builder/src/components/userInterface/EventsEditor/actions/ExecuteQuery.svelte
View file

@ -50,7 +50,7 @@
<Spacer medium />
{#if query}
{#if query?.parameters.length > 0}
<ParameterBuilder
bind:customParams={parameters.queryParams}
parameters={query.parameters}

71
packages/server/src/integrations/dynamodb.js
View file

@ -18,25 +18,56 @@ const SCHEMA = {
},
},
query: {
create: {
DynamoConfig: {
type: QUERY_TYPES.FIELDS,
fields: {
table: {
type: FIELD_TYPES.STRING,
required: true,
},
customisable: true,
},
},
},
read: {
DynamoConfig: {
type: QUERY_TYPES.FIELDS,
fields: {
Table: {
table: {
type: FIELD_TYPES.STRING,
required: true,
},
Index: {
index: {
type: FIELD_TYPES.STRING,
},
KeyConditionExpression: {
customisable: true,
},
},
},
update: {
DynamoConfig: {
type: QUERY_TYPES.FIELDS,
fields: {
table: {
type: FIELD_TYPES.STRING,
required: true,
},
ExpressionAttributeNames: {
customisable: true,
},
},
},
delete: {
"Dynamo Partition Key": {
type: QUERY_TYPES.FIELDS,
fields: {
table: {
type: FIELD_TYPES.STRING,
required: true,
},
ExpressionAttributeValues: {
key: {
type: FIELD_TYPES.STRING,
required: true,
},
},
},
@ -55,12 +86,36 @@ class DynamoDBIntegration {
AWS.config.update(this.config)
}
async create(query) {
const response = await this.client.query({
TableName: query.table,
Item: query.json,
})
return response
}
async read(query) {
const response = await this.client.query({
TableName: query.Table,
KeyConditionExpression: query.KeyConditionExpression,
ExpressionAttributeNames: query.ExpressionAttributeNames,
ExpressionAttributeValues: query.ExpressionAttributeValues,
...query.json,
})
return response
}
async update(query) {
const response = await this.client.query({
TableName: query.Table,
...query.json,
})
return response
}
async delete(query) {
const response = await this.client.query({
TableName: query.Table,
Key: {
id: query.key,
},
})
return response
}