(extName, schemaName, statement, doing, operation string)
| 598 | } |
| 599 | |
| 600 | func (c *Cluster) execCreateOrAlterExtension(extName, schemaName, statement, doing, operation string) error { |
| 601 | |
| 602 | c.logger.Infof("%s %q schema %q", doing, extName, schemaName) |
| 603 | if _, err := c.pgDb.Exec(fmt.Sprintf(statement, extName, schemaName)); err != nil { |
| 604 | return fmt.Errorf("could not execute %s: %v", operation, err) |
| 605 | } |
| 606 | |
| 607 | return nil |
| 608 | } |
| 609 | |
| 610 | // getPublications returns the list of current database publications with tables |
| 611 | // The caller is responsible for opening and closing the database connection |
no outgoing calls
no test coverage detected