mirror of
https://github.com/binwiederhier/ntfy.git
synced 2026-03-18 21:30:44 +01:00
Manual correction
This commit is contained in:
@@ -328,8 +328,7 @@ var (
|
|||||||
|
|
||||||
func setupSQLite(db *sql.DB) error {
|
func setupSQLite(db *sql.DB) error {
|
||||||
var schemaVersion int
|
var schemaVersion int
|
||||||
err := db.QueryRow(sqliteSelectSchemaVersionQuery).Scan(&schemaVersion)
|
if err := db.QueryRow(sqliteSelectSchemaVersionQuery).Scan(&schemaVersion); err != nil {
|
||||||
if err != nil {
|
|
||||||
return setupNewSQLite(db)
|
return setupNewSQLite(db)
|
||||||
}
|
}
|
||||||
if schemaVersion == sqliteCurrentSchemaVersion {
|
if schemaVersion == sqliteCurrentSchemaVersion {
|
||||||
|
|||||||
@@ -111,11 +111,9 @@ func NewSQLiteStore(filename, startupQueries string) (*Store, error) {
|
|||||||
|
|
||||||
func setupSQLite(db *sql.DB) error {
|
func setupSQLite(db *sql.DB) error {
|
||||||
var schemaVersion int
|
var schemaVersion int
|
||||||
err := db.QueryRow(sqliteSelectSchemaVersionQuery).Scan(&schemaVersion)
|
if err := db.QueryRow(sqliteSelectSchemaVersionQuery).Scan(&schemaVersion); err != nil {
|
||||||
if err != nil {
|
|
||||||
return setupNewSQLite(db)
|
return setupNewSQLite(db)
|
||||||
}
|
} else if schemaVersion > sqliteCurrentSchemaVersion {
|
||||||
if schemaVersion > sqliteCurrentSchemaVersion {
|
|
||||||
return fmt.Errorf("unexpected schema version: version %d is higher than current version %d", schemaVersion, sqliteCurrentSchemaVersion)
|
return fmt.Errorf("unexpected schema version: version %d is higher than current version %d", schemaVersion, sqliteCurrentSchemaVersion)
|
||||||
}
|
}
|
||||||
return nil
|
return nil
|
||||||
|
|||||||
Reference in New Issue
Block a user