অ্যান্ড্রয়েডে ডেটা পড়ুন এবং লিখুন

এই ডকুমেন্টে ফায়ারবেস ডেটা পড়া এবং লেখার প্রাথমিক বিষয়গুলো আলোচনা করা হয়েছে।

ফায়ারবেস ডেটা একটি FirebaseDatabase রেফারেন্সে লেখা হয় এবং সেই রেফারেন্সে একটি অ্যাসিঙ্ক্রোনাস লিসেনার সংযুক্ত করে তা পুনরুদ্ধার করা হয়। ডেটার প্রাথমিক অবস্থার জন্য লিসেনারটি একবার ট্রিগার হয় এবং ডেটা পরিবর্তিত হলেই আবার ট্রিগার হয়।

(ঐচ্ছিক) Firebase Local Emulator Suite দিয়ে প্রোটোটাইপ এবং পরীক্ষা করুন

আপনার অ্যাপ কীভাবে Realtime Database থেকে ডেটা পড়ে এবং লেখে, সে সম্পর্কে কথা বলার আগে, চলুন এমন কিছু টুলের সাথে পরিচয় করিয়ে দিই যা আপনি Realtime Database কার্যকারিতা প্রোটোটাইপ এবং পরীক্ষা করার জন্য ব্যবহার করতে পারেন: Firebase Local Emulator Suite । আপনি যদি বিভিন্ন ডেটা মডেল পরীক্ষা করে দেখেন, আপনার নিরাপত্তা নিয়মগুলো অপ্টিমাইজ করেন, অথবা ব্যাক-এন্ডের সাথে ইন্টারঅ্যাক্ট করার সবচেয়ে সাশ্রয়ী উপায় খুঁজে বের করার চেষ্টা করেন, তবে লাইভ সার্ভিস ডেপ্লয় না করে স্থানীয়ভাবে কাজ করতে পারাটা একটি দারুণ ব্যাপার হতে পারে।

একটি Realtime Database এমুলেটর হলো Local Emulator Suite একটি অংশ, যা আপনার অ্যাপকে আপনার এমুলেটেড ডেটাবেসের বিষয়বস্তু ও কনফিগারেশনের সাথে, এবং ঐচ্ছিকভাবে আপনার এমুলেটেড প্রোজেক্ট রিসোর্সগুলোর (ফাংশন, অন্যান্য ডেটাবেস এবং নিরাপত্তা বিধি) সাথে ইন্টারঅ্যাক্ট করতে সক্ষম করে।

Realtime Database এমুলেটর ব্যবহার করতে মাত্র কয়েকটি ধাপ অনুসরণ করতে হয়:

  1. এমুলেটরের সাথে সংযোগ করার জন্য আপনার অ্যাপের টেস্ট কনফিগ-এ একটি কোড লাইন যোগ করুন।
  2. আপনার স্থানীয় প্রজেক্ট ডিরেক্টরির রুট থেকে firebase emulators:start চালান।
  3. আপনার অ্যাপের প্রোটোটাইপ কোড থেকে যথারীতি Realtime Database প্ল্যাটফর্ম SDK ব্যবহার করে, অথবা Realtime Database REST API ব্যবহার করে কল করা।

Realtime Database এবং Cloud Functions সম্পর্কিত একটি বিস্তারিত নির্দেশিকা উপলব্ধ আছে। আপনার Local Emulator Suite পরিচিতিটিও দেখে নেওয়া উচিত।

একটি ডেটাবেস রেফারেন্স পান

ডাটাবেস থেকে ডেটা পড়তে বা লিখতে, আপনার DatabaseReference এর একটি ইনস্ট্যান্স প্রয়োজন।

Kotlin 

private lateinit var database: DatabaseReference
// ...
database = Firebase.database.reference
ReadAndWriteSnippets.kt

Java 

private DatabaseReference mDatabase;
// ...
mDatabase = FirebaseDatabase.getInstance().getReference();
ReadAndWriteSnippets.java

ডেটা লিখুন

মৌলিক লেখার ক্রিয়াকলাপ

