diff options
| author | Chris Lu <chris.lu@uber.com> | 2021-04-02 12:02:26 -0700 |
|---|---|---|
| committer | Chris Lu <chris.lu@uber.com> | 2021-04-02 12:02:26 -0700 |
| commit | 5e64f65632d562cde549fe1d929628af95611824 (patch) | |
| tree | 11a9597d05eb3d9d08c963ae5c3901a3eb8f1744 | |
| parent | 319743d33078262e50d6e0e5d4fae04015f1dfd4 (diff) | |
| download | seaweedfs-5e64f65632d562cde549fe1d929628af95611824.tar.xz seaweedfs-5e64f65632d562cde549fe1d929628af95611824.zip | |
ensure tables are created
fix https://github.com/chrislusf/seaweedfs/issues/1957
| -rw-r--r-- | weed/filer/abstract_sql/abstract_sql_store.go | 4 |
1 files changed, 4 insertions, 0 deletions
diff --git a/weed/filer/abstract_sql/abstract_sql_store.go b/weed/filer/abstract_sql/abstract_sql_store.go index 9e52d9f87..120a1d139 100644 --- a/weed/filer/abstract_sql/abstract_sql_store.go +++ b/weed/filer/abstract_sql/abstract_sql_store.go @@ -36,6 +36,8 @@ func (store *AbstractSqlStore) OnBucketCreation(bucket string) { store.dbsLock.Lock() defer store.dbsLock.Unlock() + store.CreateTable(context.Background(), bucket) + if store.dbs == nil { return } @@ -45,6 +47,8 @@ func (store *AbstractSqlStore) OnBucketDeletion(bucket string) { store.dbsLock.Lock() defer store.dbsLock.Unlock() + store.deleteTable(context.Background(), bucket) + if store.dbs == nil { return } |