Sink to database with multiple statements in a transaction, and with retry

[Yoni Gibbs]

I want to sink some data to a database, but the data needs to go into multiple 
tables, in a single transaction. Am I right in saying that I cannot use the 
JDBC Connector for this as it only handles single SQL statements?

Assuming that's right, I believe that I need to write a custom sink, so I need 
to subclass RichSinkFunction​ and in there write code that writes data to the 
database. I have some classes that do something similar for getting data out of 
a database, by subclassing RichAsyncFunction​, and there I use the information 
here<https://nightlies.apache.org/flink/flink-docs-master/docs/dev/datastream/operators/asyncio/#async-io-api>
 to have a retry, in case the DB connection has a blip. Is there an equivalent 
for sinks? Or do I need to do this manually myself in some way?

Thanks!