upgrade-helper Namespace Reference

Functions
def	getCmdParams ()
	# Sample of execution: . More...
def	getDBTasksWrapper (configName)
def	getTableNamesList (response, oldTableNamePart, newTableNamePart)
def	extractRequest (fileName)
def	makeSql (rawRequest, tableName, tableNamePart)

Variables
string	APP_NAME = 'upgrade-helper'
	exit_code = APP_CONSTS.EXIT_SUCCESS
	dbName
	partTableName
	tdbName
	fileName
	configName
def	wrapper = getDBTasksWrapper(configName)
string	sql = 'SHOW TABLES;'
def	response = wrapper.customRequest(sql, dbName)
	rawRequest
	tableNamePart
def	tableNames = getTableNamesList(response, partTableName, tableNamePart)

Function Documentation

extractRequest()

def upgrade-helper.extractRequest

(

fileName

)

Definition at line 114 of file upgrade-helper.py.

def extractRequest(fileName):
  rawRequest = ''
  tableNamePart = ''

  f = open(fileName, 'r')
  rawRequest = f.read()
  f.close()

  words = rawRequest.split()
  for word in words:
    if word.count('%') > 1:
      tableNamePart = word[:word.find('%')]
      break

  for elem in tableNamePart:
    if isalpha(elem):
      tableNamePart = tableNamePart[tableNamePart.find(elem):]
      break

  return rawRequest, tableNamePart


# #Make SQL request
#
# @param rawRequest - raw request
# @param tableName - table name
# @param tableNamePart - part of table name
# @return SQL request

getCmdParams()

def upgrade-helper.getCmdParams

(

)

#

Sample of execution:

.

/upgrade-helper.py -d=dc_attributes -p=att_ -t=dc_attributes -f=/home/hce/update_data.sql -c=../ini/db-task.ini #

For sample update_data.sql content string:

alter table att_SITE_ID% MODIFY column Value longblob NOT NULL;

#

Definition at line 50 of file upgrade-helper.py.

def getCmdParams():
  app = foundation.CementApp(APP_NAME)
  app.setup()
  app.add_arg('-d', '--db', action='store', metavar='use_database_name_for_show_tables', help='use database name for getting site_id')
  app.add_arg('-p', '--ptn', action='store', metavar='part_table_name', help='part of table_name')
  app.add_arg('-t', '--tdb', action='store', metavar='use_database_name_for_execution', help='use database name for execution')
  app.add_arg('-f', '--file', action='store', metavar='input_file_name', help='input file name with sql request')
  app.add_arg('-c', '--config', action='store', metavar='config_file_name', help='config ini-file', required=True)
  app.run()

  dbName = app.pargs.db
  partTableName = app.pargs.ptn
  tdbName = app.pargs.tdb
  fileName = app.pargs.file
  configName = app.pargs.config

  return dbName, partTableName, tdbName, fileName, configName


# # Get db task wrapper
#
# @param configName - config file name
# @return wrapper instance

getDBTasksWrapper()

def upgrade-helper.getDBTasksWrapper

(

configName

)

Definition at line 73 of file upgrade-helper.py.

def getDBTasksWrapper(configName):
  # variable for result value
  wrapper = None
  try:
    config = ConfigParser.ConfigParser()
    config.optionxform = str

    readOk = config.read(configName)
    if len(readOk) == 0:
      raise Exception("Wrong config file name '" + str(configName) + "'")

    wrapper = DBTasksWrapper(config)
  except Exception, err:
    raise Exception('Get DBTaskWrapper: ' + str(err))

  return wrapper


# #Get table name list
#
# @param response - response after sql request
# @param oldTableNamePart - mandatory part of old table names
# @param newTableNamePart - mandatory part of new table names
# @return list of names

getTableNamesList()

def upgrade-helper.getTableNamesList	(		response,
			oldTableNamePart,
			newTableNamePart
	)

Definition at line 97 of file upgrade-helper.py.

def getTableNamesList(response, oldTableNamePart, newTableNamePart):
  result = []
  if isinstance(response, tuple):
    for elem in response:
      if len(elem) > 0:
        if elem[0].find(oldTableNamePart) > -1:
          name = copy.deepcopy(elem[0])
          name = name.replace(oldTableNamePart, newTableNamePart)
          result.append(name)

  return result


# #Extract request
#
# @param fileName - input file name for extract
# @return request, tableNamePart

makeSql()

def upgrade-helper.makeSql	(		rawRequest,
			tableName,
			tableNamePart
	)

Definition at line 142 of file upgrade-helper.py.

def makeSql(rawRequest, tableName, tableNamePart):
  sql = ''
  words = []
  for word in rawRequest.split():
    if word.find(tableNamePart) > -1:
      words.append(tableName)
    else:
      words.append(word)

  sql = ' '.join(words)

  return sql

Variable Documentation

APP_NAME

string upgrade-helper.APP_NAME = 'upgrade-helper'

Definition at line 34 of file upgrade-helper.py.

configName

upgrade-helper.configName

Definition at line 159 of file upgrade-helper.py.

dbName

upgrade-helper.dbName

Definition at line 159 of file upgrade-helper.py.

exit_code

upgrade-helper.exit_code = APP_CONSTS.EXIT_SUCCESS

Definition at line 157 of file upgrade-helper.py.

fileName

upgrade-helper.fileName

Definition at line 159 of file upgrade-helper.py.

partTableName

upgrade-helper.partTableName

Definition at line 159 of file upgrade-helper.py.

rawRequest

upgrade-helper.rawRequest

Definition at line 165 of file upgrade-helper.py.

response

def upgrade-helper.response = wrapper.customRequest(sql, dbName)

Definition at line 164 of file upgrade-helper.py.

sql

def upgrade-helper.sql = 'SHOW TABLES;'

Definition at line 163 of file upgrade-helper.py.

tableNamePart

upgrade-helper.tableNamePart

Definition at line 165 of file upgrade-helper.py.

tableNames

def upgrade-helper.tableNames = getTableNamesList(response, partTableName, tableNamePart)

Definition at line 166 of file upgrade-helper.py.

tdbName

upgrade-helper.tdbName

Definition at line 159 of file upgrade-helper.py.

wrapper

def upgrade-helper.wrapper = getDBTasksWrapper(configName)

Definition at line 160 of file upgrade-helper.py.