go/dbschema
6
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

Made Version function public

Browse Source
This commit is contained in:
Magnus Åhall 2024-05-10 08:11:47 +02:00
parent 08df526c02
commit b83c7b1e17
1 changed files with 4 additions and 5 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

9
upgrader.go
View File

@ -43,7 +43,7 @@ func (upgrader *Upgrader) Version(dbName string) (version int, err error) {// {{
return return
} }
version, err = dbase.version() version, err = dbase.Version()
return return
}// }}} }// }}}
@ -111,7 +111,7 @@ func (dbase Database) verifySchemaEntry() (err error) {// {{{
return return
}// }}} }// }}}
func (dbase Database) version() (version int, err error) {// {{{ func (dbase Database) Version() (version int, err error) {// {{{
var rows *sql.Rows var rows *sql.Rows
rows, err = dbase.db.Query( rows, err = dbase.db.Query(
`SELECT version FROM `+dbase.upgrader.schema+`.schema ORDER BY version DESC LIMIT 1`, `SELECT version FROM `+dbase.upgrader.schema+`.schema ORDER BY version DESC LIMIT 1`,
@ -130,8 +130,7 @@ func (dbase Database) version() (version int, err error) {// {{{
}// }}} }// }}}
// AddDatabase sets a database up for the Run() function with verifying/creating the _db.schema table. // AddDatabase sets a database up for the Run() function with verifying/creating the _db.schema table.
func (upgrader Upgrader) AddDatabase(host string, port int, dbName, user, pass string) (err error) {// {{{ func (upgrader Upgrader) AddDatabase(host string, port int, dbName, user, pass string) (db Database, err error) {// {{{
var db Database
if db, err = newDatabase(host, port, dbName, user, pass); err != nil { if db, err = newDatabase(host, port, dbName, user, pass); err != nil {
return return
} }
@ -151,7 +150,7 @@ func (upgrader Upgrader) Run() (err error) {// {{{
var version int var version int
for dbName, dbase := range upgrader.databases { for dbName, dbase := range upgrader.databases {
version, err = dbase.version() version, err = dbase.Version()
if err != nil { if err != nil {
return return
} }