WIP

FerretDB · w84thesun · Jun 30, 2023 · Jun 26, 2023 · Jun 26, 2023 · Jun 26, 2023
commit 6002aeb4562424c92fff35537ed77a35a3714676
@@ -18,6 +18,7 @@ import (
 	"context"
 	"errors"
 	"fmt"
+	"strings"
 
 	"modernc.org/sqlite"
 	sqlitelib "modernc.org/sqlite/lib"
@@ -185,7 +186,9 @@ func (c *collection) Delete(ctx context.Context, params *backends.DeleteParams)
 	var deleted int64
 
 	for _, id := range params.IDs {
-		res, err := db.ExecContext(ctx, query, id)
+		idArg := strings.ReplaceAll(string(must.NotFail(sjson.MarshalSingleValue(id))), "\"", "")
+
+		res, err := db.ExecContext(ctx, query, idArg)
 		if err != nil {
 			return nil, lazyerrors.Error(err)
 		}

@@ -148,6 +148,9 @@ func execDelete(ctx context.Context, dp *execDeleteParams) (int32, error) {
 		return 0, nil
 	}
 
+	// close iterator to free db connection.
+	iter.Close()
+
 	deleteRes, err := dp.coll.Delete(ctx, &backends.DeleteParams{IDs: ids})
 	if err != nil {
 		return 0, err