midsuit
/
prasi-api
7
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

fix

This commit is contained in:
Rizky 2024-07-28 09:02:49 +07:00
parent 9d9792c56c
commit fad1e6ffc1
1 changed files with 37 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

37
pkgs/utils/query.ts
View File

@ -38,6 +38,7 @@ export const execQuery = async (args: DBArg, prisma: any) => {
if (schema_table) {
let pks: Property[] = [];
let pk_composite_rel = "";
for (const col of schema_table.properties) {
if (col.type === "field" && !col.array) {
if (col.attributes && col.attributes?.length > 0) {
@ -48,9 +49,26 @@ export const execQuery = async (args: DBArg, prisma: any) => {
}
}
}
if (
col.type === "attribute" &&
col.name === "id" &&
col.kind === "object"
) {
const value = col.args[0].value as any;
if (Array.isArray(value.args) && value.args.length > 0) {
pks = value.args.map((e: string) => ({
name: e,
}));
}
}
}
const rels = getRels({ schema_table, schema, table, tables });
if (pks.length > 0) {
if (pks.length > 1) {
pk_composite_rel = pks.map((e) => e.name).join("_");
}
if (Object.keys(where.length > 0)) {
const rel_many = {} as Record<
string,
@ -276,6 +294,15 @@ export const execQuery = async (args: DBArg, prisma: any) => {
delete row._marker;
}
if (pk_composite_rel) {
const comp_rel_val = {} as any;
for (const pk of pks) {
comp_rel_val[pk.name] = where[pk.name];
delete where[pk.name];
}
where[pk_composite_rel] = comp_rel_val;
}
transactions.push(
prisma[table].update({ data: row, where, select })
);
@ -288,6 +315,16 @@ export const execQuery = async (args: DBArg, prisma: any) => {
for (const pk of pks) {
where[pk.name] = item[pk.name];
}
if (pk_composite_rel) {
const comp_rel_val = {} as any;
for (const pk of pks) {
comp_rel_val[pk.name] = where[pk.name];
delete where[pk.name];
}
where[pk_composite_rel] = comp_rel_val;
}
transactions.push(prisma[table].delete({ where }));
}
}