dc_db.SiteDeleteTask.SiteDeleteTask Class Reference

Inheritance diagram for dc_db.SiteDeleteTask.SiteDeleteTask:

Collaboration diagram for dc_db.SiteDeleteTask.SiteDeleteTask:

Public Member Functions
def	__init__ (self, keyValueStorageDir, rawDataDir, dBDataTask)
def	process (self, siteDeletes, queryCallback)
def	dropURLTable (self, siteDelete, queryCallback)
def	dropArbitraryTable (self, tablePrefix, siteDelete, dbId, queryCallback)
def	removeSiteRecord (self, siteDelete, queryCallback)
def	clearRelatedTables (self, siteDelete, queryCallback)
Public Member Functions inherited from dc_db.SiteCleanUpTask.SiteCleanUpTask
def	__init__ (self, keyValueStorageDir, rawDataDir, dBDataTask)
def	process (self, siteCleanups, queryCallback)
def	staticUpdate (self, sqlTemplate, siteCleanup, queryCallback)
def	cleanUpMysqlStorage (self, siteCleanup, queryCallback)
def	trancateArbitraryTable (self, tablePrefix, siteCleanup, dbId, queryCallback)
def	cleanUpMysqlSiteTable (self, siteCleanup, queryCallback)
def	cleanUpDBStorage (self, siteCleanup, filesSuffix, queryCallback)
def	cleanUpRawDataStorage (self, siteCleanup)
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
	dBDataTask
	errorCode
	errorMessage
Public Attributes inherited from dc_db.SiteCleanUpTask.SiteCleanUpTask
	keyValueStorageDir
	rawDataDir
	errorCode
	errorMessage
	dBDataTask
	fieldRecalculator

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 SiteDeleteTask.py.

Constructor & Destructor Documentation

__init__()

def dc_db.SiteDeleteTask.SiteDeleteTask.__init__	(		self,
			keyValueStorageDir,
			rawDataDir,
			dBDataTask
	)

Definition at line 29 of file SiteDeleteTask.py.

  def __init__(self, keyValueStorageDir, rawDataDir, dBDataTask):
    super(SiteDeleteTask, self).__init__(keyValueStorageDir, rawDataDir, dBDataTask)
    self.dBDataTask = dBDataTask

Member Function Documentation

clearRelatedTables()

def dc_db.SiteDeleteTask.SiteDeleteTask.clearRelatedTables	(		self,
			siteDelete,
			queryCallback
	)

Definition at line 117 of file SiteDeleteTask.py.

  def clearRelatedTables(self, siteDelete, queryCallback):
    tebleList = ["`sites_urls`", "`sites_filters`", "`sites_properties`"]
    DELETE_SITE_SQL_QUERY = "DELETE FROM %s WHERE Site_Id = '%s'"
    for tableName in tebleList:
      query = DELETE_SITE_SQL_QUERY % (tableName, siteDelete.id)
      queryCallback(query, Constants.PRIMARY_DB_ID)

dropArbitraryTable()

def dc_db.SiteDeleteTask.SiteDeleteTask.dropArbitraryTable	(		self,
			tablePrefix,
			siteDelete,
			dbId,
			queryCallback
	)

Definition at line 96 of file SiteDeleteTask.py.

  def dropArbitraryTable(self, tablePrefix, siteDelete, dbId, queryCallback):
    tbName = tablePrefix % siteDelete.id
    SQL_DROP_QUERY_TEMPLATE = "DROP TABLE IF EXISTS `%s`"
    query = SQL_DROP_QUERY_TEMPLATE % tbName
    queryCallback(query, dbId)

dropURLTable()

def dc_db.SiteDeleteTask.SiteDeleteTask.dropURLTable	(		self,
			siteDelete,
			queryCallback
	)

