From 9a8d97c273430b8eb0ab9afc4209f555321da4e8 Mon Sep 17 00:00:00 2001
From: jarnou <jarnou@localhost>
Date: Mon, 09 Jul 2007 16:13:16 +0000
Subject: [PATCH] Bug: 1428 Synopsis: import-ldif could allow to write skipped entries to a specified file
---
opends/tests/unit-tests-testng/src/server/org/opends/server/backends/jeb/TestImportJob.java | 66 +++++++++++++++++++++++++++++++++
1 files changed, 66 insertions(+), 0 deletions(-)
diff --git a/opends/tests/unit-tests-testng/src/server/org/opends/server/backends/jeb/TestImportJob.java b/opends/tests/unit-tests-testng/src/server/org/opends/server/backends/jeb/TestImportJob.java
index cda9633..ba2e511 100644
--- a/opends/tests/unit-tests-testng/src/server/org/opends/server/backends/jeb/TestImportJob.java
+++ b/opends/tests/unit-tests-testng/src/server/org/opends/server/backends/jeb/TestImportJob.java
@@ -197,6 +197,36 @@
"postalAddress: Annalee Avard$43221 Hill Street$Charleston, CO 60918\n" +
"description: This is the description for Annalee Bogard.\n";
+ private String skippedEntries =
+ "dn: dc=skipped,dc=importtest1,dc=com\n" +
+ "objectclass: top\n" +
+ "objectclass: domain\n" +
+ "dc: skipped\n" +
+ "\n" +
+ "dn: uid=user.446,dc=skipped,dc=importtest1,dc=com\n" +
+ "objectClass: top\n" +
+ "objectClass: person\n" +
+ "objectClass: organizationalPerson\n" +
+ "objectClass: inetOrgPerson\n" +
+ "givenName: Annalee\n" +
+ "sn: Bogard\n" +
+ "cn: Annalee Bogard\n" +
+ "initials: ANG\n" +
+ "employeeNumber: 446\n" +
+ "uid: user.446\n" +
+ "mail: user.446@example.com\n" +
+ "userPassword: password\n" +
+ "telephoneNumber: 875-335-8882\n" +
+ "homePhone: 181-995-6635\n" +
+ "pager: 586-905-4185\n" +
+ "mobile: 826-857-7592\n" +
+ "street: 43221 Hill Street\n" +
+ "l: Charleston\n" +
+ "st: CO\n" +
+ "postalCode: 60918\n" +
+ "postalAddress: Annalee Avard$43221 Hill Street$Charleston, CO 60918\n" +
+ "description: This is the description for Annalee Bogard.\n";
+
@BeforeClass
public void setUp() throws Exception
@@ -231,6 +261,12 @@
writer.close();
ldifFile.close();
+ ldifFile = new FileOutputStream(homeDirName + File.separator + "skipped.ldif");
+ writer = new PrintStream(ldifFile);
+
+ writer.println(skippedEntries);
+ writer.close();
+ ldifFile.close();
baseDNs = new DN[]
{
@@ -255,11 +291,13 @@
fileList.add(homeDirName + File.separator + "entries1.ldif");
ByteArrayOutputStream rejectedEntries = new ByteArrayOutputStream();
+ ByteArrayOutputStream skippedEntries = new ByteArrayOutputStream();
LDIFImportConfig importConfig = new LDIFImportConfig(fileList);
importConfig.setAppendToExistingData(false);
importConfig.setReplaceExistingEntries(false);
importConfig.setValidateSchema(true);
importConfig.writeRejectedEntries(rejectedEntries);
+ importConfig.writeSkippedEntries(skippedEntries);
be=(BackendImpl) DirectoryServer.getBackend(beID);
TaskUtils.disableBackend(beID);
@@ -277,6 +315,7 @@
EntryContainer entryContainer;
assertTrue(rejectedEntries.size() <= 0);
+ assertTrue(skippedEntries.size() <= 0);
for(DN baseDN : baseDNs)
{
entryContainer = rootContainer.getEntryContainer(baseDN);
@@ -495,6 +534,33 @@
assertTrue(rejectedEntries.toString().contains("uid=user.446,dc=importtest1,dc=com"));
}
+ @Test(dependsOnMethods = "testImportAll")
+ public void testImportSkip() throws Exception
+ {
+ ArrayList<DN> excludeBranches = new ArrayList<DN>();
+ excludeBranches.add(DN.decode("dc=skipped,dc=importtest1,dc=com"));
+ ByteArrayOutputStream skippedEntries = new ByteArrayOutputStream();
+ LDIFImportConfig importConfig = new LDIFImportConfig(homeDirName + File.separator + "skipped.ldif");
+ importConfig.setAppendToExistingData(false);
+ importConfig.setReplaceExistingEntries(true);
+ importConfig.setValidateSchema(true);
+ importConfig.setExcludeBranches(excludeBranches);
+ importConfig.writeSkippedEntries(skippedEntries);
+
+ be=(BackendImpl) DirectoryServer.getBackend(beID);
+ TaskUtils.disableBackend(beID);
+ try
+ {
+ be.importLDIF(importConfig);
+ }
+ finally
+ {
+ TaskUtils.enableBackend(beID);
+ }
+ assertTrue(skippedEntries.toString().contains("dc=skipped,dc=importtest1,dc=com"));
+ assertTrue(skippedEntries.toString().contains("uid=user.446,dc=skipped,dc=importtest1,dc=com"));
+ }
+
/**
* Builds an entry suitable for using in the verify job to gather statistics about
* the verify.
--
Gitblit v1.10.0