CodeMirror/budibase
1
0
Fork 0
mirror of synced 2024-06-30 12:00:31 +12:00
Code Issues Projects Releases Wiki Activity

Deletion support for returning rows

Browse source
This commit is contained in:
Rory Powell 2021-11-26 16:50:15 +00:00
parent 115fc08aa4
commit f75928a9c9
1 changed files with 16 additions and 4 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

20
packages/server/src/integrations/oracle.ts
View file

@ -414,7 +414,7 @@ module OracleModule {
}
async query(json: QueryJson) {
const operation = this._operation(json).toLowerCase()
const operation = this._operation(json)
const input = this._query(json, { disableReturning: true })
if (Array.isArray(input)) {
const responses = []
@ -423,22 +423,34 @@ module OracleModule {
}
return responses
} else {
// read the row to be deleted up front for the return
let deletedRows
if (operation === Operation.DELETE) {
const queryFn = (query: any) => this.internalQuery(query)
deletedRows = await this.getReturningRow(queryFn, json)
}
// run the query
const response = await this.internalQuery(input)
if (response.rows?.length) {
// get the results or return the created / updated / deleted row
if (deletedRows?.rows?.length) {
return deletedRows.rows
} else if (response.rows?.length) {
return response.rows
} else {
// get the last row that was updated
if (
response.lastRowid &&
json.endpoint?.entityId &&
operation.toUpperCase() !== Operation.DELETE
operation !== Operation.DELETE
) {
const lastRow = await this.internalQuery({
sql: `SELECT * FROM \"${json.endpoint.entityId}\" WHERE ROWID = '${response.lastRowid}'`,
})
return lastRow.rows
} else {
return [{ [operation]: true }]
return [{ [ operation.toLowerCase() ]: true }]
}
}
}