Add a database instance without using connection details
This commit is contained in:
parent
b83c7b1e17
commit
825cf0fc9a
2 changed files with 8 additions and 0 deletions
|
|
@ -16,6 +16,10 @@ func newDatabase(host string, port int, dbName, user, pass string) (dbase Databa
|
|||
dbase.db, err = sql.Open("postgres", dbase.sqlConnString())
|
||||
return
|
||||
}// }}}
|
||||
func databaseFromInstance(db *sql.DB) (dbase Database, err error) {
|
||||
dbase.db = db
|
||||
return
|
||||
}
|
||||
|
||||
func (dbase Database) sqlConnString() string {// {{{
|
||||
return fmt.Sprintf(
|
||||
|
|
|
|||
|
|
@ -145,6 +145,10 @@ func (upgrader Upgrader) AddDatabase(host string, port int, dbName, user, pass s
|
|||
err = db.verifySchemaEntry()
|
||||
return
|
||||
}// }}}
|
||||
func (upgrader Upgrader) AddDatabaseInstance(sqlDB *sql.DB) (db Database, err error) {// {{{
|
||||
return databaseFromInstance(sqlDB)
|
||||
}// }}}
|
||||
|
||||
// Run executes the actual schema updates until there are no more available.
|
||||
func (upgrader Upgrader) Run() (err error) {// {{{
|
||||
var version int
|
||||
|
|
|
|||
Loading…
Add table
Reference in a new issue