[exo-jcr-commits] exo-jcr SVN: r3668 - in jcr/trunk/exo.jcr.component.ext: src/main/java/org/exoplatform/services/jcr/ext/backup/impl/rdbms and 1 other directories.

Author: tolusha Date: 2010-12-16 07:45:04 -0500 (Thu, 16 Dec 2010) New Revision: 3668 Modified: jcr/trunk/exo.jcr.component.ext/pom.xml jcr/trunk/exo.jcr.component.ext/src/main/java/org/exoplatform/services/jcr/ext/backup/impl/rdbms/RdbmsWorkspaceInitializer.java jcr/trunk/exo.jcr.component.ext/src/test/java/org/exoplatform/services/jcr/ext/backup/AbstractBackupTestCase.java jcr/trunk/exo.jcr.component.ext/src/test/java/org/exoplatform/services/jcr/ext/backup/AbstractBackupUseCasesTest.java Log: EXOJCR-1101: add test to include list, fix issues Modified: jcr/trunk/exo.jcr.component.ext/pom.xml =================================================================== --- jcr/trunk/exo.jcr.component.ext/pom.xml 2010-12-15 10:50:35 UTC (rev 3667) +++ jcr/trunk/exo.jcr.component.ext/pom.xml 2010-12-16 12:45:04 UTC (rev 3668) @@ -188,7 +188,6 @@ <include>**/backup/*.java</include> </includes> <excludes> - <exclude>**/backup/TestRDBMSBackupManager.java</exclude> <exclude>**/BaseStandaloneTest.java</exclude> <exclude>**/backup/AbstractBackupTestCase.java</exclude> <exclude>**/backup/BaseRDBMSBackupTest.java</exclude> Modified: jcr/trunk/exo.jcr.component.ext/src/main/java/org/exoplatform/services/jcr/ext/backup/impl/rdbms/RdbmsWorkspaceInitializer.java =================================================================== --- jcr/trunk/exo.jcr.component.ext/src/main/java/org/exoplatform/services/jcr/ext/backup/impl/rdbms/RdbmsWorkspaceInitializer.java 2010-12-15 10:50:35 UTC (rev 3667) +++ jcr/trunk/exo.jcr.component.ext/src/main/java/org/exoplatform/services/jcr/ext/backup/impl/rdbms/RdbmsWorkspaceInitializer.java 2010-12-16 12:45:04 UTC (rev 3668) @@ -547,7 +547,7 @@ // construct query int targetColumnCount = sourceColumnCount; - if (helper.getSkipColumnIndex() != null) + if (helper.getDeleteColumnIndex() != null) { targetColumnCount--; } @@ -613,14 +613,19 @@ } stream = spoolInputStream(contentReader, len); } - + if (helper.getSkipColumnIndex() != null && helper.getSkipColumnIndex() == i) { + continue; + } + else if (helper.getDeleteColumnIndex() != null && helper.getDeleteColumnIndex() == i) + { targetIndex--; continue; } else if (helper.getConvertColumnIndexes().contains(i)) { + // convert column value ByteArrayInputStream ba = (ByteArrayInputStream)stream; byte[] readBuffer = new byte[ba.available()]; ba.read(readBuffer); @@ -632,19 +637,34 @@ } else { - if (!helper.isMultiDb && helper.isBackupMutliDb()) + if (helper.isMultiDb) { - StringBuilder builder = new StringBuilder(); - builder.append(workspaceName); - builder.append(currentValue); - - stream = new ByteArrayInputStream(builder.toString().getBytes()); + if (!helper.isBackupMutliDb()) + { + stream = + new ByteArrayInputStream(new String(readBuffer, Constants.DEFAULT_ENCODING).substring( + helper.getBackupWorkspaceName().length()).getBytes()); + } } else { - stream = - new ByteArrayInputStream(new String(readBuffer, Constants.DEFAULT_ENCODING).substring( - helper.getBackupWorkspaceName().length()).getBytes()); + if (helper.isBackupMutliDb()) + { + StringBuilder builder = new StringBuilder(); + builder.append(workspaceName); + builder.append(currentValue); + + stream = new ByteArrayInputStream(builder.toString().getBytes()); + } + else + { + StringBuilder builder = new StringBuilder(); + builder.append(workspaceName); + builder.append(new String(readBuffer, Constants.DEFAULT_ENCODING).substring(helper + .getBackupWorkspaceName().length())); + + stream = new ByteArrayInputStream(builder.toString().getBytes()); + } } } @@ -865,6 +885,8 @@ private File contentLenFile; + private Integer deleteColumnIndex = null; + private Integer skipColumnIndex = null; private Integer newColumnIndex = null; @@ -895,7 +917,7 @@ if (!backupInfo.isMultiDb()) { // CONTAINER_NAME column index - skipColumnIndex = 4; + deleteColumnIndex = 4; // ID and PARENT_ID column indexes convertColumnIndex.add(0); @@ -914,8 +936,14 @@ convertColumnIndex.add(0); convertColumnIndex.add(1); } + else + { + // ID and PARENT_ID and CONTAINER_NAME column indexes + convertColumnIndex.add(0); + convertColumnIndex.add(1); + convertColumnIndex.add(4); + } } - } else if (tableType == VALUE_TABLE) { @@ -925,7 +953,10 @@ tableName = "JCR_" + (isMultiDb ? "M" : "S") + "VALUE"; - if (isMultiDb != backupInfo.isMultiDb()) + // auto increment ID column + skipColumnIndex = 0; + + if (!isMultiDb || !backupInfo.isMultiDb()) { // PROPERTY_ID column index convertColumnIndex.add(3); @@ -939,7 +970,7 @@ tableName = "JCR_" + (isMultiDb ? "M" : "S") + "REF"; - if (isMultiDb != backupInfo.isMultiDb()) + if (!isMultiDb || !backupInfo.isMultiDb()) { // NODE_ID and PROPERTY_ID column indexes convertColumnIndex.add(0); @@ -1013,6 +1044,17 @@ } /** + * Returns index of column which should be skipped during restore. + * + * @return Integer + */ + public Integer getDeleteColumnIndex() + { + return deleteColumnIndex; + } + + + /** * Returns index of column which should be added during restore. * * @return Integer Modified: jcr/trunk/exo.jcr.component.ext/src/test/java/org/exoplatform/services/jcr/ext/backup/AbstractBackupTestCase.java =================================================================== --- jcr/trunk/exo.jcr.component.ext/src/test/java/org/exoplatform/services/jcr/ext/backup/AbstractBackupTestCase.java 2010-12-15 10:50:35 UTC (rev 3667) +++ jcr/trunk/exo.jcr.component.ext/src/test/java/org/exoplatform/services/jcr/ext/backup/AbstractBackupTestCase.java 2010-12-16 12:45:04 UTC (rev 3668) @@ -224,7 +224,7 @@ ws1back.setAccessManager(ws1e.getAccessManager()); ws1back.setCache(ws1e.getCache()); - ws1back.setContainer(ws1e.getContainer()); + // ws1back.setContainer(ws1e.getContainer()); ws1back.setLockManager(ws1e.getLockManager()); ws1back.setInitializer(ws1e.getInitializer()); @@ -233,14 +233,14 @@ // qParams.add(new SimpleParameterEntry("indexDir", "target" + File.separator+ "temp" + // File.separator +"index" + name)); qParams.add(new SimpleParameterEntry(QueryHandlerParams.PARAM_INDEX_DIR, "target" + File.separator + name - + System.currentTimeMillis())); + + System.currentTimeMillis())); QueryHandlerEntry qEntry = new QueryHandlerEntry("org.exoplatform.services.jcr.impl.core.query.lucene.SearchIndex", qParams); ws1back.setQueryHandler(qEntry); // EXOMAN ArrayList params = new ArrayList(); - for (Iterator i = ws1back.getContainer().getParameters().iterator(); i.hasNext();) + for (Iterator i = ws1e.getContainer().getParameters().iterator(); i.hasNext();) { SimpleParameterEntry p = (SimpleParameterEntry) i.next(); SimpleParameterEntry newp = new SimpleParameterEntry(p.getName(), p.getValue()); @@ -253,31 +253,29 @@ params.add(newp); } - //Value storage - ArrayList<ValueStorageEntry> valueStorages = new ArrayList<ValueStorageEntry>(); + ContainerEntry ce = + new ContainerEntry("org.exoplatform.services.jcr.impl.storage.jdbc.JDBCWorkspaceDataContainer", params); + + ArrayList<ValueStorageEntry> list = new ArrayList<ValueStorageEntry>(); + // value storage + ArrayList<ValueStorageFilterEntry> vsparams = new ArrayList<ValueStorageFilterEntry>(); ValueStorageFilterEntry filterEntry = new ValueStorageFilterEntry(); filterEntry.setPropertyType("Binary"); + vsparams.add(filterEntry); - ArrayList<ValueStorageFilterEntry> filterEntries = new ArrayList<ValueStorageFilterEntry>(); - filterEntries.add(filterEntry); - - - ValueStorageEntry valueStorageEntry = new ValueStorageEntry(); - valueStorageEntry.setType("org.exoplatform.services.jcr.impl.storage.value.fs.TreeFileValueStorage"); + ValueStorageEntry valueStorageEntry = + new ValueStorageEntry("org.exoplatform.services.jcr.impl.storage.value.fs.TreeFileValueStorage", vsparams); + ArrayList<SimpleParameterEntry> spe = new ArrayList<SimpleParameterEntry>(); + spe.add(new SimpleParameterEntry("path", "target/temp/swap/" + name + "_" + System.currentTimeMillis())); valueStorageEntry.setId("draft"); - valueStorageEntry.setFilters(filterEntries); - - ArrayList<SimpleParameterEntry> parameterEntries = new ArrayList<SimpleParameterEntry>(); - parameterEntries.add(new SimpleParameterEntry("path", "target/temp/values/" + ws1back.getName())); - - valueStorageEntry.setParameters(parameterEntries); + valueStorageEntry.setParameters(spe); + valueStorageEntry.setFilters(vsparams); - valueStorages.add(valueStorageEntry); + // containerEntry.setValueStorages(); + list.add(valueStorageEntry); + ce.setValueStorages(list); - ContainerEntry ce = - new ContainerEntry("org.exoplatform.services.jcr.impl.storage.jdbc.JDBCWorkspaceDataContainer", params); - ce.setValueStorages(valueStorages); ws1back.setContainer(ce); @@ -328,7 +326,6 @@ ws1back.setAccessManager(baseWorkspaceEntry.getAccessManager()); ws1back.setCache(baseWorkspaceEntry.getCache()); - ws1back.setContainer(baseWorkspaceEntry.getContainer()); ws1back.setLockManager(baseWorkspaceEntry.getLockManager()); ws1back.setInitializer(baseWorkspaceEntry.getInitializer()); @@ -349,7 +346,7 @@ } ArrayList params = new ArrayList(); - for (Iterator i = ws1back.getContainer().getParameters().iterator(); i.hasNext();) + for (Iterator i = baseWorkspaceEntry.getContainer().getParameters().iterator(); i.hasNext();) { SimpleParameterEntry p = (SimpleParameterEntry) i.next(); SimpleParameterEntry newp = new SimpleParameterEntry(p.getName(), p.getValue()); @@ -371,6 +368,28 @@ ContainerEntry ce = new ContainerEntry("org.exoplatform.services.jcr.impl.storage.jdbc.JDBCWorkspaceDataContainer", params); + + ArrayList list = new ArrayList(); + + // value storage + ArrayList<ValueStorageFilterEntry> vsparams = new ArrayList<ValueStorageFilterEntry>(); + ValueStorageFilterEntry filterEntry = new ValueStorageFilterEntry(); + filterEntry.setPropertyType("Binary"); + vsparams.add(filterEntry); + + ValueStorageEntry valueStorageEntry = + new ValueStorageEntry("org.exoplatform.services.jcr.impl.storage.value.fs.TreeFileValueStorage", vsparams); + ArrayList<SimpleParameterEntry> spe = new ArrayList<SimpleParameterEntry>(); + spe.add(new SimpleParameterEntry("path", "target/temp/swap/" + repoName + "_" + wsName + "_" + + System.currentTimeMillis())); + valueStorageEntry.setId("draft"); + valueStorageEntry.setParameters(spe); + valueStorageEntry.setFilters(vsparams); + + // containerEntry.setValueStorages(); + list.add(valueStorageEntry); + ce.setValueStorages(list); + ws1back.setContainer(ce); return ws1back; Modified: jcr/trunk/exo.jcr.component.ext/src/test/java/org/exoplatform/services/jcr/ext/backup/AbstractBackupUseCasesTest.java =================================================================== --- jcr/trunk/exo.jcr.component.ext/src/test/java/org/exoplatform/services/jcr/ext/backup/AbstractBackupUseCasesTest.java 2010-12-15 10:50:35 UTC (rev 3667) +++ jcr/trunk/exo.jcr.component.ext/src/test/java/org/exoplatform/services/jcr/ext/backup/AbstractBackupUseCasesTest.java 2010-12-16 12:45:04 UTC (rev 3668) @@ -47,11 +47,9 @@ extends AbstractBackupTestCase { - protected static volatile int uuIndex = 0; - - protected static synchronized int getUUIndex() + protected static synchronized long getUUIndex() { - return uuIndex++; + return System.currentTimeMillis(); } public void testFullBackupRestore() throws Exception @@ -86,8 +84,7 @@ fail("Can't get fullBackup chain"); // restore - RepositoryEntry re = - (RepositoryEntry) ws1Session.getContainer().getComponentInstanceOfType(RepositoryEntry.class); + RepositoryEntry re = (RepositoryEntry)ws1Session.getContainer().getComponentInstanceOfType(RepositoryEntry.class); WorkspaceEntry ws1back = makeWorkspaceEntry(workspaceNameToRestore, dataSourceToWorkspaceRestore); // BackupChainLog bchLog = new BackupChainLog(backDir, rconfig); @@ -105,10 +102,10 @@ SessionImpl back1 = null; try { - back1 = (SessionImpl) getReposityToBackup().login(credentials, workspaceNameToRestore); + back1 = (SessionImpl)getReposityToBackup().login(credentials, workspaceNameToRestore); Node ws1backTestRoot = back1.getRootNode().getNode("backupTest"); assertEquals("Restored content should be same", "property-5", ws1backTestRoot.getNode("node_5") - .getProperty("exo:data").getString()); + .getProperty("exo:data").getString()); } catch (Exception e) { @@ -165,8 +162,7 @@ fail("Can't get fullBackup chain"); // restore - RepositoryEntry re = - (RepositoryEntry) ws1Session.getContainer().getComponentInstanceOfType(RepositoryEntry.class); + RepositoryEntry re = (RepositoryEntry)ws1Session.getContainer().getComponentInstanceOfType(RepositoryEntry.class); WorkspaceEntry ws1back = makeWorkspaceEntry(workspaceNameToRestore, dataSourceToWorkspaceRestore); File backLog = new File(bch.getLogFilePath()); @@ -183,16 +179,16 @@ SessionImpl back1 = null; try { - back1 = (SessionImpl) getReposityToBackup().login(credentials, workspaceNameToRestore); + back1 = (SessionImpl)getReposityToBackup().login(credentials, workspaceNameToRestore); Node ws1backTestRoot = back1.getRootNode().getNode("backupTest"); assertFalse("Node should be removed", ws1backTestRoot.hasNode("node_3")); assertFalse("Node should be removed", ws1backTestRoot.hasNode("node_4")); assertFalse("Node should be removed", ws1backTestRoot.hasNode("node_5")); assertEquals("Restored content should be same", "property #3", ws1backTestRoot.getNode("node #3") - .getProperty("exo:data").getString()); + .getProperty("exo:data").getString()); assertEquals("Restored content should be same", "property #5", ws1backTestRoot.getNode("node #5") - .getProperty("exo:extraData").getString()); + .getProperty("exo:extraData").getString()); assertFalse("Proeprty should be removed", ws1backTestRoot.getNode("node #5").hasProperty("exo:data")); } @@ -254,7 +250,7 @@ ws1TestRoot.addNode("node_102").setProperty("exo:data", new FileInputStream(tempf)); ws1TestRoot.save(); // log here via listener - ws1TestRoot.getNode("node_2").setProperty("exo:data", (InputStream) null); // remove property + ws1TestRoot.getNode("node_2").setProperty("exo:data", (InputStream)null); // remove property ws1TestRoot.getNode("node_3").setProperty("exo:data", new ByteArrayInputStream("aaa".getBytes())); // set // aaa // bytes @@ -265,7 +261,7 @@ ws1TestRoot.save(); // log here via listener Lock n107lock = ws1TestRoot.getNode("node_5").lock(true, false); ws1TestRoot.getSession().move(ws1TestRoot.getNode("node #53").getPath(), - ws1TestRoot.getNode("node_5").getPath() + "/node #53"); + ws1TestRoot.getNode("node_5").getPath() + "/node #53"); ws1TestRoot.save(); // log here via listener ws1TestRoot.getNode("node_6").addMixin("mix:referenceable"); @@ -273,8 +269,8 @@ ws1TestRoot.save(); // log here via listener // before(*), log here via listener - ws1TestRoot.getSession().getWorkspace().move(ws1TestRoot.getNode("node_6").getPath(), - ws1TestRoot.getPath() + "/node_4"); // in place of + ws1TestRoot.getSession().getWorkspace() + .move(ws1TestRoot.getNode("node_6").getPath(), ws1TestRoot.getPath() + "/node_4"); // in place of // 4 removed // stop all @@ -284,8 +280,7 @@ fail("Can't get fullBackup chain"); // restore - RepositoryEntry re = - (RepositoryEntry) ws1Session.getContainer().getComponentInstanceOfType(RepositoryEntry.class); + RepositoryEntry re = (RepositoryEntry)ws1Session.getContainer().getComponentInstanceOfType(RepositoryEntry.class); WorkspaceEntry ws1back = makeWorkspaceEntry(workspaceNameToRestore, dataSourceToWorkspaceRestore); File backLog = new File(bch.getLogFilePath()); @@ -302,12 +297,12 @@ SessionImpl back1 = null; try { - back1 = (SessionImpl) getReposityToBackup().login(credentials, workspaceNameToRestore); + back1 = (SessionImpl)getReposityToBackup().login(credentials, workspaceNameToRestore); Node ws1backTestRoot = back1.getRootNode().getNode("backupTest"); assertTrue("Node should exists", ws1backTestRoot.getNode("node_5").hasNode("node #53")); assertTrue("Property should exists", ws1backTestRoot.getNode("node_5") - .hasProperty("node #53/exo:extraData")); + .hasProperty("node #53/exo:extraData")); assertTrue("Node should exists", ws1backTestRoot.hasNode("node_7")); assertTrue("Property should exists", ws1backTestRoot.hasProperty("node_5/exo:data")); @@ -315,20 +310,20 @@ assertTrue("Node should exists", ws1backTestRoot.hasNode("node_102")); compareStream(new FileInputStream(tempf), ws1backTestRoot.getNode("node_5").getProperty("exo:data") - .getStream()); + .getStream()); compareStream(new FileInputStream(tempf), ws1backTestRoot.getNode("node_1").getProperty("exo:extraData") - .getStream()); + .getStream()); assertFalse("Property should be removed", ws1backTestRoot.getNode("node_2").hasProperty("exo:data")); - compareStream(new ByteArrayInputStream("aaa".getBytes()), ws1backTestRoot.getNode("node_3").getProperty( - "exo:data").getStream()); + compareStream(new ByteArrayInputStream("aaa".getBytes()), + ws1backTestRoot.getNode("node_3").getProperty("exo:data").getStream()); assertTrue("Node should be mix:lockable ", ws1backTestRoot.getNode("node_5").isNodeType("mix:lockable")); assertFalse("Node should be not locked ", ws1backTestRoot.getNode("node_5").isLocked()); - assertEquals("Node should be mix:referenceable and UUID should be " + id6, id6, ws1backTestRoot.getNode( - "node_4").getUUID()); + assertEquals("Node should be mix:referenceable and UUID should be " + id6, id6, + ws1backTestRoot.getNode("node_4").getUUID()); } catch (Exception e) { @@ -347,9 +342,9 @@ public void testFullBackupRestoreAsync() throws Exception { - SessionImpl sessionWS1 = (SessionImpl) getReposityToBackup().login(credentials, workspaceNameToBackup); - sessionWS1.getRootNode().getNode("backupTest").getNode("node_5").setProperty("exo:data", - "Restored content should be same"); + SessionImpl sessionWS1 = (SessionImpl)getReposityToBackup().login(credentials, workspaceNameToBackup); + sessionWS1.getRootNode().getNode("backupTest").getNode("node_5") + .setProperty("exo:data", "Restored content should be same"); sessionWS1.save(); // backup @@ -395,24 +390,23 @@ backup.restore(bchLog, repositoryNameToBackup, ws1back, true); while (backup.getLastRestore(repositoryNameToBackup, workspaceNameToRestore).getStateRestore() != JobWorkspaceRestore.RESTORE_SUCCESSFUL - && backup.getLastRestore(repositoryNameToBackup, workspaceNameToRestore).getStateRestore() != JobWorkspaceRestore.RESTORE_FAIL) + && backup.getLastRestore(repositoryNameToBackup, workspaceNameToRestore).getStateRestore() != JobWorkspaceRestore.RESTORE_FAIL) { Thread.sleep(50); } if (backup.getLastRestore(repositoryNameToBackup, workspaceNameToRestore).getStateRestore() == JobWorkspaceRestore.RESTORE_FAIL) - throw (Exception) backup.getLastRestore(repositoryNameToBackup, workspaceNameToRestore) - .getRestoreException(); + throw (Exception)backup.getLastRestore(repositoryNameToBackup, workspaceNameToRestore) + .getRestoreException(); // check SessionImpl back1 = null; try { - back1 = (SessionImpl) getReposityToBackup().login(credentials, workspaceNameToRestore); + back1 = (SessionImpl)getReposityToBackup().login(credentials, workspaceNameToRestore); Node ws1backTestRoot = back1.getRootNode().getNode("backupTest"); - assertEquals("Restored content should be same", "Restored content should be same", ws1backTestRoot.getNode( - "node_5") - .getProperty("exo:data").getString()); + assertEquals("Restored content should be same", "Restored content should be same", + ws1backTestRoot.getNode("node_5").getProperty("exo:data").getString()); } catch (Exception e) { @@ -444,8 +438,14 @@ BackupChain bch = backup.startBackup(config); - Thread.sleep(11000); + while (!bch.isFinished()) + { + Thread.yield(); + Thread.sleep(50); + } + Thread.sleep(5000); + for (BackupChain chain : backup.getCurrentBackups()) if (bch.getBackupId().equals(chain.getBackupId())) fail("The backup with id '" + chain.getBackupId() + "' should not be active"); @@ -467,7 +467,11 @@ BackupChain bch = backup.startBackup(config); - Thread.sleep(11000); + while (bch.getFullBackupState() != BackupJob.FINISHED) + { + Thread.yield(); + Thread.sleep(50); + } boolean isFail = true; @@ -477,6 +481,8 @@ if (isFail) fail("The backup with id '" + bch.getBackupId() + "' should be active"); + + backup.stopBackup(bch); } public void testAutoStopBackupIncrRepetion() throws Exception @@ -495,9 +501,13 @@ final BackupChain bch = backup.startBackup(config); - Thread.sleep(40000); + while (!bch.isFinished()) + { + Thread.yield(); + Thread.sleep(50); + } - assertTrue(bch.isFinished()); + Thread.sleep(5000); for (BackupChain chain : backup.getCurrentBackups()) if (bch.getBackupId().equals(chain.getBackupId())) @@ -507,10 +517,10 @@ public void testTwoRestores() throws Exception { { - SessionImpl sessionWS1 = (SessionImpl) getReposityToBackup().login(credentials, workspaceNameToBackup); + SessionImpl sessionWS1 = (SessionImpl)getReposityToBackup().login(credentials, workspaceNameToBackup); - sessionWS1.getRootNode().addNode("asdasdasda", "nt:unstructured").setProperty("data", - new FileInputStream(createBLOBTempFile(1024))); + sessionWS1.getRootNode().addNode("asdasdasda", "nt:unstructured") + .setProperty("data", new FileInputStream(createBLOBTempFile(1024))); sessionWS1.save(); // 1-st backup @@ -543,12 +553,12 @@ backup.restore(bchLog, repositoryNameToBackup, ws1_restore_1, false); // check - SessionImpl back1 = (SessionImpl) getReposityToBackup().login(credentials, workspaceNameToRestore); + SessionImpl back1 = (SessionImpl)getReposityToBackup().login(credentials, workspaceNameToRestore); assertNotNull(back1.getRootNode().getNode("asdasdasda").getProperty("data")); // add date to restored workspace - back1.getRootNode().addNode("gdfgrghfhf", "nt:unstructured").setProperty("data", - new FileInputStream(createBLOBTempFile(1024))); + back1.getRootNode().addNode("gdfgrghfhf", "nt:unstructured") + .setProperty("data", new FileInputStream(createBLOBTempFile(1024))); back1.save(); } else @@ -588,7 +598,7 @@ backup.restore(bchLog, repositoryNameToBackup, ws1_restore_2, false); // check - SessionImpl back2 = (SessionImpl) getReposityToBackup().login(credentials, workspaceNameToRestore); + SessionImpl back2 = (SessionImpl)getReposityToBackup().login(credentials, workspaceNameToRestore); assertNotNull(back2.getRootNode().getNode("gdfgrghfhf").getProperty("data")); } else @@ -703,8 +713,7 @@ fail("Can't get fullBackup chain"); // restore - RepositoryEntry re = - (RepositoryEntry) ws1Session.getContainer().getComponentInstanceOfType(RepositoryEntry.class); + RepositoryEntry re = (RepositoryEntry)ws1Session.getContainer().getComponentInstanceOfType(RepositoryEntry.class); WorkspaceEntry ws1back = makeWorkspaceEntry(workspaceNameToRestore, dataSourceToWorkspaceRestore + "NOT_EXIST"); File backLog = new File(bch.getLogFilePath()); @@ -730,10 +739,10 @@ SessionImpl back1 = null; try { - back1 = (SessionImpl) getReposityToBackup().login(credentials, workspaceNameToRestore); + back1 = (SessionImpl)getReposityToBackup().login(credentials, workspaceNameToRestore); Node ws1backTestRoot = back1.getRootNode().getNode("backupTest"); assertEquals("Restored content should be same", "property-5", ws1backTestRoot.getNode("node_5") - .getProperty("exo:data").getString()); + .getProperty("exo:data").getString()); } catch (Exception e) { @@ -779,8 +788,8 @@ // restore RepositoryEntry newRepositoryEntry = - makeRepositoryEntry(repositoryNameToRestore, getReposityToBackup().getConfiguration(), - dataSourceToRepositoryRestore, null); + makeRepositoryEntry(repositoryNameToRestore, getReposityToBackup().getConfiguration(), + dataSourceToRepositoryRestore, null); File backLog = new File(bch.getLogFilePath()); if (backLog.exists()) @@ -791,8 +800,8 @@ assertNotNull(bchLog.getFinishedTime()); backup.restore(bchLog, newRepositoryEntry, false); - assertEquals(JobWorkspaceRestore.RESTORE_SUCCESSFUL, backup.getLastRepositoryRestore( - newRepositoryEntry.getName()).getStateRestore()); + assertEquals(JobWorkspaceRestore.RESTORE_SUCCESSFUL, + backup.getLastRepositoryRestore(newRepositoryEntry.getName()).getStateRestore()); // check ManageableRepository restoredRepository = repositoryService.getRepository(repositoryNameToRestore); @@ -802,10 +811,10 @@ SessionImpl back1 = null; try { - back1 = (SessionImpl) restoredRepository.login(credentials, wsName); + back1 = (SessionImpl)restoredRepository.login(credentials, wsName); Node ws1backTestRoot = back1.getRootNode().getNode("backupTest"); assertEquals("Restored content should be same", "property-5", ws1backTestRoot.getNode("node_5") - .getProperty("exo:data").getString()); + .getProperty("exo:data").getString()); } catch (Exception e) { @@ -853,8 +862,8 @@ // restore RepositoryEntry newRepositoryEntry = - makeRepositoryEntry(repositoryNameToRestore, getReposityToBackup().getConfiguration(), - dataSourceToRepositoryRestore, null); + makeRepositoryEntry(repositoryNameToRestore, getReposityToBackup().getConfiguration(), + dataSourceToRepositoryRestore, null); File backLog = new File(bch.getLogFilePath()); if (backLog.exists()) @@ -874,10 +883,10 @@ SessionImpl back1 = null; try { - back1 = (SessionImpl) restoredRepository.login(credentials, wsName); + back1 = (SessionImpl)restoredRepository.login(credentials, wsName); Node ws1backTestRoot = back1.getRootNode().getNode("backupTest"); assertEquals("Restored content should be same", "property-5", ws1backTestRoot.getNode("node_5") - .getProperty("exo:data").getString()); + .getProperty("exo:data").getString()); } catch (Exception e) { @@ -924,8 +933,8 @@ // restore RepositoryEntry newRepositoryEntry = - makeRepositoryEntry(repositoryNameToRestore, getReposityToBackup().getConfiguration(), - dataSourceToRepositoryRestore, null); + makeRepositoryEntry(repositoryNameToRestore, getReposityToBackup().getConfiguration(), + dataSourceToRepositoryRestore, null); File backLog = new File(bch.getLogFilePath()); if (backLog.exists()) @@ -940,7 +949,7 @@ JobRepositoryRestore job = backup.getLastRepositoryRestore(repositoryNameToRestore); while (job.getStateRestore() != JobRepositoryRestore.REPOSITORY_RESTORE_SUCCESSFUL - || job.getStateRestore() == JobRepositoryRestore.REPOSITORY_RESTORE_FAIL) + || job.getStateRestore() == JobRepositoryRestore.REPOSITORY_RESTORE_FAIL) { Thread.yield(); Thread.sleep(50); @@ -954,10 +963,10 @@ SessionImpl back1 = null; try { - back1 = (SessionImpl) restoredRepository.login(credentials, wsName); + back1 = (SessionImpl)restoredRepository.login(credentials, wsName); Node ws1backTestRoot = back1.getRootNode().getNode("backupTest"); assertEquals("Restored content should be same", "property-5", ws1backTestRoot.getNode("node_5") - .getProperty("exo:data").getString()); + .getProperty("exo:data").getString()); } catch (Exception e) { @@ -1004,8 +1013,8 @@ // restore RepositoryEntry newRepositoryEntry = - makeRepositoryEntry(repositoryNameToRestore, getReposityToBackup().getConfiguration(), - dataSourceToRepositoryRestore, null); + makeRepositoryEntry(repositoryNameToRestore, getReposityToBackup().getConfiguration(), + dataSourceToRepositoryRestore, null); // create workspace mappingS Map<String, String> workspaceMapping = new HashedMap(); @@ -1040,7 +1049,7 @@ JobRepositoryRestore job = backup.getLastRepositoryRestore(repositoryNameToRestore); while (job.getStateRestore() != JobRepositoryRestore.REPOSITORY_RESTORE_SUCCESSFUL - || job.getStateRestore() == JobRepositoryRestore.REPOSITORY_RESTORE_FAIL) + || job.getStateRestore() == JobRepositoryRestore.REPOSITORY_RESTORE_FAIL) { Thread.yield(); Thread.sleep(50); @@ -1054,10 +1063,10 @@ SessionImpl back1 = null; try { - back1 = (SessionImpl) restoredRepository.login(credentials, workspaceMapping.get(wsName)); + back1 = (SessionImpl)restoredRepository.login(credentials, workspaceMapping.get(wsName)); Node ws1backTestRoot = back1.getRootNode().getNode("backupTest"); assertEquals("Restored content should be same", "property-5", ws1backTestRoot.getNode("node_5") - .getProperty("exo:data").getString()); + .getProperty("exo:data").getString()); } catch (Exception e) { @@ -1090,9 +1099,13 @@ final RepositoryBackupChain bch = backup.startBackup(config); - Thread.sleep(40000); + while (!bch.isFinished()) + { + Thread.yield(); + Thread.sleep(50); + } - assertTrue(bch.isFinished()); + Thread.sleep(5000); for (RepositoryBackupChain chain : backup.getCurrentRepositoryBackups()) if (bch.getBackupId().equals(chain.getBackupId())) @@ -1101,10 +1114,38 @@ public void testRepositoryRestoreFail() throws Exception { + // backup + File backDir = new File("target/backup/" + getUUIndex()); + backDir.mkdirs(); + + RepositoryBackupConfig config = new RepositoryBackupConfig(); + config.setRepository(repositoryNameToBackup); + config.setBackupType(BackupManager.FULL_BACKUP_ONLY); + + config.setBackupDir(backDir); + + backup.startBackup(config); + + RepositoryBackupChain bch = backup.findRepositoryBackup(repositoryNameToBackup); + + // wait till full backup will be stopped + while (bch.getState() != RepositoryBackupChain.FINISHED) + { + Thread.yield(); + Thread.sleep(50); + } + + // stop fullBackup + backup.stopBackup(bch); + + Thread.sleep(5000); + + String repoName = repositoryNameToRestore + System.currentTimeMillis(); + // restore RepositoryEntry newRepositoryEntry = - makeRepositoryEntry(repositoryNameToRestore, getReposityToBackup().getConfiguration(), - dataSourceToRepositoryRestore, null); + makeRepositoryEntry(repoName, getReposityToBackup().getConfiguration(), + dataSourceToRepositoryRestore, null); //create broken system workspaceEntry newRepositoryEntry.getWorkspaceEntries().get(0).getQueryHandler().setType("gg"); @@ -1124,10 +1165,9 @@ } // check - try { - ManageableRepository restoredRepository = repositoryService.getRepository(repositoryNameToRestore); + ManageableRepository restoredRepository = repositoryService.getRepository(repoName); fail("The repository " + repositoryNameToRestore + "shoulde not exists."); } catch (RepositoryException e) @@ -1198,7 +1238,7 @@ SessionImpl back1 = null; try { - back1 = (SessionImpl) getReposityToBackup().login(credentials, workspaceNameToRestore); + back1 = (SessionImpl)getReposityToBackup().login(credentials, workspaceNameToRestore); Node node_101 = back1.getRootNode().getNode("node_101"); assertNotNull(node_101); @@ -1258,8 +1298,7 @@ fail("Can't get fullBackup chain"); // restore - RepositoryEntry re = - (RepositoryEntry) ws1Session.getContainer().getComponentInstanceOfType(RepositoryEntry.class); + RepositoryEntry re = (RepositoryEntry)ws1Session.getContainer().getComponentInstanceOfType(RepositoryEntry.class); WorkspaceEntry ws1 = null; for (WorkspaceEntry we : re.getWorkspaceEntries()) { @@ -1284,10 +1323,10 @@ SessionImpl back1 = null; try { - back1 = (SessionImpl) getReposityToBackup().login(credentials, "ws1"); + back1 = (SessionImpl)getReposityToBackup().login(credentials, "ws1"); Node ws1backTestRoot = back1.getRootNode().getNode("backupTest"); assertEquals("Restored content should be same", "property-5", ws1backTestRoot.getNode("node_5") - .getProperty("exo:data").getString()); + .getProperty("exo:data").getString()); } catch (Exception e) { @@ -1336,8 +1375,7 @@ fail("Can't get fullBackup chain"); // restore - RepositoryEntry re = - (RepositoryEntry) ws1Session.getContainer().getComponentInstanceOfType(RepositoryEntry.class); + RepositoryEntry re = (RepositoryEntry)ws1Session.getContainer().getComponentInstanceOfType(RepositoryEntry.class); WorkspaceEntry ws1 = null; for (WorkspaceEntry we : re.getWorkspaceEntries()) { @@ -1359,7 +1397,7 @@ backup.restoreExistingWorkspace(bchLog, repositoryNameToBackup, ws1, true); while (backup.getLastRestore(repositoryNameToBackup, ws1.getName()).getStateRestore() != JobWorkspaceRestore.RESTORE_SUCCESSFUL - && backup.getLastRestore(repositoryNameToBackup, ws1.getName()).getStateRestore() != JobWorkspaceRestore.RESTORE_FAIL) + && backup.getLastRestore(repositoryNameToBackup, ws1.getName()).getStateRestore() != JobWorkspaceRestore.RESTORE_FAIL) { Thread.sleep(50); } @@ -1368,10 +1406,10 @@ SessionImpl back1 = null; try { - back1 = (SessionImpl) getReposityToBackup().login(credentials, workspaceNameToBackup); + back1 = (SessionImpl)getReposityToBackup().login(credentials, workspaceNameToBackup); Node ws1backTestRoot = back1.getRootNode().getNode("backupTest"); assertEquals("Restored content should be same", "property-5", ws1backTestRoot.getNode("node_5") - .getProperty("exo:data").getString()); + .getProperty("exo:data").getString()); } catch (Exception e) { @@ -1420,8 +1458,7 @@ fail("Can't get fullBackup chain"); // restore - RepositoryEntry re = - (RepositoryEntry) ws1Session.getContainer().getComponentInstanceOfType(RepositoryEntry.class); + RepositoryEntry re = (RepositoryEntry)ws1Session.getContainer().getComponentInstanceOfType(RepositoryEntry.class); WorkspaceEntry ws1 = null; for (WorkspaceEntry we : re.getWorkspaceEntries()) { @@ -1443,7 +1480,7 @@ backup.restoreExistingWorkspace(bchLog.getBackupId(), repositoryNameToBackup, ws1, true); while (backup.getLastRestore(repositoryNameToBackup, ws1.getName()).getStateRestore() != JobWorkspaceRestore.RESTORE_SUCCESSFUL - && backup.getLastRestore(repositoryNameToBackup, ws1.getName()).getStateRestore() != JobWorkspaceRestore.RESTORE_FAIL) + && backup.getLastRestore(repositoryNameToBackup, ws1.getName()).getStateRestore() != JobWorkspaceRestore.RESTORE_FAIL) { Thread.sleep(50); } @@ -1452,10 +1489,10 @@ SessionImpl back1 = null; try { - back1 = (SessionImpl) getReposityToBackup().login(credentials, workspaceNameToBackup); + back1 = (SessionImpl)getReposityToBackup().login(credentials, workspaceNameToBackup); Node ws1backTestRoot = back1.getRootNode().getNode("backupTest"); assertEquals("Restored content should be same", "property-5", ws1backTestRoot.getNode("node_5") - .getProperty("exo:data").getString()); + .getProperty("exo:data").getString()); } catch (Exception e) { @@ -1501,7 +1538,7 @@ // restore RepositoryEntry re = - makeRepositoryEntry(repositoryNameToBackup, getReposityToBackup().getConfiguration(), null, null); + makeRepositoryEntry(repositoryNameToBackup, getReposityToBackup().getConfiguration(), null, null); File backLog = new File(bch.getLogFilePath()); if (backLog.exists()) @@ -1514,7 +1551,7 @@ backup.restoreExistingRepository(bchLog, re, false); assertEquals(JobWorkspaceRestore.RESTORE_SUCCESSFUL, backup.getLastRepositoryRestore(repositoryNameToBackup) - .getStateRestore()); + .getStateRestore()); // check ManageableRepository restoredRepository = repositoryService.getRepository(repositoryNameToBackup); @@ -1524,10 +1561,10 @@ SessionImpl back1 = null; try { - back1 = (SessionImpl) restoredRepository.login(credentials, wsName); + back1 = (SessionImpl)restoredRepository.login(credentials, wsName); Node ws1backTestRoot = back1.getRootNode().getNode("backupTest"); assertEquals("Restored content should be same", "property-5", ws1backTestRoot.getNode("node_5") - .getProperty("exo:data").getString()); + .getProperty("exo:data").getString()); } catch (Exception e) { @@ -1547,8 +1584,8 @@ public void testExistedRepositoryRestoreSingelDB() throws Exception { - RepositoryImpl repositoryDB7 = (RepositoryImpl) repositoryService.getRepository(repositoryNameToBackupSingleDB); - SessionImpl sessionWS = (SessionImpl) repositoryDB7.login(credentials, workspaceNameToBackup); + RepositoryImpl repositoryDB7 = (RepositoryImpl)repositoryService.getRepository(repositoryNameToBackupSingleDB); + SessionImpl sessionWS = (SessionImpl)repositoryDB7.login(credentials, workspaceNameToBackup); // backup File backDir = new File("target/backup/" + getUUIndex()); @@ -1577,7 +1614,7 @@ // restore RepositoryEntry baseRE = - (RepositoryEntry) sessionWS.getContainer().getComponentInstanceOfType(RepositoryEntry.class); + (RepositoryEntry)sessionWS.getContainer().getComponentInstanceOfType(RepositoryEntry.class); RepositoryEntry re = makeRepositoryEntry(baseRE.getName(), baseRE, null, null); File backLog = new File(bch.getLogFilePath()); @@ -1591,7 +1628,7 @@ backup.restoreExistingRepository(bchLog, re, false); assertEquals(JobWorkspaceRestore.RESTORE_SUCCESSFUL, backup.getLastRepositoryRestore(re.getName()) - .getStateRestore()); + .getStateRestore()); // check ManageableRepository restoredRepository = repositoryService.getRepository(repositoryNameToBackupSingleDB); @@ -1601,10 +1638,10 @@ SessionImpl back1 = null; try { - back1 = (SessionImpl) restoredRepository.login(credentials, wsName); + back1 = (SessionImpl)restoredRepository.login(credentials, wsName); Node ws1backTestRoot = back1.getRootNode().getNode("backupTest"); assertEquals("Restored content should be same", "property-5", ws1backTestRoot.getNode("node_5") - .getProperty("exo:data").getString()); + .getProperty("exo:data").getString()); } catch (Exception e) { @@ -1651,7 +1688,7 @@ // restore RepositoryEntry re = - makeRepositoryEntry(repositoryNameToBackup, getReposityToBackup().getConfiguration(), null, null); + makeRepositoryEntry(repositoryNameToBackup, getReposityToBackup().getConfiguration(), null, null); File backLog = new File(bch.getLogFilePath()); if (backLog.exists()) @@ -1666,14 +1703,13 @@ JobRepositoryRestore job = backup.getLastRepositoryRestore(repositoryNameToBackup); while (job.getStateRestore() != JobRepositoryRestore.REPOSITORY_RESTORE_SUCCESSFUL - && job.getStateRestore() != JobRepositoryRestore.REPOSITORY_RESTORE_FAIL) + && job.getStateRestore() != JobRepositoryRestore.REPOSITORY_RESTORE_FAIL) { Thread.sleep(50); } - assertEquals(JobRepositoryRestore.REPOSITORY_RESTORE_SUCCESSFUL, backup.getLastRepositoryRestore( - repositoryNameToBackup) - .getStateRestore()); + assertEquals(JobRepositoryRestore.REPOSITORY_RESTORE_SUCCESSFUL, + backup.getLastRepositoryRestore(repositoryNameToBackup).getStateRestore()); // check ManageableRepository restoredRepository = repositoryService.getRepository(repositoryNameToBackup); @@ -1683,10 +1719,10 @@ SessionImpl back1 = null; try { - back1 = (SessionImpl) restoredRepository.login(credentials, wsName); + back1 = (SessionImpl)restoredRepository.login(credentials, wsName); Node ws1backTestRoot = back1.getRootNode().getNode("backupTest"); assertEquals("Restored content should be same", "property-5", ws1backTestRoot.getNode("node_5") - .getProperty("exo:data").getString()); + .getProperty("exo:data").getString()); } catch (Exception e) { @@ -1733,7 +1769,7 @@ // restore RepositoryEntry re = - makeRepositoryEntry(repositoryNameToBackup, getReposityToBackup().getConfiguration(), null, null); + makeRepositoryEntry(repositoryNameToBackup, getReposityToBackup().getConfiguration(), null, null); File backLog = new File(bch.getLogFilePath()); if (backLog.exists()) @@ -1748,13 +1784,13 @@ JobRepositoryRestore job = backup.getLastRepositoryRestore(repositoryNameToBackup); while (job.getStateRestore() != JobRepositoryRestore.REPOSITORY_RESTORE_SUCCESSFUL - && job.getStateRestore() != JobRepositoryRestore.REPOSITORY_RESTORE_FAIL) + && job.getStateRestore() != JobRepositoryRestore.REPOSITORY_RESTORE_FAIL) { Thread.sleep(50); } assertEquals(JobWorkspaceRestore.RESTORE_SUCCESSFUL, backup.getLastRepositoryRestore(repositoryNameToBackup) - .getStateRestore()); + .getStateRestore()); // check ManageableRepository restoredRepository = repositoryService.getRepository(repositoryNameToBackup); @@ -1764,10 +1800,10 @@ SessionImpl back1 = null; try { - back1 = (SessionImpl) restoredRepository.login(credentials, wsName); + back1 = (SessionImpl)restoredRepository.login(credentials, wsName); Node ws1backTestRoot = back1.getRootNode().getNode("backupTest"); assertEquals("Restored content should be same", "property-5", ws1backTestRoot.getNode("node_5") - .getProperty("exo:data").getString()); + .getProperty("exo:data").getString()); } catch (Exception e) { @@ -1787,8 +1823,8 @@ public void testExistedWorkspaceRestoreSingelDB() throws Exception { - RepositoryImpl repositoryDB7 = (RepositoryImpl) repositoryService.getRepository(repositoryNameToBackupSingleDB); - SessionImpl sessionWS = (SessionImpl) repositoryDB7.login(credentials, workspaceNameToBackup); + RepositoryImpl repositoryDB7 = (RepositoryImpl)repositoryService.getRepository(repositoryNameToBackupSingleDB); + SessionImpl sessionWS = (SessionImpl)repositoryDB7.login(credentials, workspaceNameToBackup); // backup File backDir = new File("target/backup/" + getUUIndex()); @@ -1820,7 +1856,7 @@ fail("Can't get fullBackup chain"); // restore - RepositoryEntry re = (RepositoryEntry) sessionWS.getContainer().getComponentInstanceOfType(RepositoryEntry.class); + RepositoryEntry re = (RepositoryEntry)sessionWS.getContainer().getComponentInstanceOfType(RepositoryEntry.class); WorkspaceEntry ws1 = null; for (WorkspaceEntry we : re.getWorkspaceEntries()) { @@ -1845,11 +1881,11 @@ SessionImpl back1 = null; try { - repositoryDB7 = (RepositoryImpl) repositoryService.getRepository(repositoryNameToBackupSingleDB); - back1 = (SessionImpl) repositoryDB7.login(credentials, workspaceNameToBackup); + repositoryDB7 = (RepositoryImpl)repositoryService.getRepository(repositoryNameToBackupSingleDB); + back1 = (SessionImpl)repositoryDB7.login(credentials, workspaceNameToBackup); Node ws1backTestRoot = back1.getRootNode().getNode("backupTest"); assertEquals("Restored content should be same", "property-5", ws1backTestRoot.getNode("node_5") - .getProperty("exo:data").getString()); + .getProperty("exo:data").getString()); } catch (Exception e) { @@ -1912,10 +1948,10 @@ SessionImpl back1 = null; try { - back1 = (SessionImpl) getReposityToBackup().login(credentials, workspaceNameToBackup); + back1 = (SessionImpl)getReposityToBackup().login(credentials, workspaceNameToBackup); Node ws1backTestRoot = back1.getRootNode().getNode("backupTest"); assertEquals("Restored content should be same", "property-5", ws1backTestRoot.getNode("node_5") - .getProperty("exo:data").getString()); + .getProperty("exo:data").getString()); } catch (Exception e) { @@ -1973,7 +2009,7 @@ backup.restoreExistingRepository(bchLog.getBackupId(), false); assertEquals(JobWorkspaceRestore.RESTORE_SUCCESSFUL, backup.getLastRepositoryRestore(repositoryNameToBackup) - .getStateRestore()); + .getStateRestore()); // check ManageableRepository restoredRepository = repositoryService.getRepository(repositoryNameToBackup); @@ -1983,10 +2019,10 @@ SessionImpl back1 = null; try { - back1 = (SessionImpl) restoredRepository.login(credentials, wsName); + back1 = (SessionImpl)restoredRepository.login(credentials, wsName); Node ws1backTestRoot = back1.getRootNode().getNode("backupTest"); assertEquals("Restored content should be same", "property-5", ws1backTestRoot.getNode("node_5") - .getProperty("exo:data").getString()); + .getProperty("exo:data").getString()); } catch (Exception e) { @@ -2053,10 +2089,10 @@ SessionImpl back1 = null; try { - back1 = (SessionImpl) getReposityToBackup().login(credentials, "ws1"); + back1 = (SessionImpl)getReposityToBackup().login(credentials, "ws1"); Node ws1backTestRoot = back1.getRootNode().getNode("backupTest"); assertEquals("Restored content should be same", "property-5", ws1backTestRoot.getNode("node_5") - .getProperty("exo:data").getString()); + .getProperty("exo:data").getString()); } catch (Exception e) { @@ -2116,7 +2152,7 @@ backup.restoreRepository(bchLog.getBackupId(), false); assertEquals(JobWorkspaceRestore.RESTORE_SUCCESSFUL, backup.getLastRepositoryRestore(repositoryNameToBackup) - .getStateRestore()); + .getStateRestore()); // check ManageableRepository restoredRepository = repositoryService.getRepository(repositoryNameToBackup); @@ -2126,10 +2162,10 @@ SessionImpl back1 = null; try { - back1 = (SessionImpl) restoredRepository.login(credentials, wsName); + back1 = (SessionImpl)restoredRepository.login(credentials, wsName); Node ws1backTestRoot = back1.getRootNode().getNode("backupTest"); assertEquals("Restored content should be same", "property-5", ws1backTestRoot.getNode("node_5") - .getProperty("exo:data").getString()); + .getProperty("exo:data").getString()); } catch (Exception e) {