সাধারণ রাইট অপারেশনের জন্য, আপনি setValue() ব্যবহার করে একটি নির্দিষ্ট রেফারেন্সে ডেটা সেভ করতে পারেন, যা ওই পাথে থাকা যেকোনো ডেটাকে প্রতিস্থাপন করে। আপনি এই মেথডটি ব্যবহার করতে পারেন:

  • উপলব্ধ JSON টাইপগুলোর সাথে সঙ্গতিপূর্ণ টাইপগুলো নিম্নরূপে পাস করুন:
    • String
    • Long
    • Double
    • Boolean
    • Map<String, Object>
    • List<Object>
  • একটি কাস্টম জাভা অবজেক্ট পাস করুন, যদি সেটিকে সংজ্ঞায়িতকারী ক্লাসটির একটি ডিফল্ট কনস্ট্রাক্টর থাকে যা কোনো আর্গুমেন্ট গ্রহণ করে না এবং অ্যাসাইন করার জন্য প্রোপার্টিগুলোর পাবলিক গেটার থাকে।

আপনি যদি একটি জাভা অবজেক্ট ব্যবহার করেন, তাহলে আপনার অবজেক্টের বিষয়বস্তু স্বয়ংক্রিয়ভাবে নেস্টেড পদ্ধতিতে চাইল্ড লোকেশনে ম্যাপ হয়ে যায়। জাভা অবজেক্ট ব্যবহার করলে সাধারণত আপনার কোড আরও সহজে পাঠযোগ্য এবং রক্ষণাবেক্ষণ করা সহজ হয়। উদাহরণস্বরূপ, আপনার যদি একটি সাধারণ ইউজার প্রোফাইলসহ কোনো অ্যাপ থাকে, তাহলে আপনার User অবজেক্টটি দেখতে নিচের মতো হতে পারে:

Kotlin 

@IgnoreExtraProperties
data class User(val username: String? = null, val email: String? = null) {
    // Null default values create a no-argument default constructor, which is needed
    // for deserialization from a DataSnapshot.
}
User.kt

Java 

@IgnoreExtraProperties
public class User {

    public String username;
    public String email;

    public User() {
        // Default constructor required for calls to DataSnapshot.getValue(User.class)
    }

    public User(String username, String email) {
        this.username = username;
        this.email = email;
    }

}
User.java

আপনি setValue() ব্যবহার করে নিম্নলিখিতভাবে একজন ব্যবহারকারী যোগ করতে পারেন:

Kotlin 

fun writeNewUser(userId: String, name: String, email: String) {
    val user = User(name, email)

    database.child("users").child(userId).setValue(user)
}
ReadAndWriteSnippets.kt

Java 

public void writeNewUser(String userId, String name, String email) {
    User user = new User(name, email);

    mDatabase.child("users").child(userId).setValue(user);
}
ReadAndWriteSnippets.java

এইভাবে setValue() ব্যবহার করলে নির্দিষ্ট স্থানের ডেটা ওভাররাইট হয়ে যায়, যার মধ্যে যেকোনো চাইল্ড নোডও অন্তর্ভুক্ত থাকে। তবে, আপনি পুরো অবজেক্টটি পুনরায় না লিখেও একটি চাইল্ডকে আপডেট করতে পারেন। আপনি যদি ব্যবহারকারীদের তাদের প্রোফাইল আপডেট করার অনুমতি দিতে চান, তাহলে আপনি নিম্নলিখিতভাবে ইউজারনেম আপডেট করতে পারেন:

Kotlin 

database.child("users").child(userId).child("username").setValue(name)

Java 

mDatabase.child("users").child(userId).child("username").setValue(name);

ডেটা পড়ুন

স্থায়ী লিসেনার ব্যবহার করে ডেটা পড়ুন

কোনো পাথের ডেটা পড়তে এবং পরিবর্তনের জন্য নজর রাখতে, একটি DatabaseReference এ ValueEventListener যোগ করার জন্য addValueEventListener() মেথডটি ব্যবহার করুন।

শ্রোতা ইভেন্ট কলব্যাক সাধারণ ব্যবহার
ValueEventListener onDataChange() একটি পাথের সম্পূর্ণ বিষয়বস্তুর পরিবর্তনগুলো পড়ুন এবং শুনুন।

