diff --git a/src/main/java/com/avaje/ebeaninternal/server/core/DefaultServer.java b/src/main/java/com/avaje/ebeaninternal/server/core/DefaultServer.java index 6af9caca0..5894fe077 100644 --- a/src/main/java/com/avaje/ebeaninternal/server/core/DefaultServer.java +++ b/src/main/java/com/avaje/ebeaninternal/server/core/DefaultServer.java @@ -249,7 +249,7 @@ public final class DefaultServer implements SpiEbeanServer { for (SpiEbeanPlugin plugin : ServiceLoader.load(SpiEbeanPlugin.class)) { spiPlugins.add(plugin); - plugin.setup(this, this.getDatabasePlatform(), config); + plugin.setup(this, config); if (plugin instanceof DdlGenerator) { // backwards compatible @@ -261,7 +261,7 @@ public final class DefaultServer implements SpiEbeanServer { // ServiceLoader not finding ddlGenerator (typically OSGi) ddlGenerator = new DdlGenerator(); spiPlugins.add(ddlGenerator); - ddlGenerator.setup(this, this.getDatabasePlatform(), config); + ddlGenerator.setup(this, config); } ebeanPlugins = Collections.unmodifiableList(spiPlugins); diff --git a/src/main/java/com/avaje/ebeaninternal/server/ddl/AbstractBeanVisitor.java b/src/main/java/com/avaje/ebeaninternal/server/ddl/AbstractBeanVisitor.java deleted file mode 100644 index b83d4cd03..000000000 --- a/src/main/java/com/avaje/ebeaninternal/server/ddl/AbstractBeanVisitor.java +++ /dev/null @@ -1,46 +0,0 @@ -package com.avaje.ebeaninternal.server.ddl; - -import com.avaje.ebeaninternal.server.deploy.BeanDescriptor; -import com.avaje.ebeaninternal.server.deploy.BeanProperty; -import com.avaje.ebeaninternal.server.deploy.InheritInfo; -import com.avaje.ebeaninternal.server.deploy.InheritInfoVisitor; - -/** - * Base BeanVisitor that can help visiting inherited properties. - * - * @author rbygrave - */ -public abstract class AbstractBeanVisitor implements BeanVisitor { - - /** - * Visit all the other inheritance properties that are not on the root. - */ - public void visitInheritanceProperties(BeanDescriptor descriptor, PropertyVisitor pv) { - - InheritInfo inheritInfo = descriptor.getInheritInfo(); - if (inheritInfo != null && inheritInfo.isRoot()){ - // add all properties on the children objects - InheritChildVisitor childVisitor = new InheritChildVisitor(pv); - inheritInfo.visitChildren(childVisitor); - } - } - - - /** - * Helper used to visit all the inheritInfo/BeanDescriptor in - * the inheritance hierarchy (to add their 'local' properties). - */ - protected static class InheritChildVisitor implements InheritInfoVisitor { - - final PropertyVisitor pv; - - protected InheritChildVisitor(PropertyVisitor pv) { - this.pv = pv; - } - - public void visit(InheritInfo inheritInfo) { - BeanProperty[] propertiesLocal = inheritInfo.getBeanDescriptor().propertiesLocal(); - VisitorUtil.visit(propertiesLocal, pv); - } - } -} diff --git a/src/main/java/com/avaje/ebeaninternal/server/ddl/AbstractPropertyVisitor.java b/src/main/java/com/avaje/ebeaninternal/server/ddl/AbstractPropertyVisitor.java deleted file mode 100644 index 28c1a0232..000000000 --- a/src/main/java/com/avaje/ebeaninternal/server/ddl/AbstractPropertyVisitor.java +++ /dev/null @@ -1,41 +0,0 @@ -package com.avaje.ebeaninternal.server.ddl; - -import com.avaje.ebeaninternal.server.deploy.BeanProperty; -import com.avaje.ebeaninternal.server.deploy.BeanPropertyAssocMany; -import com.avaje.ebeaninternal.server.deploy.BeanPropertyAssocOne; -import com.avaje.ebeaninternal.server.deploy.BeanPropertyCompound; - -/** - * Has no implementation. Can be used as a base object so that - * selective methods can be implemented. - */ -public abstract class AbstractPropertyVisitor implements PropertyVisitor { - - public void visitEmbedded(BeanPropertyAssocOne p) { - } - - public void visitEmbeddedScalar(BeanProperty p, BeanPropertyAssocOne embedded) { - } - - public void visitMany(BeanPropertyAssocMany p) { - } - - public void visitOneExported(BeanPropertyAssocOne p) { - } - - public void visitOneImported(BeanPropertyAssocOne p) { - } - - public void visitScalar(BeanProperty p) { - } - - public void visitCompound(BeanPropertyCompound p) { - } - - public void visitCompoundScalar(BeanPropertyCompound compound, BeanProperty p) { - } - - - - -} diff --git a/src/main/java/com/avaje/ebeaninternal/server/ddl/AddForeignKeysVisitor.java b/src/main/java/com/avaje/ebeaninternal/server/ddl/AddForeignKeysVisitor.java deleted file mode 100644 index bbb34b40a..000000000 --- a/src/main/java/com/avaje/ebeaninternal/server/ddl/AddForeignKeysVisitor.java +++ /dev/null @@ -1,166 +0,0 @@ -package com.avaje.ebeaninternal.server.ddl; - -import com.avaje.ebean.config.dbplatform.DbDdlSyntax; -import com.avaje.ebeaninternal.server.deploy.BeanDescriptor; -import com.avaje.ebeaninternal.server.deploy.BeanProperty; -import com.avaje.ebeaninternal.server.deploy.BeanPropertyAssocOne; -import com.avaje.ebeaninternal.server.deploy.BeanPropertyCompound; -import com.avaje.ebeaninternal.server.deploy.TableJoin; -import com.avaje.ebeaninternal.server.deploy.TableJoinColumn; - -/** - * Used to generate the foreign key DDL and related indexes. - */ -public class AddForeignKeysVisitor extends AbstractBeanVisitor { - - final DdlGenContext ctx; - - final FkeyPropertyVisitor pv; - - public AddForeignKeysVisitor(boolean addMode, DdlGenContext ctx) { - this.ctx = ctx; - this.pv = new FkeyPropertyVisitor(addMode, this, ctx); - } - - public boolean visitBean(BeanDescriptor descriptor) { - return descriptor.isInheritanceRoot(); - } - - public void visitBeanEnd(BeanDescriptor descriptor) { - - visitInheritanceProperties(descriptor, pv); - } - - public void visitBegin() { - } - - public void visitEnd() { - ctx.addIntersectionFkeys(); - } - - public PropertyVisitor visitProperty(BeanProperty p) { - return pv; - } - - - public static class FkeyPropertyVisitor extends BaseTablePropertyVisitor { - - /** - * Set to false when generating drop foreign key statements. - */ - final boolean addMode; - - final DdlGenContext ctx; - - final AddForeignKeysVisitor parent; - - public FkeyPropertyVisitor(boolean addMode, AddForeignKeysVisitor parent, DdlGenContext ctx) { - this.addMode = addMode; - this.parent = parent; - this.ctx = ctx; - } - - @Override - public void visitEmbeddedScalar(BeanProperty p, BeanPropertyAssocOne embedded) { - // not interested - } - - @Override - public void visitOneImported(BeanPropertyAssocOne p) { - - // alter table {basetable} add foreign key (...) references {} (...) on delete restrict on update restrict; - // Alter table o_address add Foreign Key (country_code) references o_country (code) on delete restrict on update restrict; - - String baseTable = p.getBeanDescriptor().getBaseTable(); - TableJoin tableJoin = p.getTableJoin(); - TableJoinColumn[] columns = tableJoin.columns(); - - String tableName = p.getBeanDescriptor().getBaseTable(); - DbDdlSyntax ddlSyntax = ctx.getDdlSyntax(); - String fkName = ddlSyntax.getForeignKeyName(tableName, p.getName(), ctx.incrementFkCount()); - - if (!addMode) { - // look to generate drop foreign key statement - String dropKeyConstraintPrefix = ddlSyntax.dropKeyConstraintPrefix(tableName, fkName); - if (dropKeyConstraintPrefix != null && !dropKeyConstraintPrefix.isEmpty()) { - ctx.write(dropKeyConstraintPrefix).write(" "); - } - } - - ctx.write("alter table ").write(baseTable).write(addOrDrop()); - if (fkName != null) { - ctx.write("constraint ").write(fkName).write(" "); - } - if (addMode) { - ctx.write("foreign key ("); - for (int i = 0; i < columns.length; i++) { - if (i > 0) { - ctx.write(","); - } - ctx.write(columns[i].getLocalDbColumn()); - } - ctx.write(")"); - - ctx.write(" references "); - ctx.write(tableJoin.getTable()); - ctx.write(" ("); - for (int i = 0; i < columns.length; i++) { - if (i > 0) { - ctx.write(","); - } - ctx.write(columns[i].getForeignDbColumn()); - } - ctx.write(")"); - - String fkeySuffix = ctx.getDdlSyntax().getForeignKeySuffix(); - if (fkeySuffix != null) { - ctx.write(" ").write(fkeySuffix); - } - } - ctx.write(";").writeNewLine(); - - if (addMode && ddlSyntax.isRenderIndexForFkey()){ - - //create index idx_fk_o_address_ctry on o_address(country_code); - ctx.write("create index "); - - String idxName = ddlSyntax.getIndexName(tableName, p.getName(), ctx.incrementIxCount()); - if (idxName != null){ - ctx.write(idxName); - } - - ctx.write(" on ").write(baseTable).write(" ("); - for (int i = 0; i < columns.length; i++) { - if (i > 0){ - ctx.write(","); - } - ctx.write(columns[i].getLocalDbColumn()); - } - ctx.write(");").writeNewLine(); - } - } - - /** - * Return 'add' or 'drop' of foreign key. - */ - protected String addOrDrop() { - return addMode ? " add " : " drop " ; - } - - @Override - public void visitScalar(BeanProperty p) { - // not interested - } - - @Override - public void visitCompound(BeanPropertyCompound p) { - // not interested - } - - @Override - public void visitCompoundScalar(BeanPropertyCompound compound, BeanProperty p) { - // not interested - } - } - -} diff --git a/src/main/java/com/avaje/ebeaninternal/server/ddl/BaseTablePropertyVisitor.java b/src/main/java/com/avaje/ebeaninternal/server/ddl/BaseTablePropertyVisitor.java deleted file mode 100644 index b02109deb..000000000 --- a/src/main/java/com/avaje/ebeaninternal/server/ddl/BaseTablePropertyVisitor.java +++ /dev/null @@ -1,60 +0,0 @@ -package com.avaje.ebeaninternal.server.ddl; - -import com.avaje.ebeaninternal.server.deploy.BeanProperty; -import com.avaje.ebeaninternal.server.deploy.BeanPropertyAssocMany; -import com.avaje.ebeaninternal.server.deploy.BeanPropertyAssocOne; -import com.avaje.ebeaninternal.server.deploy.BeanPropertyCompound; - -/** - * Used to help mark PropertyVisitor methods that need to be implemented - * to visit base table properties. - */ -public abstract class BaseTablePropertyVisitor implements PropertyVisitor { - - /** - * Not required in that you can use the visitEmbeddedScalar. - */ - public void visitEmbedded(BeanPropertyAssocOne p) { - } - - /** - * Override this method. - */ - public abstract void visitEmbeddedScalar(BeanProperty p, BeanPropertyAssocOne embedded); - - /** - * Not part of base table. - */ - public void visitMany(BeanPropertyAssocMany p) { - } - - /** - * Not part of base table. - */ - public void visitOneExported(BeanPropertyAssocOne p) { - } - - /** - * Override this method for the foreign key. - */ - public abstract void visitOneImported(BeanPropertyAssocOne p); - - /** - * Override this method for normal scalar property. - */ - public abstract void visitScalar(BeanProperty p); - - /** - * Not required in that the scalar properties map to the columns. - */ - public void visitCompound(BeanPropertyCompound p){ - } - - /** - * Override this method for scalar property inside a Immutable Compound Value object. - */ - public abstract void visitCompoundScalar(BeanPropertyCompound compound, BeanProperty p); - - - -} diff --git a/src/main/java/com/avaje/ebeaninternal/server/ddl/BeanVisitor.java b/src/main/java/com/avaje/ebeaninternal/server/ddl/BeanVisitor.java deleted file mode 100644 index 50ffa643f..000000000 --- a/src/main/java/com/avaje/ebeaninternal/server/ddl/BeanVisitor.java +++ /dev/null @@ -1,42 +0,0 @@ -package com.avaje.ebeaninternal.server.ddl; - -import com.avaje.ebeaninternal.server.deploy.BeanDescriptor; -import com.avaje.ebeaninternal.server.deploy.BeanProperty; - -/** - * Visitor pattern for visiting a BeanDescriptor and potentially all its bean - * properties. - */ -public interface BeanVisitor { - - /** - * Starting. - */ - void visitBegin(); - - /** - * Visit a BeanDescriptor and return true to continue visiting the bean - * (return false to skip visiting this bean). - */ - boolean visitBean(BeanDescriptor descriptor); - - /** - * Visit a property potentially return a specific PropertyVisitor. - *

- * A PropertyVisitor can be returned to more easily process bean properties - * by their specific type. - *

- */ - PropertyVisitor visitProperty(BeanProperty p); - - /** - * Finished visiting the BeanDescriptor. - */ - void visitBeanEnd(BeanDescriptor descriptor); - - /** - * Finished all visiting. - */ - void visitEnd(); - -} diff --git a/src/main/java/com/avaje/ebeaninternal/server/ddl/CreateIndexVisitor.java b/src/main/java/com/avaje/ebeaninternal/server/ddl/CreateIndexVisitor.java deleted file mode 100644 index 0d11865d8..000000000 --- a/src/main/java/com/avaje/ebeaninternal/server/ddl/CreateIndexVisitor.java +++ /dev/null @@ -1,87 +0,0 @@ -package com.avaje.ebeaninternal.server.ddl; - -import com.avaje.ebeaninternal.server.deploy.BeanDescriptor; -import com.avaje.ebeaninternal.server.deploy.BeanProperty; -import com.avaje.ebeaninternal.server.deploy.BeanPropertyAssocOne; -import com.avaje.ebeaninternal.server.deploy.BeanPropertyCompound; - -/** - * A visitor that creates indexes for columns annotated with ColumnIndex - * - * @author rvbiljouw - * @see com.avaje.ebean.annotation.Index - */ -public class CreateIndexVisitor extends AbstractBeanVisitor { - private final IndexPropertyVisitor iv; - - public CreateIndexVisitor(DdlGenContext ctx) { - this.iv = new IndexPropertyVisitor(ctx); - } - - @Override - public void visitBegin() { - - } - - @Override - public boolean visitBean(BeanDescriptor descriptor) { - return descriptor.isInheritanceRoot(); - } - - @Override - public PropertyVisitor visitProperty(BeanProperty p) { - return iv; - } - - @Override - public void visitBeanEnd(BeanDescriptor descriptor) { - visitInheritanceProperties(descriptor, iv); - } - - @Override - public void visitEnd() { - - } - - private static final class IndexPropertyVisitor extends BaseTablePropertyVisitor { - private final DdlGenContext ctx; - - public IndexPropertyVisitor(DdlGenContext ctx) { - this.ctx = ctx; - } - - @Override - public void visitEmbeddedScalar(BeanProperty p, BeanPropertyAssocOne embedded) { - - } - - @Override - public void visitOneImported(BeanPropertyAssocOne p) { - - } - - @Override - public void visitScalar(BeanProperty p) { - String baseTable = p.getBeanDescriptor().getBaseTable(); - if (p.isIndexed()) { - String indexName = p.getIndexName(); - if (indexName.length() == 0) { - indexName = ctx.getDdlSyntax().getIndexName(baseTable, p.getDbColumn(), ctx.incrementIxCount()); - } - ctx.write("create index ") - .write(indexName) - .write(" on ") - .write(baseTable) - .write("(") - .write(p.getDbColumn()) - .write(");") - .writeNewLine(); - } - } - - @Override - public void visitCompoundScalar(BeanPropertyCompound compound, BeanProperty p) { - - } - } -} diff --git a/src/main/java/com/avaje/ebeaninternal/server/ddl/CreateIntersectionTable.java b/src/main/java/com/avaje/ebeaninternal/server/ddl/CreateIntersectionTable.java deleted file mode 100644 index e7c114fdc..000000000 --- a/src/main/java/com/avaje/ebeaninternal/server/ddl/CreateIntersectionTable.java +++ /dev/null @@ -1,173 +0,0 @@ -package com.avaje.ebeaninternal.server.ddl; - -import com.avaje.ebeaninternal.server.deploy.BeanDescriptor; -import com.avaje.ebeaninternal.server.deploy.BeanProperty; -import com.avaje.ebeaninternal.server.deploy.BeanPropertyAssocMany; -import com.avaje.ebeaninternal.server.deploy.TableJoin; -import com.avaje.ebeaninternal.server.deploy.TableJoinColumn; - - -/** - * Create the sql to create the intersection table and its foreign key - * constraints. - */ -public class CreateIntersectionTable { - - private static final String NEW_LINE = "\n"; - - private final DdlGenContext ctx; - - private final BeanPropertyAssocMany manyProp; - private final TableJoin intersectionTableJoin; - private final TableJoin tableJoin; - - private final StringBuilder sb = new StringBuilder(); - - private final StringBuilder pkeySb = new StringBuilder(); - - private int foreignKeyCount; - - private final int maxFkeyLength; - - public CreateIntersectionTable(DdlGenContext ctx, BeanPropertyAssocMany manyProp) { - this.ctx = ctx; - this.manyProp = manyProp; - this.intersectionTableJoin = manyProp.getIntersectionTableJoin(); - this.tableJoin = manyProp.getTableJoin(); - this.maxFkeyLength = ctx.getDdlSyntax().getMaxConstraintNameLength()-3; - } - - public void build() { - - String createTable = buildCreateTable(); - ctx.addCreateIntersectionTable(createTable); - - foreignKeyCount = 0; - buildFkConstraints(); - } - - private void buildFkConstraints() { - - BeanDescriptor localDesc = manyProp.getBeanDescriptor(); - String fk1 = buildFkConstraints(localDesc, intersectionTableJoin.columns(), true); - ctx.addIntersectionTableFk(fk1); - - BeanDescriptor targetDesc = manyProp.getTargetDescriptor(); - String fk2 = buildFkConstraints(targetDesc, tableJoin.columns(), false); - ctx.addIntersectionTableFk(fk2); - - } - - - - private String getFkNameSuffix() { - - foreignKeyCount++; - - if (foreignKeyCount > 9){ - return "_"+foreignKeyCount; - } else { - return "_0"+foreignKeyCount; - } - } - - private String getFkNameWithSuffix(String fkName) { - if (fkName.length() > maxFkeyLength){ - fkName = fkName.substring(0, maxFkeyLength); - } - return fkName+getFkNameSuffix(); - } - - private String buildFkConstraints(BeanDescriptor desc, TableJoinColumn[] columns, boolean direction) { - - - StringBuilder fkBuf = new StringBuilder(); - - String fkName = "fk_"+intersectionTableJoin.getTable()+"_"+desc.getBaseTable(); - - fkName = getFkNameWithSuffix(fkName); - - fkBuf.append("alter table "); - fkBuf.append(intersectionTableJoin.getTable()); - fkBuf.append(" add constraint ").append(fkName); - - fkBuf.append(" foreign key ("); - - for (int i = 0; i < columns.length; i++) { - if (i > 0) { - fkBuf.append(", "); - } - String col = direction ? columns[i].getForeignDbColumn() : columns[i].getLocalDbColumn(); - fkBuf.append(col); - } - fkBuf.append(") references ").append(desc.getBaseTable()).append(" ("); - - for (int i = 0; i < columns.length; i++) { - if (i > 0) { - fkBuf.append(", "); - } - String col = !direction ? columns[i].getForeignDbColumn() : columns[i].getLocalDbColumn(); - fkBuf.append(col); - } - fkBuf.append(")"); - - String fkeySuffix = ctx.getDdlSyntax().getForeignKeySuffix(); - if (fkeySuffix != null){ - fkBuf.append(" "); - fkBuf.append(fkeySuffix); - } - fkBuf.append(";").append(NEW_LINE); - - return fkBuf.toString(); - } - - private String buildCreateTable() { - - BeanDescriptor localDesc = manyProp.getBeanDescriptor(); - BeanDescriptor targetDesc = manyProp.getTargetDescriptor(); - - sb.append("create table "); - sb.append(intersectionTableJoin.getTable()); - sb.append(" (").append(NEW_LINE); - - TableJoinColumn[] columns = intersectionTableJoin.columns(); - for (int i = 0; i < columns.length; i++) { - - addColumn(localDesc, columns[i].getForeignDbColumn(), columns[i].getLocalDbColumn()); - } - - TableJoinColumn[] otherColumns = tableJoin.columns(); - for (int i = 0; i < otherColumns.length; i++) { - - addColumn(targetDesc, otherColumns[i].getLocalDbColumn(), otherColumns[i].getForeignDbColumn()); - } - - sb.append(" constraint pk_").append(intersectionTableJoin.getTable()); - sb.append(" primary key (").append(pkeySb.toString().substring(2)); - sb.append("))").append(NEW_LINE).append(";").append(NEW_LINE); - - return sb.toString(); - } - - private void addColumn(BeanDescriptor desc, String column, String findPropColumn) { - - pkeySb.append(", "); - pkeySb.append(column); - - writeColumn(column); - - BeanProperty p = desc.getIdBinder().findBeanProperty(findPropColumn); - if (p == null) { - throw new RuntimeException("Could not find id property for " + findPropColumn); - } - - String columnDefn = ctx.getColumnDefn(p); - sb.append(columnDefn); - sb.append(" not null"); - sb.append(",").append(NEW_LINE); - } - - private void writeColumn(String columnName) { - sb.append(" ").append(ctx.pad(columnName, 30)).append(" "); - } -} diff --git a/src/main/java/com/avaje/ebeaninternal/server/ddl/CreateSequenceVisitor.java b/src/main/java/com/avaje/ebeaninternal/server/ddl/CreateSequenceVisitor.java deleted file mode 100644 index eb2690296..000000000 --- a/src/main/java/com/avaje/ebeaninternal/server/ddl/CreateSequenceVisitor.java +++ /dev/null @@ -1,66 +0,0 @@ -package com.avaje.ebeaninternal.server.ddl; - -import com.avaje.ebeaninternal.server.deploy.BeanDescriptor; -import com.avaje.ebeaninternal.server.deploy.BeanProperty; -import org.slf4j.Logger; -import org.slf4j.LoggerFactory; - -/** - * Used to generate the drop table DDL script. - */ -public class CreateSequenceVisitor implements BeanVisitor { - - private static final Logger logger = LoggerFactory.getLogger(CreateSequenceVisitor.class); - - private final DdlGenContext ctx; - - private final boolean supportsSequence; - - public CreateSequenceVisitor(DdlGenContext ctx) { - this.ctx = ctx; - this.supportsSequence = ctx.getDbPlatform().getDbIdentity().isSupportsSequence(); - } - - public boolean visitBean(BeanDescriptor descriptor) { - - if (!descriptor.isInheritanceRoot()){ - return false; - } - if (descriptor.getSequenceName() == null) { - return false; - } - - if (!supportsSequence){ - // Hopefully a generic test case - String msg = "Not creating sequence "+descriptor.getSequenceName()+" on Bean "+descriptor.getName() - +" as DatabasePlatform does not support sequences"; - logger.warn(msg); - return false; - } - - String sequenceName = descriptor.getSequenceName(); - if (sequenceName != null) { - int initialValue = descriptor.getSequenceInitialValue(); - int allocationSize = descriptor.getSequenceAllocationSize(); - String createSeq = ctx.getDbPlatform().ddlCreateSequence(sequenceName, initialValue, allocationSize); - ctx.write(createSeq).writeNewLine().writeNewLine(); - } - return true; - } - - - public void visitBeanEnd(BeanDescriptor descriptor) { - } - - public void visitBegin() { - } - - public void visitEnd() { - } - - public PropertyVisitor visitProperty(BeanProperty p) { - // Return null as we are not interested in properties - return null; - } - -} diff --git a/src/main/java/com/avaje/ebeaninternal/server/ddl/CreateTableColumnVisitor.java b/src/main/java/com/avaje/ebeaninternal/server/ddl/CreateTableColumnVisitor.java deleted file mode 100644 index 03f73e061..000000000 --- a/src/main/java/com/avaje/ebeaninternal/server/ddl/CreateTableColumnVisitor.java +++ /dev/null @@ -1,231 +0,0 @@ -package com.avaje.ebeaninternal.server.ddl; - -import java.sql.Types; - -import org.slf4j.Logger; -import org.slf4j.LoggerFactory; - -import com.avaje.ebean.config.TableName; -import com.avaje.ebean.config.dbplatform.DbDdlSyntax; -import com.avaje.ebean.config.dbplatform.IdType; -import com.avaje.ebeaninternal.server.deploy.BeanProperty; -import com.avaje.ebeaninternal.server.deploy.BeanPropertyAssocMany; -import com.avaje.ebeaninternal.server.deploy.BeanPropertyAssocOne; -import com.avaje.ebeaninternal.server.deploy.BeanPropertyCompound; -import com.avaje.ebeaninternal.server.deploy.TableJoin; -import com.avaje.ebeaninternal.server.deploy.TableJoinColumn; -import com.avaje.ebeaninternal.server.deploy.id.ImportedId; -import com.avaje.ebeaninternal.server.lib.util.StringHelper; - -/** - * Used as part of CreateTableVisitor to generated the create table DDL script. - */ -public class CreateTableColumnVisitor extends BaseTablePropertyVisitor { - - private static final Logger logger = LoggerFactory.getLogger(CreateTableColumnVisitor.class); - - private final DdlGenContext ctx; - - private final DbDdlSyntax ddl; - - private final CreateTableVisitor parent; - - private BeanPropertyAssocOne embedded; - - public CreateTableColumnVisitor(CreateTableVisitor parent, DdlGenContext ctx) { - this.parent = parent; - this.ctx = ctx; - this.ddl = ctx.getDdlSyntax(); - } - - @Override - public void visitMany(BeanPropertyAssocMany p) { - if (p.isManyToMany()) { - //noinspection StatementWithEmptyBody - if (p.getMappedBy() != null) { - // only create on other 'owning' side - - } else { - TableJoin intersectionTableJoin = p.getIntersectionTableJoin(); - - // check if the intersection table has already been created - String intTable = intersectionTableJoin.getTable(); - if (ctx.isProcessIntersectionTable(intTable)) { - // build the create table and fkey constraints - // putting the DDL into ctx for later output as we are - // in the middle of rendering the create table DDL - new CreateIntersectionTable(ctx, p).build(); - } - } - } - } - - public void visitCompoundScalar(BeanPropertyCompound compound, BeanProperty p) { - visitScalar(p); - } - - public void visitCompound(BeanPropertyCompound p) { - // do nothing - } - - @Override - public void visitEmbeddedScalar(BeanProperty p, BeanPropertyAssocOne embedded) { - - this.embedded = embedded; - visitScalar(p); - } - - private StringBuilder createUniqueConstraintBuffer(String table, String column) { - - String uqConstraintName = "uq_"+TableName.parse(table)+"_"+column; - - if (uqConstraintName.length() > ddl.getMaxConstraintNameLength()) { - uqConstraintName = uqConstraintName.substring(0, ddl.getMaxConstraintNameLength()); - } - - uqConstraintName = ctx.removeQuotes(uqConstraintName); - uqConstraintName = StringHelper.replaceString(uqConstraintName, " ", "_"); - - StringBuilder constraintExpr = new StringBuilder(); - constraintExpr.append("constraint ").append(uqConstraintName).append(" unique ("); - - return constraintExpr; - } - - @Override - public void visitOneImported(BeanPropertyAssocOne p) { - - ImportedId importedId = p.getImportedId(); - - TableJoinColumn[] columns = p.getTableJoin().columns(); - if (columns.length == 0) { - String msg = "No join columns for " + p.getFullBeanName(); - throw new RuntimeException(msg); - } - - StringBuilder constraintExpr = createUniqueConstraintBuffer(p.getBeanDescriptor().getBaseTable(), columns[0].getLocalDbColumn()); - - for (int i = 0; i < columns.length; i++) { - - String dbCol = columns[i].getLocalDbColumn(); - - if (i > 0) { - constraintExpr.append(", "); - } - constraintExpr.append(dbCol); - - if (parent.isDbColumnWritten(dbCol)) { - continue; - } - - parent.writeColumnName(dbCol, p); - - BeanProperty importedProperty = importedId.findMatchImport(dbCol); - if (importedProperty != null) { - - String columnDefn = ctx.getColumnDefn(importedProperty); - ctx.write(columnDefn); - - } else { - throw new RuntimeException("Imported BeanProperty not found?"); - } - - if (!p.isNullable()) { - ctx.write(" not null"); - } - ctx.write(",").writeNewLine(); - } - constraintExpr.append(")"); - - if (p.isOneToOne()) { - if (ddl.isAddOneToOneUniqueContraint()) { - parent.addUniqueConstraint(constraintExpr.toString()); - } - } - - } - - @Override - public void visitScalar(BeanProperty p) { - - if (p.isSecondaryTable()) { - return; - } - - if (parent.isDbColumnWritten(p.getDbColumn())) { - return; - } - - parent.writeColumnName(p.getDbColumn(), p); - - String columnDefn = ctx.getColumnDefn(p); - - boolean identity = isIdentity(p); - if (identity) { - ctx.write(ddl.getIdentityColumnDefn(columnDefn)); - } else { - ctx.write(columnDefn); - } - - if (p.isId() && ddl.isInlinePrimaryKeyConstraint()){ - ctx.write(" primary key"); - - } else if (!p.isNullable() || p.isDDLNotNull()) { - ctx.write(" not null"); - } - - if (identity) { - writeIdentitySuffix(); - } - - if (p.isUnique() && !p.isId()) { - parent.addUniqueConstraint(createUniqueConstraint(p)); - } - - parent.addCheckConstraint(p); - ctx.write(",").writeNewLine(); - } - - private String createUniqueConstraint(BeanProperty p) { - - String baseTable = p.getBeanDescriptor().getBaseTable(); - if (baseTable == null) { - // Embedded bean property that has unique constraint on it - baseTable = embedded.getBeanDescriptor().getBaseTable(); - } - StringBuilder expr = createUniqueConstraintBuffer(baseTable, p.getDbColumn()); - - expr.append(p.getDbColumn()).append(")"); - return expr.toString(); - } - - protected void writeIdentitySuffix() { - String identity = ddl.getIdentitySuffix(); - if (identity != null && identity.length() > 0) { - ctx.write(" ").write(identity); - } - } - - protected boolean isIdentity(BeanProperty p) { - - if (p.isId()) { - try { - IdType idType = p.getBeanDescriptor().getIdType(); - - if (idType.equals(IdType.IDENTITY)) { - - int jdbcType = p.getScalarType().getJdbcType(); - if (jdbcType == Types.INTEGER || jdbcType == Types.BIGINT || jdbcType == Types.SMALLINT) { - - return true; - } - } - } catch (Exception e) { - String msg = "Error determining identity on property " + p.getFullBeanName(); - logger.error(msg, e); - } - } - return false; - } - -} \ No newline at end of file diff --git a/src/main/java/com/avaje/ebeaninternal/server/ddl/CreateTableVisitor.java b/src/main/java/com/avaje/ebeaninternal/server/ddl/CreateTableVisitor.java deleted file mode 100644 index 5c11200f4..000000000 --- a/src/main/java/com/avaje/ebeaninternal/server/ddl/CreateTableVisitor.java +++ /dev/null @@ -1,264 +0,0 @@ -package com.avaje.ebeaninternal.server.ddl; - -import java.util.ArrayList; -import java.util.HashSet; -import java.util.Set; - -import org.slf4j.Logger; -import org.slf4j.LoggerFactory; - -import com.avaje.ebean.config.TableName; -import com.avaje.ebean.config.dbplatform.DbDdlSyntax; -import com.avaje.ebean.config.dbplatform.DbType; -import com.avaje.ebeaninternal.server.deploy.BeanDescriptor; -import com.avaje.ebeaninternal.server.deploy.BeanProperty; -import com.avaje.ebeaninternal.server.deploy.BeanPropertyAssocOne; -import com.avaje.ebeaninternal.server.deploy.BeanPropertyCompound; -import com.avaje.ebeaninternal.server.deploy.CompoundUniqueContraint; -import com.avaje.ebeaninternal.server.deploy.InheritInfo; -import com.avaje.ebeaninternal.server.deploy.parse.SqlReservedWords; - -/** - * Used to generated the create table DDL script. - */ -public class CreateTableVisitor extends AbstractBeanVisitor { - - private static final Logger logger = LoggerFactory.getLogger(CreateTableVisitor.class); - - private final DdlGenContext ctx; - - private final PropertyVisitor pv; - - private final DbDdlSyntax ddl; - - private final int columnNameWidth; - - // avoid writing columns twice, e.g. when used in associations with insertable=false and updateable=false - private final Set wroteColumns = new HashSet(); - - private ArrayList checkConstraints = new ArrayList(); - - private ArrayList uniqueConstraints = new ArrayList(); - - private String table; - - public Set getWroteColumns() { - return wroteColumns; - } - - - public CreateTableVisitor(DdlGenContext ctx) { - this.ctx = ctx; - this.ddl = ctx.getDdlSyntax(); - this.columnNameWidth = ddl.getColumnNameWidth(); - this.pv = new CreateTableColumnVisitor(this, ctx); - } - - public boolean isDbColumnWritten(String dbColumn) { - // Columns are not case sensitive - user lower case - // as e.g. @JoinColumn(s) may use a different case - return wroteColumns.contains(dbColumn.toLowerCase()); - } - - public void addDbColumnWritten(String dbColumn) { - // Column names are case insensitive - wroteColumns.add(dbColumn.toLowerCase()); - } - - /** - * Write the table name including a check for SQL reserved words. - */ - protected void writeTableName(BeanDescriptor descriptor) { - - // parse to remove any catalog or schema prefix on the table - table = TableName.parse(descriptor.getBaseTable()); - ctx.write(descriptor.getBaseTable()); - } - - - /** - * Write the column name including a check for the SQL reserved words. - */ - protected void writeColumnName(String columnName, BeanProperty p) { - - addDbColumnWritten(columnName); - - if (SqlReservedWords.isKeyword(columnName)) { - String propName = p == null ? "(Unknown)" : p.getFullBeanName(); - logger.warn("Column name [" + columnName + "] is a suspected SQL reserved word for property " + propName); - } - - ctx.write(" ").write(columnName, columnNameWidth).write(" "); - } - - /** - * Build a check constraint for the property if required. - *

- * Typically check constraint based on Enum mapping values. - *

- */ - protected void addCheckConstraint(BeanProperty p, String prefix, String constraintExpression) { - - if (p != null && constraintExpression != null) { - - // build constraint clause - String s = "constraint " + getConstraintName(prefix, p) + " " + constraintExpression; - - // add to list as we render all check constraints just prior to primary key - checkConstraints.add(s); - } - } - - protected String getConstraintName(String prefix, BeanProperty p) { - return prefix + table + "_" + p.getDbColumn(); - } - - protected void addUniqueConstraint(String constraintExpression) { - uniqueConstraints.add(constraintExpression); - } - - protected void addCheckConstraint(String constraintExpression) { - checkConstraints.add(constraintExpression); - } - - protected void addCheckConstraint(BeanProperty p) { - addCheckConstraint(p, "ck_", p.getDbConstraintExpression()); - } - - public boolean visitBean(BeanDescriptor descriptor) { - - wroteColumns.clear(); - - if (!descriptor.isInheritanceRoot()) { - return false; - } - - ctx.write("create table "); - writeTableName(descriptor); - ctx.write(" (").writeNewLine(); - - InheritInfo inheritInfo = descriptor.getInheritInfo(); - if (inheritInfo != null && inheritInfo.isRoot()) { - String discColumn = inheritInfo.getDiscriminatorColumn(); - int discType = inheritInfo.getDiscriminatorType(); - int discLength = inheritInfo.getDiscriminatorLength(); - DbType dbType = ctx.getDbTypeMap().get(discType); - String discDbType = dbType.renderType(discLength, 0); - - writeColumnName(discColumn, null); - ctx.write(discDbType); - ctx.write(" not null,"); - ctx.writeNewLine(); - } - - return true; - } - - public void visitBeanEnd(BeanDescriptor descriptor) { - - visitInheritanceProperties(descriptor, pv); - - if (checkConstraints.size() > 0) { - for (String checkConstraint : checkConstraints) { - ctx.write(" ").write(checkConstraint).write(",").writeNewLine(); - } - checkConstraints = new ArrayList(); - } - - if (uniqueConstraints.size() > 0) { - for (String constraint : uniqueConstraints) { - ctx.write(" ").write(constraint).write(",").writeNewLine(); - } - uniqueConstraints = new ArrayList(); - } - - CompoundUniqueContraint[] compoundUniqueConstraints = descriptor.getCompoundUniqueConstraints(); - if (compoundUniqueConstraints != null) { - String table = descriptor.getBaseTable(); - for (int i = 0; i < compoundUniqueConstraints.length; i++) { - String constraint = createUniqueConstraint(table, i, compoundUniqueConstraints[i]); - ctx.write(" ").write(constraint).write(",").writeNewLine(); - } - } - - BeanProperty idProp = descriptor.getIdProperty(); - - if (idProp == null) { - // No comma + new line - ctx.removeLast().removeLast(); - } else if (ddl.isInlinePrimaryKeyConstraint()) { - // The Primary Key constraint was inlined with the column - // ... No comma + new line - ctx.removeLast().removeLast(); - - } else { - // Add the primay key constraint - String pkName = ddl.getPrimaryKeyName(table); - ctx.write(" constraint ").write(pkName).write(" primary key ("); - - VisitorUtil.visit(idProp, new AbstractPropertyVisitor() { - - @Override - public void visitEmbeddedScalar(BeanProperty p, BeanPropertyAssocOne embedded) { - ctx.write(p.getDbColumn()).write(", "); - } - - @Override - public void visitScalar(BeanProperty p) { - ctx.write(p.getDbColumn()).write(", "); - } - - @Override - public void visitCompoundScalar(BeanPropertyCompound compound, BeanProperty p) { - ctx.write(p.getDbColumn()).write(", "); - } - - }); - // remove the last comma, end of PK - ctx.removeLast().write(")"); - } - - // end of table - ctx.write(")").writeNewLine(); - ctx.write(";").writeNewLine().writeNewLine(); - ctx.flush(); - } - - private String createUniqueConstraint(String table, int idx, CompoundUniqueContraint uc) { - - StringBuilder sb = new StringBuilder(50); - sb.append("constraint ") - .append("uq_").append(TableName.parse(table)).append("_").append(idx + 1) - .append(" unique ("); - - String[] columns = uc.getColumns(); - - for (int i = 0; i < columns.length; i++) { - if (i > 0) { - sb.append(","); - } - sb.append(columns[i]); - } - sb.append(")"); - - return sb.toString(); - } - - public void visitBeanDescriptorEnd() { - ctx.write(");").writeNewLine().writeNewLine(); - } - - public PropertyVisitor visitProperty(BeanProperty p) { - return pv; - } - - public void visitBegin() { - - } - - public void visitEnd() { - ctx.addIntersectionCreateTables(); - ctx.flush(); - } - -} diff --git a/src/main/java/com/avaje/ebeaninternal/server/ddl/DdlGenContext.java b/src/main/java/com/avaje/ebeaninternal/server/ddl/DdlGenContext.java deleted file mode 100644 index a1e947921..000000000 --- a/src/main/java/com/avaje/ebeaninternal/server/ddl/DdlGenContext.java +++ /dev/null @@ -1,252 +0,0 @@ -package com.avaje.ebeaninternal.server.ddl; - -import java.io.StringWriter; -import java.sql.Types; -import java.util.ArrayList; -import java.util.HashSet; -import java.util.List; -import java.util.Set; - -import com.avaje.ebean.config.NamingConvention; -import com.avaje.ebean.config.dbplatform.DatabasePlatform; -import com.avaje.ebean.config.dbplatform.DbDdlSyntax; -import com.avaje.ebean.config.dbplatform.DbType; -import com.avaje.ebean.config.dbplatform.DbTypeMap; -import com.avaje.ebeaninternal.server.deploy.BeanProperty; -import com.avaje.ebeaninternal.server.lib.util.StringHelper; -import com.avaje.ebeaninternal.server.type.ScalarType; - -/** - * The context used during DDL generation. - */ -public class DdlGenContext { - - private final StringWriter stringWriter = new StringWriter(); - - /** - * Used to map bean types to DB specific types. - */ - private final DbTypeMap dbTypeMap; - - /** - * Handles DB specific DDL syntax. - */ - private final DbDdlSyntax ddlSyntax; - - /** - * The new line character that is used. - */ - private final String newLine; - - /** - * Last content written (used with removeLast()) - */ - private final List contentBuffer = new ArrayList(); - - private final Set intersectionTables = new HashSet(); - - private final List intersectionTablesCreateDdl = new ArrayList(); - private final List intersectionTablesFkDdl = new ArrayList(); - - private final DatabasePlatform dbPlatform; - - /** The Naming convention used to define FK an IX names */ - private final NamingConvention namingConvention; - - /** The global fk count used to keep FK names unique */ - private int fkCount; - - /** The ix count. */ - private int ixCount; - - public DdlGenContext(DatabasePlatform dbPlatform, NamingConvention namingConvention){ - this.dbPlatform = dbPlatform; - this.dbTypeMap = dbPlatform.getDbTypeMap(); - this.ddlSyntax = dbPlatform.getDbDdlSyntax(); - this.newLine = ddlSyntax.getNewLine(); - this.namingConvention = namingConvention; - } - - /** - * Return the dbPlatform. - */ - public DatabasePlatform getDbPlatform() { - return dbPlatform; - } - - public boolean isProcessIntersectionTable(String tableName){ - return intersectionTables.add(tableName); - } - - public void addCreateIntersectionTable(String createTableDdl){ - intersectionTablesCreateDdl.add(createTableDdl); - } - - public void addIntersectionTableFk(String intTableFk){ - intersectionTablesFkDdl.add(intTableFk); - } - - public void addIntersectionCreateTables() { - for (String intTableCreate : intersectionTablesCreateDdl) { - write(newLine); - write(intTableCreate); - } - } - - public void addIntersectionFkeys() { - write(newLine); - write(newLine); - for (String intTableFk : intersectionTablesFkDdl) { - write(newLine); - write(intTableFk); - } - } - - /** - * Return the generated content (DDL script). - */ - public String getContent(){ - return stringWriter.toString(); - } - - /** - * Return the map used to determine the DB specific type - * for a given bean property. - */ - public DbTypeMap getDbTypeMap() { - return dbTypeMap; - } - - /** - * Return object to handle DB specific DDL syntax. - */ - public DbDdlSyntax getDdlSyntax() { - return ddlSyntax; - } - - public String getColumnDefn(BeanProperty p) { - DbType dbType = getDbType(p); - return p.renderDbType(dbType); - } - - private DbType getDbType(BeanProperty p) { - - ScalarType scalarType = p.getScalarType(); - if (scalarType == null) { - throw new RuntimeException("No scalarType for " + p.getFullBeanName()); - } - - if (p.isDbEncrypted()){ - return dbTypeMap.get(p.getDbEncryptedType()); - } - - int jdbcType = scalarType.getJdbcType(); - if (p.isLob() && jdbcType == Types.VARCHAR){ - // workaround for Postgres TEXT type which is - // VARCHAR in jdbc API but TEXT in ddl - jdbcType = Types.CLOB; - } - return dbTypeMap.get(jdbcType); - } - /** - * Write content to the buffer. - */ - public DdlGenContext write(String content, int minWidth){ - - content = pad(content, minWidth); - - contentBuffer.add(content); - - return this; - - } - - /** - * Write content to the buffer. - */ - public DdlGenContext write(String content){ - return write(content, 0); - } - - public DdlGenContext writeNewLine() { - write(newLine); - return this; - } - - /** - * Remove the last content that was written. - */ - public DdlGenContext removeLast() { - if (!contentBuffer.isEmpty()){ - contentBuffer.remove(contentBuffer.size()-1); - } else { - throw new RuntimeException("No lastContent to remove?"); - } - return this; - } - - /** - * Flush the content to the buffer. - */ - public DdlGenContext flush() { - if (!contentBuffer.isEmpty()){ - for (String s:contentBuffer){ - - if (s != null){ - stringWriter.write(s); - } - } - contentBuffer.clear(); - } - return this; - } - - private String padding(int length){ - - StringBuilder sb = new StringBuilder(length); - for (int i = 0; i < length; i++) { - sb.append(" "); - } - return sb.toString(); - } - - public String pad(String content, int minWidth){ - if (minWidth > 0 && content.length() < minWidth){ - int padding = minWidth - content.length(); - return content + padding(padding); - } - return content; - } - - /** - * @return the namingConvention - */ - public NamingConvention getNamingConvention() { - return namingConvention; - } - - /** - * @return the incremented fkCount - */ - public int incrementFkCount() { - return ++fkCount; - } - - /** - * @return the incremented ixCount - */ - public int incrementIxCount() { - return ++ixCount; - } - - /** - * Strips off the Database Platform specific quoted identifier characters. - */ - public String removeQuotes(String dbColumn) { - - dbColumn = StringHelper.replaceString(dbColumn, dbPlatform.getOpenQuote(), ""); - dbColumn = StringHelper.replaceString(dbColumn, dbPlatform.getCloseQuote(), ""); - - return dbColumn; - } -} diff --git a/src/main/java/com/avaje/ebeaninternal/server/ddl/DdlGenerator.java b/src/main/java/com/avaje/ebeaninternal/server/ddl/DdlGenerator.java index 551fb8dde..f6372eb2d 100644 --- a/src/main/java/com/avaje/ebeaninternal/server/ddl/DdlGenerator.java +++ b/src/main/java/com/avaje/ebeaninternal/server/ddl/DdlGenerator.java @@ -1,5 +1,14 @@ package com.avaje.ebeaninternal.server.ddl; +import com.avaje.ebean.Transaction; +import com.avaje.ebean.config.ServerConfig; +import com.avaje.ebean.dbmigration.model.CurrentModel; +import com.avaje.ebeaninternal.api.SpiEbeanPlugin; +import com.avaje.ebeaninternal.api.SpiEbeanServer; +import org.slf4j.Logger; +import org.slf4j.LoggerFactory; + +import javax.persistence.PersistenceException; import java.io.BufferedReader; import java.io.File; import java.io.FileReader; @@ -13,19 +22,6 @@ import java.sql.SQLException; import java.util.ArrayList; import java.util.List; -import javax.persistence.PersistenceException; - -import com.avaje.ebean.dbmigration.model.CurrentModel; -import org.slf4j.Logger; -import org.slf4j.LoggerFactory; - -import com.avaje.ebean.Transaction; -import com.avaje.ebean.config.NamingConvention; -import com.avaje.ebean.config.ServerConfig; -import com.avaje.ebean.config.dbplatform.DatabasePlatform; -import com.avaje.ebeaninternal.api.SpiEbeanPlugin; -import com.avaje.ebeaninternal.api.SpiEbeanServer; - /** * Controls the generation of DDL and potentially runs the resulting scripts. */ @@ -35,8 +31,6 @@ public class DdlGenerator implements SpiEbeanPlugin { private SpiEbeanServer server; - private DatabasePlatform dbPlatform; - private boolean generateDdl; private boolean runDdl; @@ -44,14 +38,10 @@ public class DdlGenerator implements SpiEbeanPlugin { private String dropContent; private String createContent; - private NamingConvention namingConvention; - - public void setup(SpiEbeanServer server, DatabasePlatform dbPlatform, ServerConfig serverConfig) { + public void setup(SpiEbeanServer server, ServerConfig serverConfig) { this.server = server; - this.dbPlatform = dbPlatform; this.generateDdl = serverConfig.isDdlGenerate(); this.runDdl = serverConfig.isDdlRun(); - this.namingConvention = serverConfig.getNamingConvention(); } /** @@ -134,25 +124,8 @@ public class DdlGenerator implements SpiEbeanPlugin { } catch (IOException e) { throw new RuntimeException(e); } -// DdlGenContext ctx = createContext(); -// -// if (ctx.getDdlSyntax().isDropKeyConstraints()) { -// // generate drop foreign key constraint statements (sql server joy) -// AddForeignKeysVisitor fkeys = new AddForeignKeysVisitor(false, ctx); -// VisitorUtil.visit(server, fkeys); -// ctx.writeNewLine(); -// } -// -// DropTableVisitor drop = new DropTableVisitor(ctx); -// VisitorUtil.visit(server, drop); -// -// DropSequenceVisitor dropSequence = new DropSequenceVisitor(ctx); -// VisitorUtil.visit(server, dropSequence); -// -// ctx.flush(); -// dropContent = ctx.getContent(); -// return dropContent; } + public void writeMigration(File file) { currentModel().writeMigration(file); @@ -166,22 +139,6 @@ public class DdlGenerator implements SpiEbeanPlugin { } catch (IOException e) { throw new RuntimeException(e); } -// DdlGenContext ctx = createContext(); -// CreateTableVisitor create = new CreateTableVisitor(ctx); -// VisitorUtil.visit(server, create); -// -// CreateSequenceVisitor createSequence = new CreateSequenceVisitor(ctx); -// VisitorUtil.visit(server, createSequence); -// -// AddForeignKeysVisitor fkeys = new AddForeignKeysVisitor(true, ctx); -// VisitorUtil.visit(server, fkeys); -// -// CreateIndexVisitor indexes = new CreateIndexVisitor(ctx); -// VisitorUtil.visit(server, indexes); -// -// ctx.flush(); -// createContent = ctx.getContent(); -// return createContent; } protected String getDropFileName() { @@ -192,12 +149,6 @@ public class DdlGenerator implements SpiEbeanPlugin { return server.getName() + "-create.sql"; } - protected DdlGenContext createContext() { - return new DdlGenContext(dbPlatform, namingConvention); - } - - - protected CurrentModel currentModel() { if (currentModel == null) { currentModel = new CurrentModel(server); diff --git a/src/main/java/com/avaje/ebeaninternal/server/ddl/DropSequenceVisitor.java b/src/main/java/com/avaje/ebeaninternal/server/ddl/DropSequenceVisitor.java deleted file mode 100644 index 7af634b83..000000000 --- a/src/main/java/com/avaje/ebeaninternal/server/ddl/DropSequenceVisitor.java +++ /dev/null @@ -1,69 +0,0 @@ -package com.avaje.ebeaninternal.server.ddl; - -import com.avaje.ebean.config.dbplatform.DbDdlSyntax; -import com.avaje.ebeaninternal.server.deploy.BeanDescriptor; -import com.avaje.ebeaninternal.server.deploy.BeanProperty; -import org.slf4j.Logger; -import org.slf4j.LoggerFactory; - -/** - * Used to generate the drop table DDL script. - */ -public class DropSequenceVisitor implements BeanVisitor { - - private static final Logger logger = LoggerFactory.getLogger(DropSequenceVisitor.class); - - private final DdlGenContext ctx; - - private final DbDdlSyntax ddlSyntax; - - private final boolean supportsSequence; - - public DropSequenceVisitor(DdlGenContext ctx) { - this.ctx = ctx; - this.ddlSyntax = ctx.getDdlSyntax(); - this.supportsSequence = ctx.getDbPlatform().getDbIdentity().isSupportsSequence(); - } - - public boolean visitBean(BeanDescriptor descriptor) { - - - if (!descriptor.isInheritanceRoot()){ - return false; - } - if (descriptor.getSequenceName() != null) { - - if (!supportsSequence){ - // Hopefully a generic test case - String msg = "Not dropping sequence "+descriptor.getSequenceName()+" on Bean "+descriptor.getName() - +" as DatabasePlatform does not support sequences"; - logger.trace(msg); - return false; - } - - ctx.write("drop sequence "); - if (ddlSyntax.getDropIfExists() != null){ - ctx.write(ddlSyntax.getDropIfExists()).write(" "); - } - ctx.write(descriptor.getSequenceName()); - ctx.write(";").writeNewLine().writeNewLine(); - } - return true; - } - - - public void visitBeanEnd(BeanDescriptor descriptor) { - } - - public void visitBegin() { - } - - public void visitEnd() { - } - - public PropertyVisitor visitProperty(BeanProperty p) { - // Return null as we are not interested in properties - return null; - } - -} diff --git a/src/main/java/com/avaje/ebeaninternal/server/ddl/DropTableVisitor.java b/src/main/java/com/avaje/ebeaninternal/server/ddl/DropTableVisitor.java deleted file mode 100644 index 19e0db9ff..000000000 --- a/src/main/java/com/avaje/ebeaninternal/server/ddl/DropTableVisitor.java +++ /dev/null @@ -1,89 +0,0 @@ -package com.avaje.ebeaninternal.server.ddl; - -import com.avaje.ebean.config.dbplatform.DbDdlSyntax; -import com.avaje.ebeaninternal.server.deploy.BeanDescriptor; -import com.avaje.ebeaninternal.server.deploy.BeanProperty; -import com.avaje.ebeaninternal.server.deploy.BeanPropertyAssocMany; - -/** - * Used to generate the drop table DDL script. - */ -public class DropTableVisitor implements BeanVisitor { - - final DdlGenContext ctx; - - final DbDdlSyntax ddlSyntax; - - public DropTableVisitor(DdlGenContext ctx) { - this.ctx = ctx; - this.ddlSyntax = ctx.getDdlSyntax(); - } - - protected void writeDropTable(BeanDescriptor descriptor){ - writeDropTable(descriptor.getBaseTable()); - } - - protected void writeDropTable(String tableName){ - ctx.write(ddlSyntax.dropTablePrefix(tableName)); - ctx.write("drop table "); - if (ddlSyntax.getDropIfExists() != null){ - ctx.write(ddlSyntax.getDropIfExists()).write(" "); - } - ctx.write(tableName); - - if (ddlSyntax.getDropTableCascade() != null){ - ctx.write(" ").write(ddlSyntax.getDropTableCascade()); - } - ctx.write(";").writeNewLine().writeNewLine(); - } - - public boolean visitBean(BeanDescriptor descriptor) { - - if (!descriptor.isInheritanceRoot()){ - return false; - } - - writeDropTable(descriptor); - - dropIntersectionTables(descriptor); - - return true; - } - - private void dropIntersectionTables(BeanDescriptor descriptor) { - - BeanPropertyAssocMany[] manyProps = descriptor.propertiesMany(); - for (int i = 0; i < manyProps.length; i++) { - if (manyProps[i].isManyToMany()){ - String intTable = manyProps[i].getIntersectionTableJoin().getTable(); - if (ctx.isProcessIntersectionTable(intTable)) { - writeDropTable(intTable); - } - } - } - } - - public void visitBeanEnd(BeanDescriptor descriptor) { - } - - public void visitBegin() { - - if (ddlSyntax.getDisableReferentialIntegrity() != null){ - ctx.write(ddlSyntax.getDisableReferentialIntegrity()); - ctx.write(";").writeNewLine().writeNewLine(); - } - } - - public void visitEnd() { - if (ddlSyntax.getEnableReferentialIntegrity() != null){ - ctx.write(ddlSyntax.getEnableReferentialIntegrity()); - ctx.write(";").writeNewLine().writeNewLine(); - } - } - - public PropertyVisitor visitProperty(BeanProperty p) { - // Return null as we are not interested in properties - return null; - } - -} diff --git a/src/main/java/com/avaje/ebeaninternal/server/ddl/PropertyVisitor.java b/src/main/java/com/avaje/ebeaninternal/server/ddl/PropertyVisitor.java deleted file mode 100644 index 03bcd6d65..000000000 --- a/src/main/java/com/avaje/ebeaninternal/server/ddl/PropertyVisitor.java +++ /dev/null @@ -1,53 +0,0 @@ -package com.avaje.ebeaninternal.server.ddl; - -import com.avaje.ebeaninternal.server.deploy.BeanProperty; -import com.avaje.ebeaninternal.server.deploy.BeanPropertyAssocMany; -import com.avaje.ebeaninternal.server.deploy.BeanPropertyAssocOne; -import com.avaje.ebeaninternal.server.deploy.BeanPropertyCompound; - -/** - * Used to visit a BeanProperty given the type of bean property it is. - */ -public interface PropertyVisitor { - - /** - * Visit a OneToMany or ManyToMany property. - */ - void visitMany(BeanPropertyAssocMany p); - - /** - * Visit the imported side of a OneToOne property. - */ - void visitOneImported(BeanPropertyAssocOne p); - - /** - * Visit the exported side of a OneToOne property. - */ - void visitOneExported(BeanPropertyAssocOne p); - - /** - * Visit an embedded property. - */ - void visitEmbedded(BeanPropertyAssocOne p); - - /** - * Visit the scalar property of an embedded bean. - */ - void visitEmbeddedScalar(BeanProperty p, BeanPropertyAssocOne embedded); - - /** - * Visit a scalar property. - */ - void visitScalar(BeanProperty p); - - /** - * Visit a compound value object. - */ - void visitCompound(BeanPropertyCompound p); - - /** - * Visit the scalar value inside a compound value object. - */ - void visitCompoundScalar(BeanPropertyCompound compound, BeanProperty p); - -} diff --git a/src/main/java/com/avaje/ebeaninternal/server/ddl/VisitorUtil.java b/src/main/java/com/avaje/ebeaninternal/server/ddl/VisitorUtil.java deleted file mode 100644 index d9520e1a3..000000000 --- a/src/main/java/com/avaje/ebeaninternal/server/ddl/VisitorUtil.java +++ /dev/null @@ -1,125 +0,0 @@ -package com.avaje.ebeaninternal.server.ddl; - -import java.util.List; - -import com.avaje.ebeaninternal.api.SpiEbeanServer; -import com.avaje.ebeaninternal.server.deploy.BeanDescriptor; -import com.avaje.ebeaninternal.server.deploy.BeanProperty; -import com.avaje.ebeaninternal.server.deploy.BeanPropertyAssocMany; -import com.avaje.ebeaninternal.server.deploy.BeanPropertyAssocOne; -import com.avaje.ebeaninternal.server.deploy.BeanPropertyCompound; - -/** - * Utility object to use BeanVisitor. - */ -public class VisitorUtil { - - /** - * Visit all the descriptors for a given server. - */ - public static void visit(SpiEbeanServer server, BeanVisitor visitor){ - - visit(server.getBeanDescriptors(), visitor); - } - - - /** - * Visit all the descriptors in the list. - */ - public static void visit(List> descriptors, BeanVisitor visitor){ - - visitor.visitBegin(); - - for (BeanDescriptor desc : descriptors) { - - if (desc.getBaseTable() != null){ - visitBean(desc, visitor); - } - } - - visitor.visitEnd(); - } - - /** - * Visit the bean using a visitor. - */ - public static void visitBean(BeanDescriptor desc, BeanVisitor visitor) { - - if (visitor.visitBean(desc)) { - - BeanProperty idProp = desc.getIdProperty(); - if (idProp != null) { - visit(visitor, idProp); - } - BeanPropertyAssocOne unidirectional = desc.getUnidirectional(); - if (unidirectional != null) { - visit(visitor, unidirectional); - } - BeanProperty[] propertiesNonTransient = desc.propertiesNonTransient(); - for (int i = 0; i < propertiesNonTransient.length; i++) { - BeanProperty p = propertiesNonTransient[i]; - if (!p.isFormula() && !p.isSecondaryTable()) { - visit(visitor, p); - } - } - - visitor.visitBeanEnd(desc); - } - } - - private static void visit(BeanVisitor visitor, BeanProperty p) { - PropertyVisitor pv = visitor.visitProperty(p); - if (pv != null) { - visit(p, pv); - } - } - - /** - * Visit all the properties. - */ - public static void visit(BeanProperty[] p, PropertyVisitor pv){ - - for (int i = 0; i < p.length; i++) { - visit(p[i], pv); - } - } - - /** - * Visit the property. - */ - public static void visit(BeanProperty p, PropertyVisitor pv) { - - if (p instanceof BeanPropertyAssocMany){ - pv.visitMany((BeanPropertyAssocMany)p); - - } else if (p instanceof BeanPropertyAssocOne){ - BeanPropertyAssocOne assocOne = (BeanPropertyAssocOne)p; - if (assocOne.isEmbedded()){ - pv.visitEmbedded(assocOne); - BeanProperty[] embProps = assocOne.getProperties(); - for (int i = 0; i < embProps.length; i++) { - pv.visitEmbeddedScalar(embProps[i], assocOne); - } - - - } else if (assocOne.isOneToOneExported()){ - pv.visitOneExported(assocOne); - - } else { - pv.visitOneImported(assocOne); - - } - } else if (p instanceof BeanPropertyCompound){ - BeanPropertyCompound compound = (BeanPropertyCompound)p; - pv.visitCompound(compound); - - BeanProperty[] properties = compound.getScalarProperties(); - for (int i = 0; i < properties.length; i++) { - pv.visitCompoundScalar(compound, properties[i]); - } - - } else { - pv.visitScalar(p); - } - } -} diff --git a/src/main/java/com/avaje/ebeaninternal/server/ddl/package-info.java b/src/main/java/com/avaje/ebeaninternal/server/ddl/package-info.java deleted file mode 100644 index 320bfa876..000000000 --- a/src/main/java/com/avaje/ebeaninternal/server/ddl/package-info.java +++ /dev/null @@ -1 +0,0 @@ -package com.avaje.ebeaninternal.server.ddl; \ No newline at end of file diff --git a/src/test/resources/ebean.properties b/src/test/resources/ebean.properties index dd95cd75e..2e05dcfd4 100644 --- a/src/test/resources/ebean.properties +++ b/src/test/resources/ebean.properties @@ -23,6 +23,7 @@ ebean.autofetch.traceUsageCollection=false ebean.ddl.generate=true ebean.ddl.run=true +datasource.default=h2 ebean.persistBatch=NONE ebean.persistBatchOnCascade=ALL @@ -50,7 +51,7 @@ ebean.cacheWarmingDelay=-1 ## DataSources (If using default Ebean DataSourceFactory) ## ------------------------------------------------------------- -datasource.default=ora + datasource.h2.username=sa datasource.h2.password= @@ -96,9 +97,9 @@ datasource.hsqldb.databaseUrl=jdbc:hsqldb:mem:tests datasource.hsqldb.databaseDriver=org.hsqldb.jdbcDriver -datasource.mysql.username=test -datasource.mysql.password=test -datasource.mysql.databaseUrl=jdbc:mysql://127.0.0.1:3306/test +datasource.mysql.username=unit +datasource.mysql.password=unit +datasource.mysql.databaseUrl=jdbc:mysql://127.0.0.1:3306/unit datasource.mysql.databaseDriver=com.mysql.jdbc.Driver