diff --git a/src/java/org/apache/sqoop/mapreduce/db/SQLServerDBRecordReader.java b/src/java/org/apache/sqoop/mapreduce/db/SQLServerDBRecordReader.java index 2c8a9fd2..c879c709 100644 --- a/src/java/org/apache/sqoop/mapreduce/db/SQLServerDBRecordReader.java +++ b/src/java/org/apache/sqoop/mapreduce/db/SQLServerDBRecordReader.java @@ -242,7 +242,7 @@ protected String getSelectQuery() { StringBuilder lowerClause = new StringBuilder(); lowerClause.append(getDBConf().getInputOrderBy()); lowerClause.append(" > "); - lowerClause.append(lastRecordValue.toString()); + lowerClause.append("'" + lastRecordValue.toString() + "'"); // Get the select query with the lowerClause, and split upper clause selectQuery = getSelectQuery(lowerClause.toString(),