Definition at line 83 of file SiteDeleteTask.py.

  def dropURLTable(self, siteDelete, queryCallback):
    SQL_DROP_QUERY_TEMPLATE = "DROP TABLE IF EXISTS `%s`"
    tbName = Constants.DC_URLS_TABLE_NAME_TEMPLATE % siteDelete.id
    query = SQL_DROP_QUERY_TEMPLATE % tbName
    queryCallback(query, Constants.SECONDARY_DB_ID)
    queryCallback(query, Constants.FOURTH_DB_ID)

process()

def dc_db.SiteDeleteTask.SiteDeleteTask.process	(		self,
			siteDeletes,
			queryCallback
	)

Definition at line 38 of file SiteDeleteTask.py.

  def process(self, siteDeletes, queryCallback):
    ret = GeneralResponse()
    if not isinstance(siteDeletes, list):
      siteDeletes = [siteDeletes]

    for siteDelete in siteDeletes:
      localIds = []
      if siteDelete.id is None:
        localIds = SiteTask.SiteTask.execSiteCriterions(siteDelete.criterions, queryCallback)
      else:
        localIds.append(siteDelete.id)
      logger.debug(">>> SiteDeleteTask, ids are = " + str(localIds))

      for localId in localIds:
        self.errorCode = 0
        self.errorMessage = "OK"
        siteDelete.id = localId
        self.dropURLTable(siteDelete, queryCallback)
        self.dropArbitraryTable(Constants.DC_FREQ_TABLE_NAME_TEMPLATE, siteDelete, Constants.STAT_DB_ID, queryCallback)
        self.dropArbitraryTable(Constants.DC_LOG_TABLE_NAME_TEMPLATE, siteDelete, Constants.LOG_DB_ID, queryCallback)
        self.dropArbitraryTable(Constants.DC_ATT_TABLE_NAME_TEMPLATE, siteDelete, Constants.ATT_DB_ID, queryCallback)
        self.removeSiteRecord(siteDelete, queryCallback)
        self.clearRelatedTables(siteDelete, queryCallback)

        # the rest as in  SiteCleanUpTask
        if siteDelete.delayedType == dc.EventObjects.NOT_DELAYED_OPERATION:
          super(SiteDeleteTask, self).cleanUpDBStorage(siteDelete, SiteCleanUpTask.KEY_VALUE_FILE_NAME_TEMPLATE,
                                                       queryCallback)
          super(SiteDeleteTask, self).cleanUpDBStorage(siteDelete, SiteCleanUpTask.KEY_VALUE_FIELDS_FILE_NAME_TEMPLATE,
                                                       queryCallback)
          super(SiteDeleteTask, self).cleanUpRawDataStorage(siteDelete)
        ret.errorCode = self.errorCode
        ret.statuses.append(ret.errorCode)
        if ret.errorMessage is None or ret.errorMessage == "":
          ret.errorMessage = self.errorMessage
        else:
          ret.errorMessage += ("-" + self.errorMessage)

    return ret

Here is the caller graph for this function:

removeSiteRecord()

def dc_db.SiteDeleteTask.SiteDeleteTask.removeSiteRecord	(		self,
			siteDelete,
			queryCallback
	)

Definition at line 107 of file SiteDeleteTask.py.

  def removeSiteRecord(self, siteDelete, queryCallback):
    DELETE_SITE_SQL_QUERY = "DELETE FROM `sites` WHERE id = '%s'"
    query = DELETE_SITE_SQL_QUERY % siteDelete.id
    queryCallback(query, Constants.PRIMARY_DB_ID)

Member Data Documentation

dBDataTask

dc_db.SiteDeleteTask.SiteDeleteTask.dBDataTask

Definition at line 31 of file SiteDeleteTask.py.

errorCode

dc_db.SiteDeleteTask.SiteDeleteTask.errorCode

Definition at line 52 of file SiteDeleteTask.py.

errorMessage

dc_db.SiteDeleteTask.SiteDeleteTask.errorMessage

Definition at line 53 of file SiteDeleteTask.py.

---

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

• sources/hce/dc_db/SiteDeleteTask.py