forked from ttc/micro-service-api
85 lines
2.2 KiB
JavaScript
85 lines
2.2 KiB
JavaScript
import { GeneralService } from '../../share/generalservice.js'
|
|
|
|
export class PrjmstInterface {
|
|
|
|
constructor() {
|
|
this.general = new GeneralService()
|
|
this.table = 'prjmst'
|
|
this.pk = ['prjseq', 'prjnam']
|
|
}
|
|
|
|
async saveInterface(database, data) {
|
|
const method = data.methods.toLowerCase()
|
|
const { methods, ...payload } = data
|
|
|
|
if (method === 'put') return this.update(database, payload)
|
|
if (method === 'post') return this.insert(database, payload)
|
|
if (method === 'delete') return this.remove(database, payload)
|
|
|
|
throw new Error(`Unknown method: ${method}`)
|
|
}
|
|
|
|
async insert(database, payload) {
|
|
const cols = Object.keys(payload)
|
|
const vals = Object.values(payload)
|
|
const placeholders = cols.map((_, i) => `$${i + 1}`).join(', ')
|
|
|
|
const sql = `
|
|
INSERT INTO ${database}.${this.table} (${cols.join(', ')})
|
|
VALUES (${placeholders})
|
|
RETURNING *
|
|
`
|
|
return await this.general.executeQueryParam(database, sql, vals)
|
|
}
|
|
|
|
async update(database, payload) {
|
|
const where = {}
|
|
const update = {}
|
|
|
|
for (const col in payload) {
|
|
if (this.pk.includes(col)) where[col] = payload[col]
|
|
else update[col] = payload[col]
|
|
}
|
|
|
|
const setCols = Object.keys(update)
|
|
.map((col, i) => `${col} = $${i + 1}`)
|
|
.join(', ')
|
|
|
|
const whereCols = Object.keys(where)
|
|
.map((col, i) => `${col} = $${i + 1 + Object.keys(update).length}`)
|
|
.join(' AND ')
|
|
|
|
const params = [...Object.values(update), ...Object.values(where)]
|
|
|
|
const sql = `
|
|
UPDATE ${database}.${this.table}
|
|
SET ${setCols}
|
|
WHERE ${whereCols}
|
|
RETURNING *
|
|
`
|
|
return await this.general.executeQueryParam(database, sql, params)
|
|
}
|
|
|
|
async remove(database, payload) {
|
|
const where = {}
|
|
|
|
this.pk.forEach(pk => {
|
|
if (!payload[pk]) throw new Error(`Missing PK: ${pk}`)
|
|
where[pk] = payload[pk]
|
|
})
|
|
|
|
const whereCols = Object.keys(where)
|
|
.map((col, i) => `${col} = $${i + 1}`)
|
|
.join(' AND ')
|
|
|
|
const params = Object.values(where)
|
|
|
|
const sql = `
|
|
DELETE FROM ${database}.${this.table}
|
|
WHERE ${whereCols}
|
|
RETURNING *
|
|
`
|
|
return await this.general.executeQueryParam(database, sql, params)
|
|
}
|
|
}
|