Partia Apache Cassandra

Przetwarzanie wsadowe jest bardzo ważną funkcją podczas pracy z bazami danych. Nie tylko zapewniają programistom sposób na wykonanie serii instrukcji z jednego skryptu, ale także zapewniają atomię w klastrze docelowym.

W tym poście omówimy podstawy pracy z przetwarzaniem wsadowym w Apache Cassandra. To pozwala połączyć serię zapytań w jednym kontekście wykonania.

Zanurzmy się.

Składnia przetwarzania partii Cassandra

Poniżej pokazuje składnię instrukcji wsadowej w Cassandra:

Rozpocznij [(nielogowany | licznik)]
[Za pomocą znacznika czasu [epoch_microseconds]]]
dml_statement [za pomocą znacznika czasu [epoch_microseconds]];
[dml_statement [za pomocą znacznika czasu [epoch_microseconds]] [;…]]
Zastosuj partię;

Możesz użyć wstawki, aktualizacji lub usuwania instrukcji w klauzuli wsadowej.

Oświadczenie o nieistotności określa, czy partia jest rejestrowana, czy nie. Zrejestrowana partia zapewnia maksymalną atomowość, zapewniając pomyślnie wykonywane stwierdzenia w partii. Jeśli którekolwiek z instrukcji w rejestrowanej partii nie powiedzie się, cała partia nie uda się wykonać.

Używające instrukcje dotyczące znacznika czasu służą do ustawiania czasu zapisu dla transakcji przeprowadzanych przez instrukcje w partii. Możesz zezwolić klastrze na przypisanie pojedynczego znacznika czasu we wszystkich transakcjach przeprowadzonych przez partię lub możesz określić instrukcje, na których chcesz zastosować znacznik czasu.

Przykładem jest jak pokazano:

Rozpocznij partię przy użyciu znacznika czasu [epoch_microseconds]
instrukcja_1;
…
instrukcja_n;
Zastosuj partię;

W poprzednim przykładzie Cassandra tworzy znacznik czasu dla wszystkich transakcji dokonanych przez określone stwierdzenia w partii.

Innym przykładem jest to, jak pokazano:

Rozpocznij partię
instrukcja_1;
instrukcja_2 przy użyciu znacznika czasu [epoch_microseconds];
instrukcja_n;
Zastosuj partię;

W tym przypadku Cassandra stosuje tylko znaczniki czasu dla transakcji dokonanych przez instrukcję_2.

Przykład:

Poniższy przykład ilustruje, jak użyć instrukcji wsadowej za pomocą instrukcji Insert DML:

cassandra@cqlsh: testowanie> Utwórz użytkowników tabeli (
… Id Int,
… Tekst nazwy użytkownika,
… Klucz podstawowy (id));

Po konfiguracji tabeli możemy uruchomić wkładkę wsadową w następujący sposób:

cassandra@cqlsh: Testowanie> Rozpocznij partię za pomocą znacznika czasu 1664050149 Wstaw do użytkowników (id, nazwa użytkownika) (1, „nazwa użytkownika1 '); Wstaw wartości użytkowników (ID, nazwa użytkownika) (2, „nazwa użytkownika2”); Zastosuj partię;

Zapytanie powinno wykonać wkładkę wsadową do określonej tabeli. Ponieważ ustawiamy znacznik czasu na wszystkich stwierdzeniach, zapytanie powinno zapewnić, że wszystkie rekordy mają podobny znacznik czasu.

Wniosek

W tym artykule omówiliśmy podstawy pracy z trybem wsadowym w Apache Cassandra. Warto pamiętać, że jest to podstawowy samouczek. Podczas pracy z przetwarzaniem wsadowym należy rozważyć o wiele więcej. Zalecamy sprawdzenie dokumentacji w celu uzyskania szczegółowych informacji.