ESMove.ESMoveManager

Module ESMove :: Class ESMoveManager

[show private | hide private]

Class ESMoveManager

ESFileTypes --+    
              |    
    SQLUtil --+    
              |    
         ESInit --+
                  |
                 ESMoveManager

ESMoveManager is in charge of moving files in EventStore

Method Summary
	`__init__(self, db, dbType, logFile)` Initialize database pointer, cursor, db type (MySQL or SQLite).
tuple	`moveFileInES(self, fileIn, fileOut)` Move a single fileIn to fileOut destination.
integer	`moveFilesInES(self, iFileList, fileOut)` High-level method to move a list of files to fileOut destination.
Inherited from ESFileTypes
integer	`allow(self, type)` Check if given file type is allowed in EventStore.
integer	`allowToInject(self, type)` Check if given file type is allowed for injection in EventStore.
list	`esFileTypes(self)` Return a list of known file types supported in EventStore.
list	`esInjectionFileTypes(self)` Return a list of known file types supported in EventStore which allowed for injection.
integer	`isDatType(self, iFileType)` Check if given file type is data file.
integer	`isKeyType(self, iFileType)` Check if given file type is index file.
integer	`isLocType(self, iFileType)` Check if given file type is location file.
Inherited from SQLUtil
	`close(self)` Close cursor and db connector
	`commit(self)` Explicit commit
	`createTables(self, table)` Create table(s) in EventStore database.
	`dropTable(self, table)` Drop table in EventStore
	`endTxn(self, msg)` Update EventStore db log and invoke COMMIT transaction.
	`fetchAll(self, query)` Update a EventStore log and retrieve all rows for given query
	`fetchOne(self, query)` Update a EventStore log and retrieve one row for given query
	`findFileForRun(self, run, time)` Find location of the data file holding given run
	`getAllParents(self, childName)` Get all parents for given child name
	`getIsolationLevel(self)` Get isolation level of SQLite DB
	`getLastId(self, table)` Get last autoincemented id for given table
	`getTableNames(self)` Return a list of table names in EventStore DB
	`getTables(self)` Return list of tables from DB
	`getTableSchema(self, tableName)` Return EventStore table schema
	`idx(self, name)`
	`lockTables(self, tableName)` Lock tables in EventStore.
	`makeESQuery(self, timeStamp)` Return the following dictionary: dict[time]=[(grade,minR,maxR,svName)]
	`printDBContent(self, table)` Print content of given table in EventStore DB
	`printESInfo(self, timeStamp)` Dump EventStore DB content in user readable format.
	`printRuns(self, minR, maxR)` Print list of runs for given run range
	`rollback(self)` Rollback transaction
	`setCommitFlag(self, flag)` Set flag which will inform underlying DB what to do with transaction commits.
	`setIsolationLevel(self, level)` Set isolation level for internal DB (necessary to perform SQLite transactions.
	`setVerboseLevel(self, verbose)` Set verbose level, 0 low, 1 is high.
	`showDepend(self, childName)` Print all dependencies for given data version name.
	`startTxn(self, msg)` Update EventStore db log and invoke BEGIN transaction.
	`unlockTables(self)` Unlock all locked tables in EventStore
	`updateDBAndLog(self, iQuery, cQuery)`
	`updateLog(self, iQuery, cQuery)` Update EventStore log and execute given query.
	`writeToLog(self, msg)` Update EventStore db log with time/pid/msg signature

Method Details

init(self, db, dbType, logFile)
(Constructor)

Initialize database pointer, cursor, db type (MySQL or SQLite). Retrieve information about table names from underlying DB.

Overrides:: es_init.ESInit.__init__ (inherited documentation)

moveFileInES(self, fileIn, fileOut)

Move a single fileIn to fileOut destination. First update FileID table and then physically copy file to new location.

Parameters:: fileIn - file name
(type=string); fileOut - file name
(type=string)

Returns:: (status code, query, compensatingQuery), where query is SQL query how to update FileID table. It's printed out by moveFilesInES in the case of failure for debugging purpose.
(type=tuple)

moveFilesInES(self, iFileList, fileOut)

High-level method to move a list of files to fileOut destination. All job is done by using moveFileInES method.

Parameters:: iFileList - list of files
(type=list); fileOut - file name
(type=string)

Returns:: status code
(type=integer)

Generated by Epydoc 2.1 on Tue Jan 24 10:46:00 2006

http://epydoc.sf.net

Class ESMoveManager

__init__(self, db, dbType, logFile) (Constructor)

moveFileInES(self, fileIn, fileOut)

moveFilesInES(self, iFileList, fileOut)

init(self, db, dbType, logFile)
(Constructor)