Firebase hadir kembali di Google I/O pada 10 Mei. Daftar sekarang

Menghitung dokumen dengan kueri agregasi

Tetap teratur dengan koleksi Simpan dan kategorikan konten berdasarkan preferensi Anda.

Kueri agregasi memproses data dari beberapa entri indeks untuk menampilkan satu nilai ringkasan.

Cloud Firestore mendukung kueri agregasi count(). count() memungkinkan Anda menentukan jumlah dokumen dalam koleksi atau kueri. Server menghitung jumlah dan hanya mentransmisikan hasil, yaitu bilangan bulat tunggal, kembali ke aplikasi Anda sehingga menghemat pembacaan dokumen yang ditagih dan byte yang ditransfer, dibandingkan dengan menjalankan kueri penuh.

Kueri agregasi bergantung pada konfigurasi indeks yang ada yang sudah digunakan kueri, dan diskalakan secara proporsional dengan jumlah entri indeks yang dipindai. Ini berarti agregasi set data berukuran kecil hingga sedang berfungsi dalam 20-40 milidetik, meskipun latensi meningkat seiring bertambahnya jumlah item yang dihitung.

Menggunakan agregasi count()

Lihat contoh data yang kami siapkan di Mendapatkan data.

Agregasi count() berikut menampilkan jumlah total kota dalam koleksi cities.

Web version 9

const coll = collection(db, "cities");
const snapshot = await getCountFromServer(coll);
console.log('count: ', snapshot.data().count);
count_aggregate_collection.js
Swift
Catatan: Produk ini tidak tersedia di target watchOS dan App Clip. 
let query = db.collection("cities")
let countQuery = query.count
do {
    let snapshot = try await countQuery.getAggregation(source: .server)
    print(snapshot.count)
} catch {
    print(error);
}
ViewController.swift
Objective-C
Catatan: Produk ini tidak tersedia di target watchOS dan App Clip. 
FIRCollectionReference *query = [self.db collectionWithPath:@"cities"];
[query.count aggregationWithSource:FIRAggregateSourceServer
                        completion:^(FIRAggregateQuerySnapshot *snapshot,
                                     NSError *error) {
    if (error != nil) {
        NSLog(@"Error fetching count: %@", error);
    } else {
        NSLog(@"Cities count: %@", snapshot.count);
    }
}];
ViewController.m

Java

Query query = db.collection("cities");
AggregateQuery countQuery = query.count();
countQuery.get(AggregateSource.SERVER).addOnCompleteListener(new OnCompleteListener<AggregateQuerySnapshot>() {
    @Override
    public void onComplete(@NonNull Task<AggregateQuerySnapshot> task) {
        if (task.isSuccessful()) {
            // Count fetched successfully
            AggregateQuerySnapshot snapshot = task.getResult();
            Log.d(TAG, "Count: " + snapshot.getCount());
        } else {
            Log.d(TAG, "Count failed: ", task.getException());
        }
    }
});
DocSnippets.java

Kotlin+KTX

val query = db.collection("cities")
val countQuery = query.count()
countQuery.get(AggregateSource.SERVER).addOnCompleteListener { task ->
    if (task.isSuccessful) {
        // Count fetched successfully
        val snapshot = task.result
        Log.d(TAG, "Count: ${snapshot.count}")
    } else {
        Log.d(TAG, "Count failed: ", task.getException())
    }
}
DocSnippets.kt

Java

CollectionReference collection = db.collection("cities");
AggregateQuery countQuery = collection.count();
countQuery.get(AggregateSource.SERVER).addOnCompleteListener(task -> {
  if (task.isSuccessful()) {
    AggregateQuerySnapshot snapshot = task.getResult();
    Log.d(TAG, "Count: " + snapshot.getCount());
  } else {
    Log.d(TAG, "Count failed: ", task.getException());
  }
});
Java
CollectionReference collection = db.collection("cities");
AggregateQuerySnapshot snapshot = collection.count().get().get();
System.out.println("Count: " + snapshot.getCount());
Node.js
const collectionRef = db.collection('cities');
const snapshot = await collectionRef.count().get();
console.log(snapshot.data().count);

Agregasi count() memperhitungkan semua filter pada kueri dan klausa limit. Misalnya, agregasi berikut menampilkan hitungan jumlah kota dengan state sama dengan CA.

Web version 9

