server/sources/storages.py
changeset 8900 010a59e12d89
parent 8695 358d8bed9626
child 9463 d62e13eba033
equal deleted inserted replaced
8899:c7a95ebcc093 8900:010a59e12d89
   237         not stored yet.
   237         not stored yet.
   238         """
   238         """
   239         sysource = entity._cw.cnxset.source('system')
   239         sysource = entity._cw.cnxset.source('system')
   240         cu = sysource.doexec(entity._cw,
   240         cu = sysource.doexec(entity._cw,
   241                              'SELECT cw_%s FROM cw_%s WHERE cw_eid=%s' % (
   241                              'SELECT cw_%s FROM cw_%s WHERE cw_eid=%s' % (
   242                              attr, entity.__regid__, entity.eid))
   242                              attr, entity.cw_etype, entity.eid))
   243         rawvalue = cu.fetchone()[0]
   243         rawvalue = cu.fetchone()[0]
   244         if rawvalue is None: # no previous value
   244         if rawvalue is None: # no previous value
   245             return None
   245             return None
   246         return sysource._process_value(rawvalue, cu.description[0],
   246         return sysource._process_value(rawvalue, cu.description[0],
   247                                        binarywrap=str)
   247                                        binarywrap=str)
   251         entity.cw_edited = EditedEntity(entity, **entity.cw_attr_cache)
   251         entity.cw_edited = EditedEntity(entity, **entity.cw_attr_cache)
   252         self.entity_added(entity, attribute)
   252         self.entity_added(entity, attribute)
   253         session = entity._cw
   253         session = entity._cw
   254         source = session.repo.system_source
   254         source = session.repo.system_source
   255         attrs = source.preprocess_entity(entity)
   255         attrs = source.preprocess_entity(entity)
   256         sql = source.sqlgen.update('cw_' + entity.__regid__, attrs,
   256         sql = source.sqlgen.update('cw_' + entity.cw_etype, attrs,
   257                                    ['cw_eid'])
   257                                    ['cw_eid'])
   258         source.doexec(session, sql, attrs)
   258         source.doexec(session, sql, attrs)
   259         entity.cw_edited = None
   259         entity.cw_edited = None
   260 
   260 
   261 
   261