diff options
| author | chrislu <chris.lu@gmail.com> | 2022-10-12 00:03:14 -0700 |
|---|---|---|
| committer | chrislu <chris.lu@gmail.com> | 2022-10-12 00:03:14 -0700 |
| commit | dff85e9c71efad812d92410dad56d6ab7c13c67c (patch) | |
| tree | ece7f2d2cd02712546ad7d1ab80110c00732f349 | |
| parent | 8aec786a6d00fc825a9875f1d993c1e141ce71b6 (diff) | |
| download | seaweedfs-dff85e9c71efad812d92410dad56d6ab7c13c67c.tar.xz seaweedfs-dff85e9c71efad812d92410dad56d6ab7c13c67c.zip | |
fix error handling
| -rw-r--r-- | weed/filer/sqlite/sqlite_store.go | 8 |
1 files changed, 5 insertions, 3 deletions
diff --git a/weed/filer/sqlite/sqlite_store.go b/weed/filer/sqlite/sqlite_store.go index 2bacf051a..202834fa2 100644 --- a/weed/filer/sqlite/sqlite_store.go +++ b/weed/filer/sqlite/sqlite_store.go @@ -63,9 +63,11 @@ func (store *SqliteStore) initialize(dbFile, createTable, upsertQuery string) (e var dbErr error store.DB, dbErr = sql.Open("sqlite", dbFile) if dbErr != nil { - store.DB.Close() - store.DB = nil - return fmt.Errorf("can not connect to %s error:%v", dbFile, err) + if store.DB != nil { + store.DB.Close() + store.DB = nil + } + return fmt.Errorf("can not connect to %s error:%v", dbFile, dbErr) } if err = store.DB.Ping(); err != nil { |