mindol1004/spring-boot-rest
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

formatting work

Browse Source
This commit is contained in:
eugenp
2017-01-29 16:03:33 +02:00
parent 44bf48068f
commit 034cde6e20
42 changed files with 455 additions and 700 deletions
Download Patch File Download Diff File Expand all files Collapse all files

14
java-cassandra/src/main/java/com/baeldung/cassandra/java/client/CassandraClient.java
View File

@@ -11,12 +11,12 @@ import com.datastax.driver.core.utils.UUIDs;
public class CassandraClient {
private static final Logger LOG = LoggerFactory.getLogger(CassandraClient.class);
public static void main(String args[]) {
CassandraConnector connector = new CassandraConnector();
connector.connect("127.0.0.1", null);
Session session = connector.getSession();
KeyspaceRepository sr = new KeyspaceRepository(session);
sr.createKeyspace("library", "SimpleStrategy", 1);
sr.useKeyspace("library");
@@ -24,21 +24,21 @@ public class CassandraClient {
BookRepository br = new BookRepository(session);
br.createTable();
br.alterTablebooks("publisher", "text");
br.createTableBooksByTitle();
Book book = new Book(UUIDs.timeBased(), "Effective Java", "Joshua Bloch", "Programming");
br.insertBookBatch(book);
br.selectAll().forEach(o -> LOG.info("Title in books: " + o.getTitle()));
br.selectAllBookByTitle().forEach(o -> LOG.info("Title in booksByTitle: " + o.getTitle()));
br.deletebookByTitle("Effective Java");
br.deleteTable("books");
br.deleteTable("booksByTitle");
sr.deleteKeyspace("library");
connector.close();
}
}

4
java-cassandra/src/main/java/com/baeldung/cassandra/java/client/domain/Book.java
View File

@@ -16,14 +16,14 @@ public class Book {
Book() {
}
public Book(UUID id, String title, String author, String subject) {
this.id = id;
this.title = title;
this.author = author;
this.subject = subject;
}
public UUID getId() {
return id;
}

20
java-cassandra/src/main/java/com/baeldung/cassandra/java/client/repository/BookRepository.java
View File

@@ -11,7 +11,7 @@ import com.datastax.driver.core.Session;
public class BookRepository {
private static final String TABLE_NAME = "books";
private static final String TABLE_NAME_BY_TITLE = TABLE_NAME + "ByTitle";
private Session session;
@@ -29,7 +29,7 @@ public class BookRepository {
final String query = sb.toString();
session.execute(query);
}
/**
* Creates the books table.
*/
@@ -62,7 +62,7 @@ public class BookRepository {
final String query = sb.toString();
session.execute(query);
}
/**
* Insert a row in the table booksByTitle.
* @param book
@@ -73,19 +73,15 @@ public class BookRepository {
final String query = sb.toString();
session.execute(query);
}
/**
* Insert a book into two identical tables using a batch query.
*
* @param book
*/
public void insertBookBatch(Book book) {
StringBuilder sb = new StringBuilder("BEGIN BATCH ")
.append("INSERT INTO ").append(TABLE_NAME).append("(id, title, author, subject) ")
.append("VALUES (").append(book.getId()).append(", '").append(book.getTitle()).append("', '").append(book.getAuthor()).append("', '")
.append(book.getSubject()).append("');")
.append("INSERT INTO ").append(TABLE_NAME_BY_TITLE).append("(id, title) ")
.append("VALUES (").append(book.getId()).append(", '").append(book.getTitle()).append("');")
StringBuilder sb = new StringBuilder("BEGIN BATCH ").append("INSERT INTO ").append(TABLE_NAME).append("(id, title, author, subject) ").append("VALUES (").append(book.getId()).append(", '").append(book.getTitle()).append("', '").append(book.getAuthor())
.append("', '").append(book.getSubject()).append("');").append("INSERT INTO ").append(TABLE_NAME_BY_TITLE).append("(id, title) ").append("VALUES (").append(book.getId()).append(", '").append(book.getTitle()).append("');")
.append("APPLY BATCH;");
final String query = sb.toString();
@@ -101,7 +97,7 @@ public class BookRepository {
StringBuilder sb = new StringBuilder("SELECT * FROM ").append(TABLE_NAME_BY_TITLE).append(" WHERE title = '").append(title).append("';");
final String query = sb.toString();
ResultSet rs = session.execute(query);
List<Book> books = new ArrayList<Book>();
@@ -133,7 +129,7 @@ public class BookRepository {
}
return books;
}
/**
* Select all books from booksByTitle
* @return