Return-Path: X-Original-To: apmail-directory-commits-archive@www.apache.org Delivered-To: apmail-directory-commits-archive@www.apache.org Received: from mail.apache.org (hermes.apache.org [140.211.11.3]) by minotaur.apache.org (Postfix) with SMTP id 102E64FDB for ; Wed, 8 Jun 2011 15:12:03 +0000 (UTC) Received: (qmail 23252 invoked by uid 500); 8 Jun 2011 15:12:03 -0000 Delivered-To: apmail-directory-commits-archive@directory.apache.org Received: (qmail 22903 invoked by uid 500); 8 Jun 2011 15:12:02 -0000 Mailing-List: contact commits-help@directory.apache.org; run by ezmlm Precedence: bulk List-Help: List-Unsubscribe: List-Post: List-Id: Reply-To: dev@directory.apache.org Delivered-To: mailing list commits@directory.apache.org Received: (qmail 22017 invoked by uid 99); 8 Jun 2011 15:12:01 -0000 Received: from nike.apache.org (HELO nike.apache.org) (192.87.106.230) by apache.org (qpsmtpd/0.29) with ESMTP; Wed, 08 Jun 2011 15:12:01 +0000 X-ASF-Spam-Status: No, hits=-2000.0 required=5.0 tests=ALL_TRUSTED X-Spam-Check-By: apache.org Received: from [140.211.11.4] (HELO eris.apache.org) (140.211.11.4) by apache.org (qpsmtpd/0.29) with ESMTP; Wed, 08 Jun 2011 15:11:57 +0000 Received: by eris.apache.org (Postfix, from userid 65534) id B44EE238896F; Wed, 8 Jun 2011 15:11:35 +0000 (UTC) Content-Type: text/plain; charset="utf-8" MIME-Version: 1.0 Content-Transfer-Encoding: 7bit Subject: svn commit: r1133419 - in /directory/apacheds/trunk/server-integ/src/test/java/org/apache/directory/server/schema: ./ SchemaIT.java Date: Wed, 08 Jun 2011 15:11:35 -0000 To: commits@directory.apache.org From: elecharny@apache.org X-Mailer: svnmailer-1.0.8 Message-Id: <20110608151135.B44EE238896F@eris.apache.org> X-Virus-Checked: Checked by ClamAV on apache.org Author: elecharny Date: Wed Jun 8 15:11:35 2011 New Revision: 1133419 URL: http://svn.apache.org/viewvc?rev=1133419&view=rev Log: Added a test to check that DIRSERVER-1457 is now fixed : all is fine Added: directory/apacheds/trunk/server-integ/src/test/java/org/apache/directory/server/schema/ directory/apacheds/trunk/server-integ/src/test/java/org/apache/directory/server/schema/SchemaIT.java Added: directory/apacheds/trunk/server-integ/src/test/java/org/apache/directory/server/schema/SchemaIT.java URL: http://svn.apache.org/viewvc/directory/apacheds/trunk/server-integ/src/test/java/org/apache/directory/server/schema/SchemaIT.java?rev=1133419&view=auto ============================================================================== --- directory/apacheds/trunk/server-integ/src/test/java/org/apache/directory/server/schema/SchemaIT.java (added) +++ directory/apacheds/trunk/server-integ/src/test/java/org/apache/directory/server/schema/SchemaIT.java Wed Jun 8 15:11:35 2011 @@ -0,0 +1,343 @@ + /* + * Licensed to the Apache Software Foundation (ASF) under one + * or more contributor license agreements. See the NOTICE file + * distributed with this work for additional information + * regarding copyright ownership. The ASF licenses this file + * to you under the Apache License, Version 2.0 (the + * "License"); you may not use this file except in compliance + * with the License. You may obtain a copy of the License at + * + * http://www.apache.org/licenses/LICENSE-2.0 + * + * Unless required by applicable law or agreed to in writing, + * software distributed under the License is distributed on an + * "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY + * KIND, either express or implied. See the License for the + * specific language governing permissions and limitations + * under the License. + * + */ +package org.apache.directory.server.schema; + +import static org.apache.directory.server.core.integ.IntegrationUtils.getRootContext; +import static org.apache.directory.server.core.integ.IntegrationUtils.getSchemaContext; +import static org.junit.Assert.assertEquals; +import static org.junit.Assert.assertFalse; +import static org.junit.Assert.assertNotNull; +import static org.junit.Assert.assertNull; +import static org.junit.Assert.assertTrue; +import static org.junit.Assert.fail; + +import java.util.ArrayList; +import java.util.Arrays; +import java.util.List; + +import javax.naming.NamingEnumeration; +import javax.naming.NamingException; +import javax.naming.directory.Attribute; +import javax.naming.directory.Attributes; +import javax.naming.directory.BasicAttribute; +import javax.naming.directory.BasicAttributes; +import javax.naming.directory.DirContext; +import javax.naming.directory.SearchControls; +import javax.naming.directory.SearchResult; + +import org.apache.directory.server.core.annotations.CreateDS; +import org.apache.directory.server.core.integ.AbstractLdapTestUnit; +import org.apache.directory.server.core.integ.FrameworkRunner; +import org.apache.directory.shared.ldap.model.name.Dn; +import org.apache.directory.shared.ldap.model.schema.AttributeType; +import org.apache.directory.shared.ldap.model.schema.ObjectClass; +import org.apache.directory.shared.ldap.model.schema.parsers.AttributeTypeDescriptionSchemaParser; +import org.apache.directory.shared.ldap.model.schema.parsers.ObjectClassDescriptionSchemaParser; +import org.apache.directory.shared.ldap.util.JndiUtils; +import org.junit.Test; +import org.junit.runner.RunWith; + +/** + * An integration test class for testing the addition of schema elements + * + * @author Apache Directory Project + */ +@RunWith(FrameworkRunner.class) +@CreateDS( name="SchemaIT-class" ) +public class SchemaIT extends AbstractLdapTestUnit +{ + private static final String SUBSCHEMA_SUBENTRY = "subschemaSubentry"; + private static final AttributeTypeDescriptionSchemaParser ATTRIBUTE_TYPE_DESCRIPTION_SCHEMA_PARSER = new AttributeTypeDescriptionSchemaParser(); + private static final ObjectClassDescriptionSchemaParser OBJECT_CLASS_DESCRIPTION_SCHEMA_PARSER = new ObjectClassDescriptionSchemaParser(); + + + /** + * Tests to see if an attributeType is persisted when added, then server + * is shutdown, then restarted again. + * + * @throws Exception on error + */ + @Test + public void testAddBinaryAttributeType() throws Exception + { + List descriptions = new ArrayList(); + + // ------------------------------------------------------------------- + // test successful add with everything + // ------------------------------------------------------------------- + + descriptions.add( + "( 1.3.6.1.4.1.65536.0.4.3.2.1" + + " NAME 'templateData'" + + " DESC 'template data'" + + " SYNTAX 1.3.6.1.4.1.1466.115.121.1.5" + + " SINGLE-VALUE" + + " X-SCHEMA 'other' )" ); + + modify( DirContext.ADD_ATTRIBUTE, descriptions, "attributeTypes" ); + + descriptions.clear(); + descriptions.add( + "( 1.3.6.1.4.1.65536.0.4.3.2.2 " + + " NAME 'templateObject' " + + " DESC 'test OC' " + + " SUP top " + + " STRUCTURAL " + + " MUST ( templateData $ cn ) " + + " X-SCHEMA 'other' )"); + + modify( DirContext.ADD_ATTRIBUTE, descriptions, "objectClasses" ); + + checkAttributeTypePresent( "1.3.6.1.4.1.65536.0.4.3.2.1", "other", true ); + checkObjectClassPresent( "1.3.6.1.4.1.65536.0.4.3.2.2", "other", true ); + + // sync operation happens anyway on shutdowns but just to make sure we can do it again + getService().sync(); + + getService().shutdown(); + getService().startup(); + + checkAttributeTypePresent( "1.3.6.1.4.1.65536.0.4.3.2.1", "other", true ); + checkObjectClassPresent( "1.3.6.1.4.1.65536.0.4.3.2.2", "other", true ); + + Attributes attrs = new BasicAttributes(); + BasicAttribute ocattr = new BasicAttribute( "objectclass" ); + ocattr.add( "top" ); + ocattr.add( "templateObject" ); + attrs.put( ocattr ); + byte[] templateData = new byte[4096]; + attrs.put( "templateData", templateData ); + attrs.put( "cn", "atemplate" ); + getRootContext( getService() ).bind( "cn=atemplate,ou=system", null, attrs ); + + Attributes data = getRootContext( getService() ).getAttributes( "cn=atemplate,ou=system", new String[]{"templateData", "cn"} ); + + assertTrue( Arrays.equals( templateData, (byte[])data.get( "templateData" ).get() ) ); + } + + + // ----------------------------------------------------------------------- + // Private Utility Methods + // ----------------------------------------------------------------------- + + private void modify( int op, List descriptions, String opAttr ) throws Exception + { + Dn dn = new Dn( getSubschemaSubentryDN() ); + Attribute attr = new BasicAttribute( opAttr ); + + for ( String description : descriptions ) + { + attr.add( description ); + } + + Attributes mods = new BasicAttributes( true ); + mods.put( attr ); + + getRootContext( getService() ).modifyAttributes( JndiUtils.toName( dn ), op, mods ); + } + + + /** + * Get's the subschemaSubentry attribute value from the rootDSE. + * + * @return the subschemaSubentry distinguished name + * @throws NamingException if there are problems accessing the RootDSE + */ + private String getSubschemaSubentryDN() throws Exception + { + SearchControls controls = new SearchControls(); + controls.setSearchScope( SearchControls.OBJECT_SCOPE ); + controls.setReturningAttributes( new String[] + { SUBSCHEMA_SUBENTRY } ); + + NamingEnumeration results = getRootContext( getService() ).search( "", "(objectClass=*)", controls ); + SearchResult result = results.next(); + results.close(); + Attribute subschemaSubentry = result.getAttributes().get( SUBSCHEMA_SUBENTRY ); + return ( String ) subschemaSubentry.get(); + } + + + /** + * Gets the subschemaSubentry attributes for the global schema. + * + * @return all operational attributes of the subschemaSubentry + * @throws NamingException if there are problems accessing this entry + */ + private Attributes getSubschemaSubentryAttributes() throws Exception + { + SearchControls controls = new SearchControls(); + controls.setSearchScope( SearchControls.OBJECT_SCOPE ); + controls.setReturningAttributes( new String[] + { "+", "*" } ); + + NamingEnumeration results = getRootContext( getService() ).search( getSubschemaSubentryDN(), + "(objectClass=*)", controls ); + SearchResult result = results.next(); + results.close(); + return result.getAttributes(); + } + + + private void checkAttributeTypePresent( String oid, String schemaName, boolean isPresent ) throws Exception + { + // ------------------------------------------------------------------- + // check first to see if it is present in the subschemaSubentry + // ------------------------------------------------------------------- + + Attributes attrs = getSubschemaSubentryAttributes(); + Attribute attrTypes = attrs.get( "attributeTypes" ); + AttributeType attributeType = null; + + for ( int i = 0; i < attrTypes.size(); i++ ) + { + String desc = ( String ) attrTypes.get( i ); + + if ( desc.indexOf( oid ) != -1 ) + { + attributeType = ATTRIBUTE_TYPE_DESCRIPTION_SCHEMA_PARSER + .parseAttributeTypeDescription( desc ); + break; + } + } + + if ( isPresent ) + { + assertNotNull( attributeType ); + assertEquals( oid, attributeType.getOid() ); + } + else + { + assertNull( attributeType ); + } + + // ------------------------------------------------------------------- + // check next to see if it is present in the schema partition + // ------------------------------------------------------------------- + + attrs = null; + + if ( isPresent ) + { + attrs = getSchemaContext( getService() ).getAttributes( "m-oid=" + oid + ",ou=attributeTypes,cn=" + schemaName ); + assertNotNull( attrs ); + } + else + { + //noinspection EmptyCatchBlock + try + { + attrs = getSchemaContext( getService() ).getAttributes( + "m-oid=" + oid + ",ou=attributeTypes,cn=" + schemaName ); + fail( "should never get here" ); + } + catch ( NamingException e ) + { + } + assertNull( attrs ); + } + + // ------------------------------------------------------------------- + // check to see if it is present in the attributeTypeRegistry + // ------------------------------------------------------------------- + + if ( isPresent ) + { + assertTrue( getService().getSchemaManager().getAttributeTypeRegistry().contains( oid ) ); + } + else + { + assertFalse( getService().getSchemaManager().getAttributeTypeRegistry().contains( oid ) ); + } + } + + + private void checkObjectClassPresent( String oid, String schemaName, boolean isPresent ) throws Exception + { + // ------------------------------------------------------------------- + // check first to see if it is present in the subschemaSubentry + // ------------------------------------------------------------------- + + Attributes attrs = getSubschemaSubentryAttributes(); + Attribute attrTypes = attrs.get( "objectClasses" ); + ObjectClass objectClass = null; + + for ( int i = 0; i < attrTypes.size(); i++ ) + { + String desc = ( String ) attrTypes.get( i ); + + if ( desc.indexOf( oid ) != -1 ) + { + objectClass = OBJECT_CLASS_DESCRIPTION_SCHEMA_PARSER + .parseObjectClassDescription( desc ); + break; + } + } + + if ( isPresent ) + { + assertNotNull( objectClass ); + assertEquals( oid, objectClass.getOid() ); + } + else + { + assertNull( objectClass ); + } + + // ------------------------------------------------------------------- + // check next to see if it is present in the schema partition + // ------------------------------------------------------------------- + + attrs = null; + + if ( isPresent ) + { + attrs = getSchemaContext( getService() ).getAttributes( "m-oid=" + oid + ",ou=objectClasses,cn=" + schemaName ); + assertNotNull( attrs ); + } + else + { + //noinspection EmptyCatchBlock + try + { + attrs = getSchemaContext( getService() ).getAttributes( + "m-oid=" + oid + ",ou=objectClasses,cn=" + schemaName ); + fail( "should never get here" ); + } + catch ( NamingException e ) + { + } + assertNull( attrs ); + } + + // ------------------------------------------------------------------- + // check to see if it is present in the objectClassRegistry + // ------------------------------------------------------------------- + + if ( isPresent ) + { + assertTrue( getService().getSchemaManager().getObjectClassRegistry().contains( oid ) ); + } + else + { + assertFalse( getService().getSchemaManager().getObjectClassRegistry().contains( oid ) ); + } + } +}