gdamour 2005/09/10 10:49:07
Added: modules/openejb-builder/src/java/org/openejb/deployment/ant
DDLExporterTask.java EjbJarLocation.java
OpenejbJarLocation.java
Log:
GERONIMO-710 Generating DDLs for CMP deployment.
o An Ant task to export the DDL associated to the CMP of an ejb-jar module.
o Refactor CMPEntityBuilder: all the logic specific to the creation of the
three TranQL schemata is refactored within SchemataBuilder.
Revision Changes Path
1.1
openejb/modules/openejb-builder/src/java/org/openejb/deployment/ant/DDLExporterTask.java
Index: DDLExporterTask.java
===================================================================
/**
* Redistribution and use of this software and associated documentation
* ("Software"), with or without modification, are permitted provided
* that the following conditions are met:
*
* 1. Redistributions of source code must retain copyright
* statements and notices. Redistributions must also contain a
* copy of this document.
*
* 2. Redistributions in binary form must reproduce the
* above copyright notice, this list of conditions and the
* following disclaimer in the documentation and/or other
* materials provided with the distribution.
*
* 3. The name "OpenEJB" must not be used to endorse or promote
* products derived from this Software without prior written
* permission of The OpenEJB Group. For written permission,
* please contact [EMAIL PROTECTED]
*
* 4. Products derived from this Software may not be called "OpenEJB"
* nor may "OpenEJB" appear in their names without prior written
* permission of The OpenEJB Group. OpenEJB is a registered
* trademark of The OpenEJB Group.
*
* 5. Due credit should be given to the OpenEJB Project
* (http://openejb.org/).
*
* THIS SOFTWARE IS PROVIDED BY THE OPENEJB GROUP AND CONTRIBUTORS
* ``AS IS'' AND ANY EXPRESSED OR IMPLIED WARRANTIES, INCLUDING, BUT
* NOT LIMITED TO, THE IMPLIED WARRANTIES OF MERCHANTABILITY AND
* FITNESS FOR A PARTICULAR PURPOSE ARE DISCLAIMED. IN NO EVENT SHALL
* THE OPENEJB GROUP OR ITS CONTRIBUTORS BE LIABLE FOR ANY DIRECT,
* INDIRECT, INCIDENTAL, SPECIAL, EXEMPLARY, OR CONSEQUENTIAL DAMAGES
* (INCLUDING, BUT NOT LIMITED TO, PROCUREMENT OF SUBSTITUTE GOODS OR
* SERVICES; LOSS OF USE, DATA, OR PROFITS; OR BUSINESS INTERRUPTION)
* HOWEVER CAUSED AND ON ANY THEORY OF LIABILITY, WHETHER IN CONTRACT,
* STRICT LIABILITY, OR TORT (INCLUDING NEGLIGENCE OR OTHERWISE)
* ARISING IN ANY WAY OUT OF THE USE OF THIS SOFTWARE, EVEN IF ADVISED
* OF THE POSSIBILITY OF SUCH DAMAGE.
*
* Copyright 2005 (C) The OpenEJB Group. All Rights Reserved.
*
* $Id: DDLExporterTask.java,v 1.1 2005/09/10 14:49:07 gdamour Exp $
*/
package org.openejb.deployment.ant;
import java.io.BufferedOutputStream;
import java.io.File;
import java.io.FileOutputStream;
import java.io.IOException;
import java.io.InputStream;
import java.io.OutputStream;
import java.io.PrintWriter;
import java.lang.reflect.Constructor;
import javax.sql.DataSource;
import org.apache.geronimo.common.DeploymentException;
import org.apache.geronimo.schema.SchemaConversionUtils;
import org.apache.geronimo.xbeans.j2ee.EjbJarType;
import org.apache.geronimo.xbeans.j2ee.EntityBeanType;
import org.apache.tools.ant.AntClassLoader;
import org.apache.tools.ant.BuildException;
import org.apache.tools.ant.Task;
import org.apache.tools.ant.types.Path;
import org.apache.xmlbeans.XmlObject;
import org.openejb.deployment.Schemata;
import org.openejb.deployment.SchemataBuilder;
import org.openejb.xbeans.ejbjar.OpenejbOpenejbJarType;
import org.openejb.xbeans.pkgen.EjbKeyGeneratorType;
import org.tranql.ddl.DDLCommandBuilder;
import org.tranql.ddl.DDLGenerator;
import org.tranql.ddl.DDLGenerator.ExecutionStrategy;
import org.tranql.ddl.DDLGenerator.GenerationStrategy;
import org.tranql.ejb.EJBProxyFactory;
import org.tranql.pkgenerator.PrimaryKeyGenerator;
import org.tranql.ql.QueryException;
/**
*
* @version $Revision: 1.1 $ $Date: 2005/09/10 14:49:07 $
*/
public class DDLExporterTask extends Task {
private static String SCHEMA_NAME = "UNDEFINED";
private Path classpath;
private EjbJarLocation ejbJarLocation;
private OpenejbJarLocation openejbJarLocation;
private File output;
private String ddlCommandBuilder;
private String type;
public void setClasspath(Path classpath) {
this.classpath = classpath;
}
public Path createClasspath() {
if (null == classpath) {
classpath = new Path(getProject());
}
return classpath.createPath();
}
public void setEjbJar(EjbJarLocation ejbJarLocation) {
this.ejbJarLocation = ejbJarLocation;
}
public void setOpenejbJar(OpenejbJarLocation openejbJarLocation) {
this.openejbJarLocation = openejbJarLocation;
}
public File getOutput() {
return output;
}
public void setOutput(File output) {
this.output = output;
}
public String getDdlCommandBuilder() {
return ddlCommandBuilder;
}
public void setDdlCommandBuilder(String ddlCommandBuilder) {
this.ddlCommandBuilder = ddlCommandBuilder;
}
public String getType() {
return type;
}
public void setType(String type) {
this.type = type;
}
public void execute() throws BuildException {
if (null == ejbJarLocation) {
throw new BuildException("ejbJar file is required.");
} else if (null == openejbJarLocation) {
throw new BuildException("openejbJar file is required.");
} else if (null == ddlCommandBuilder) {
throw new BuildException("ddlCommandBuilder is required.");
} else if (null == type) {
throw new BuildException("type is required.");
}
SchemataBuilder schemataBuilder = new SchemataBuilder() {
protected EJBProxyFactory buildEJBProxyFactory(EntityBeanType
entityBean, String remoteInterfaceName, String homeInterfaceName, String
localInterfaceName, String localHomeInterfaceName, ClassLoader cl) throws
DeploymentException {
return null;
}
protected PrimaryKeyGenerator
buildPKGenerator(EjbKeyGeneratorType config, Class pkClass) throws
DeploymentException, QueryException {
return null;
}
};
ClassLoader cl = new AntClassLoader(getClass().getClassLoader(),
getProject(), classpath, true);
Schemata schemata;
try {
InputStream in = ejbJarLocation.getInputStream(project);
XmlObject xmlObject;
try {
xmlObject = SchemaConversionUtils.parse(in);
} finally {
in.close();
}
EjbJarType ejbJarType =
SchemaConversionUtils.convertToEJBSchema(xmlObject).getEjbJar();
in = openejbJarLocation.getInputStream(project);
try {
xmlObject = SchemaConversionUtils.parse(in);
} finally {
in.close();
}
OpenejbOpenejbJarType openejbJarType = (OpenejbOpenejbJarType)
SchemaConversionUtils.getNestedObjectAsType(xmlObject,
"openejb-jar",
OpenejbOpenejbJarType.type);
schemata = schemataBuilder.buildSchemata(SCHEMA_NAME, ejbJarType,
openejbJarType, null, cl);
} catch (Exception e) {
throw new BuildException("Cannot read DD", e);
}
DDLCommandBuilder builder;
try {
Class clazz = cl.loadClass(ddlCommandBuilder);
Constructor ctr = clazz.getConstructor(new Class[]
{DataSource.class});
builder = (DDLCommandBuilder) ctr.newInstance(new Object[]
{null});
} catch (Exception e) {
throw new BuildException("Cannot create ddlCommandBuilder", e);
}
DDLGenerator generator = new DDLGenerator(schemata.getSqlSchema(),
builder);
OutputStream out = null;
try {
out = new BufferedOutputStream(new FileOutputStream(output));
ExecutionStrategy exec = new
DDLGenerator.WriterExecutionStrategy(new PrintWriter(out));
GenerationStrategy gen;
if (type.equals("drop")) {
gen = new DDLGenerator.DropStrategy(exec);
} else if (type.equals("create") ||
type.equals("create-constraint")) {
gen = new DDLGenerator.CreateStrategy(exec);
} else if (type.equals("drop-create") ||
type.equals("drop-create-constraint")) {
GenerationStrategy strategies[] = new GenerationStrategy[] {
new DDLGenerator.DropStrategy(exec),
new DDLGenerator.CreateStrategy(exec)
};
gen = new DDLGenerator.SequenceStrategy(strategies, exec);
} else {
throw new BuildException("type " + type + " is not
supported.");
}
generator.generate(gen);
if (type.equals("create-constraint") ||
type.equals("drop-create-constraint")) {
gen = new DDLGenerator.CreateConstraintStrategy(exec);
generator.generate(gen);
}
out.flush();
} catch (Exception e) {
throw new BuildException(e);
} finally {
try {
out.close();
} catch (IOException e) {
}
}
}
}
1.1
openejb/modules/openejb-builder/src/java/org/openejb/deployment/ant/EjbJarLocation.java
Index: EjbJarLocation.java
===================================================================
/**
* Redistribution and use of this software and associated documentation
* ("Software"), with or without modification, are permitted provided
* that the following conditions are met:
*
* 1. Redistributions of source code must retain copyright
* statements and notices. Redistributions must also contain a
* copy of this document.
*
* 2. Redistributions in binary form must reproduce the
* above copyright notice, this list of conditions and the
* following disclaimer in the documentation and/or other
* materials provided with the distribution.
*
* 3. The name "OpenEJB" must not be used to endorse or promote
* products derived from this Software without prior written
* permission of The OpenEJB Group. For written permission,
* please contact [EMAIL PROTECTED]
*
* 4. Products derived from this Software may not be called "OpenEJB"
* nor may "OpenEJB" appear in their names without prior written
* permission of The OpenEJB Group. OpenEJB is a registered
* trademark of The OpenEJB Group.
*
* 5. Due credit should be given to the OpenEJB Project
* (http://openejb.org/).
*
* THIS SOFTWARE IS PROVIDED BY THE OPENEJB GROUP AND CONTRIBUTORS
* ``AS IS'' AND ANY EXPRESSED OR IMPLIED WARRANTIES, INCLUDING, BUT
* NOT LIMITED TO, THE IMPLIED WARRANTIES OF MERCHANTABILITY AND
* FITNESS FOR A PARTICULAR PURPOSE ARE DISCLAIMED. IN NO EVENT SHALL
* THE OPENEJB GROUP OR ITS CONTRIBUTORS BE LIABLE FOR ANY DIRECT,
* INDIRECT, INCIDENTAL, SPECIAL, EXEMPLARY, OR CONSEQUENTIAL DAMAGES
* (INCLUDING, BUT NOT LIMITED TO, PROCUREMENT OF SUBSTITUTE GOODS OR
* SERVICES; LOSS OF USE, DATA, OR PROFITS; OR BUSINESS INTERRUPTION)
* HOWEVER CAUSED AND ON ANY THEORY OF LIABILITY, WHETHER IN CONTRACT,
* STRICT LIABILITY, OR TORT (INCLUDING NEGLIGENCE OR OTHERWISE)
* ARISING IN ANY WAY OUT OF THE USE OF THIS SOFTWARE, EVEN IF ADVISED
* OF THE POSSIBILITY OF SUCH DAMAGE.
*
* Copyright 2005 (C) The OpenEJB Group. All Rights Reserved.
*
* $Id: EjbJarLocation.java,v 1.1 2005/09/10 14:49:07 gdamour Exp $
*/
package org.openejb.deployment.ant;
import java.io.FileInputStream;
import java.io.IOException;
import java.io.InputStream;
import java.util.jar.JarFile;
import java.util.zip.ZipEntry;
import org.apache.geronimo.deployment.util.NestedJarFile;
import org.apache.tools.ant.BuildException;
import org.apache.tools.ant.Project;
/**
*
* @version $Revision: 1.1 $ $Date: 2005/09/10 14:49:07 $
*/
public class EjbJarLocation {
private static final String EJB_JAR = "META-INF/ejb-jar.xml";
private final String location;
public EjbJarLocation(String location) {
this.location = location;
}
public InputStream getInputStream(Project project) throws BuildException,
IOException {
String newLoc = location;
if (newLoc.startsWith("jar:")) {
JarFile jarFile;
newLoc = newLoc.substring("jar:".length());
if (newLoc.startsWith("jar:")) {
String name = newLoc.substring("jar:".length(),
newLoc.indexOf("!/"));
jarFile = new JarFile(project.resolveFile(name));
name = newLoc.substring(newLoc.indexOf("!/") + 2);
jarFile = new NestedJarFile(jarFile, name);
} else {
jarFile = new JarFile(project.resolveFile(newLoc));
}
ZipEntry entry = jarFile.getEntry(EJB_JAR);
if (null == entry) {
throw new BuildException(EJB_JAR + " not found");
}
return jarFile.getInputStream(entry);
}
return new FileInputStream(project.resolveFile(newLoc));
}
}
1.1
openejb/modules/openejb-builder/src/java/org/openejb/deployment/ant/OpenejbJarLocation.java
Index: OpenejbJarLocation.java
===================================================================
/**
* Redistribution and use of this software and associated documentation
* ("Software"), with or without modification, are permitted provided
* that the following conditions are met:
*
* 1. Redistributions of source code must retain copyright
* statements and notices. Redistributions must also contain a
* copy of this document.
*
* 2. Redistributions in binary form must reproduce the
* above copyright notice, this list of conditions and the
* following disclaimer in the documentation and/or other
* materials provided with the distribution.
*
* 3. The name "OpenEJB" must not be used to endorse or promote
* products derived from this Software without prior written
* permission of The OpenEJB Group. For written permission,
* please contact [EMAIL PROTECTED]
*
* 4. Products derived from this Software may not be called "OpenEJB"
* nor may "OpenEJB" appear in their names without prior written
* permission of The OpenEJB Group. OpenEJB is a registered
* trademark of The OpenEJB Group.
*
* 5. Due credit should be given to the OpenEJB Project
* (http://openejb.org/).
*
* THIS SOFTWARE IS PROVIDED BY THE OPENEJB GROUP AND CONTRIBUTORS
* ``AS IS'' AND ANY EXPRESSED OR IMPLIED WARRANTIES, INCLUDING, BUT
* NOT LIMITED TO, THE IMPLIED WARRANTIES OF MERCHANTABILITY AND
* FITNESS FOR A PARTICULAR PURPOSE ARE DISCLAIMED. IN NO EVENT SHALL
* THE OPENEJB GROUP OR ITS CONTRIBUTORS BE LIABLE FOR ANY DIRECT,
* INDIRECT, INCIDENTAL, SPECIAL, EXEMPLARY, OR CONSEQUENTIAL DAMAGES
* (INCLUDING, BUT NOT LIMITED TO, PROCUREMENT OF SUBSTITUTE GOODS OR
* SERVICES; LOSS OF USE, DATA, OR PROFITS; OR BUSINESS INTERRUPTION)
* HOWEVER CAUSED AND ON ANY THEORY OF LIABILITY, WHETHER IN CONTRACT,
* STRICT LIABILITY, OR TORT (INCLUDING NEGLIGENCE OR OTHERWISE)
* ARISING IN ANY WAY OUT OF THE USE OF THIS SOFTWARE, EVEN IF ADVISED
* OF THE POSSIBILITY OF SUCH DAMAGE.
*
* Copyright 2005 (C) The OpenEJB Group. All Rights Reserved.
*
* $Id: OpenejbJarLocation.java,v 1.1 2005/09/10 14:49:07 gdamour Exp $
*/
package org.openejb.deployment.ant;
import java.io.FileInputStream;
import java.io.IOException;
import java.io.InputStream;
import java.util.jar.JarFile;
import java.util.zip.ZipEntry;
import org.apache.geronimo.deployment.util.NestedJarFile;
import org.apache.geronimo.schema.SchemaConversionUtils;
import org.apache.tools.ant.BuildException;
import org.apache.tools.ant.Project;
import org.apache.xmlbeans.XmlCursor;
import org.apache.xmlbeans.XmlException;
import org.apache.xmlbeans.XmlObject;
/**
*
* @version $Revision: 1.1 $ $Date: 2005/09/10 14:49:07 $
*/
public class OpenejbJarLocation {
private static final String OPENEJB_JAR = "META-INF/openejb-jar.xml";
private static final String GERONIMO_APP =
"META-INF/geronimo-application.xml";
private final String location;
public OpenejbJarLocation(String location) {
this.location = location;
}
public InputStream getInputStream(Project project) throws BuildException,
IOException, XmlException {
String newLoc = location;
if (newLoc.startsWith("jar:")) {
JarFile jarFile;
newLoc = newLoc.substring("jar:".length());
if (newLoc.startsWith("jar:")) {
String name = newLoc.substring("jar:".length(),
newLoc.indexOf("!/"));
jarFile = new JarFile(project.resolveFile(name));
name = newLoc.substring(newLoc.indexOf("!/") + 2);
jarFile = new NestedJarFile(jarFile, name);
} else {
jarFile = new JarFile(project.resolveFile(newLoc));
}
ZipEntry ejbJarEntry = jarFile.getEntry(OPENEJB_JAR);
if (null == ejbJarEntry) {
throw new BuildException(OPENEJB_JAR + " not found");
}
return jarFile.getInputStream(ejbJarEntry);
} else if (newLoc.startsWith("nested:")) {
JarFile jarFile = null;
newLoc = newLoc.substring("nested:".length());
InputStream in = null;
if (newLoc.startsWith("jar:")) {
String name = newLoc.substring("jar:".length(),
newLoc.indexOf("!/"));
jarFile = new JarFile(project.resolveFile(name));
ZipEntry entry = jarFile.getEntry(GERONIMO_APP);
if (null == entry) {
throw new BuildException(GERONIMO_APP + " not found");
}
in = jarFile.getInputStream(entry);
} else {
String name = newLoc.substring(0, newLoc.indexOf("!/"));
in = new FileInputStream(project.resolveFile(name));
}
XmlObject xmlObject = SchemaConversionUtils.parse(in);
int index =
Integer.parseInt(newLoc.substring(newLoc.indexOf("!/") + 2));
int found = 0;
XmlCursor cursor = xmlObject.newCursor();
try {
while (cursor.hasNextToken()) {
if (cursor.isStart()) {
String localName = cursor.getName().getLocalPart();
if (localName.equals("openejb-jar")) {
if (found == index) {
if (false == cursor.toParent()) {
throw new AssertionError("No parent
found.");
}
return cursor.getObject().newInputStream();
}
found++;
}
}
cursor.toNextToken();
}
} finally {
cursor.dispose();
}
throw new BuildException("Only " + found + " openejb-jar DD are
nested.");
}
return new FileInputStream(project.resolveFile(newLoc));
}
}