const coll = collection(db, "cities");
const q = query(coll, where("state", "==", "CA"));
const snapshot = await getCountFromServer(q);
console.log('count: ', snapshot.data().count);
count_aggregate_query.js
Swift
Catatan: Produk ini tidak tersedia di target watchOS dan App Clip. 
let query = db.collection("cities").whereField("state", isEqualTo: "CA")
let countQuery = query.count
do {
    let snapshot = try await countQuery.getAggregation(source: .server)
    print(snapshot.count)
} catch {
    print(error);
}
ViewController.swift
Objective-C
Catatan: Produk ini tidak tersedia di target watchOS dan App Clip. 
FIRQuery *query =
    [[self.db collectionWithPath:@"cities"]
                 queryWhereField:@"state"
                       isEqualTo:@"CA"];
[query.count aggregationWithSource:FIRAggregateSourceServer
                        completion:^(FIRAggregateQuerySnapshot *snapshot,
                                      NSError *error) {
    if (error != nil) {
        NSLog(@"Error fetching count: %@", error);
    } else {
        NSLog(@"Cities count: %@", snapshot.count);
    }
}];
ViewController.m

Java

Query query = db.collection("cities").whereEqualTo("state", "CA");
AggregateQuery countQuery = query.count();
countQuery.get(AggregateSource.SERVER).addOnCompleteListener(new OnCompleteListener<AggregateQuerySnapshot>() {
    @Override
    public void onComplete(@NonNull Task<AggregateQuerySnapshot> task) {
        if (task.isSuccessful()) {
            // Count fetched successfully
            AggregateQuerySnapshot snapshot = task.getResult();
            Log.d(TAG, "Count: " + snapshot.getCount());
        } else {
            Log.d(TAG, "Count failed: ", task.getException());
        }
    }
});
DocSnippets.java

Kotlin+KTX

val query = db.collection("cities").whereEqualTo("state", "CA")
val countQuery = query.count()
countQuery.get(AggregateSource.SERVER).addOnCompleteListener { task ->
    if (task.isSuccessful) {
        // Count fetched successfully
        val snapshot = task.result
        Log.d(TAG, "Count: ${snapshot.count}")
    } else {
        Log.d(TAG, "Count failed: ", task.getException())
    }
}
DocSnippets.kt

Java

CollectionReference collection = db.collection("cities");
Query query = collection.whereEqualTo("state", "CA");
AggregateQuery countQuery = query.count();
countQuery.get(AggregateSource.SERVER).addOnCompleteListener(task -> {
  if (task.isSuccessful()) {
    AggregateQuerySnapshot snapshot = task.getResult();
    Log.d(TAG, "Count: " + snapshot.getCount());
  } else {
    Log.d(TAG, "Count failed: ", task.getException());
  }
});
Java
CollectionReference collection = db.collection("cities");
Query query = collection.whereEqualTo("state", "CA");
AggregateQuerySnapshot snapshot = query.count().get().get();
System.out.println("Count: " + snapshot.getCount());
Node.js
const collectionRef = db.collection('cities');
const query = collectionRef.where('state', '==', 'CA');
const snapshot = await query.count().get();
console.log(snapshot.data().count);

Aturan Keamanan Cloud Firestore berfungsi sama pada kueri agregasi count() seperti pada kueri normal yang menampilkan dokumen. Dengan kata lain, jika dan hanya jika aturan Anda mengizinkan klien untuk mengeksekusi kueri koleksi atau grup koleksi tertentu, klien juga dapat melakukan agregasi count() pada kueri tersebut. Pelajari lebih lanjut cara Aturan Keamanan Cloud Firestore berinteraksi dengan kueri.

Batasan

Perhatikan batasan berikut pada kueri agregasi count():

  • Kueri agregasi count() saat ini hanya didukung melalui respons server langsung. Kueri hanya ditayangkan oleh backend Cloud Firestore, serta melewati cache lokal dan update yang di buffer. Perilaku ini sama dengan operasi yang dilakukan di dalam transaksi Cloud Firestore. Saat ini Anda tidak dapat menggunakan kueri count() dengan pemroses real-time dan kueri offline.

  • Jika agregasi count() tidak dapat diselesaikan dalam waktu 60 detik, error DEADLINE_EXCEEDED akan ditampilkan. Performa bergantung pada konfigurasi indeks Anda dan ukuran set data.

    Jika operasi tidak dapat diselesaikan dalam batas waktu 60 detik, solusi yang memungkinkan adalah menggunakan penghitung untuk set data besar.

  • Agregasi count() membaca dari entri indeks dan hanya menghitung kolom terindeks.

  • Menambahkan klausa OrderBy ke kueri akan membatasi jumlah pada entity tempat properti pengurutan berada.

Harga

Harga untuk count() bergantung pada jumlah entri indeks yang cocok dengan kueri. Anda akan dikenai biaya dalam jumlah kecil untuk pembacaan dalam jumlah yang sesuai.

Lihat informasi harga yang lebih mendetail.