|
def | __init__ (self) |
|
def | process (self, attrDeletes, queryCallback) |
|
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) |
|
Definition at line 23 of file AttrDeleteTask.py.
◆ __init__()
def dc_db.AttrDeleteTask.AttrDeleteTask.__init__ |
( |
|
self | ) |
|
◆ deleteUrlsAttributes()
def dc_db.AttrDeleteTask.AttrDeleteTask.deleteUrlsAttributes |
( |
|
siteId, |
|
|
|
urlMd5, |
|
|
|
queryCallback |
|
) |
| |
|
static |
Definition at line 71 of file AttrDeleteTask.py.
71 def deleteUrlsAttributes(siteId, urlMd5, queryCallback):
72 attrDeleteTask = AttrDeleteTask()
74 res = attrDeleteTask.process(attrDeletes, queryCallback)
75 logger.debug(
">>> AttrDeleteTask.deleteUrlsAttributes operation result = " +
varDump(res))
76
def varDump(obj, stringify=True, strTypeMaxLen=256, strTypeCutSuffix='...', stringifyType=1, ignoreErrors=False, objectsHash=None, depth=0, indent=2, ensure_ascii=False, maxDepth=10)
◆ process()
def dc_db.AttrDeleteTask.AttrDeleteTask.process |
( |
|
self, |
|
|
|
attrDeletes, |
|
|
|
queryCallback |
|
) |
| |
Definition at line 40 of file AttrDeleteTask.py.
40 def process(self, attrDeletes, queryCallback):
41 ret = GeneralResponse()
42 for attrDelete
in attrDeletes:
43 if self.isSiteExist(attrDelete.siteId, queryCallback):
46 if attrDelete.name
is None:
47 additionWhere = self.generateCriterionSQL(attrDelete.criterions)
49 additionWhere = (
"WHERE `Name` = '%s'" % attrDelete.name)
50 logger.debug(
">>> additionWhere = " + str(additionWhere))
51 if additionWhere
is not None and len(additionWhere) > 0:
52 query = AttrDeleteTask.ATTR_DELETE_TEMPLATE % ((Constants.DC_ATT_TABLE_NAME_TEMPLATE % attrDelete.siteId))
53 queryCallback(query + additionWhere, Constants.ATT_DB_ID)
54 ret.statuses.append(
True)
56 ret.statuses.append(
False)
57 except Exception
as excp:
58 logger.debug(
">>> [AttributeDelete] Some Exception = " + str(
type(excp)) +
" " + str(excp))
59 ret.statuses.append(
False)
61 ret.statuses.append(
False)
◆ ATTR_DELETE_TEMPLATE
string dc_db.AttrDeleteTask.AttrDeleteTask.ATTR_DELETE_TEMPLATE = "DELETE FROM `%s` " |
|
static |
The documentation for this class was generated from the following file: