我正在使用 Prisma ( https://www.prisma.io ) 作为 ORM。我想在存储数据时检查重复项,如果不存在,则创建一条新记录。
我想我可以用 Prisma 提供的 upsert 方法来做到这一点,并且在生成的客户端中可用,但是该方法的 where 子句仅适用于 id (或@unique 字段),但如果记录不存在,则不存在要提供的任何 ID。
我提供了一个问题的例子。
数据模型.prisma
type System {
id: ID! @unique
performances: [SystemPerformance!]! @relation(name: "PerformanceBySystem" onDelete: CASCADE)
name: String! @unique
}
type SystemPerformance {
id: ID! @unique
system: System! @relation(name: "PerformanceBySystem")
date: DateTime!
perf1: Float
perf2: Float
}
种子.js
const { prisma } = require('./generated/prisma-client');
async function main(){
await prisma.createSystem({
name: 's1',
});
await prisma.createSystem({
name: 's2',
});
await prisma.createSystem({
name: 's3',
});
}
main();
创建后,有一个包含三个没有性能的系统的数据库。如果没有任何具有相同日期和相同系统的系统,我正在尝试插入一个新的 SystemPerformance。我努力了
const { prisma } = require('./prisma/generated/prisma-client');
const perf = await prisma.upsertSystemPerformance({
where: {
system: {name: 's1'},
date: "2019-03-12T00:01:06.000Z"
},
update: {
perf1: 13.45,
perf2: 18.93
},
create: {
system: {
connect: { name: 's1' }
},
date: "2019-03-12T00:01:06.000Z",
perf1: 13.45,
perf2: 18.93
}
})
但抛出异常:
UnhandledPromiseRejectionWarning:错误:变量“$where”类型为“SystemPerformanceWhereUniqueInput!”的预期值!但得到:{“系统”:{“名称”:'s1'},“日期”:“2019-03-12T00:01:06.000Z”}。原因:“system”字段“system”未在输入类型“SystemPerformanceWhereUniqueInput”中定义
我找到的唯一解决方案是检查存在,然后更新或创建,但我想用 upsert 来做。
let check = await prisma.$exists.SystemPerformance({
system: {name: 's1'},
date: "2019-03-12T00:01:06.000Z"
});
let perfo;
if (check){
const sysPerf = await prisma.systemPerformances({where:{system: {name: 's1'}, date: "2019-03-12T00:01:06.000Z"}})
.$fragment(`
{
id
}
`);
perfo = await prisma.updateSystemPerformance({
where: {id: sysPerf[0].id},
data: {
perf1: 13.45,
perf2: 18.93
}
})
}
else {
perfo = await prisma.createSystemPerformance({
system: {
connect: { name: 's1' }
},
date: "2019-03-12T00:01:06.000Z",
perf1: 13.45,
perf2: 18.93
}
})
有没有办法用 upsert 做到这一点?