javadoc

sdks/java/io/jdbc/src/main/java/org/apache/beam/sdk/io/jdbc/JdbcIO.java

@@ -810,7 +810,11 @@ public ReadRows withOutputParallelization(boolean outputParallelization) {
       return toBuilder().setOutputParallelization(outputParallelization).build();
     }
 
-    /** Whether to disable auto commit on read. Defaults to true if not provided. */
+    /**
+     * Whether to disable auto commit on read. Defaults to true if not provided.
+     * The need for this config varies depending on the database platform.
+     * Informix requires this to be set to false while Postgres requires this to be set to true.
+     */
     public ReadRows withDisableAutoCommit(boolean disableAutoCommit) {
       return toBuilder().setDisableAutoCommit(disableAutoCommit).build();
     }
@@ -980,7 +984,11 @@ public Read<T> withOutputParallelization(boolean outputParallelization) {
       return toBuilder().setOutputParallelization(outputParallelization).build();
     }
 
-    /** Whether to disable auto commit on read. Defaults to true if not provided. */
+    /**
+     * Whether to disable auto commit on read. Defaults to true if not provided.
+     * The need for this config varies depending on the database platform.
+     * Informix requires this to be set to false while Postgres requires this to be set to true.
+     */
     public Read<T> withDisableAutoCommit(boolean disableAutoCommit) {
       return toBuilder().setDisableAutoCommit(disableAutoCommit).build();
     }
@@ -1159,7 +1167,11 @@ public ReadAll<ParameterT, OutputT> withOutputParallelization(boolean outputPara
       return toBuilder().setOutputParallelization(outputParallelization).build();
     }
 
-    /** Whether to disable auto commit on read. Defaults to true if not provided. */
+    /**
+     * Whether to disable auto commit on read. Defaults to true if not provided.
+     * The need for this config varies depending on the database platform.
+     * Informix requires this to be set to false while Postgres requires this to be set to true.
+     */
     public ReadAll<ParameterT, OutputT> withDisableAutoCommit(boolean disableAutoCommit) {
       return toBuilder().setDisableAutoCommit(disableAutoCommit).build();
     }
@@ -1380,6 +1392,16 @@ public ReadWithPartitions<T, PartitionColumnT> withFetchSize(int fetchSize) {
       return toBuilder().setFetchSize(fetchSize).build();
     }
 
+    /**
+     * Whether to disable auto commit on read. Defaults to true if not provided.
+     * The need for this config varies depending on the database platform.
+     * Informix requires this to be set to false while Postgres requires this to be set to true.
+     */
+    public ReadWithPartitions<T, PartitionColumnT> withDisableAutoCommit(
+        boolean disableAutoCommit) {
+      return toBuilder().setDisableAutoCommit(disableAutoCommit).build();
+    }
+
     /** Data output type is {@link Row}, and schema is auto-inferred from the database. */
     public ReadWithPartitions<T, PartitionColumnT> withRowOutput() {
       return toBuilder().setUseBeamSchema(true).build();
@@ -1623,7 +1645,6 @@ private Connection getConnection() throws SQLException {
     public void processElement(ProcessContext context) throws Exception {
       // Only acquire the connection if we need to perform a read.
       Connection connection = getConnection();
-
       // PostgreSQL requires autocommit to be disabled to enable cursor streaming
       // see https://jdbc.postgresql.org/documentation/head/query.html#query-with-cursor
       // This option is configurable as Informix will error