dc_db.AttrUpdateTask.AttrUpdateTask Class Reference

Inheritance diagram for dc_db.AttrUpdateTask.AttrUpdateTask:

Collaboration diagram for dc_db.AttrUpdateTask.AttrUpdateTask:

Public Member Functions
def	__init__ (self)
def	process (self, attrUpdates, queryCallback)
def	updateAttribute (self, attrObject, queryCallback)
Public Member Functions inherited from dc_db.BaseTask.BaseTask
def	isSiteExist (self, siteId, queryCallback, userId=None)
def	generateCriterionSQL (self, criterions, additionWhere=None, siteId=None)
def	fetchByCriterions (self, criterions, queryCallback)
def	dbLock (self, mutexName, queryCallback, sleepTime=1, mutexLockTTL=Constants.DEFAULT_LOCK_TTL)
def	dbUnlock (self, mutexName, queryCallback)
def	createUrlsInsertQuery (self, siteId, localKeys, localValues)
def	copyUrlsToDcUrls (self, siteId, queryCallback)
def	statisticLogUpdate (self, localObj, urlMd5, siteId, status, queryCallback, isInsert=False)
def	calculateMd5FormUrl (self, url, urlType, useNormilize=False)

Public Attributes
	arrtSet

Additional Inherited Members
Static Public Member Functions inherited from dc_db.BaseTask.BaseTask
def	readValueFromSiteProp (siteId, propName, queryCallback, urlMd5=None)

Detailed Description

Definition at line 22 of file AttrUpdateTask.py.

Constructor & Destructor Documentation

__init__()

def dc_db.AttrUpdateTask.AttrUpdateTask.__init__

(

self

)

Definition at line 27 of file AttrUpdateTask.py.

  def __init__(self):
    super(AttrUpdateTask, self).__init__()
    self.arrtSet = AttrSetTask()

Member Function Documentation

process()

def dc_db.AttrUpdateTask.AttrUpdateTask.process	(		self,
			attrUpdates,
			queryCallback
	)

Definition at line 37 of file AttrUpdateTask.py.

  def process(self, attrUpdates, queryCallback):
    ret = GeneralResponse()
    for attrUpdate in attrUpdates:
      statusValue = False
      if self.isSiteExist(attrUpdate.siteId, queryCallback):
        if self.arrtSet.selectAttribute(attrUpdate, queryCallback):
          self.updateAttribute(attrUpdate, queryCallback)
          statusValue = True
        else:
          localAttribute = dc.EventObjects.Attribute(attrUpdate.siteId, attrUpdate.name)
          localAttribute.urlMd5 = attrUpdate.urlMd5 if attrUpdate.urlMd5 is not None else ""
          localAttribute.value = attrUpdate.value if attrUpdate.value is not None else ""
          localRet = self.arrtSet.process([localAttribute], queryCallback)
          if len(localRet.statuses) > 0 and localRet.statuses[0] == AttrSetTask.CODE_GOOD_INSERT:
            statusValue = True
      ret.statuses.append(statusValue)
    return ret

Here is the call graph for this function:

Here is the caller graph for this function:

updateAttribute()

def dc_db.AttrUpdateTask.AttrUpdateTask.updateAttribute	(		self,
			attrObject,
			queryCallback
	)

Definition at line 60 of file AttrUpdateTask.py.

  def updateAttribute(self, attrObject, queryCallback):
    UPDATE_TEMPLATE = "UPDATE `att_%s` SET `Value` = '%s' WHERE `Name` = '%s' AND `URLMd5` = '%s'"
    query = UPDATE_TEMPLATE % (attrObject.siteId, Utils.escape(attrObject.value), attrObject.name,
                               attrObject.urlMd5 if attrObject.urlMd5 is not None else "")
    queryCallback(query, Constants.ATT_DB_ID, Constants.EXEC_NAME, True)

Member Data Documentation

arrtSet

dc_db.AttrUpdateTask.AttrUpdateTask.arrtSet

Definition at line 29 of file AttrUpdateTask.py.

---

The documentation for this class was generated from the following file:

• sources/hce/dc_db/AttrUpdateTask.py