vitalif
/
imposm3
1
0
Fork 0
Code Issues Pull Requests Releases Wiki Activity

only create schema when it does not exists

master
Oliver Tonnhofer 2013-05-10 10:26:37 +02:00
parent ea40987895
commit 24c928a102
1 changed files with 16 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

17
db/postgis.go
View File

@ -112,7 +112,6 @@ func (pg *PostGIS) createTable(spec TableSpec) error {
}
sql = spec.CreateTableSQL()
log.Println(sql)
_, err = pg.Db.Exec(sql)
if err != nil {
return &SQLError{sql, err}
@ -130,6 +129,22 @@ func (pg *PostGIS) createSchema() error {
var sql string
var err error
sql = fmt.Sprintf("SELECT EXISTS(SELECT schema_name FROM information_schema.schemata WHERE schema_name = '%s');",
pg.Config.Schema)
row := pg.Db.QueryRow(sql)
var exists bool
err = row.Scan(&exists)
if err != nil {
return &SQLError{sql, err}
}
if exists {
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 {