Bugfix with partition operator

gabfl · Oct 5, 2017 · f979d13 · f979d13
1 parent 4c60169
commit f979d13
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/src/fdw.py b/src/fdw.py
@@ -361,7 +361,7 @@ def buildWhereClause(self, quals):
             clause += "WHERE "
             for qual in quals:
                 if qual.field_name == self.partitionPseudoColumn:
-                    clause += "_PARTITIONTIME = ?"
+                    clause += "_PARTITIONTIME " + str(self.getOperator(qual.operator)) + " ?"
                     parameters.append(self.setParameter(qual.field_name, 'TIMESTAMP', qual.value))  # Force data type to `TIMESTAMP`
 
                     # Store the value to return it to PostgreSQL