Anonymous committed 3c5aa45

boulder-oracle-sprint: Made Oracle return DecimalField values as decimal objects.

Comments (0)

Files changed (2)


         def resolve_columns(self, row, fields=()):
             from django.db.models.fields import DateField, DateTimeField, \
-                TimeField, BooleanField, NullBooleanField
+                TimeField, BooleanField, NullBooleanField, DecimalField
             values = []
             for value, field in map(None, row, fields):
                 if isinstance(value, Database.LOB):
                 # Convert 1 or 0 to True or False
                 elif value in (1, 0) and isinstance(field, (BooleanField, NullBooleanField)):
                     value = bool(value)
+                # Convert floats to decimals
+                elif value is not None and isinstance(field, DecimalField):
+                    value = util.typecast_decimal(field.format_number(value))
                 # cx_Oracle always returns datetime.datetime objects for
                 # DATE and TIMESTAMP columns, but Django wants to see a
                 # python, .time, or .datetime.  We use the type


     def __init__(self, *args, **kwargs):
         dispatcher.send(signal=signals.pre_init, sender=self.__class__, args=args, kwargs=kwargs)
         # There is a rather weird disparity here; if kwargs, it's set, then args
-        # overrides it. It should be one or the other; don't duplicate the work 
+        # overrides it. It should be one or the other; don't duplicate the work
         # The reason for the kwargs check is that standard iterator passes in by
         # args, and nstantiation for iteration is 33% faster.
         args_len = len(args)
                 # Maintain compatibility with existing calls.
                 if isinstance(field.rel, ManyToOneRel):
                     kwargs.pop(field.attname, None)
         # Now we're left with the unprocessed fields that *must* come from
         # keywords, or default.
         for field in fields_iter:
             if kwargs:
                 if isinstance(field.rel, ManyToOneRel):
                                 val = getattr(rel_obj, field.rel.get_related_field().attname)
                             except AttributeError:
-                                raise TypeError("Invalid value: %r should be a %s instance, not a %s" % 
+                                raise TypeError("Invalid value: %r should be a %s instance, not a %s" %
                                     (,, type(rel_obj)))
                     val = kwargs.pop(field.attname, field.get_default())
         if pk_set:
             # Determine whether a record with the primary key already exists.
             cursor.execute("SELECT COUNT(*) FROM %s WHERE %s=%%s" % \
-                (backend.quote_name(self._meta.db_table), backend.quote_name(, [pk_val])
+                (backend.quote_name(self._meta.db_table), backend.quote_name(,
+      'exact', pk_val))
             # If it does already exist, do an UPDATE.
             if cursor.fetchone()[0] > 0:
                 db_values = [f.get_db_prep_save(f.pre_save(self, False)) for f in non_pks]
                         ','.join(['%s=%%s' % backend.quote_name(f.column) for f in non_pks]),
-                        db_values + [pk_val])
+                        db_values +'exact', pk_val))
                 record_exists = False
         if not pk_set or not record_exists: