aboutsummaryrefslogtreecommitdiff
path: root/weed/filer/abstract_sql/abstract_sql_store.go
diff options
context:
space:
mode:
authorChris Lu <chris.lu@gmail.com>2021-01-19 18:07:29 -0800
committerChris Lu <chris.lu@gmail.com>2021-01-19 18:07:29 -0800
commitd5add83e85da0c61fe107842e7dd82b52af2bcdb (patch)
tree1892f643a0564bf1dd27beec46fc9224f91af83a /weed/filer/abstract_sql/abstract_sql_store.go
parent52a8f1470ef92b9d0075c3dccc76a4170ab30c07 (diff)
downloadseaweedfs-d5add83e85da0c61fe107842e7dd82b52af2bcdb.tar.xz
seaweedfs-d5add83e85da0c61fe107842e7dd82b52af2bcdb.zip
filer store: add postgres2
Diffstat (limited to 'weed/filer/abstract_sql/abstract_sql_store.go')
-rw-r--r--weed/filer/abstract_sql/abstract_sql_store.go4
1 files changed, 2 insertions, 2 deletions
diff --git a/weed/filer/abstract_sql/abstract_sql_store.go b/weed/filer/abstract_sql/abstract_sql_store.go
index 8345d7a7b..91b0bc98f 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
}
}
@@ -322,7 +322,7 @@ func isValidBucket(bucket string) bool {
return bucket != DEFAULT_TABLE && bucket != ""
}
-func (store *AbstractSqlStore) createTable(ctx context.Context, bucket string) error {
+func (store *AbstractSqlStore) CreateTable(ctx context.Context, bucket string) error {
if !store.SupportBucketTable {
return nil
}