Skip to content

Commit fa72aa2

Browse files
committed
#9551 (#29) - create schema if not exists
1 parent 1475454 commit fa72aa2

File tree

2 files changed

+9
-1
lines changed

2 files changed

+9
-1
lines changed

deegree-datastores/deegree-featurestores/deegree-featurestore-sql/src/main/java/org/deegree/feature/persistence/sql/ddl/DDLCreator.java

Lines changed: 5 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -174,7 +174,7 @@ private List<StringBuffer> process(FeatureTypeMapping ftMapping) {
174174

175175
protected void appendCreateSchema(String schema, StringBuffer sql) {
176176
if (schema != null && !createdSchemas.contains(schema)) {
177-
sql.append("CREATE SCHEMA ").append(schema).append(";\n");
177+
createSchemaSnippet(schema, sql);
178178
createdSchemas.add(schema);
179179
}
180180
}
@@ -191,6 +191,10 @@ private String getPkConstraintName(TableName ftTable) {
191191
return s;
192192
}
193193

194+
protected void createSchemaSnippet(String schema, StringBuffer sql) {
195+
sql.append("CREATE SCHEMA ").append(schema).append(";\n");
196+
}
197+
194198
protected abstract void primitiveMappingSnippet(StringBuffer sql, PrimitiveMapping mapping);
195199

196200
protected abstract void geometryMappingSnippet(StringBuffer sql, GeometryMapping mapping, List<StringBuffer> ddls,

deegree-datastores/deegree-featurestores/deegree-featurestore-sql/src/main/java/org/deegree/feature/persistence/sql/ddl/PostGISDDLCreator.java

Lines changed: 4 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -242,6 +242,10 @@ protected String getDBType(BaseType type) {
242242
return postgresqlType;
243243
}
244244

245+
protected void createSchemaSnippet(String schema, StringBuffer sql) {
246+
sql.append("CREATE SCHEMA IF NOT EXISTS ").append(schema).append(";\n");
247+
}
248+
245249
private String retrieveTypeOfPrimaryKey(TableName fromTable, SQLIdentifier toColumn, FIDMapping fidMapping) {
246250
if (fidMapping != null) {
247251
for (Pair<SQLIdentifier, BaseType> column : fidMapping.getColumns()) {

0 commit comments

Comments
 (0)