Подтвердить что ты не робот

Обновление массива в MongoDB с использованием драйвера Java

Я использую MongoDB с официальным драйвером Java (версия 2.6.3). У меня есть коллекция MongoDB, содержащая списки покупок. Список покупок имеет формат

{ "_id" : { "$oid" : "4e2af1f43f8de96494d5271d"} ,
  "name" : "default" ,
  "items" : [ { "description" : "Cheese" , "quantity" : 1 , "unit" : "kg"} ,
              { "description" : "Water" , "quantity" : 3 , "unit" : "bottle"} ] }

Теперь я хочу добавить новый элемент в список с помощью метода update() DBCollection. Но что бы я ни пытался, это не сработает, хотя он говорит мне

{ "updatedExisting" : true , "n" : 1 , "connectionId" : 63 , "err" :  null  , "ok" : 1.0}

Мой код делает следующее:

    BasicDBObject updateQuery = new BasicDBObject();
    updateQuery.put( "name", "default" );

    BasicDBObject updateCommand = new BasicDBObject();
    updateCommand.put( "$push", new BasicDBObject( "items", newShoppingItem ) );
    WriteResult result = shoppingLists.update( updateQuery, updateCommand, true, true );

newShoppingItem - это BasicDBObject, который содержит данные для нового элемента. Я также попытался создать параметры update() с помощью BasicDBObjectBuilder и JSON.parse(), но это не имеет значения.

Я также просмотрел другие сообщения, попробовал googleing, но безрезультатно. Что я делаю неправильно?

Спасибо за помощь! Оливер

4b9b3361

Ответ 1

да, приведенный выше код работает отлично. Теперь я знаю, где была моя ошибка. Я хотел сделать это пуленепробиваемым, поэтому я подумал, что лучше всего использовать save() на DBCollection в конце и явно сохранить список DBObject списка покупок:

shoppingLists.save( shoppingList );

Теперь я читаю в каком-то другом форуме, что объекты, которые вы извлекаете из базы данных, затем не синхронизируются с базой данных (теперь мне кажется логичным:)). Поэтому я каждый раз записывал изменения. После удаления строки над ней работало:)

Итак, одно важное правило: при обновлении DBCollection - это отправляется непосредственно в базу данных! - не сохраняйте DBObject, который вы запрашивали перед обновлением! Он перезапишет ваше обновление!