dc_db.AttrSetTask.AttrSetTask Class Reference

Inheritance diagram for dc_db.AttrSetTask.AttrSetTask:

Collaboration diagram for dc_db.AttrSetTask.AttrSetTask:

Public Member Functions
def	__init__ (self)
def	process (self, attrs, queryCallback)
def	selectAttribute (self, attrObject, queryCallback)
def	addAttribute (self, attrObject, 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)

Static Public Attributes
int	CODE_GOOD_INSERT = 0
int	CODE_BAD_INSERT = 1
int	CODE_ALREADY_EXIST = 2
int	CODE_SITE_NOT_EXIST = 3

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 19 of file AttrSetTask.py.

Constructor & Destructor Documentation

__init__()

def dc_db.AttrSetTask.AttrSetTask.__init__

(

self

)

Definition at line 28 of file AttrSetTask.py.

  def __init__(self):
    super(AttrSetTask, self).__init__()

Member Function Documentation

addAttribute()

def dc_db.AttrSetTask.AttrSetTask.addAttribute	(		self,
			attrObject,
			queryCallback
	)

Definition at line 73 of file AttrSetTask.py.

  def addAttribute(self, attrObject, queryCallback):
    ret = False
    fields, values = Constants.getFieldsValuesTuple(attrObject, Constants.AttrTableDict)
    fieldValueString = Constants.createFieldsValuesString(fields, values)
    if fieldValueString is not None and fieldValueString != "":
      query = Constants.INSERT_COMMON_TEMPLATE % ((Constants.DC_ATT_TABLE_NAME_TEMPLATE % attrObject.siteId),
                                                  fieldValueString)
      queryCallback(query, Constants.ATT_DB_ID, Constants.EXEC_NAME, True)
      ret = True

    return ret

Here is the caller graph for this function:

process()

def dc_db.AttrSetTask.AttrSetTask.process	(		self,
			attrs,
			queryCallback
	)

Definition at line 37 of file AttrSetTask.py.

  def process(self, attrs, queryCallback):
    ret = GeneralResponse()
    for attr in attrs:
      if self.isSiteExist(attr.siteId, queryCallback):
        if self.selectAttribute(attr, queryCallback):
          ret.statuses.append(AttrSetTask.CODE_ALREADY_EXIST)
          self.updateAttribute(attr, queryCallback)
        elif self.addAttribute(attr, queryCallback):
          ret.statuses.append(AttrSetTask.CODE_GOOD_INSERT)
        else:
          ret.statuses.append(AttrSetTask.CODE_BAD_INSERT)
      else:
        ret.statuses.append(AttrSetTask.CODE_SITE_NOT_EXIST)
    return ret

Here is the call graph for this function:

Here is the caller graph for this function:

selectAttribute()

def dc_db.AttrSetTask.AttrSetTask.selectAttribute	(		self,
			attrObject,
			queryCallback
	)

Definition at line 57 of file AttrSetTask.py.

  def selectAttribute(self, attrObject, queryCallback):
    ret = False
    LOCAL_URL_CHECK_QUERY = "SELECT COUNT(*) FROM `att_%s` WHERE `Name` = '%s' AND `URLMd5` = '%s'"
    query = LOCAL_URL_CHECK_QUERY % (attrObject.siteId, attrObject.name,
                                     attrObject.urlMd5 if attrObject.urlMd5 is not None else "")
    res = queryCallback(query, Constants.ATT_DB_ID)
    if hasattr(res, '__iter__') and len(res) > 0 and len(res[0]) > 0 and res[0][0] > 0:
      ret = True

    return ret

Here is the caller graph for this function:

updateAttribute()

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

Definition at line 90 of file AttrSetTask.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

CODE_ALREADY_EXIST

int dc_db.AttrSetTask.AttrSetTask.CODE_ALREADY_EXIST = 2

static

Definition at line 23 of file AttrSetTask.py.

CODE_BAD_INSERT

int dc_db.AttrSetTask.AttrSetTask.CODE_BAD_INSERT = 1

static

Definition at line 22 of file AttrSetTask.py.

CODE_GOOD_INSERT

int dc_db.AttrSetTask.AttrSetTask.CODE_GOOD_INSERT = 0

static

Definition at line 21 of file AttrSetTask.py.

CODE_SITE_NOT_EXIST

int dc_db.AttrSetTask.AttrSetTask.CODE_SITE_NOT_EXIST = 3

static

Definition at line 24 of file AttrSetTask.py.

---

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

• sources/hce/dc_db/AttrSetTask.py