В этом документе рассматривается работа со списками данных в Firebase. Чтобы изучить основы чтения и записи данных Firebase, см. раздел Чтение и запись данных на Android .
Получить ссылку на базу данных
Для чтения и записи данных из базы данных вам понадобится экземпляр DatabaseReference
:
Kotlin+KTX
private lateinit var database: DatabaseReference // ... database = Firebase.database.reference
Java
private DatabaseReference mDatabase; // ... mDatabase = FirebaseDatabase.getInstance().getReference();
Читать и писать списки
Добавить в список данных
Используйте метод push()
для добавления данных в список в многопользовательских приложениях. Метод push()
генерирует уникальный ключ каждый раз, когда к указанной ссылке Firebase добавляется новый дочерний элемент. Используя эти автоматически сгенерированные ключи для каждого нового элемента в списке, несколько клиентов могут одновременно добавлять дочерние элементы в одно и то же место без конфликтов записи. Уникальный ключ, сгенерированный функцией push()
основан на временной метке, поэтому элементы списка автоматически упорядочиваются в хронологическом порядке.
Вы можете использовать ссылку на новые данные, возвращаемые методом push()
чтобы получить значение автоматически сгенерированного ключа дочернего элемента или установить данные для дочернего элемента. Вызов getKey()
по ссылке push()
возвращает значение автоматически сгенерированного ключа.
Вы можете использовать эти автоматически сгенерированные ключи, чтобы упростить выравнивание структуры данных. Дополнительные сведения см. в примере разветвления данных.
Прослушивание дочерних событий
При работе со списками ваше приложение должно прослушивать дочерние события, а не события значений, используемые для отдельных объектов.
Дочерние события запускаются в ответ на определенные операции, которые происходят с дочерними узлами в результате такой операции, как добавление нового дочернего узла с помощью метода push()
или обновление дочернего элемента с помощью метода updateChildren()
. Каждый из них вместе может быть полезен для прослушивания изменений определенного узла в базе данных.
Чтобы прослушивать дочерние события в DatabaseReference
, прикрепите ChildEventListener
:
Слушатель | Обратный вызов события | Типичное использование |
---|---|---|
ChildEventListener | onChildAdded() | Получайте списки элементов или прослушивайте дополнения к списку элементов. Этот обратный вызов запускается один раз для каждого существующего дочернего элемента, а затем снова каждый раз, когда к указанному пути добавляется новый дочерний элемент. DataSnapshot , передаваемый прослушивателю, содержит данные нового дочернего элемента. |
onChildChanged() | Прослушивайте изменения элементов в списке. Это событие вызывается каждый раз, когда изменяется дочерний узел, включая любые изменения потомков дочернего узла. DataSnapshot , передаваемый прослушивателю событий, содержит обновленные данные для дочернего элемента. | |
onChildRemoved() | Прослушивайте удаление элементов из списка. DataSnapshot , передаваемый обратному вызову события, содержит данные об удаленном дочернем элементе. | |
onChildMoved() | Прослушивайте изменения порядка элементов в упорядоченном списке. Это событие срабатывает всякий раз, когда обратный вызов onChildChanged() запускается обновлением, которое вызывает изменение порядка дочернего элемента. Он используется с данными, упорядоченными с помощью orderByChild или orderByValue . |
Например, приложение для социальных блогов может использовать эти методы вместе для отслеживания активности в комментариях к публикации, как показано ниже:
Kotlin+KTX
val childEventListener = object : ChildEventListener { override fun onChildAdded(dataSnapshot: DataSnapshot, previousChildName: String?) { Log.d(TAG, "onChildAdded:" + dataSnapshot.key!!) // A new comment has been added, add it to the displayed list val comment = dataSnapshot.getValue<Comment>() // ... } override fun onChildChanged(dataSnapshot: DataSnapshot, previousChildName: String?) { Log.d(TAG, "onChildChanged: ${dataSnapshot.key}") // A comment has changed, use the key to determine if we are displaying this // comment and if so displayed the changed comment. val newComment = dataSnapshot.getValue<Comment>() val commentKey = dataSnapshot.key // ... } override fun onChildRemoved(dataSnapshot: DataSnapshot) { Log.d(TAG, "onChildRemoved:" + dataSnapshot.key!!) // A comment has changed, use the key to determine if we are displaying this // comment and if so remove it. val commentKey = dataSnapshot.key // ... } override fun onChildMoved(dataSnapshot: DataSnapshot, previousChildName: String?) { Log.d(TAG, "onChildMoved:" + dataSnapshot.key!!) // A comment has changed position, use the key to determine if we are // displaying this comment and if so move it. val movedComment = dataSnapshot.getValue<Comment>() val commentKey = dataSnapshot.key // ... } override fun onCancelled(databaseError: DatabaseError) { Log.w(TAG, "postComments:onCancelled", databaseError.toException()) Toast.makeText( context, "Failed to load comments.", Toast.LENGTH_SHORT, ).show() } } databaseReference.addChildEventListener(childEventListener)
Java
ChildEventListener childEventListener = new ChildEventListener() { @Override public void onChildAdded(DataSnapshot dataSnapshot, String previousChildName) { Log.d(TAG, "onChildAdded:" + dataSnapshot.getKey()); // A new comment has been added, add it to the displayed list Comment comment = dataSnapshot.getValue(Comment.class); // ... } @Override public void onChildChanged(DataSnapshot dataSnapshot, String previousChildName) { Log.d(TAG, "onChildChanged:" + dataSnapshot.getKey()); // A comment has changed, use the key to determine if we are displaying this // comment and if so displayed the changed comment. Comment newComment = dataSnapshot.getValue(Comment.class); String commentKey = dataSnapshot.getKey(); // ... } @Override public void onChildRemoved(DataSnapshot dataSnapshot) { Log.d(TAG, "onChildRemoved:" + dataSnapshot.getKey()); // A comment has changed, use the key to determine if we are displaying this // comment and if so remove it. String commentKey = dataSnapshot.getKey(); // ... } @Override public void onChildMoved(DataSnapshot dataSnapshot, String previousChildName) { Log.d(TAG, "onChildMoved:" + dataSnapshot.getKey()); // A comment has changed position, use the key to determine if we are // displaying this comment and if so move it. Comment movedComment = dataSnapshot.getValue(Comment.class); String commentKey = dataSnapshot.getKey(); // ... } @Override public void onCancelled(DatabaseError databaseError) { Log.w(TAG, "postComments:onCancelled", databaseError.toException()); Toast.makeText(mContext, "Failed to load comments.", Toast.LENGTH_SHORT).show(); } }; databaseReference.addChildEventListener(childEventListener);
Слушайте события значений
Хотя использование ChildEventListener
является рекомендуемым способом чтения списков данных, существуют ситуации, когда присоединение ValueEventListener
к ссылке на список может оказаться полезным.
Присоединение ValueEventListener
к списку данных вернет весь список данных в виде одного DataSnapshot
, который затем можно будет использовать в цикле для доступа к отдельным дочерним элементам.
Даже если запросу соответствует только одно совпадение, снимок по-прежнему представляет собой список; он содержит только один элемент. Чтобы получить доступ к элементу, вам нужно перебрать результат:
Kotlin+KTX
// My top posts by number of stars myTopPostsQuery.addValueEventListener(object : ValueEventListener { override fun onDataChange(dataSnapshot: DataSnapshot) { for (postSnapshot in dataSnapshot.children) { // TODO: handle the post } } override fun onCancelled(databaseError: DatabaseError) { // Getting Post failed, log a message Log.w(TAG, "loadPost:onCancelled", databaseError.toException()) // ... } })
Java
// My top posts by number of stars myTopPostsQuery.addValueEventListener(new ValueEventListener() { @Override public void onDataChange(@NonNull DataSnapshot dataSnapshot) { for (DataSnapshot postSnapshot: dataSnapshot.getChildren()) { // TODO: handle the post } } @Override public void onCancelled(@NonNull DatabaseError databaseError) { // Getting Post failed, log a message Log.w(TAG, "loadPost:onCancelled", databaseError.toException()); // ... } });
Этот шаблон может быть полезен, если вы хотите получить все дочерние элементы списка за одну операцию, а не прослушивать дополнительные события onChildAdded
.
Отключить прослушиватели
Обратные вызовы удаляются путем вызова метода removeEventListener()
в ссылке на базу данных Firebase.
Если прослушиватель был добавлен к местоположению данных несколько раз, он вызывается несколько раз для каждого события, и вам придется отсоединить его столько же раз, чтобы удалить его полностью.
Вызов метода removeEventListener()
для родительского прослушивателя не удаляет автоматически прослушиватели, зарегистрированные на его дочерних узлах; removeEventListener()
также должен быть вызван для всех дочерних прослушивателей, чтобы удалить обратный вызов.
Сортировка и фильтрация данных
Вы можете использовать класс Query
Realtime Database для получения данных, отсортированных по ключу, по значению или по значению дочернего элемента. Вы также можете отфильтровать отсортированный результат по определенному количеству результатов или диапазону ключей или значений.
Сортировка данных
Чтобы получить отсортированные данные, начните с указания одного из методов упорядочивания, чтобы определить, как упорядочиваются результаты:
Метод | Использование |
---|---|
orderByChild() | Упорядочите результаты по значению указанного дочернего ключа или вложенного дочернего пути. | orderByKey() | Упорядочить результаты по дочерним ключам. |
orderByValue() | Упорядочить результаты по дочерним значениям. |
Одновременно можно использовать только один метод order-by. Вызов метода упорядочивания несколько раз в одном и том же запросе приводит к ошибке.
В следующем примере показано, как можно получить список самых популярных сообщений пользователя, отсортированный по количеству звезд:
Kotlin+KTX
// My top posts by number of stars val myUserId = uid val myTopPostsQuery = databaseReference.child("user-posts").child(myUserId) .orderByChild("starCount") myTopPostsQuery.addChildEventListener(object : ChildEventListener { // TODO: implement the ChildEventListener methods as documented above // ... })
Java
// My top posts by number of stars String myUserId = getUid(); Query myTopPostsQuery = databaseReference.child("user-posts").child(myUserId) .orderByChild("starCount"); myTopPostsQuery.addChildEventListener(new ChildEventListener() { // TODO: implement the ChildEventListener methods as documented above // ... });
Это определяет запрос, который в сочетании с дочерним прослушивателем синхронизирует клиента с сообщениями пользователя из пути в базе данных на основе его идентификатора пользователя, упорядоченного по количеству звезд, полученных каждым сообщением. Этот метод использования идентификаторов в качестве ключей индекса называется разветвлением данных. Подробнее о нем можно прочитать в разделе «Структурирование базы данных» .
Вызов метода orderByChild()
указывает дочерний ключ, по которому упорядочиваются результаты. В этом случае сообщения сортируются по значению соответствующего дочернего элемента "starCount"
. Запросы также можно упорядочить по вложенным дочерним элементам, если у вас есть данные, которые выглядят следующим образом:
"posts": { "ts-functions": { "metrics": { "views" : 1200000, "likes" : 251000, "shares": 1200, }, "title" : "Why you should use TypeScript for writing Cloud Functions", "author": "Doug", }, "android-arch-3": { "metrics": { "views" : 900000, "likes" : 117000, "shares": 144, }, "title" : "Using Android Architecture Components with Firebase Realtime Database (Part 3)", "author": "Doug", } },
В этом примере мы можем упорядочить элементы нашего списка по значениям, вложенным в ключ metrics
, указав относительный путь к вложенному дочернему элементу в нашем вызове orderByChild()
.
Kotlin+KTX
// Most viewed posts val myMostViewedPostsQuery = databaseReference.child("posts") .orderByChild("metrics/views") myMostViewedPostsQuery.addChildEventListener(object : ChildEventListener { // TODO: implement the ChildEventListener methods as documented above // ... })
Java
// Most viewed posts Query myMostViewedPostsQuery = databaseReference.child("posts") .orderByChild("metrics/views"); myMostViewedPostsQuery.addChildEventListener(new ChildEventListener() { // TODO: implement the ChildEventListener methods as documented above // ... });
Дополнительные сведения о том, как упорядочиваются другие типы данных, см. в разделе Как упорядочиваются данные запроса .
Фильтрация данных
Чтобы фильтровать данные, вы можете комбинировать любой метод ограничения или диапазона с методом упорядочивания при построении запроса.
Метод | Использование |
---|---|
limitToFirst() | Устанавливает максимальное количество возвращаемых элементов с начала упорядоченного списка результатов. |
limitToLast() | Устанавливает максимальное количество элементов, возвращаемых с конца упорядоченного списка результатов. |
startAt() | Возвращает элементы, которые больше или равны указанному ключу или значению в зависимости от выбранного метода упорядочения. |
startAfter() | Возвращает элементы, превышающие указанный ключ или значение, в зависимости от выбранного метода упорядочения. |
endAt() | Возвращает элементы, меньшие или равные указанному ключу или значению, в зависимости от выбранного метода упорядочения. |
endBefore() | Возвращает элементы, меньшие указанного ключа или значения, в зависимости от выбранного метода упорядочения. |
equalTo() | Возвращает элементы, равные указанному ключу или значению, в зависимости от выбранного метода упорядочения. |
В отличие от методов упорядочивания, вы можете комбинировать несколько функций ограничения или диапазона. Например, вы можете объединить методы startAt()
и endAt()
чтобы ограничить результаты указанным диапазоном значений.
Даже если запросу соответствует только одно совпадение, снимок по-прежнему представляет собой список; он содержит только один элемент. Чтобы получить доступ к элементу, вам нужно перебрать результат:
Kotlin+KTX
// My top posts by number of stars myTopPostsQuery.addValueEventListener(object : ValueEventListener { override fun onDataChange(dataSnapshot: DataSnapshot) { for (postSnapshot in dataSnapshot.children) { // TODO: handle the post } } override fun onCancelled(databaseError: DatabaseError) { // Getting Post failed, log a message Log.w(TAG, "loadPost:onCancelled", databaseError.toException()) // ... } })
Java
// My top posts by number of stars myTopPostsQuery.addValueEventListener(new ValueEventListener() { @Override public void onDataChange(@NonNull DataSnapshot dataSnapshot) { for (DataSnapshot postSnapshot: dataSnapshot.getChildren()) { // TODO: handle the post } } @Override public void onCancelled(@NonNull DatabaseError databaseError) { // Getting Post failed, log a message Log.w(TAG, "loadPost:onCancelled", databaseError.toException()); // ... } });
Ограничить количество результатов
Вы можете использовать методы limitToFirst()
и limitToLast()
чтобы установить максимальное количество дочерних элементов, которые будут синхронизироваться для данного обратного вызова. Например, если вы используете limitToFirst()
для установки ограничения в 100, изначально вы получаете только до 100 обратных вызовов onChildAdded()
. Если в вашей базе данных Firebase хранится менее 100 элементов, для каждого элемента срабатывает обратный вызов onChildAdded()
.
По мере изменения элементов вы получаете обратные вызовы onChildAdded()
для элементов, которые входят в запрос, и обратные вызовы onChildRemoved()
для элементов, которые исключаются из него, так что общее число остается равным 100.
В следующем примере показано, как приложение для ведения блога определяет запрос для получения списка из 100 последних сообщений всех пользователей:
Kotlin+KTX
// Last 100 posts, these are automatically the 100 most recent // due to sorting by push() keys. databaseReference.child("posts").limitToFirst(100)
Java
// Last 100 posts, these are automatically the 100 most recent // due to sorting by push() keys Query recentPostsQuery = databaseReference.child("posts") .limitToFirst(100);
В этом примере определяется только запрос. Для фактической синхронизации данных необходимо иметь подключенный прослушиватель .
Фильтровать по ключу или значению
Вы можете использовать startAt()
, startAfter()
, endAt()
, endBefore()
и equalTo()
для выбора произвольных начальных, конечных и эквивалентных точек для запросов. Это может быть полезно для разбивки данных на страницы или поиска элементов с дочерними элементами, имеющими определенное значение.
Как упорядочиваются данные запроса
В этом разделе объясняется, как данные сортируются каждым из методов упорядочивания в классе Query
.
orderByChild
При использовании orderByChild()
данные, содержащие указанный дочерний ключ, упорядочиваются следующим образом:
- Дочерние элементы с
null
значением для указанного дочернего ключа идут первыми. - Следующими идут дочерние элементы со значением
false
для указанного дочернего ключа. Если несколько дочерних элементов имеют значениеfalse
, они сортируются лексикографически по ключу. - Следующими идут дочерние элементы со значением
true
для указанного дочернего ключа. Если несколько дочерних элементов имеют значениеtrue
, они сортируются лексикографически по ключу. - Следующими идут дети с числовым значением, отсортированные в порядке возрастания. Если несколько дочерних узлов имеют одинаковое числовое значение для указанного дочернего узла, они сортируются по ключу.
- Строки идут после чисел и сортируются лексикографически по возрастанию. Если несколько дочерних узлов имеют одинаковое значение для указанного дочернего узла, они упорядочиваются лексикографически по ключу.
- Объекты идут последними и сортируются лексикографически по ключу в порядке возрастания.
orderByKey
При использовании orderByKey()
для сортировки данных данные возвращаются в порядке возрастания ключа.
- Первыми идут дочерние элементы с ключом, который можно проанализировать как 32-битное целое число, отсортированное в порядке возрастания.
- Следующими идут дочерние элементы со строковым значением в качестве ключа, отсортированные лексикографически в порядке возрастания.
orderByValue
При использовании orderByValue()
дочерние элементы упорядочиваются по их значению. Критерии упорядочивания такие же, как и в orderByChild()
, за исключением того, что вместо значения указанного дочернего ключа используется значение узла.