আপনি onDataChange() মেথডটি ব্যবহার করে একটি নির্দিষ্ট পাথের বিষয়বস্তুর একটি স্ট্যাটিক স্ন্যাপশট পড়তে পারেন, যা ইভেন্টের সময় যেমন ছিল। এই মেথডটি লিসেনার সংযুক্ত হওয়ার সময় একবার এবং চাইল্ডসহ ডেটা প্রতিবার পরিবর্তিত হলে আবার ট্রিগার হয়। ইভেন্ট কলব্যাকে একটি স্ন্যাপশট পাস করা হয়, যাতে চাইল্ড ডেটাসহ সেই লোকেশনের সমস্ত ডেটা থাকে। যদি কোনো ডেটা না থাকে, তাহলে আপনি exists() কল করলে স্ন্যাপশটটি false রিটার্ন করবে এবং getValue() কল করলে null রিটার্ন করবে।

নিম্নলিখিত উদাহরণটি একটি সোশ্যাল ব্লগিং অ্যাপ্লিকেশন প্রদর্শন করে যা ডাটাবেস থেকে একটি পোস্টের বিবরণ পুনরুদ্ধার করে:

Kotlin 

val postListener = object : ValueEventListener {
    override fun onDataChange(dataSnapshot: DataSnapshot) {
        // Get Post object and use the values to update the UI
        val post = dataSnapshot.getValue<Post>()
        // ...
    }

    override fun onCancelled(databaseError: DatabaseError) {
        // Getting Post failed, log a message
        Log.w(TAG, "loadPost:onCancelled", databaseError.toException())
    }
}
postReference.addValueEventListener(postListener)
ReadAndWriteSnippets.kt

Java 

ValueEventListener postListener = new ValueEventListener() {
    @Override
    public void onDataChange(DataSnapshot dataSnapshot) {
        // Get Post object and use the values to update the UI
        Post post = dataSnapshot.getValue(Post.class);
        // ..
    }

    @Override
    public void onCancelled(DatabaseError databaseError) {
        // Getting Post failed, log a message
        Log.w(TAG, "loadPost:onCancelled", databaseError.toException());
    }
};
mPostReference.addValueEventListener(postListener);
ReadAndWriteSnippets.java

লিসেনার একটি DataSnapshot গ্রহণ করে, যাতে ইভেন্টের সময় ডাটাবেসের নির্দিষ্ট অবস্থানে থাকা ডেটা থাকে। একটি স্ন্যাপশটের উপর getValue() কল করলে ডেটার জাভা অবজেক্ট রিপ্রেজেন্টেশন ফেরত আসে। যদি সেই অবস্থানে কোনো ডেটা না থাকে, তাহলে getValue() কল করলে null ফেরত আসে।

এই উদাহরণে, ValueEventListener onCancelled() মেথডটিও সংজ্ঞায়িত করা হয়েছে, যা রিড বাতিল করা হলে কল করা হয়। উদাহরণস্বরূপ, কোনো ক্লায়েন্টের যদি ফায়ারবেস ডাটাবেস লোকেশন থেকে রিড করার অনুমতি না থাকে, তবে একটি রিড বাতিল করা যেতে পারে। এই মেথডটিতে একটি DatabaseError অবজেক্ট পাস করা হয়, যা ব্যর্থতার কারণ নির্দেশ করে।

ডেটা একবার পড়ুন

get() ব্যবহার করে একবার পড়ুন

আপনার অ্যাপ অনলাইন বা অফলাইন যাই থাকুক না কেন, ডাটাবেস সার্ভারের সাথে যোগাযোগ পরিচালনার জন্য এই SDK-টি ডিজাইন করা হয়েছে।

সাধারণত, ব্যাকএন্ড থেকে ডেটার আপডেটের নোটিফিকেশন পেতে আপনার উপরে বর্ণিত ValueEventListener টেকনিকগুলো ব্যবহার করা উচিত। এই লিসেনার টেকনিকগুলো আপনার ব্যবহার ও বিলিং কমায় এবং ব্যবহারকারীরা অনলাইন ও অফলাইন উভয় অবস্থাতেই যাতে সেরা অভিজ্ঞতা পান, সেজন্য এগুলোকে অপ্টিমাইজ করা হয়।

