aboutsummaryrefslogtreecommitdiff
path: root/weed/filer/mysql/mysql_sql_gen.go
diff options
context:
space:
mode:
authorKonstantin Lebedev <lebedev_k@tochka.com>2021-06-15 18:12:39 +0500
committerKonstantin Lebedev <lebedev_k@tochka.com>2021-06-15 18:12:39 +0500
commit6aa1a56ec87ca63f7a072eb6c9599e06fbb5ca9a (patch)
tree2e894d711e7bff2e7e81043f2a00e88c34b685dd /weed/filer/mysql/mysql_sql_gen.go
parentebe971da2e12bc155819ba1e60f720513d0cfc20 (diff)
downloadseaweedfs-6aa1a56ec87ca63f7a072eb6c9599e06fbb5ca9a.tar.xz
seaweedfs-6aa1a56ec87ca63f7a072eb6c9599e06fbb5ca9a.zip
avoid crashes Galera Cluster
https://github.com/chrislusf/seaweedfs/issues/2125
Diffstat (limited to 'weed/filer/mysql/mysql_sql_gen.go')
-rw-r--r--weed/filer/mysql/mysql_sql_gen.go2
1 files changed, 1 insertions, 1 deletions
diff --git a/weed/filer/mysql/mysql_sql_gen.go b/weed/filer/mysql/mysql_sql_gen.go
index 93d3e3f9e..477baf66b 100644
--- a/weed/filer/mysql/mysql_sql_gen.go
+++ b/weed/filer/mysql/mysql_sql_gen.go
@@ -38,7 +38,7 @@ func (gen *SqlGenMysql) GetSqlDelete(tableName string) string {
}
func (gen *SqlGenMysql) GetSqlDeleteFolderChildren(tableName string) string {
- return fmt.Sprintf("DELETE FROM `%s` WHERE dirhash=? AND directory=?", tableName)
+ return fmt.Sprintf("DELETE FROM `%s` WHERE dirhash=? AND directory=? LIMIT ?", tableName)
}
func (gen *SqlGenMysql) GetSqlListExclusive(tableName string) string {