diff options
| author | elee <eddy@gfxlabs.io> | 2022-03-17 05:07:40 -0500 |
|---|---|---|
| committer | elee <eddy@gfxlabs.io> | 2022-03-17 05:07:40 -0500 |
| commit | 31571dd96e9c3b299dc72d0afac2859098248fc9 (patch) | |
| tree | 5ea3213bbebf1eec420ed157de933adb03a2beb3 /weed/filer/arangodb | |
| parent | b25d03340b8fe7ca3c25ac20a9f14f85e1935f90 (diff) | |
| download | seaweedfs-31571dd96e9c3b299dc72d0afac2859098248fc9.tar.xz seaweedfs-31571dd96e9c3b299dc72d0afac2859098248fc9.zip | |
fix file listing
Diffstat (limited to 'weed/filer/arangodb')
| -rw-r--r-- | weed/filer/arangodb/arangodb_store.go | 19 |
1 files changed, 8 insertions, 11 deletions
diff --git a/weed/filer/arangodb/arangodb_store.go b/weed/filer/arangodb/arangodb_store.go index 3cc9e14c9..dc4fbad84 100644 --- a/weed/filer/arangodb/arangodb_store.go +++ b/weed/filer/arangodb/arangodb_store.go @@ -268,22 +268,19 @@ func (store *ArangodbStore) ListDirectoryPrefixedEntries(ctx context.Context, di } func (store *ArangodbStore) ListDirectoryEntries(ctx context.Context, dirPath util.FullPath, startFileName string, includeStartFile bool, limit int64, eachEntryFunc filer.ListEachEntryFunc) (lastFileName string, err error) { - dir, name := dirPath.DirAndName() eq := "" - if includeStartFile { - eq = "=" + if !includeStartFile { + eq = "filter d.name != \"" + startFileName + "\"" } - _ = eq - _ = name - - cur, err := store.database.Query(ctx, fmt.Sprintf(` + fmt.Println(dirPath, startFileName, includeStartFile) + query := fmt.Sprintf(` for d in files -filter d.directory == @dir +filter d.directory == "%s" sort d.name desc +%s limit %d -return d`, limit), map[string]interface{}{ - "dir": dir, - }) +return d`, string(dirPath), eq, limit) + cur, err := store.database.Query(ctx, query, nil) if err != nil { return lastFileName, fmt.Errorf("failed to list directory entries: find error: %w", err) } |
