Dynamic insert sql statement in JDBCIO.write.withStatement (based on inputfile and mapping)

[Sarath Sowri <go...@gmail.com>]

Hi Team,

We are working on a ETL pipeline, As part of some transformation, some
columns are deleted from the input pcollection( that are no mapped to
appropriate Transactional TableColumns).

Based on the input mapping, attributes that gets imported will be dynamic
to the inputfile and the mapping.

We are uysing JDBCIO.write as sink to our database.
In jdbcio.write().withStatement(" fixed query ") , it accepts a fixedquery.
Is there any way to build this query as part of global transformation (or)
any transformation (or) refer this query based on input pipelineoptions?.

Please let us know how to build and use runtime query in jdbcio.write.
withstatement().
Please share us any reference or pattern to solve this scenario.

Thanks & Regards,
Sarath G