Questo argomento descrive come scrivere un timestamp di commit per ogni operazione di inserimento e aggiornamento che esegui con Spanner.
Panoramica dei timestamp di commit
Il timestamp del commit, basato sulla tecnologia TrueTime, indica il momento in cui viene eseguito il commit di una transazione nel database. Puoi archiviare a livello atomico il timestamp di commit di una transazione in una colonna. Utilizzando i timestamp di commit archiviati nelle tabelle, puoi determinare l'ordine esatto delle mutazioni e creare funzionalità come i log delle modifiche.
Per inserire i timestamp di commit nel database, completa i seguenti passaggi:
Crea una colonna di tipo
SPANNER.COMMIT_TIMESTAMP
. Ad esempio:CREATE TABLE Performances ( ... LastUpdateTime SPANNER.COMMIT_TIMESTAMP NOT NULL, ... PRIMARY KEY (...) ) ;
Se esegui insert o aggiornamenti con DML, utilizza la funzione
SPANNER.PENDING_COMMIT_TIMESTAMP()
per scrivere il timestamp di commit.Se esegui insert o aggiornamenti con dichiarazioni o mutazioni preparate, utilizza la stringa segnaposto
SPANNER.COMMIT_TIMESTAMP()
per la colonna del timestamp del commit. Puoi anche utilizzare la costante di timestamp del commit fornita dalla libreria client. Ad esempio, questa costante nel client Java èValue.COMMIT_TIMESTAMP
.
Quando Spanner esegue il commit della transazione utilizzando questi segnaposto come valori della colonna, il timestamp di commit effettivo viene scritto nella colonna specificata. Puoi quindi utilizzare questo valore della colonna per creare una cronologia degli aggiornamenti della tabella.
Non è garantito che i valori dei timestamp di commit siano univoci. Le transazioni che scrivono in insiemi di campi non sovrapposti potrebbero avere lo stesso timestamp. Le transazioni che scrivono in insiemi di campi sovrapposti hanno timestamp univoci.
I timestamp di commit Spanner hanno granularità in microsecondi e vengono convertiti in nanosecondi se archiviati in colonne SPANNER.COMMIT_TIMESTAMP
.
Chiavi e indici
Puoi utilizzare una colonna di timestamp di commit come colonna di chiave primaria o come colonna non chiave. Le chiavi primarie possono essere definite come ASC
o DESC
.
ASC
(predefinito): le chiavi crescenti sono ideali per rispondere alle query da un momento specifico in poi.DESC
: le chiavi decrescenti mantengono le ultime righe in cima alla tabella. Consentono di accedere rapidamente ai record più recenti.
Evita hotspot
L'utilizzo di timestamp di commit nei seguenti scenari crea hotspot che riducono le prestazioni dei dati:
Esegui il commit della colonna del timestamp come prima parte della chiave primaria di una tabella.
CREATE TABLE Users ( LastAccess SPANNER.COMMIT_TIMESTAMP NOT NULL, UserId INT64 NOT NULL, ... PRIMARY KEY (LastAccess, UserId) ) ;
Esegui il commit della colonna di chiave primaria del timestamp come prima parte di un indice secondario.
CREATE INDEX UsersByLastAccess ON Users(LastAccess)
o
CREATE INDEX UsersByLastAccessAndName ON Users(LastAccess, FirstName)
Gli hotspot riducono le prestazioni dei dati, anche con velocità di scrittura basse. Non esiste un sovraccarico delle prestazioni se i timestamp di commit sono abilitati su colonne non chiave non indicizzate.
Aggiungi una colonna di timestamp del commit a una tabella esistente
Per aggiungere una colonna di timestamp del commit a una tabella esistente, utilizza l'istruzione ALTER TABLE
. Ad esempio, per aggiungere una colonna LastUpdateTime
alla tabella Performances
, utilizza la seguente istruzione:
ALTER TABLE Performances ADD COLUMN LastUpdateTime SPANNER.COMMIT_TIMESTAMP
NOT NULL;
Scrivi un timestamp di commit utilizzando un'istruzione DML
Puoi utilizzare la funzione SPANNER.PENDING_COMMIT_TIMESTAMP()
per scrivere il timestamp di commit in un'istruzione DML. Spanner seleziona il timestamp di commit quando viene eseguito il commit della transazione.
La seguente istruzione DML aggiorna la colonna LastUpdateTime
nella
tabella Performances
con il timestamp di commit:
UPDATE Performances SET LastUpdateTime = SPANNER.PENDING_COMMIT_TIMESTAMP()
WHERE SingerId=1 AND VenueId=2 AND EventDate="2015-10-21"
Inserisci una riga utilizzando una mutazione
Quando inserisci una riga, Spanner scrive il valore del timestamp di commit solo se includi la colonna nell'elenco delle colonne e passi la stringa segnaposto spanner.commit_timestamp()
(o la costante della libreria client) come valore. Ad esempio:
C++
C#
Go
Java
Node.js
PHP
Python
Ruby
Se sono presenti modifiche nelle righe di più tabelle, devi specificare spanner.commit_timestamp()
(o la costante della libreria client) per la colonna del timestamp del commit in ogni tabella.
Aggiorna una riga utilizzando una mutazione
Quando aggiorna una riga, Spanner scrive il valore del timestamp di commit solo se includi la colonna nell'elenco delle colonne e trasmetti la stringa segnaposto spanner.commit_timestamp()
(o la costante della libreria client) come valore. Non puoi aggiornare la chiave primaria di una riga. Per aggiornare
la chiave primaria, elimina la riga esistente e creane una nuova.
Ad esempio, per aggiornare una colonna del timestamp di commit denominata LastUpdateTime
:
C++
C#
Go
Java
Node.js
PHP
Python
Ruby
Se sono presenti modifiche nelle righe di più tabelle, devi specificare spanner.commit_timestamp()
(o la costante della libreria client) per la colonna del timestamp del commit in ogni tabella.
Esegui una query su una colonna del timestamp del commit
La query nell'esempio seguente viene eseguita nella colonna del timestamp del commit della tabella.
C++
C#
Go
Java
Node.js
PHP
Python
Ruby
Fornisci un valore personale per la colonna del timestamp del commit
Nel codice, puoi fornire un valore personale per la colonna del timestamp di commit
anziché passare spanner.commit_timestamp()
(o la costante della libreria client disponibile) come
valore della colonna. Il valore deve essere un timestamp passato. Questa limitazione garantisce che la scrittura di timestamp sia un'operazione rapida e poco costosa. Un modo semplice per verificare che un valore sia nel passato consiste nel confrontarlo con il valore restituito dalla funzione SQL di CURRENT_TIMESTAMP
.
Il server restituisce un errore FailedPrecondition
se viene specificato un timestamp futuro.
Crea un log delle modifiche
Supponiamo di voler creare un log delle modifiche per ogni mutazione che si verifica in una tabella e di utilizzare questo log per il controllo. Un esempio potrebbe essere una tabella che archivia la cronologia delle modifiche apportate ai documenti di elaborazione testi. Il timestamp del commit semplifica la creazione del log delle modifiche poiché i timestamp possono forzare l'ordine delle voci del log delle modifiche. Puoi creare un log delle modifiche che archivi la cronologia delle modifiche apportate a un determinato documento utilizzando uno schema come quello nell'esempio seguente:
CREATE TABLE Documents (
UserId int8 NOT NULL,
DocumentId int8 NOT NULL,
Contents text NOT NULL,
PRIMARY KEY (UserId, DocumentId)
);
CREATE TABLE DocumentHistory (
UserId int8 NOT NULL,
DocumentId int8 NOT NULL,
Ts SPANNER.COMMIT_TIMESTAMP NOT NULL,
Delta text,
PRIMARY KEY (UserId, DocumentId, Ts)
) INTERLEAVE IN PARENT Documents;
Per creare un log delle modifiche, inserisci una nuova riga in DocumentHistory
nella stessa transazione in cui inserisci o aggiorni una riga in Document
. Nell'inserimento
della nuova riga in DocumentHistory
, utilizza il segnaposto
spanner.commit_timestamp()
(o la costante della libreria client) per indicare a
Spanner di scrivere il timestamp del commit nella colonna Ts
. L'interfoliazione
della tabella DocumentsHistory
con la tabella Documents
consentirà la località dei dati
e l'inserimento e gli aggiornamenti in modo più efficiente. Tuttavia, aggiunge anche il vincolo che le righe padre e figlio devono essere eliminate insieme. Per mantenere le righe in DocumentHistory
dopo l'eliminazione delle righe in Documents
, non interfoliare le tabelle.
Ottimizza le query sui dati recenti con i timestamp di commit
I timestamp di commit consentono un'ottimizzazione di Spanner che può ridurre l'I/O delle query durante il recupero dei dati scritti dopo un determinato periodo di tempo.
Per attivare questa ottimizzazione, la clausola WHERE
di una query deve includere un confronto tra la colonna del timestamp di commit di una tabella e un orario specifico fornito, con i seguenti attributi:
Fornisci il tempo specifico come espressione costante: un valore letterale, un parametro o una funzione i cui argomenti vengono valutati in costanti.
Confronta se il timestamp del commit è più recente del tempo specificato tramite gli operatori
>
o>=
.Se vuoi, aggiungi ulteriori limitazioni alla clausola
WHERE
conAND
. L'estensione della clausola conOR
rende la query non idonea da questa ottimizzazione.
Ad esempio, considera la seguente tabella Performances
, che include una colonna del timestamp del commit:
CREATE TABLE Performances (
SingerId bigint NOT NULL,
VenueId bigint NOT NULL,
EventDate timestamp with time zone NOT NULL,
Revenue bigint,
LastUpdateTime spanner.commit_timestamp,
PRIMARY KEY(SingerId, VenueId, EventDate)
);
Questa query trae vantaggio dall'ottimizzazione del timestamp di commit descritta in precedenza, perché presenta un confronto maggiore o uguale tra la colonna del timestamp di commit della tabella e un'espressione costante, in questo caso un valore letterale:
SELECT * FROM Performances WHERE LastUpdateTime >= '2022-01-01';