diff --git a/db/postgis.go b/db/postgis.go index 4e4a6b1..3b8a2e5 100644 --- a/db/postgis.go +++ b/db/postgis.go @@ -129,6 +129,10 @@ func (pg *PostGIS) createSchema() error { var sql string var err error + if pg.Config.Schema == "public" { + return nil + } + sql = fmt.Sprintf("SELECT EXISTS(SELECT schema_name FROM information_schema.schemata WHERE schema_name = '%s');", pg.Config.Schema) row := pg.Db.QueryRow(sql) @@ -141,10 +145,6 @@ func (pg *PostGIS) createSchema() error { return nil } - if err != nil { - return &SQLError{sql, err} - } - sql = fmt.Sprintf("CREATE SCHEMA \"%s\"", pg.Config.Schema) _, err = pg.Db.Exec(sql) if err != nil {