aboutsummaryrefslogtreecommitdiff
path: root/weed/filer/abstract_sql/abstract_sql_store_kv.go
diff options
context:
space:
mode:
authorchrislu <chris.lu@gmail.com>2022-05-06 01:51:28 -0700
committerchrislu <chris.lu@gmail.com>2022-05-06 01:51:28 -0700
commitb2a43dd044123d244be26c87155187d211be1c49 (patch)
tree7dc5edc901f204b2da91f245eb44abae1b04df29 /weed/filer/abstract_sql/abstract_sql_store_kv.go
parentd5fe5d12b74d65a65138de62e9d98cfb3bac14de (diff)
parenta69bf53405d703f29f7b8ca358c67840c2876499 (diff)
downloadseaweedfs-b2a43dd044123d244be26c87155187d211be1c49.tar.xz
seaweedfs-b2a43dd044123d244be26c87155187d211be1c49.zip
Merge branch 'master' of https://github.com/chrislusf/seaweedfs
Diffstat (limited to 'weed/filer/abstract_sql/abstract_sql_store_kv.go')
-rw-r--r--weed/filer/abstract_sql/abstract_sql_store_kv.go8
1 files changed, 4 insertions, 4 deletions
diff --git a/weed/filer/abstract_sql/abstract_sql_store_kv.go b/weed/filer/abstract_sql/abstract_sql_store_kv.go
index 03b016c76..aaf1c196c 100644
--- a/weed/filer/abstract_sql/abstract_sql_store_kv.go
+++ b/weed/filer/abstract_sql/abstract_sql_store_kv.go
@@ -18,7 +18,7 @@ func (store *AbstractSqlStore) KvPut(ctx context.Context, key []byte, value []by
return fmt.Errorf("findDB: %v", err)
}
- dirStr, dirHash, name := genDirAndName(key)
+ dirStr, dirHash, name := GenDirAndName(key)
res, err := db.ExecContext(ctx, store.GetSqlInsert(DEFAULT_TABLE), dirHash, name, dirStr, value)
if err == nil {
@@ -53,7 +53,7 @@ func (store *AbstractSqlStore) KvGet(ctx context.Context, key []byte) (value []b
return nil, fmt.Errorf("findDB: %v", err)
}
- dirStr, dirHash, name := genDirAndName(key)
+ dirStr, dirHash, name := GenDirAndName(key)
row := db.QueryRowContext(ctx, store.GetSqlFind(DEFAULT_TABLE), dirHash, name, dirStr)
err = row.Scan(&value)
@@ -76,7 +76,7 @@ func (store *AbstractSqlStore) KvDelete(ctx context.Context, key []byte) (err er
return fmt.Errorf("findDB: %v", err)
}
- dirStr, dirHash, name := genDirAndName(key)
+ dirStr, dirHash, name := GenDirAndName(key)
res, err := db.ExecContext(ctx, store.GetSqlDelete(DEFAULT_TABLE), dirHash, name, dirStr)
if err != nil {
@@ -92,7 +92,7 @@ func (store *AbstractSqlStore) KvDelete(ctx context.Context, key []byte) (err er
}
-func genDirAndName(key []byte) (dirStr string, dirHash int64, name string) {
+func GenDirAndName(key []byte) (dirStr string, dirHash int64, name string) {
for len(key) < 8 {
key = append(key, 0)
}