আপনার যদি ডেটা শুধু একবারই প্রয়োজন হয়, তাহলে ডাটাবেস থেকে ডেটার একটি স্ন্যাপশট নিতে আপনি get() ব্যবহার করতে পারেন। যদি কোনো কারণে get() সার্ভারের মান ফেরত দিতে না পারে, তাহলে ক্লায়েন্ট স্থানীয় স্টোরেজ ক্যাশে অনুসন্ধান করবে এবং তারপরেও মানটি খুঁজে না পেলে একটি ত্রুটি ফেরত দেবে।

get() এর অপ্রয়োজনীয় ব্যবহার ব্যান্ডউইথের ব্যবহার বাড়িয়ে দিতে পারে এবং পারফরম্যান্সের অবনতি ঘটাতে পারে, যা উপরে দেখানো পদ্ধতি অনুযায়ী একটি রিয়েলটাইম লিসেনার ব্যবহার করে প্রতিরোধ করা যায়।

Kotlin 

mDatabase.child("users").child(userId).get().addOnSuccessListener {
    Log.i("firebase", "Got value ${it.value}")
}.addOnFailureListener{
    Log.e("firebase", "Error getting data", it)
}

Java 

mDatabase.child("users").child(userId).get().addOnCompleteListener(new OnCompleteListener<DataSnapshot>() {
    @Override
    public void onComplete(@NonNull Task<DataSnapshot> task) {
        if (!task.isSuccessful()) {
            Log.e("firebase", "Error getting data", task.getException());
        }
        else {
            Log.d("firebase", String.valueOf(task.getResult().getValue()));
        }
    }
});

লিসেনার ব্যবহার করে একবার পড়ুন

কিছু ক্ষেত্রে, সার্ভারে আপডেট হওয়া মান পরীক্ষা করার পরিবর্তে, আপনি স্থানীয় ক্যাশে থেকে মানটি অবিলম্বে ফেরত পেতে চাইতে পারেন। সেইসব ক্ষেত্রে, স্থানীয় ডিস্ক ক্যাশে থেকে অবিলম্বে ডেটা পেতে আপনি addListenerForSingleValueEvent ব্যবহার করতে পারেন।

এটি এমন ডেটার জন্য উপযোগী যা কেবল একবার লোড করা প্রয়োজন এবং যা ঘন ঘন পরিবর্তন হবে বলে আশা করা যায় না বা যার জন্য সক্রিয়ভাবে পর্যবেক্ষণের প্রয়োজন হয় না। উদাহরণস্বরূপ, পূর্ববর্তী উদাহরণগুলিতে থাকা ব্লগিং অ্যাপটি কোনো ব্যবহারকারী যখন একটি নতুন পোস্ট লেখা শুরু করেন, তখন তার প্রোফাইল লোড করার জন্য এই পদ্ধতিটি ব্যবহার করে।

ডেটা আপডেট বা মুছে ফেলা

নির্দিষ্ট ক্ষেত্রগুলি আপডেট করুন

কোনো নোডের অন্যান্য চাইল্ড নোড ওভাররাইট না করে একই সাথে নির্দিষ্ট চাইল্ড নোডগুলোতে লেখার জন্য, updateChildren() মেথডটি ব্যবহার করুন।

updateChildren() কল করার সময়, আপনি key-এর জন্য একটি path নির্দিষ্ট করে নিম্ন-স্তরের চাইল্ড ভ্যালুগুলো আপডেট করতে পারেন। যদি আরও ভালোভাবে স্কেল করার জন্য ডেটা একাধিক স্থানে সংরক্ষিত থাকে, তাহলে আপনি data fan-out ব্যবহার করে সেই ডেটার সমস্ত ইনস্ট্যান্স আপডেট করতে পারেন। উদাহরণস্বরূপ, একটি সোশ্যাল ব্লগিং অ্যাপে এইরকম একটি Post ক্লাস থাকতে পারে:

