Questo documento illustra i quattro metodi per scrivere dati nel tuo Firebase Realtime Database: set, aggiornamento, push e supporto per le transazioni.
Modi per salvare i dati
impostato | Scrivi o sostituisci i dati in un percorso definito , come messages/users/<username> |
aggiornamento | Aggiorna alcune chiavi per un percorso definito senza sostituire tutti i dati |
spingere | Aggiungi a un elenco di dati nel database. Ogni volta che inserisci un nuovo nodo in un elenco, il tuo database genera una chiave univoca, come messages/users/<unique-user-id>/<username> |
transazione | Utilizza le transazioni quando lavori con dati complessi che potrebbero essere danneggiati da aggiornamenti simultanei |
Salvataggio dei dati
L'operazione di scrittura del database di base è un insieme che salva i nuovi dati nel riferimento al database specificato, sostituendo tutti i dati esistenti in quel percorso. Per comprendere il set, creeremo una semplice app di blogging. I dati per la tua app sono archiviati in questo riferimento al database:
Giava
final FirebaseDatabase database = FirebaseDatabase.getInstance(); DatabaseReference ref = database.getReference("server/saving-data/fireblog");
Node.js
// Import Admin SDK const { getDatabase } = require('firebase-admin/database'); // Get a database reference to our blog const db = getDatabase(); const ref = db.ref('server/saving-data/fireblog');
Pitone
# Import database module. from firebase_admin import db # Get a database reference to our blog. ref = db.reference('server/saving-data/fireblog')
Andare
// Create a database client from App. client, err := app.Database(ctx) if err != nil { log.Fatalln("Error initializing database client:", err) } // Get a database reference to our blog. ref := client.NewRef("server/saving-data/fireblog")
Iniziamo salvando alcuni dati utente. Memorizzeremo ciascun utente con un nome utente univoco e memorizzeremo anche il nome completo e la data di nascita. Poiché ogni utente avrà un nome utente univoco, ha senso utilizzare qui il metodo set invece del metodo push poiché hai già la chiave e non è necessario crearne una.
Innanzitutto, crea un riferimento al database per i tuoi dati utente. Quindi utilizzare set()
/ setValue()
per salvare un oggetto utente nel database con il nome utente, il nome completo e la data di nascita dell'utente. Puoi passare set a string, number, boolean, null
, array o qualsiasi oggetto JSON. Il passaggio null
rimuoverà i dati nella posizione specificata. In questo caso gli passerai un oggetto:
Giava
public static class User { public String date_of_birth; public String full_name; public String nickname; public User(String dateOfBirth, String fullName) { // ... } public User(String dateOfBirth, String fullName, String nickname) { // ... } } DatabaseReference usersRef = ref.child("users"); Map<String, User> users = new HashMap<>(); users.put("alanisawesome", new User("June 23, 1912", "Alan Turing")); users.put("gracehop", new User("December 9, 1906", "Grace Hopper")); usersRef.setValueAsync(users);
Node.js
const usersRef = ref.child('users'); usersRef.set({ alanisawesome: { date_of_birth: 'June 23, 1912', full_name: 'Alan Turing' }, gracehop: { date_of_birth: 'December 9, 1906', full_name: 'Grace Hopper' } });
Pitone
users_ref = ref.child('users') users_ref.set({ 'alanisawesome': { 'date_of_birth': 'June 23, 1912', 'full_name': 'Alan Turing' }, 'gracehop': { 'date_of_birth': 'December 9, 1906', 'full_name': 'Grace Hopper' } })
Andare
// User is a json-serializable type. type User struct { DateOfBirth string `json:"date_of_birth,omitempty"` FullName string `json:"full_name,omitempty"` Nickname string `json:"nickname,omitempty"` } usersRef := ref.Child("users") err := usersRef.Set(ctx, map[string]*User{ "alanisawesome": { DateOfBirth: "June 23, 1912", FullName: "Alan Turing", }, "gracehop": { DateOfBirth: "December 9, 1906", FullName: "Grace Hopper", }, }) if err != nil { log.Fatalln("Error setting value:", err) }
Quando un oggetto JSON viene salvato nel database, le proprietà dell'oggetto vengono automaticamente mappate alle posizioni secondarie del database in modo nidificato. Ora se accedi all'URL https://docs-examples.firebaseio.com/server/ saving-data/fireblog/users/alanisawesome/full_name , vedremo il valore "Alan Turing". Puoi anche salvare i dati direttamente in una posizione secondaria:
Giava
usersRef.child("alanisawesome").setValueAsync(new User("June 23, 1912", "Alan Turing")); usersRef.child("gracehop").setValueAsync(new User("December 9, 1906", "Grace Hopper"));
Node.js
const usersRef = ref.child('users'); usersRef.child('alanisawesome').set({ date_of_birth: 'June 23, 1912', full_name: 'Alan Turing' }); usersRef.child('gracehop').set({ date_of_birth: 'December 9, 1906', full_name: 'Grace Hopper' });
Pitone
users_ref.child('alanisawesome').set({ 'date_of_birth': 'June 23, 1912', 'full_name': 'Alan Turing' }) users_ref.child('gracehop').set({ 'date_of_birth': 'December 9, 1906', 'full_name': 'Grace Hopper' })
Andare
if err := usersRef.Child("alanisawesome").Set(ctx, &User{ DateOfBirth: "June 23, 1912", FullName: "Alan Turing", }); err != nil { log.Fatalln("Error setting value:", err) } if err := usersRef.Child("gracehop").Set(ctx, &User{ DateOfBirth: "December 9, 1906", FullName: "Grace Hopper", }); err != nil { log.Fatalln("Error setting value:", err) }
I due esempi precedenti, ovvero scrivere entrambi i valori contemporaneamente come oggetto e scriverli separatamente nelle posizioni secondarie, comporteranno il salvataggio degli stessi dati nel database:
{ "users": { "alanisawesome": { "date_of_birth": "June 23, 1912", "full_name": "Alan Turing" }, "gracehop": { "date_of_birth": "December 9, 1906", "full_name": "Grace Hopper" } } }
Il primo esempio attiverà solo un evento sui client che stanno guardando i dati, mentre il secondo esempio ne attiverà due. È importante notare che se i dati esistessero già in usersRef
, il primo approccio li sovrascriverebbe, ma il secondo metodo modificherebbe solo il valore di ciascun nodo figlio separato lasciando invariati gli altri figli di usersRef
.
Aggiornamento dei dati salvati
Se desideri scrivere su più nodi secondari di una posizione di database contemporaneamente senza sovrascrivere altri nodi secondari, puoi utilizzare il metodo di aggiornamento come mostrato di seguito:
Giava
DatabaseReference hopperRef = usersRef.child("gracehop"); Map<String, Object> hopperUpdates = new HashMap<>(); hopperUpdates.put("nickname", "Amazing Grace"); hopperRef.updateChildrenAsync(hopperUpdates);
Node.js
const usersRef = ref.child('users'); const hopperRef = usersRef.child('gracehop'); hopperRef.update({ 'nickname': 'Amazing Grace' });
Pitone
hopper_ref = users_ref.child('gracehop') hopper_ref.update({ 'nickname': 'Amazing Grace' })
Andare
hopperRef := usersRef.Child("gracehop") if err := hopperRef.Update(ctx, map[string]interface{}{ "nickname": "Amazing Grace", }); err != nil { log.Fatalln("Error updating child:", err) }
Ciò aggiornerà i dati di Grace per includere il suo nickname. Se avessi utilizzato set here invece di update, sarebbero stati eliminati sia full_name
che date_of_birth
dal tuo hopperRef
.
Il Firebase Realtime Database supporta anche aggiornamenti multipercorso. Ciò significa che update ora può aggiornare valori in più posizioni nel database contemporaneamente, una potente funzionalità che consente di denormalizzare i dati . Utilizzando gli aggiornamenti multipercorso, puoi aggiungere soprannomi sia a Grace che ad Alan contemporaneamente:
Giava
Map<String, Object> userUpdates = new HashMap<>(); userUpdates.put("alanisawesome/nickname", "Alan The Machine"); userUpdates.put("gracehop/nickname", "Amazing Grace"); usersRef.updateChildrenAsync(userUpdates);
Node.js
const usersRef = ref.child('users'); usersRef.update({ 'alanisawesome/nickname': 'Alan The Machine', 'gracehop/nickname': 'Amazing Grace' });
Pitone
users_ref.update({ 'alanisawesome/nickname': 'Alan The Machine', 'gracehop/nickname': 'Amazing Grace' })
Andare
if err := usersRef.Update(ctx, map[string]interface{}{ "alanisawesome/nickname": "Alan The Machine", "gracehop/nickname": "Amazing Grace", }); err != nil { log.Fatalln("Error updating children:", err) }
Dopo questo aggiornamento, sia Alan che Grace hanno aggiunto i loro soprannomi:
{ "users": { "alanisawesome": { "date_of_birth": "June 23, 1912", "full_name": "Alan Turing", "nickname": "Alan The Machine" }, "gracehop": { "date_of_birth": "December 9, 1906", "full_name": "Grace Hopper", "nickname": "Amazing Grace" } } }
Tieni presente che provare ad aggiornare gli oggetti scrivendo oggetti con i percorsi inclusi comporterà un comportamento diverso. Diamo un'occhiata a cosa succede se provi invece ad aggiornare Grace e Alan in questo modo:
Giava
Map<String, Object> userNicknameUpdates = new HashMap<>(); userNicknameUpdates.put("alanisawesome", new User(null, null, "Alan The Machine")); userNicknameUpdates.put("gracehop", new User(null, null, "Amazing Grace")); usersRef.updateChildrenAsync(userNicknameUpdates);
Node.js
const usersRef = ref.child('users'); usersRef.update({ 'alanisawesome': { 'nickname': 'Alan The Machine' }, 'gracehop': { 'nickname': 'Amazing Grace' } });
Pitone
users_ref.update({ 'alanisawesome': { 'nickname': 'Alan The Machine' }, 'gracehop': { 'nickname': 'Amazing Grace' } })
Andare
if err := usersRef.Update(ctx, map[string]interface{}{ "alanisawesome": &User{Nickname: "Alan The Machine"}, "gracehop": &User{Nickname: "Amazing Grace"}, }); err != nil { log.Fatalln("Error updating children:", err) }
Ciò si traduce in un comportamento diverso, ovvero la sovrascrittura dell'intero nodo /users
:
{ "users": { "alanisawesome": { "nickname": "Alan The Machine" }, "gracehop": { "nickname": "Amazing Grace" } } }
Aggiunta di una richiamata di completamento
In Node.js e Java Admin SDK, se desideri sapere quando i tuoi dati sono stati salvati, puoi aggiungere un callback di completamento. Sia i metodi di impostazione che quelli di aggiornamento in questi SDK accettano un callback di completamento facoltativo che viene chiamato quando la scrittura è stata confermata nel database. Se per qualche motivo la chiamata non ha avuto successo, al callback viene passato un oggetto errore che indica il motivo dell'errore. Negli SDK Python e Go Admin, tutti i metodi di scrittura sono bloccanti. Cioè, i metodi di scrittura non restituiscono risultati finché le scritture non vengono confermate nel database.
Giava
DatabaseReference dataRef = ref.child("data"); dataRef.setValue("I'm writing data", new DatabaseReference.CompletionListener() { @Override public void onComplete(DatabaseError databaseError, DatabaseReference databaseReference) { if (databaseError != null) { System.out.println("Data could not be saved " + databaseError.getMessage()); } else { System.out.println("Data saved successfully."); } } });
Node.js
dataRef.set('I\'m writing data', (error) => { if (error) { console.log('Data could not be saved.' + error); } else { console.log('Data saved successfully.'); } });
Salvataggio di elenchi di dati
Quando si creano elenchi di dati, è importante tenere presente la natura multiutente della maggior parte delle applicazioni e modificare di conseguenza la struttura dell'elenco. Ampliando l'esempio precedente, aggiungiamo i post del blog alla tua app. Il tuo primo istinto potrebbe essere quello di utilizzare set per archiviare elementi secondari con indici interi a incremento automatico, come il seguente:
// NOT RECOMMENDED - use push() instead! { "posts": { "0": { "author": "gracehop", "title": "Announcing COBOL, a New Programming Language" }, "1": { "author": "alanisawesome", "title": "The Turing Machine" } } }
Se un utente aggiunge un nuovo post, verrà archiviato come /posts/2
. Funzionerebbe se solo un singolo autore aggiungesse post, ma nella tua applicazione di blogging collaborativo molti utenti potrebbero aggiungere post contemporaneamente. Se due autori scrivessero su /posts/2
contemporaneamente, uno dei post verrebbe eliminato dall'altro.
Per risolvere questo problema, i client Firebase forniscono una funzione push()
che genera una chiave univoca per ogni nuovo figlio . Utilizzando chiavi figlio univoche, diversi client possono aggiungere figli alla stessa posizione contemporaneamente senza preoccuparsi di conflitti di scrittura.
Giava
public static class Post { public String author; public String title; public Post(String author, String title) { // ... } } DatabaseReference postsRef = ref.child("posts"); DatabaseReference newPostRef = postsRef.push(); newPostRef.setValueAsync(new Post("gracehop", "Announcing COBOL, a New Programming Language")); // We can also chain the two calls together postsRef.push().setValueAsync(new Post("alanisawesome", "The Turing Machine"));
Node.js
const newPostRef = postsRef.push(); newPostRef.set({ author: 'gracehop', title: 'Announcing COBOL, a New Programming Language' }); // we can also chain the two calls together postsRef.push().set({ author: 'alanisawesome', title: 'The Turing Machine' });
Pitone
posts_ref = ref.child('posts') new_post_ref = posts_ref.push() new_post_ref.set({ 'author': 'gracehop', 'title': 'Announcing COBOL, a New Programming Language' }) # We can also chain the two calls together posts_ref.push().set({ 'author': 'alanisawesome', 'title': 'The Turing Machine' })
Andare
// Post is a json-serializable type. type Post struct { Author string `json:"author,omitempty"` Title string `json:"title,omitempty"` } postsRef := ref.Child("posts") newPostRef, err := postsRef.Push(ctx, nil) if err != nil { log.Fatalln("Error pushing child node:", err) } if err := newPostRef.Set(ctx, &Post{ Author: "gracehop", Title: "Announcing COBOL, a New Programming Language", }); err != nil { log.Fatalln("Error setting value:", err) } // We can also chain the two calls together if _, err := postsRef.Push(ctx, &Post{ Author: "alanisawesome", Title: "The Turing Machine", }); err != nil { log.Fatalln("Error pushing child node:", err) }
La chiave univoca si basa su un timestamp, quindi gli elementi dell'elenco verranno automaticamente ordinati cronologicamente. Poiché Firebase genera una chiave univoca per ogni post del blog, non si verificheranno conflitti di scrittura se più utenti aggiungono un post contemporaneamente. I dati del tuo database ora appaiono così:
{ "posts": { "-JRHTHaIs-jNPLXOQivY": { "author": "gracehop", "title": "Announcing COBOL, a New Programming Language" }, "-JRHTHaKuITFIhnj02kE": { "author": "alanisawesome", "title": "The Turing Machine" } } }
In JavaScript, Python e Go, il modello di chiamata push()
e quindi di chiamata immediata set()
è così comune che l'SDK Firebase ti consente di combinarli passando i dati da impostare direttamente a push()
come segue:
Giava
// No Java equivalent
Node.js
// This is equivalent to the calls to push().set(...) above postsRef.push({ author: 'gracehop', title: 'Announcing COBOL, a New Programming Language' });;
Pitone
# This is equivalent to the calls to push().set(...) above posts_ref.push({ 'author': 'gracehop', 'title': 'Announcing COBOL, a New Programming Language' })
Andare
if _, err := postsRef.Push(ctx, &Post{ Author: "gracehop", Title: "Announcing COBOL, a New Programming Language", }); err != nil { log.Fatalln("Error pushing child node:", err) }
Ottenere la chiave univoca generata da push()
La chiamata push()
restituirà un riferimento al nuovo percorso dati, che puoi utilizzare per ottenere la chiave o impostarvi i dati. Il codice seguente genererà gli stessi dati dell'esempio precedente, ma ora avremo accesso alla chiave univoca che è stata generata:
Giava
// Generate a reference to a new location and add some data using push() DatabaseReference pushedPostRef = postsRef.push(); // Get the unique ID generated by a push() String postId = pushedPostRef.getKey();
Node.js
// Generate a reference to a new location and add some data using push() const newPostRef = postsRef.push(); // Get the unique key generated by push() const postId = newPostRef.key;
Pitone
# Generate a reference to a new location and add some data using push() new_post_ref = posts_ref.push() # Get the unique key generated by push() post_id = new_post_ref.key
Andare
// Generate a reference to a new location and add some data using Push() newPostRef, err := postsRef.Push(ctx, nil) if err != nil { log.Fatalln("Error pushing child node:", err) } // Get the unique key generated by Push() postID := newPostRef.Key
Come puoi vedere, puoi ottenere il valore della chiave univoca dal riferimento push()
.
Nella prossima sezione sul recupero dei dati , impareremo come leggere questi dati da un database Firebase.
Salvataggio dei dati transazionali
Quando si lavora con dati complessi che potrebbero essere danneggiati da modifiche simultanee, come i contatori incrementali, l'SDK fornisce un'operazione di transazione .
In Java e Node.js, assegni all'operazione di transazione due callback: una funzione di aggiornamento e un callback di completamento opzionale. In Python e Go l'operazione di transazione è bloccante e quindi accetta solo la funzione di aggiornamento.
La funzione di aggiornamento prende lo stato corrente dei dati come argomento e dovrebbe restituire il nuovo stato desiderato che desideri scrivere. Ad esempio, se desideri incrementare il numero di voti positivi su un post del blog specifico, dovresti scrivere una transazione come la seguente:
Giava
DatabaseReference upvotesRef = ref.child("server/saving-data/fireblog/posts/-JRHTHaIs-jNPLXOQivY/upvotes"); upvotesRef.runTransaction(new Transaction.Handler() { @Override public Transaction.Result doTransaction(MutableData mutableData) { Integer currentValue = mutableData.getValue(Integer.class); if (currentValue == null) { mutableData.setValue(1); } else { mutableData.setValue(currentValue + 1); } return Transaction.success(mutableData); } @Override public void onComplete( DatabaseError databaseError, boolean committed, DataSnapshot dataSnapshot) { System.out.println("Transaction completed"); } });
Node.js
const upvotesRef = db.ref('server/saving-data/fireblog/posts/-JRHTHaIs-jNPLXOQivY/upvotes'); upvotesRef.transaction((current_value) => { return (current_value || 0) + 1; });
Pitone
def increment_votes(current_value): return current_value + 1 if current_value else 1 upvotes_ref = db.reference('server/saving-data/fireblog/posts/-JRHTHaIs-jNPLXOQivY/upvotes') try: new_vote_count = upvotes_ref.transaction(increment_votes) print('Transaction completed') except db.TransactionAbortedError: print('Transaction failed to commit')
Andare
fn := func(t db.TransactionNode) (interface{}, error) { var currentValue int if err := t.Unmarshal(¤tValue); err != nil { return nil, err } return currentValue + 1, nil } ref := client.NewRef("server/saving-data/fireblog/posts/-JRHTHaIs-jNPLXOQivY/upvotes") if err := ref.Transaction(ctx, fn); err != nil { log.Fatalln("Transaction failed to commit:", err) }
L'esempio precedente controlla se il contatore è null
o non è stato ancora incrementato, poiché le transazioni possono essere chiamate con null
se non è stato scritto alcun valore predefinito.
Se il codice precedente fosse stato eseguito senza una funzione di transazione e due client tentassero di incrementarlo simultaneamente, entrambi scriverebbero 1
come nuovo valore, ottenendo un incremento invece di due.
Connettività di rete e scritture offline
Firebase Node.js e i client Java mantengono la propria versione interna di tutti i dati attivi. Quando i dati vengono scritti, vengono scritti prima in questa versione locale. Il client sincronizza quindi i dati con il database e con altri client in base al "massimo sforzo".
Di conseguenza, tutte le scritture nel database attiveranno immediatamente eventi locali, prima ancora che i dati vengano scritti nel database. Ciò significa che quando scrivi un'applicazione utilizzando Firebase, la tua app rimarrà reattiva indipendentemente dalla latenza di rete o dalla connettività Internet.
Una volta ristabilita la connettività, riceveremo l'insieme appropriato di eventi in modo che il client "si allinei" con lo stato corrente del server, senza dover scrivere alcun codice personalizzato.
Protezione dei tuoi dati
Il Firebase Realtime Database dispone di un linguaggio di sicurezza che ti consente di definire quali utenti hanno accesso in lettura e scrittura ai diversi nodi dei tuoi dati. Puoi leggere di più a riguardo in Proteggi i tuoi dati .