diff options
| -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 } |