Kotlin 

@IgnoreExtraProperties
data class Post(
    var uid: String? = "",
    var author: String? = "",
    var title: String? = "",
    var body: String? = "",
    var starCount: Int = 0,
    var stars: MutableMap<String, Boolean> = HashMap(),
) {

    @Exclude
    fun toMap(): Map<String, Any?> {
        return mapOf(
            "uid" to uid,
            "author" to author,
            "title" to title,
            "body" to body,
            "starCount" to starCount,
            "stars" to stars,
        )
    }
}
Post.kt

Java 

@IgnoreExtraProperties
public class Post {

    public String uid;
    public String author;
    public String title;
    public String body;
    public int starCount = 0;
    public Map<String, Boolean> stars = new HashMap<>();

    public Post() {
        // Default constructor required for calls to DataSnapshot.getValue(Post.class)
    }

    public Post(String uid, String author, String title, String body) {
        this.uid = uid;
        this.author = author;
        this.title = title;
        this.body = body;
    }

    @Exclude
    public Map<String, Object> toMap() {
        HashMap<String, Object> result = new HashMap<>();
        result.put("uid", uid);
        result.put("author", author);
        result.put("title", title);
        result.put("body", body);
        result.put("starCount", starCount);
        result.put("stars", stars);

        return result;
    }
}
Post.java

একটি পোস্ট তৈরি করতে এবং একই সাথে সেটিকে সাম্প্রতিক কার্যকলাপ ফিড ও পোস্টকারী ব্যবহারকারীর কার্যকলাপ ফিডে আপডেট করতে, ব্লগিং অ্যাপ্লিকেশনটি এই ধরনের কোড ব্যবহার করে:

Kotlin 

private fun writeNewPost(userId: String, username: String, title: String, body: String) {
    // Create new post at /user-posts/$userid/$postid and at
    // /posts/$postid simultaneously
    val key = database.child("posts").push().key
    if (key == null) {
        Log.w(TAG, "Couldn't get push key for posts")
        return
    }

    val post = Post(userId, username, title, body)
    val postValues = post.toMap()

    val childUpdates = hashMapOf<String, Any>(
        "/posts/$key" to postValues,
        "/user-posts/$userId/$key" to postValues,
    )

    database.updateChildren(childUpdates)
}
ReadAndWriteSnippets.kt

Java 

private void writeNewPost(String userId, String username, String title, String body) {
    // Create new post at /user-posts/$userid/$postid and at
    // /posts/$postid simultaneously
    String key = mDatabase.child("posts").push().getKey();
    Post post = new Post(userId, username, title, body);
    Map<String, Object> postValues = post.toMap();

    Map<String, Object> childUpdates = new HashMap<>();
    childUpdates.put("/posts/" + key, postValues);
    childUpdates.put("/user-posts/" + userId + "/" + key, postValues);

    mDatabase.updateChildren(childUpdates);
}
ReadAndWriteSnippets.java

এই উদাহরণে /posts/$postid এ সকল ব্যবহারকারীর পোস্ট ধারণকারী নোডে একটি পোস্ট তৈরি করতে push() ব্যবহার করা হয়েছে এবং একই সাথে getKey() দিয়ে কী-টি পুনরুদ্ধার করা হয়েছে। এরপর এই কী-টি ব্যবহার করে /user-posts/$userid/$postid এ ব্যবহারকারীর পোস্টগুলোর মধ্যে একটি দ্বিতীয় এন্ট্রি তৈরি করা যেতে পারে।

এই পাথগুলো ব্যবহার করে, আপনি updateChildren() ফাংশনের একটিমাত্র কলের মাধ্যমে JSON ট্রি-এর একাধিক স্থানে একযোগে আপডেট করতে পারেন, যেমনটি এই উদাহরণে উভয় স্থানেই নতুন পোস্টটি তৈরি করা হয়েছে। এইভাবে করা একযোগে আপডেটগুলো অ্যাটমিক হয়: হয় সব আপডেট সফল হয় অথবা সব আপডেট ব্যর্থ হয়।

একটি সমাপ্তি কলব্যাক যোগ করুন

