diff --git a/drivers/python/rethinkdb.py b/drivers/python/rethinkdb.py
index <HASH>..<HASH> 100644
--- a/drivers/python/rethinkdb.py
+++ b/drivers/python/rethinkdb.py
@@ -213,6 +213,14 @@ def gt(*terms):
 def gte(*terms):
     return Comparison(list(terms), p.GE)
 
+def and_eq(_hash):
+    terms = []
+    for key in _hash.iterkeys():
+        val = _hash[key]
+        terms.append(eq(key, val))
+    return Conjunction(terms)
+        
+
 class Arithmetic(Term):
     def __init__(self, terms, op_type):
         if not terms:
Adding support for and_eq (to be used in filter later as sugar)