akka Slick 3 -如何在使用纯SQL插入时获得正确的(数据库)模式

t1rydlwq  于 2022-11-05  发布在  其他
关注(0)|答案(1)|浏览(170)

我试图在Slick 3中使用基本的纯SQL示例,在Postgres上,但是使用自定义的DB模式,比如local,而不是默认的public

sqlu"INSERT INTO schedule(user_id, product_code, run_at)  VALUES ($userId, $code, $nextRun)"

org.postgresql.util.PSQLException: ERROR: relation "schedule" does not exist

该表已经就位,因为当我在insert语句中使用local.作为schedule的前缀时,它可以按预期工作。如何获得为该查询提供的正确模式?
我将其用作akka投影处理程序的一部分,所有投影内部操作(如维护偏移量)都按预期在local模式上工作。
我不能简单地把schema作为一个变量,因为它在解析参数时出错:

sqlu"INSERT INTO ${schema}.schedule(user_id, product_code, run_at)  VALUES ($userId, $code, $nextRun)"
dkqlctbz

dkqlctbz1#

您可以使用#${value}插入模式名称:

sqlu"INSERT INTO #${schema}.table ..."

相关问题