aboutsummaryrefslogtreecommitdiff
path: root/weed/filer/ydb/ydb_queries.go
diff options
context:
space:
mode:
Diffstat (limited to 'weed/filer/ydb/ydb_queries.go')
-rw-r--r--weed/filer/ydb/ydb_queries.go18
1 files changed, 9 insertions, 9 deletions
diff --git a/weed/filer/ydb/ydb_queries.go b/weed/filer/ydb/ydb_queries.go
index 6e0939948..659cc2158 100644
--- a/weed/filer/ydb/ydb_queries.go
+++ b/weed/filer/ydb/ydb_queries.go
@@ -4,7 +4,7 @@ import asql "github.com/chrislusf/seaweedfs/weed/filer/abstract_sql"
const (
insertQuery = `
- DECLARE $dir_hash int64;
+ DECLARE $dir_hash AS int64;
DECLARE $name AS Utf8;
DECLARE $directory AS Utf8;
DECLARE $meta AS String;
@@ -15,7 +15,7 @@ const (
($dir_hash, $name, $directory, $meta);`
updateQuery = `
- DECLARE $dir_hash int64;
+ DECLARE $dir_hash AS int64;
DECLARE $name AS Utf8;
DECLARE $directory AS Utf8;
DECLARE $meta AS String;
@@ -27,7 +27,7 @@ const (
COMMIT;`
deleteQuery = `
- DECLARE $dir_hash int64;
+ DECLARE $dir_hash AS int64;
DECLARE $name AS Utf8;
DELETE FROM ` + asql.DEFAULT_TABLE + `
@@ -35,15 +35,15 @@ const (
COMMIT;`
findQuery = `
- DECLARE $dir_hash int64;
+ DECLARE $dir_hash AS int64;
DECLARE $name AS Utf8;
SELECT meta
- FROM file_meta
+ FROM ` + asql.DEFAULT_TABLE + `
WHERE dir_hash == $dir_hash AND name == $name;`
deleteFolderChildrenQuery = `
- DECLARE $dir_hash int64;
+ DECLARE $dir_hash AS int64;
DECLARE $directory AS Utf8;
DELETE FROM ` + asql.DEFAULT_TABLE + `
@@ -51,14 +51,14 @@ const (
COMMIT;`
listDirectoryQuery = `
- DECLARE $dir_hash int64;
+ DECLARE $dir_hash AS int64;
DECLARE $directory AS Utf8;
DECLARE $start_name AS Utf8;
DECLARE $prefix AS Utf8;
- DECLARE $limit AS int64;
+ DECLARE $limit AS Uint64;
SELECT name, meta
FROM ` + asql.DEFAULT_TABLE + `
- WHERE dir_hash == $dir_hash AND directory == $directory and name %s $start_name and name LIKE '$prefix%%'
+ WHERE dir_hash == $dir_hash AND directory == $directory and name %s $start_name and name LIKE $prefix
ORDER BY name ASC LIMIT $limit;`
)