Necesito automatizar la creación de una partición en PostgreSQL pero utilizando un job de spark.
Si corro la siguiente consulta en la consola de postgresql, jala bien:
CREATE TABLE IF NOT EXISTS mi_particion
PARTITION OF mi_tabla
FOR VALUES FROM ('<fecha1>') TO ('<fecha2>');
Pero cuando la intento meter dentro de una query en un job de spark de la siguiente manera:
var CreatePartitionTemplate=
s"""
|CREATE TABLE IF NOT EXISTS mitabla_miparticion
|PARTITION OF mi_tabla
|FOR VALUES FROM ('%s') TO ('%s')
|""".stripMargin
val createNewPartition = CreatePartitionTemplate.format(today, tomorrow)
spark.read
.format("jdbc")
.option("url", JdbcUrl)
.option("user", PgUser)
.option("password", PgPass)
.option("query", createNewPartition)
.load()
Me aparece el error:
PSQLException: ERROR: syntax error at or near "CREATE"