[BEAM-12511] JdbcIO.Write.withResults work without statement

• Type: Improvement
• Status: Triage Needed
• Priority: P2
• Resolution: Fixed
• Fix Version/s: 2.32.0
• Component/s: io-java-jdbc
• Assignee: Sanamyan Raphael
• Reporter: Sanamyan Raphael
• Created: 18/Jun/21 14:24
• Updated: 13/Apr/23 11:06
• Resolved: 08/Jul/21 14:22

Description

JdbcIO.Write can work without statement and preparedStatementSetter in all case except using "Write.withResults". e.g.

      PCollection<Row> dataCollection = pipeline.apply(Create.of(data));
      PCollection<Void> rowsWritten =
          dataCollection.apply(
              JdbcIO.<Row>write()
                  .withDataSourceConfiguration(DATA_SOURCE_CONFIGURATION)
                  .withBatchSize(10L)
                  .withTable(firstTableName)
                  .withResults());
      .dataCollection .
          .apply(Wait.on(rowsWritten))
          .apply(
              JdbcIO.<Row>write()
                  .withDataSourceConfiguration(DATA_SOURCE_CONFIGURATION)
                  .withBatchSize(10L)
                  .withTable(secondTableName));

      .run();

Need to add ability to use "Write.withResults" without statement and preparedStatementSetter.

Issue Links

• links to: GitHub Pull Request #15052