dc_db.SQLCustomTask.SQLCustomTask Class Reference

Inheritance diagram for dc_db.SQLCustomTask.SQLCustomTask:

Collaboration diagram for dc_db.SQLCustomTask.SQLCustomTask:

Public Member Functions
def	__init__ (self)
def	process (self, sqlRequest, queryCallback, bdResolveFunc)
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)

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 20 of file SQLCustomTask.py.

Constructor & Destructor Documentation

__init__()

def dc_db.SQLCustomTask.SQLCustomTask.__init__

(

self

)

Definition at line 24 of file SQLCustomTask.py.

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

Member Function Documentation

process()

def dc_db.SQLCustomTask.SQLCustomTask.process	(		self,
			sqlRequest,
			queryCallback,
			bdResolveFunc
	)

Definition at line 34 of file SQLCustomTask.py.

  def process(self, sqlRequest, queryCallback, bdResolveFunc):
    # variable for result
    ret = dbi.EventObjects.CustomResponse(sqlRequest.rid, sqlRequest.query, sqlRequest.dbName)
    try:
      logger.debug("!!! SQL Custom request: %s", str(sqlRequest.query))

      if sqlRequest is None:
        raise Exception("Error: request object is None")

      if sqlRequest.query is None or \
      (not isinstance(sqlRequest.query, basestring) and not isinstance(sqlRequest.query, list)):
        raise Exception("Error: wrong type of sql request param (%s)", str(type(sqlRequest)))

      if isinstance(sqlRequest.query, basestring) and sqlRequest.query == "":
        raise Exception("Error: sql request is empty string")

      if isinstance(sqlRequest.query, list) and len(sqlRequest.query) == 0:
        raise Exception("Error: input list of sql requests is empty")

      if sqlRequest.dbName is None or \
      not isinstance(sqlRequest.dbName, basestring) or \
      sqlRequest.dbName == "":
        raise Exception("Error: wrong database name '%s'", str(sqlRequest.dbName))

      dbIndex = bdResolveFunc(sqlRequest.dbName)
      if dbIndex is None:
        raise Exception("Error: there isn't '%s' database connection", str(sqlRequest.dbName))

      isSingleQuery = True
      if isinstance(sqlRequest.query, basestring):
        queries = [sqlRequest.query]
      else:
        queries = sqlRequest.query
        isSingleQuery = False

      results = []
      for query in queries:
        # execute single request
        if sqlRequest.includeFieldsNames == dbi.EventObjects.CustomRequest.SQL_BY_INDEX:
          res = queryCallback(query, dbIndex)
        elif sqlRequest.includeFieldsNames == dbi.EventObjects.CustomRequest.SQL_BY_NAME:
          res = queryCallback(query, dbIndex, Constants.EXEC_NAME)

        if res is None:
          raise Exception("Error: wrong SQL request '%s'", str(query))

        # success execution
        results.append(res)

#       logger.debug("!!! SQL Custom results: '%s' ", Utils.varDump(results))
      if isSingleQuery and len(results) > 0:
        ret.result = results[0]
      else:
        ret.result = results

    except Exception, err:
      ret.errString = str(err)
      logger.debug("!!! SQL Custom request: %s", str(err))

    return ret

---

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

• sources/hce/dc_db/SQLCustomTask.py