1 files changed, 10 insertions, 3 deletions
diff --git a/lib/sqlalchemy/dialects/postgresql/base.py b/lib/sqlalchemy/dialects/postgresql/base.py
index cfbef69e8..7d4cbbbd8 100644
--- a/lib/sqlalchemy/dialects/postgresql/base.py
+++ b/lib/sqlalchemy/dialects/postgresql/base.py
@@ -349,9 +349,16 @@ class PGCompiler(compiler.SQLCompiler):
 
     def visit_extract(self, extract, **kwargs):
         field = self.extract_map.get(extract.field, extract.field)
-        affinity = sql_util.determine_date_affinity(extract.expr)
-
-        casts = {sqltypes.Date:'date', sqltypes.DateTime:'timestamp', sqltypes.Interval:'interval', sqltypes.Time:'time'}
+        if extract.expr.type:
+            affinity = extract.expr.type._type_affinity
+        else:
+            affinity = None
+        
+        casts = {
+                    sqltypes.Date:'date', 
+                    sqltypes.DateTime:'timestamp', 
+                    sqltypes.Interval:'interval', sqltypes.Time:'time'
+                }
         cast = casts.get(affinity, None)
         if isinstance(extract.expr, sql.ColumnElement) and cast is not None:
             expr = extract.expr.op('::')(sql.literal_column(cast))