如何批量更新用户类（Parse.com、Android）中的所有对象？

Posted 2023-03-16

【中文标题】如何批量更新用户类（Parse.com、Android）中的所有对象？

【英文标题】：How can I batch update all objects in User class (Parse.com, Android)?

【发布时间】：2016-08-08 08:58:50

【问题描述】：

我最初犯了一个错误，忘记在用户注册时初始化我的 Array 字段（设计），所以在我的 Parse 仪表板中，行显示为 (undefined)，我希望它们是 []。我必须为大约 5000 个用户执行此操作。我尝试了以下代码：

var query = new Parse.Query("User");
query.equalTo("designs", "(undefined)");
query.each(function(obj) 
  obj.set("designs", "[]");
  return obj.save();
).then(function() 
  // All objects updated.
, function(err) 
  console.log(err);
);

我认为(undefined) 应该是别的东西，但我不确定是什么，因为它可能不是字符串。我该如何解决这个问题？

更新：第二次尝试。是不是越来越近了？

    private void updateAllRows(final int skip) 

    ParseQuery<ParseUser> query = ParseUser.getQuery();
    query.setLimit(500);
    query.setSkip(skip);
    query.whereDoesNotExist("designs");
    query.findInBackground(new FindCallback<ParseUser>() 

        @Override
        public void done(List<ParseUser> results, ParseException e) 
            if (results.size() > 0) 

                // The query was successful.
                for (int i = 0; i < results.size(); i++) 
                    ParseUser user = results.get(i);
                    String[] designs = new String[0];
                    user.put("designs", Arrays.asList(designs));

                    try 
                        ParseUser.saveAll(results);
                        if (results.size() >= 500) 
                            updateAllRows(skip + 500); // make a recursion call with different skip value
                        
                     catch (ParseException e1) 
                        e1.printStackTrace();
                    
                

                Log.d(getClass().toString(), ": The batch job was successfully completed.");

             else 
                // The query was unsuccessful.
                Log.d(getClass().toString(), ": The batch job was not successful.");
            
        
    );

我使用我班级的 onCreate 方法中的以下函数调用上述函数：

int skip = 0;
updateAllRows(skip);

这是在不使用云代码的情况下解决此问题的最佳方式吗？

错误：

08-08 12:38:43.034 24003-24053/? E/HttpOperation: [luqcheckandengageuser, getmobileexperiments] Unexpected exception
                                                  java.io.IOException: 1 of 2 operations in the batch failed
                                                      at luj.a(PG:268)
                                                      at lth.o(PG:10642)
                                                      at ltc.a(PG:1402)
                                                      at lth.i(PG:154)
                                                      at ly.f(PG:51849)
                                                      at dsr.a(PG:1255)
                                                      at dsr.a(PG:20077)
                                                      at dsr.a(PG:706)
                                                      at dss.run(PG:1548)
                                                      at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:423)
                                                      at java.util.concurrent.FutureTask.run(FutureTask.java:237)
                                                      at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1113)
                                                      at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:588)
                                                      at java.lang.Thread.run(Thread.java:818)

【问题讨论】：

你得到这个查询的答案了吗？我也面临一个问题，我想获取 wherecontainsIn("CP") AND whereDoesnotExists 都不起作用如何查询这个？

【参考方案1】：

JavaScript 版本 1. 您可以使用 Parse.Object.saveAll 在一次服务调用中保存多个对象 2. 您必须使用 limit 和 skip 才能一次处理 500 个（或更少）项目。 3.你需要使用query.doesNotExist("designs");来获取所有在设计列中包含undefined的项目

function updateAllRows(skip) 

  var query = new Parse.Query(Parse.User);
  query.limit(500);
  query.skip(skip);
  // get recors where designs is not exist or is undefined      
  query.doesNotExist("designs");

  query.find().then(function(results) 

    // if we got results then change the designs property 
    if (results.length > 0) 

      for (var i = 0; i < results.length; i++) 
        var item = results[i];
        item.set("designs", []);
      

      Parse.Object.saveAll(results).then(function() 
        // if we got 500 or more results then we know
        // that we have more results
        // otherwise we finish
        if (results.length >= 500) 
          updateAllRows(skip + 500); // make a recursion call with different skip value
        

      , function(err) 
        // error occured 
      );
    
  , function(error) 
    // error occured while trying to fetch data 
  );
;

Android Java 版本

private void updateAllRows(final int skip)

    ParseQuery<ParseUser> query = ParseUser.getQuery();
    query.setLimit(500);
    query.setSkip(skip);
    query.whereDoesNotExist("designs");

    query.findInBackground(new FindCallback<ParseUser>() 
        @Override
        public void done(final List<ParseUser> users, ParseException e) 

            if (e == null)
                for (ParseUser user : users)
                    user.put("designs",new ArrayList<>());
                

                // save all objects in one server call
                ParseObject.saveAllInBackground(users, new SaveCallback() 
                    @Override
                    public void done(ParseException e) 

                        if (e == null)
                            if (users.size() >= 500)
                                updateAllRows(skip + 500);
                            
                         else 
                            // error  while saving objects
                        


                    
                );
            
        
    );

顺便说一句！你也可以在云代码中创建一个云函数并从客户端触发这个函数

【讨论】：

我注意到这是用 javascript 编写的。我更新了我的问题以包含 Java 版本。整个跳过位仍然需要吗？我还注意到您将“skip”作为参数传递。这对 android 有什么影响？

它是用 JS 写的，因为你的例子是用 JavaScript 写的。我会发布 android 版本

哦，对不起，哈哈。我的剪贴板简直一团糟。我以前在某个地方用 Java 写过一个替代方案。

还有一件事，我应该将我的跳过变量初始化为 0 吗？调用该方法时，我在 onCreate 中使用以下内容：int skip = 0; updateAllRows(skip);.

您的代码出现错误。我已经记录了上面的异常。

【参考方案2】：

Javascript 版本：

async updateAllRows(skip) 
    const query = new Parse.Query(Question);
    query.limit(500);
    query.skip(skip);
    query.doesNotExist("update");
    try 
      const results = await query.find();
      for (const result of results) 
        result.set('update', 'your update')
      
      await Parse.Object.saveAll(results)
      if (results.length >= 500)
        updateAllRows(skip + 500).then().catch();
      
     catch (e)