Skip to content

Commit 95d5b66

Browse files
committed
add basic read snippet
1 parent 4c5ad18 commit 95d5b66

File tree

2 files changed

+42
-0
lines changed

2 files changed

+42
-0
lines changed

firestore/app/src/main/java/com/google/example/firestore/DocSnippets.java

Lines changed: 24 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -55,6 +55,7 @@
5555
import java.util.concurrent.TimeUnit;
5656
import com.google.firebase.firestore.GeoPoint;
5757
import com.google.firebase.firestore.Pipeline;
58+
import com.google.firebase.firestore.PipelineResult;
5859
import com.google.firebase.firestore.PipelineSource;
5960
import com.google.firebase.firestore.VectorValue;
6061
import com.google.firebase.firestore.pipeline.AggregateFunction;
@@ -1586,6 +1587,29 @@ void pipelineConcepts() {
15861587
System.out.println(pipeline);
15871588
}
15881589

1590+
void basicPipelineRead() {
1591+
// [START basic_pipeline_read]
1592+
Pipeline readDataPipeline = db.pipeline()
1593+
.collection("users");
1594+
1595+
readDataPipeline.execute()
1596+
.addOnSuccessListener(new OnSuccessListener<Pipeline.Snapshot>() {
1597+
@Override
1598+
public void onSuccess(Pipeline.Snapshot snapshot) {
1599+
for (PipelineResult result : snapshot.getResults()) {
1600+
System.out.println(result.getId() + " => " + result.getData());
1601+
}
1602+
}
1603+
})
1604+
.addOnFailureListener(new OnFailureListener() {
1605+
@Override
1606+
public void onFailure(@NonNull Exception e) {
1607+
System.out.println("Error getting documents: " + e);
1608+
}
1609+
});
1610+
// [END basic_pipeline_read]
1611+
}
1612+
15891613
// https://cloud.google.com/firestore/docs/pipeline/overview#initialization
15901614
void pipelineInitialization() {
15911615
// [START pipeline_initialization]

firestore/app/src/main/java/com/google/example/firestore/kotlin/DocSnippets.kt

Lines changed: 18 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -1343,6 +1343,24 @@ abstract class DocSnippets(val db: FirebaseFirestore) {
13431343
println(pipeline)
13441344
}
13451345

1346+
fun basicPipelineRead() {
1347+
// [START basic_pipeline_read]
1348+
val readDataPipeline = db.pipeline()
1349+
.collection("users")
1350+
1351+
// Execute the pipeline and handle the result
1352+
readDataPipeline.execute()
1353+
.addOnSuccessListener { result ->
1354+
for (document in result) {
1355+
println("${document.getId()} => ${document.getData()}")
1356+
}
1357+
}
1358+
.addOnFailureListener { exception ->
1359+
println("Error getting documents: $exception")
1360+
}
1361+
// [END basic_pipeline_read]
1362+
}
1363+
13461364
// https://cloud.google.com/firestore/docs/pipeline/overview#initialization
13471365
fun pipelineInitialization() {
13481366
// [START pipeline_initialization]

0 commit comments

Comments
 (0)