আপনার ডেটা কখন কমিট করা হয়েছে তা জানতে চাইলে, আপনি একটি কমপ্লিশন লিসেনার যোগ করতে পারেন। setValue() এবং updateChildren() উভয় ফাংশনেই একটি ঐচ্ছিক কমপ্লিশন লিসেনার থাকে, যা ডাটাবেসে রাইট সফলভাবে কমিট হয়ে গেলে কল করা হয়। যদি কলটি অসফল হয়, তবে লিসেনারটিকে একটি এরর অবজেক্ট পাঠানো হয়, যা ব্যর্থতার কারণ নির্দেশ করে।

Kotlin 

database.child("users").child(userId).setValue(user)
    .addOnSuccessListener {
        // Write was successful!
        // ...
    }
    .addOnFailureListener {
        // Write failed
        // ...
    }
ReadAndWriteSnippets.kt

Java 

mDatabase.child("users").child(userId).setValue(user)
        .addOnSuccessListener(new OnSuccessListener<Void>() {
            @Override
            public void onSuccess(Void aVoid) {
                // Write was successful!
                // ...
            }
        })
        .addOnFailureListener(new OnFailureListener() {
            @Override
            public void onFailure(@NonNull Exception e) {
                // Write failed
                // ...
            }
        });
ReadAndWriteSnippets.java

ডেটা মুছে ফেলুন

ডেটা মুছে ফেলার সবচেয়ে সহজ উপায় হলো, সেই ডেটার অবস্থানের রেফারেন্সের উপর removeValue() কল করা।

আপনি setValue() বা updateChildren() এর মতো অন্য কোনো রাইট অপারেশনের ভ্যালু হিসেবে null উল্লেখ করেও ডিলিট করতে পারেন। updateChildren() এর সাথে এই কৌশলটি ব্যবহার করে আপনি একটিমাত্র API কলে একাধিক চাইল্ড ডিলিট করতে পারেন।

শ্রোতাদের বিচ্ছিন্ন করুন

আপনার Firebase ডাটাবেস রেফারেন্সে removeEventListener() মেথডটি কল করার মাধ্যমে কলব্যাকগুলি সরিয়ে ফেলা হয়।

যদি কোনো ডেটা লোকেশনে একটি লিসেনার একাধিকবার যোগ করা হয়, তবে প্রতিটি ইভেন্টের জন্য এটি একাধিকবার কল করা হয়, এবং এটিকে সম্পূর্ণরূপে অপসারণ করতে আপনাকে অবশ্যই ততবারই ডিটাচ করতে হবে।

প্যারেন্ট লিসেনারে removeEventListener() কল করলে তার চাইল্ড নোডগুলিতে রেজিস্টার করা লিসেনারগুলি স্বয়ংক্রিয়ভাবে মুছে যায় না; কলব্যাকটি মুছে ফেলার জন্য যেকোনো চাইল্ড লিসেনারেও removeEventListener() কল করতে হবে।

লেনদেন হিসেবে ডেটা সংরক্ষণ করুন

যখন এমন ডেটা নিয়ে কাজ করা হয় যা যুগপৎ পরিবর্তনের ফলে নষ্ট হয়ে যেতে পারে, যেমন ইনক্রিমেন্টাল কাউন্টার, তখন আপনি একটি ট্রানজ্যাকশন অপারেশন ব্যবহার করতে পারেন। এই অপারেশনে আপনি দুটি আর্গুমেন্ট দেন: একটি আপডেট ফাংশন এবং একটি ঐচ্ছিক কমপ্লিশন কলব্যাক। আপডেট ফাংশনটি আর্গুমেন্ট হিসেবে ডেটার বর্তমান অবস্থা গ্রহণ করে এবং আপনি যে নতুন কাঙ্ক্ষিত অবস্থাটি লিখতে চান তা রিটার্ন করে। যদি আপনার নতুন মান সফলভাবে লেখার আগে অন্য কোনো ক্লায়েন্ট সেই লোকেশনে লেখে, তাহলে আপনার আপডেট ফাংশনটি নতুন বর্তমান মান দিয়ে আবার কল করা হয় এবং লেখার চেষ্টাটি পুনরায় করা হয়।

