cassandra

Projekt ten jest podmudułem dla projektu lambda-stack.

Wstep

Niniejszy projekt, oprócz funkcjonalności związanych z obsługa Cassandry, jest także punktem startowym aplikacji, w ktorym dokonuje się wstępna konfiguracja - definiowanie zapytań - oraz przeglądanie rezultatów.

Architektura

Tabele w bazie danych

Wykorzystywane przez nas tabele mają następujące definicje:

TABLE queries (
	id int,
	query varchar,
	PRIMARY KEY (id)
);

TABLE results (
	query_id int,
	group_by varchar,
	result varchar,
	PRIMARY KEY (query_id, group_by)
);

Main

Metoda startowa programu prezentuje się następująco (pewne nieistotne fragmenty zostały pominięte - (...)):

public static void main(String[] args) {
		(...)
		
		//1
		QueriesManager queriesManager = new QueriesManager(scanner, dbHandler);
		queriesManager.operate();
		
		(...)
		
		//2
		while (!shouldQuit) {
			(...)
			queryId = new Integer(text);
			queries.put(queryId, queriesManager.getQuery(queryId));
			(...)
		}
		
		//3
		sendQueriesToStorm();
		
		(...)
		
		//4
		ResultsManager resultsManager = new ResultsManager(scanner, dbHandler, queries);
		resultsManager.operate();

		(...)
}

Jak nie trudno zauważyć, można tu wyróżnić 4 etapy:

1. zarządzanie zapytaniami (queriesManager):
   • wyświetlanie istniejących w bazie zapytań wraz z ich ID, które posłuży przy pozyskiwaniu rezultatów
   • dodanie nowego zapytania
2. wybór z dostępnej listy zapytań tych, które zamierzamy odpalić na Stormie (queries.put(...))
3. dynamiczne przekazywanie zapytań do aplikacji Storma (podmoduł Storm projektu)
4. przeglądanie rezultatów dla wykonywanych zapytań (resultsManager)

DBHandler

Poniżej przedstawiono klasę obsługującą komunikację z bazą danych:

public class DBHandler {

	public void insertQuery(String query);
	public List<QueryResultsRow> getResultsForId(int id);
	public Map<Integer,String> getAllQueries();
	
}

Metoda insertQuery() wstawia podane zapytanie do tabeli queries, a także inicjalizuje powiązany z zapytaniem wiersz w tabeli results.

Metoda getResultsForId() odpytuje tabelę results o wynik zapytania o podanym ID. Zwraca liste QueryResultsRow, które to obiekty reprezentuja pojedyńczy wiersz (dla zapytań z group by takich wierszy jest wiecej niż jeden).

Ostatnia z kluczowych metod - getAllQueries() - pobiera wszystkie istniejące w bazie zapytania i zwraca je w postaci kolekcji Map: {[id_zapytania], [zapytanie]}. Warto tu zaznaczyć, iż dane te są cache'owane w aplikacji i uaktualniane w przypadku dodanie kolejnego zapytania do bazy.

Użycie

Zanim przystąpimy do uruchomienia aplikacji warto upewnić się, że wykorzystywane przez nas tabele queries i results isteniją w bazie danych. Można tego dokonać z poziomu bazowego commandline'a (apache-cassandra/bin/cqlsh), wykonując prostego select'a. Należy jednak pamiętać o przejściu do keyspace'a (USE demo;). Istnieją dwie możliwości uruchomienia tej aplikacji:

• W katalogu /cassandra-development klastra należy wykonać następujące polecenie:

java -jar cassandra-0.0.1-SNAPSHOT-jar-with-dependencies.jar

Położenie pliku .jar nie ma jednak znaczenia - przy starcie używane są ścieżki bezwzględne dla kompomnentów

• Sklonować powyższe repozytorium i wygenerować plik .jar za pomocą fazy package dostarczonego pliku pom.xml. Następnie, umieścić ten plik na klastrze, w dowolnym katalogu.