jdbc-protolib/src/main/java/com/streamsets/pipeline/lib/jdbc/multithread/util/OffsetQueryUtil.java
private static String getConditionForPartitionColumn(
      String partitionColumn,
      OffsetComparison comparison,
      List<String> preconditions,
      String quoteChar
  ) {
    String conditionTemplate = comparison.getQueryCondition();
    List<String> finalConditions = new ArrayList<>(preconditions);
    finalConditions.add(
        String.format(
            conditionTemplate,
            String.format(QUOTED_NAME, quoteChar, partitionColumn, quoteChar),
            PREPARED_STATEMENT_POSITIONAL_PARAMETER
        )
    );
    return AND_JOINER.join(finalConditions);
  }
private static String getConditionForPartitionColumn(
      String partitionColumn,
      OffsetComparison comparison,
      List<String> preconditions,
      String quoteChar
  ) {
    String conditionTemplate = comparison.getQueryCondition();
    List<String> finalConditions = new ArrayList<>(preconditions);
    finalConditions.add(
        String.format(
            conditionTemplate,
            String.format(QUOTED_NAME, quoteChar, partitionColumn, quoteChar),
            PREPARED_STATEMENT_POSITIONAL_PARAMETER
        )
    );
    return AND_JOINER.join(finalConditions);
  }
Builds parts of the query in the where clause for the the partitition column.

@param partitionColumn Partition Column
@param comparison The comparison to use with respect to the partition column
@param preconditions Any other precondition in the specific condition that needs to be combined with partition column.
(For EX: if there are multiple order by we may need to say equals for columns
before this partition column and apply the current partition column conditions)
@return the constructed condition for the partition column