org.xmlBlaster.contrib.dbupdate
Class OneToThree

java.lang.Object
  org.xmlBlaster.contrib.dbupdate.OneToThree

public class OneToThree
extends java.lang.Object

Important: subjectId ending with a number can't be converted from xb_entries to xbstore.

You need to have a xmlBlaster.properties with JdbcQueue configured

Author:

Marcel

Field Summary

private java.lang.String	clusterNodeToIgnore
private CommonTableDatabaseAccessor	dbAccessorClientOne
private XBDatabaseAccessor	dbAccessorClientThree
private CommonTableDatabaseAccessor	dbAccessorServerOne
private XBDatabaseAccessor	dbAccessorServerThree
private Global	globalOne
private Global	globalThree
private boolean	limitPositivePubToOneDigit
private static java.util.logging.Logger	log
private int	numAnalysed
private java.io.FileOutputStream	out_
private int	processed
private ServerScope	serverScopeOne
private ServerScope	serverScopeThree
private StopWatch	stopWatch
private java.io.File	to_file
private int	totalProcessed
private java.util.Map<java.lang.String,XBStore>	xbStoreMap

Constructor Summary

OneToThree(ServerScope serverScopeOne, ServerScope serverScopeThree, Global globalOne, Global globalThree)

Method Summary

void	closeReportFile()
CommonTableDatabaseAccessor	createClientAccessorOne()
XBDatabaseAccessor	createClientAccessorThree()
void	createReportFile()
CommonTableDatabaseAccessor	createServerScopeAccessorOne()
XBDatabaseAccessor	createServerScopeAccessorThree()
XBStore	getXBStore(XBDatabaseAccessor accessor, Global glob, StorageId oldStorageId)
void	initConnections()
void	logToFile(java.lang.String text)
static void	main(java.lang.String[] args)
private java.util.Properties	parsePropertyValue(java.lang.String rawString)
private boolean	transferClusterNode(java.lang.String nodeToTransfer)
void	transformClientSide()
void	transformServerScope()
void	wipeOutThree()

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Field Detail

log

private static java.util.logging.Logger log

serverScopeOne

private ServerScope serverScopeOne

serverScopeThree

private ServerScope serverScopeThree

globalOne

private Global globalOne

globalThree

private Global globalThree

to_file

private java.io.File to_file

out_

private java.io.FileOutputStream out_

xbStoreMap

private java.util.Map<java.lang.String,XBStore> xbStoreMap

processed

private int processed

totalProcessed

private int totalProcessed

numAnalysed

private int numAnalysed

limitPositivePubToOneDigit

private boolean limitPositivePubToOneDigit

clusterNodeToIgnore

private java.lang.String clusterNodeToIgnore

dbAccessorServerOne

private CommonTableDatabaseAccessor dbAccessorServerOne

dbAccessorServerThree

private XBDatabaseAccessor dbAccessorServerThree

dbAccessorClientOne

private CommonTableDatabaseAccessor dbAccessorClientOne

dbAccessorClientThree

private XBDatabaseAccessor dbAccessorClientThree

stopWatch

private StopWatch stopWatch

Constructor Detail

OneToThree

public OneToThree(ServerScope serverScopeOne,
                  ServerScope serverScopeThree,
                  Global globalOne,
                  Global globalThree)
           throws XmlBlasterException

Throws:

XmlBlasterException

Method Detail

initConnections

public void initConnections()
                     throws java.lang.Exception

Throws:

java.lang.Exception

transferClusterNode

private boolean transferClusterNode(java.lang.String nodeToTransfer)

transformServerScope

public void transformServerScope()
                          throws java.lang.Exception

Throws:

java.lang.Exception

transformClientSide

public void transformClientSide()
                         throws java.lang.Exception

Throws:

java.lang.Exception

parsePropertyValue

private java.util.Properties parsePropertyValue(java.lang.String rawString)
                                         throws XmlBlasterException

Parameters:

rawString - e.g."org.xmlBlaster.protocol.soap.SoapDriver,classpath=xerces.jar:soap.jar,MAXSIZE=100"

Throws:

XmlBlasterException

logToFile

public void logToFile(java.lang.String text)

createReportFile

public void createReportFile()
                      throws java.lang.Exception

Throws:

java.lang.Exception

closeReportFile

public void closeReportFile()

createServerScopeAccessorOne

public CommonTableDatabaseAccessor createServerScopeAccessorOne()
                                                         throws java.lang.Exception

Throws:

java.lang.Exception

createClientAccessorOne

public CommonTableDatabaseAccessor createClientAccessorOne()
                                                    throws java.lang.Exception

Throws:

java.lang.Exception

createServerScopeAccessorThree

public XBDatabaseAccessor createServerScopeAccessorThree()
                                                  throws java.lang.Exception

Throws:

java.lang.Exception

createClientAccessorThree

public XBDatabaseAccessor createClientAccessorThree()
                                             throws java.lang.Exception

Throws:

java.lang.Exception

wipeOutThree

public void wipeOutThree()
                  throws java.lang.Exception

Throws:

java.lang.Exception

getXBStore

public XBStore getXBStore(XBDatabaseAccessor accessor,
                          Global glob,
                          StorageId oldStorageId)
                   throws XmlBlasterException

Throws:

XmlBlasterException

main

public static void main(java.lang.String[] args)