Rename setStatementTimeout

hieudion · hieudion · commit 66458343f7c5 · 2021-08-19T21:05:38.000+07:00
diff --git a/embulk-input-postgresql/src/main/java/org/embulk/input/postgresql/PostgreSQLInputConnection.java b/embulk-input-postgresql/src/main/java/org/embulk/input/postgresql/PostgreSQLInputConnection.java
@@ -23,7 +23,7 @@ public PostgreSQLInputConnection(Connection connection, String schemaName, Optio
             throws SQLException
     {
         super(connection, schemaName);
-        setStatementTimeout(statementTimeoutMillis);
+        setStatementTimeoutIfSpecified(statementTimeoutMillis);
     }
 
     @Override
@@ -81,7 +81,7 @@ public void close() throws SQLException
         }
     }
 
-    private void setStatementTimeout(Optional<Integer> statementTimeoutMillis)
+    private void setStatementTimeoutIfSpecified(Optional<Integer> statementTimeoutMillis)
         throws SQLException
     {
         if (statementTimeoutMillis.isPresent() && statementTimeoutMillis.get() > 0) {

Original file line number	Diff line number	Diff line change
`@@ -23,7 +23,7 @@ public PostgreSQLInputConnection(Connection connection, String schemaName, Optio`
`23`	`23`	`throws SQLException`
`24`	`24`	`{`
`25`	`25`	`super(connection, schemaName);`
`26`		`- setStatementTimeout(statementTimeoutMillis);`
	`26`	`+ setStatementTimeoutIfSpecified(statementTimeoutMillis);`
`27`	`27`	`}`
`28`	`28`
`29`	`29`	`@Override`
`@@ -81,7 +81,7 @@ public void close() throws SQLException`
`81`	`81`	`}`
`82`	`82`	`}`
`83`	`83`
`84`		`- private void setStatementTimeout(Optional<Integer> statementTimeoutMillis)`
	`84`	`+ private void setStatementTimeoutIfSpecified(Optional<Integer> statementTimeoutMillis)`
`85`	`85`	`throws SQLException`
`86`	`86`	`{`
`87`	`87`	`if (statementTimeoutMillis.isPresent() && statementTimeoutMillis.get() > 0) {`