Public Member Functions | |
LSDImportFileBlock (LSDDbAdmin admin, ConcurrentLinkedQueue< LSDExtQueueMembers > queue, ConcurrentLinkedQueue< LSDExtQueueMember > result, boolean isBatch) | |
void | run () |
LSDExtDbDocument[] | getNewStorageDocumentsProcedureCommit (LSDDbAdmin admin, LSDDbLegacy legacy, LSDExtQueueMembers members, boolean sameLegacy, boolean isMove) |
Protected Attributes | |
ConcurrentLinkedQueue < LSDExtQueueMember > | queue1 = null |
LSDDbAdmin | admin = null |
LSDCommonFunctions | lcf = null |
Private Member Functions | |
boolean | executeImport (LSDExtQueueMembers members) |
boolean | executeImport (LSDExtQueueMember member) |
Private Attributes | |
ConcurrentLinkedQueue < LSDExtQueueMembers > | queueb = null |
File | file = null |
boolean | isBatch = true |
openlsd.appli.autoimport.commonimport.LSDImportFileBlock.LSDImportFileBlock | ( | LSDDbAdmin | admin, | |
ConcurrentLinkedQueue< LSDExtQueueMembers > | queue, | |||
ConcurrentLinkedQueue< LSDExtQueueMember > | result, | |||
boolean | isBatch | |||
) |
Create an ImportFile Thread Runner from DB, RunQueue and ResultQueue
admin | ||
queue | ||
result | ||
isBatch |
void openlsd.appli.autoimport.commonimport.LSDImportFileBlock.run | ( | ) |
Run the import of all files from the Run Queue and put the result in the Done Queue
boolean openlsd.appli.autoimport.commonimport.LSDImportFileBlock.executeImport | ( | LSDExtQueueMembers | members | ) | [private] |
Run the import of one file from the Run Queue and put the result in the Done Queue
members |
boolean openlsd.appli.autoimport.commonimport.LSDImportFileBlock.executeImport | ( | LSDExtQueueMember | member | ) | [private] |
Simple put
member |
LSDExtDbDocument [] openlsd.appli.autoimport.commonimport.LSDImportFileBlock.getNewStorageDocumentsProcedureCommit | ( | LSDDbAdmin | admin, | |
LSDDbLegacy | legacy, | |||
LSDExtQueueMembers | members, | |||
boolean | sameLegacy, | |||
boolean | isMove | |||
) |
Get New Storage for a set of New Documents. If they already exist, return null. This version uses a stored procedure: insertdocscommit. Commit is done once the storage is updated and all documents are inserted at all (must be updated manually after). (only LSDConstants.NBLINEOP members can be handle at a time due to a limitation of VARCHAR2 as out in PL/SQL procedures)
admin | ||
legacy | ||
members | ||
sameLegacy | ||
isMove |
Reimplemented in openlsd.multiple.autoimport.commonimport.LSDImportFileBlockExtOp.
ConcurrentLinkedQueue<LSDExtQueueMembers> openlsd.appli.autoimport.commonimport.LSDImportFileBlock.queueb = null [private] |
Queue of BlockMembers to import
ConcurrentLinkedQueue<LSDExtQueueMember> openlsd.appli.autoimport.commonimport.LSDImportFileBlock.queue1 = null [protected] |
Queue of Member in one BlockMember to import
LSDDbAdmin openlsd.appli.autoimport.commonimport.LSDImportFileBlock.admin = null [protected] |
DB Admin object
File openlsd.appli.autoimport.commonimport.LSDImportFileBlock.file = null [private] |
File to import
boolean openlsd.appli.autoimport.commonimport.LSDImportFileBlock.isBatch = true [private] |
Is this import done in Batch mode
LSDCommonFunctions openlsd.appli.autoimport.commonimport.LSDImportFileBlock.lcf = null [protected] |
Common Functions Object