- field_q = self._get_cursor_field(table_id, table_f)
- query['where'].append((field_q, '=', cPickle.dumps(v)))
+ field_name = 'value'
+ field_v = msgpack.dumps(v)
+ if k == '_id':
+ field_q = (table_id, field_name)
+ else:
+ field_q = self._get_cursor_field(table_id, table_f, field_name=field_name)
+ query['where'].append((field_q, '=', field_v))