aboutsummaryrefslogtreecommitdiff
diff options
context:
space:
mode:
authorChris Lu <chris.lu@gmail.com>2021-02-15 16:19:24 -0800
committerChris Lu <chris.lu@gmail.com>2021-02-15 16:19:24 -0800
commitb9b5b932c5892f14da6b489a6907ffd8649a3eb5 (patch)
tree8caa02ef9ac6036e459cda1389b130e5ad14b21f
parent71f0c195157b79223a3c8e35a57da10b7ff0720d (diff)
downloadseaweedfs-b9b5b932c5892f14da6b489a6907ffd8649a3eb5.tar.xz
seaweedfs-b9b5b932c5892f14da6b489a6907ffd8649a3eb5.zip
filer: postgres2 mysql2 avoid repeatedly creating tables
-rw-r--r--weed/filer/abstract_sql/abstract_sql_store.go2
1 files changed, 1 insertions, 1 deletions
diff --git a/weed/filer/abstract_sql/abstract_sql_store.go b/weed/filer/abstract_sql/abstract_sql_store.go
index 91b0bc98f..07ce56145 100644
--- a/weed/filer/abstract_sql/abstract_sql_store.go
+++ b/weed/filer/abstract_sql/abstract_sql_store.go
@@ -107,7 +107,7 @@ func (store *AbstractSqlStore) getTxOrDB(ctx context.Context, fullpath util.Full
}
if _, found := store.dbs[bucket]; !found {
- if err = store.CreateTable(ctx, bucket); err != nil {
+ if err = store.CreateTable(ctx, bucket); err == nil {
store.dbs[bucket] = true
}
}