go/pocketbase
1
0
Fork 0
mirror of https://github.com/pocketbase/pocketbase.git synced 2025-03-20 14:31:09 +02:00
Code Issues Releases Activity

minor code optimizations

Browse Source
This commit is contained in:
Gani Georgiev 2022-12-13 09:07:50 +02:00
parent 1248421703
commit b1a63bb98d
2 changed files with 7 additions and 7 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

12
daos/record.go
View File

@ -423,7 +423,7 @@ func (dao *Dao) cascadeRecordDelete(mainRecord *models.Record, refs map[*models.
// trigger cascade for each 1000 rel items until there is none
batchSize := 1000
for {
rows := []dbx.NullStringMap{}
rows := make([]dbx.NullStringMap, 0, batchSize)
if err := query.Limit(int64(batchSize)).All(&rows); err != nil {
return err
}
@ -433,8 +433,8 @@ func (dao *Dao) cascadeRecordDelete(mainRecord *models.Record, refs map[*models.
break
}
perWorkers := 50
workers := int(math.Ceil(float64(total) / float64(perWorkers)))
perWorker := 50
workers := int(math.Ceil(float64(total) / float64(perWorker)))
batchErr := func() error {
ch := make(chan error)
@ -442,12 +442,12 @@ func (dao *Dao) cascadeRecordDelete(mainRecord *models.Record, refs map[*models.
for i := 0; i < workers; i++ {
var chunks []dbx.NullStringMap
if len(rows) <= perWorkers {
if len(rows) <= perWorker {
chunks = rows
rows = nil
} else {
chunks = rows[:perWorkers]
rows = rows[perWorkers:]
chunks = rows[:perWorker]
rows = rows[perWorker:]
}
go func() {

2
daos/record_expand.go
View File

@ -176,7 +176,7 @@ func (dao *Dao) expandRecords(records []*models.Record, expandPath string, fetch
}
// reindex with the rel id
indexedRels := map[string]*models.Record{}
indexedRels := make(map[string]*models.Record, len(rels))
for _, rel := range rels {
indexedRels[rel.GetId()] = rel
}