উদাহরণস্বরূপ, উদাহরণে দেওয়া সোশ্যাল ব্লগিং অ্যাপটিতে, আপনি ব্যবহারকারীদের পোস্ট স্টার ও আনস্টার করার সুযোগ দিতে পারেন এবং একটি পোস্ট কতগুলো স্টার পেয়েছে তার হিসাব নিম্নোক্তভাবে রাখতে পারেন:

Kotlin 

private fun onStarClicked(postRef: DatabaseReference) {
    // ...
    postRef.runTransaction(object : Transaction.Handler {
        override fun doTransaction(mutableData: MutableData): Transaction.Result {
            val p = mutableData.getValue(Post::class.java)
                ?: return Transaction.success(mutableData)

            if (p.stars.containsKey(uid)) {
                // Unstar the post and remove self from stars
                p.starCount = p.starCount - 1
                p.stars.remove(uid)
            } else {
                // Star the post and add self to stars
                p.starCount = p.starCount + 1
                p.stars[uid] = true
            }

            // Set value and report transaction success
            mutableData.value = p
            return Transaction.success(mutableData)
        }

        override fun onComplete(
            databaseError: DatabaseError?,
            committed: Boolean,
            currentData: DataSnapshot?,
        ) {
            // Transaction completed
            Log.d(TAG, "postTransaction:onComplete:" + databaseError!!)
        }
    })
}
ReadAndWriteSnippets.kt

Java 

private void onStarClicked(DatabaseReference postRef) {
    postRef.runTransaction(new Transaction.Handler() {
        @NonNull
        @Override
        public Transaction.Result doTransaction(@NonNull MutableData mutableData) {
            Post p = mutableData.getValue(Post.class);
            if (p == null) {
                return Transaction.success(mutableData);
            }

            if (p.stars.containsKey(getUid())) {
                // Unstar the post and remove self from stars
                p.starCount = p.starCount - 1;
                p.stars.remove(getUid());
            } else {
                // Star the post and add self to stars
                p.starCount = p.starCount + 1;
                p.stars.put(getUid(), true);
            }

            // Set value and report transaction success
            mutableData.setValue(p);
            return Transaction.success(mutableData);
        }

        @Override
        public void onComplete(DatabaseError databaseError, boolean committed,
                               DataSnapshot currentData) {
            // Transaction completed
            Log.d(TAG, "postTransaction:onComplete:" + databaseError);
        }
    });
}
ReadAndWriteSnippets.java

ট্রানজ্যাকশন ব্যবহার করলে, একাধিক ব্যবহারকারী একই সময়ে একই পোস্টে স্টার দিলে বা ক্লায়েন্টের কাছে পুরোনো ডেটা থাকলেও স্টারের সংখ্যা ভুল হওয়া থেকে রক্ষা করা যায়। যদি ট্রানজ্যাকশনটি প্রত্যাখ্যাত হয়, সার্ভার ক্লায়েন্টকে বর্তমান মানটি ফেরত পাঠায়, যা আপডেট করা মান দিয়ে ট্রানজ্যাকশনটি আবার চালায়। এই প্রক্রিয়াটি ততক্ষণ চলতে থাকে যতক্ষণ না ট্রানজ্যাকশনটি গৃহীত হয় বা অনেক বেশিবার চেষ্টা করা হয়ে যায়।

পারমাণবিক সার্ভার-সাইড বৃদ্ধি

উপরের উদাহরণে আমরা ডাটাবেসে দুটি ভ্যালু লিখছি: যে ইউজার পোস্টটি স্টার বা আনস্টার করছেন তার আইডি, এবং স্টারের সংখ্যা বৃদ্ধির পরিমাণ। যদি আমরা আগে থেকেই জানি যে ইউজার পোস্টটি স্টার করছেন, তাহলে আমরা ট্রানজ্যাকশনের পরিবর্তে একটি অ্যাটমিক ইনক্রিমেন্ট অপারেশন ব্যবহার করতে পারি।

Kotlin 

private fun onStarClicked(uid: String, key: String) {
    val updates: MutableMap<String, Any> = hashMapOf(
        "posts/$key/stars/$uid" to true,
        "posts/$key/starCount" to ServerValue.increment(1),
        "user-posts/$uid/$key/stars/$uid" to true,
        "user-posts/$uid/$key/starCount" to ServerValue.increment(1),
    )
    database.updateChildren(updates)
}
ReadAndWriteSnippets.kt

Java 

private void onStarClicked(String uid, String key) {
    Map<String, Object> updates = new HashMap<>();
    updates.put("posts/"+key+"/stars/"+uid, true);
    updates.put("posts/"+key+"/starCount", ServerValue.increment(1));
    updates.put("user-posts/"+uid+"/"+key+"/stars/"+uid, true);
    updates.put("user-posts/"+uid+"/"+key+"/starCount", ServerValue.increment(1));
    mDatabase.updateChildren(updates);
}
ReadAndWriteSnippets.java

এই কোডটি কোনো ট্রানজ্যাকশন অপারেশন ব্যবহার করে না, তাই কোনো সাংঘর্ষিক আপডেট ঘটলে এটি স্বয়ংক্রিয়ভাবে পুনরায় রান হয় না। তবে, যেহেতু ইনক্রিমেন্ট অপারেশনটি সরাসরি ডাটাবেস সার্ভারে সম্পন্ন হয়, তাই কোনো সংঘাতের সম্ভাবনা থাকে না।

যদি আপনি অ্যাপ্লিকেশন-নির্দিষ্ট দ্বন্দ্ব শনাক্ত ও বাতিল করতে চান, যেমন কোনো ব্যবহারকারী পূর্বে স্টার দেওয়া কোনো পোস্টে আবার স্টার দেওয়া, তাহলে সেই নির্দিষ্ট পরিস্থিতির জন্য আপনার নিজস্ব নিরাপত্তা নিয়ম লেখা উচিত।

অফলাইনে ডেটা নিয়ে কাজ করুন

যদি কোনো ক্লায়েন্ট তার নেটওয়ার্ক সংযোগ হারায়, আপনার অ্যাপটি সঠিকভাবে কাজ করতে থাকবে।

ফায়ারবেস ডেটাবেসের সাথে সংযুক্ত প্রতিটি ক্লায়েন্ট, লিসেনার ব্যবহৃত হচ্ছে এমন ডেটা অথবা সার্ভারের সাথে সিঙ্ক করে রাখার জন্য ফ্ল্যাগ করা ডেটার নিজস্ব একটি অভ্যন্তরীণ সংস্করণ বজায় রাখে। যখন ডেটা পড়া বা লেখা হয়, তখন ডেটার এই স্থানীয় সংস্করণটি প্রথমে ব্যবহৃত হয়। এরপর ফায়ারবেস ক্লায়েন্ট সেই ডেটাটিকে রিমোট ডেটাবেস সার্ভার এবং অন্যান্য ক্লায়েন্টদের সাথে "সর্বোত্তম প্রচেষ্টা"র ভিত্তিতে সিঙ্ক্রোনাইজ করে।

এর ফলে, সার্ভারের সাথে কোনো রকম যোগাযোগের আগেই ডেটাবেসে করা সমস্ত রাইট অপারেশন তাৎক্ষণিকভাবে লোকাল ইভেন্ট ট্রিগার করে। এর মানে হলো, নেটওয়ার্ক ল্যাটেন্সি বা কানেক্টিভিটি নির্বিশেষে আপনার অ্যাপটি রেসপন্সিভ থাকে।

সংযোগ পুনঃপ্রতিষ্ঠিত হলে, আপনার অ্যাপটি প্রয়োজনীয় ইভেন্টগুলো পেয়ে যায়, যার ফলে কোনো কাস্টম কোড না লিখেই ক্লায়েন্ট বর্তমান সার্ভার অবস্থার সাথে সিঙ্ক হয়ে যায়।

অনলাইন এবং অফলাইন সক্ষমতা সম্পর্কে আরও জানুন অংশে আমরা অফলাইন আচরণ নিয়ে আরও আলোচনা করব।

পরবর্তী পদক্ষেপ