Feature 150

FlashCards_Repository/FlashCards_Repository_Jpa_Commons/src/main/java/org/robbins/flashcards/repository/conversion/DtoConverter.java → FlashCards_API/src/main/java/org/robbins/flashcards/conversion/DtoConverter.java

@@ -1,5 +1,5 @@
 
-package org.robbins.flashcards.repository.conversion;
+package org.robbins.flashcards.conversion;
 
 import java.util.List;
 import java.util.Set;
@@ -11,6 +11,7 @@ public interface DtoConverter<D, E> {
     D getDto(E entity) throws RepositoryException;
     D getDto(E entity, Set<String> fields) throws RepositoryException;
     E getEntity(D dto);
+    List<D> getDtos(List<E> entities) throws RepositoryException;
     List<D> getDtos(List<E> entities, Set<String> fields) throws RepositoryException;
-    List<E> getEtnties(List<D> entities);
+    List<E> getEntities(List<D> entities);
 }

FlashCards_Repository/FlashCards_Repository_Cassandra/pom.xml

@@ -0,0 +1,95 @@
+<?xml version="1.0" encoding="UTF-8"?>
+<project xmlns="http://maven.apache.org/POM/4.0.0" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
+	xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/maven-v4_0_0.xsd">
+	<parent>
+		<groupId>org.robbins.flashcards</groupId>
+		<artifactId>FlashCards_Repository</artifactId>
+		<version>0.0.1-SNAPSHOT</version>
+	</parent>
+	<modelVersion>4.0.0</modelVersion>
+	<artifactId>FlashCards_Repository_Cassandra</artifactId>
+	<packaging>jar</packaging>
+	<name>FlashCards_Repository_Cassandra</name>
+	<description>FlashCards_Repository_Cassandra description</description>
+	<properties>
+		<skip.coveralls>false</skip.coveralls>
+	</properties>
+	<scm>
+		<connection>scm:git:git@github.com:justinhrobbins/FlashCards_App.git</connection>
+		<url>scm:git:git@github.com:justinhrobbins/FlashCards_App.git</url>
+		<developerConnection>scm:git:git@github.com:justinhrobbins/FlashCards_App.git</developerConnection>
+	</scm>
+	<dependencies>
+        <dependency>
+            <groupId>org.robbins.flashcards</groupId>
+            <artifactId>FlashCards_Repository_Commons</artifactId>
+            <version>${project.version}</version>
+        </dependency>
+        <dependency>
+            <groupId>org.robbins.flashcards</groupId>
+            <artifactId>FlashCards_DTO</artifactId>
+            <version>${project.version}</version>
+        </dependency>
+        <dependency>
+            <groupId>org.robbins.flashcards</groupId>
+            <artifactId>FlashCards_API</artifactId>
+            <version>${project.version}</version>
+        </dependency>
+
+        <dependency>
+            <groupId>org.springframework.data</groupId>
+            <artifactId>spring-data-cassandra</artifactId>
+        </dependency>
+        <dependency>
+            <groupId>org.springframework.data</groupId>
+            <artifactId>spring-data-commons-core</artifactId>
+        </dependency>
+
+        <dependency>
+            <groupId>org.apache.commons</groupId>
+            <artifactId>commons-lang3</artifactId>
+        </dependency>
+
+        <!-- Dozer for mapping to DTOs -->
+        <dependency>
+            <groupId>net.sf.dozer</groupId>
+            <artifactId>dozer</artifactId>
+        </dependency>
+
+        <!-- JSR 330: Dependency Injection for Java -->
+        <dependency>
+            <groupId>javax.inject</groupId>
+            <artifactId>javax.inject</artifactId>
+        </dependency>
+
+        <!-- test dependencies -->
+        <dependency>
+            <groupId>org.robbins.flashcards</groupId>
+            <artifactId>FlashCards_Test</artifactId>
+            <version>${project.version}</version>
+            <scope>test</scope>
+        </dependency>
+        <dependency>
+            <groupId>org.hamcrest</groupId>
+            <artifactId>hamcrest-all</artifactId>
+        </dependency>
+
+        <dependency>
+            <groupId>org.cassandraunit</groupId>
+            <artifactId>cassandra-unit-spring</artifactId>
+        </dependency>
+
+        <!-- logging -->
+        <dependency>
+            <groupId>org.slf4j</groupId>
+            <artifactId>slf4j-api</artifactId>
+        </dependency>
+        <dependency>
+            <groupId>ch.qos.logback</groupId>
+            <artifactId>logback-classic</artifactId>
+        </dependency>
+	</dependencies>
+	<build>
+		<finalName>FlashCards_Repository_Cassandra</finalName>
+	</build>
+</project>

FlashCards_Repository/FlashCards_Repository_Cassandra/src/main/java/org/robbins/flashcards/cassandra/repository/TagRepository.java

@@ -0,0 +1,12 @@
+package org.robbins.flashcards.cassandra.repository;
+
+import org.robbins.flashcards.cassandra.repository.domain.TagCassandraDto;
+import org.springframework.data.cassandra.repository.TypedIdCassandraRepository;
+import org.springframework.stereotype.Repository;
+
+import java.util.UUID;
+
+@Repository("tagRepository")
+public interface TagRepository extends TypedIdCassandraRepository<TagCassandraDto, UUID> {
+
+}

FlashCards_Repository/FlashCards_Repository_Cassandra/src/main/java/org/robbins/flashcards/cassandra/repository/UserRepository.java

@@ -0,0 +1,15 @@
+package org.robbins.flashcards.cassandra.repository;
+
+import org.robbins.flashcards.cassandra.repository.domain.UserCassandraDto;
+import org.springframework.data.cassandra.repository.Query;
+import org.springframework.data.cassandra.repository.TypedIdCassandraRepository;
+import org.springframework.stereotype.Repository;
+
+import java.util.UUID;
+
+@Repository("userRepository")
+public interface UserRepository extends TypedIdCassandraRepository<UserCassandraDto, UUID> {
+
+    @Query("SELECT * FROM user WHERE openid = ?0")
+    public UserCassandraDto findUserByOpenid(final String openid);
+}

FlashCards_Repository/FlashCards_Repository_Cassandra/src/main/java/org/robbins/flashcards/cassandra/repository/conversion/impl/DefaultTagDtoConverter.java

@@ -0,0 +1,57 @@
+package org.robbins.flashcards.cassandra.repository.conversion.impl;
+
+import org.apache.commons.lang3.NotImplementedException;
+import org.robbins.flashcards.cassandra.repository.domain.TagCassandraDto;
+import org.robbins.flashcards.conversion.DtoConverter;
+import org.robbins.flashcards.dto.TagDto;
+import org.robbins.flashcards.exceptions.RepositoryException;
+import org.robbins.flashcards.repository.conversion.impl.AbstractDtoConverter;
+import org.springframework.stereotype.Component;
+
+import java.util.ArrayList;
+import java.util.List;
+import java.util.Set;
+
+@Component("tagDtoConverter")
+public class DefaultTagDtoConverter extends AbstractDtoConverter implements DtoConverter<TagDto, TagCassandraDto> {
+
+    @Override
+    public TagDto getDto(final TagCassandraDto entity) throws RepositoryException {
+        return getMapper().map(entity, TagDto.class);
+    }
+
+    @Override
+    public TagDto getDto(final TagCassandraDto entity, final Set<String> fields)
+            throws RepositoryException
+	{
+        throw new NotImplementedException("method not yet implemented in Cassandra repository");
+    }
+
+    @Override
+    public TagCassandraDto getEntity(final TagDto dto) {
+        return getMapper().map(dto, TagCassandraDto.class);
+    }
+
+    @Override
+    public List<TagDto> getDtos(List<TagCassandraDto> entities) throws RepositoryException {
+        List<TagDto> dtos = new ArrayList<>();
+        for (TagCassandraDto entity : entities) {
+            dtos.add(getDto(entity));
+        }
+        return dtos;
+    }
+
+    @Override
+    public List<TagDto> getDtos(final List<TagCassandraDto> entities, final Set<String> fields)
+            throws RepositoryException {throw new NotImplementedException("method not yet implemented in Cassandra repository");
+    }
+
+    @Override
+    public List<TagCassandraDto> getEntities(final List<TagDto> dtos) {
+        List<TagCassandraDto> entities = new ArrayList<>();
+        for (TagDto dto : dtos) {
+            entities.add(getEntity(dto));
+        }
+        return entities;
+    }
+}

FlashCards_Repository/FlashCards_Repository_Cassandra/src/main/java/org/robbins/flashcards/cassandra/repository/conversion/impl/DefaultUserDtoConverter.java

@@ -0,0 +1,57 @@
+package org.robbins.flashcards.cassandra.repository.conversion.impl;
+
+import org.apache.commons.lang3.NotImplementedException;
+import org.robbins.flashcards.cassandra.repository.domain.UserCassandraDto;
+import org.robbins.flashcards.conversion.DtoConverter;
+import org.robbins.flashcards.dto.UserDto;
+import org.robbins.flashcards.exceptions.RepositoryException;
+import org.robbins.flashcards.repository.conversion.impl.AbstractDtoConverter;
+import org.springframework.stereotype.Component;
+
+import java.util.ArrayList;
+import java.util.List;
+import java.util.Set;
+
+@Component("userDtoConverter")
+public class DefaultUserDtoConverter extends AbstractDtoConverter implements DtoConverter<UserDto, UserCassandraDto> {
+
+    @Override
+    public UserDto getDto(final UserCassandraDto entity) throws RepositoryException {
+        return getMapper().map(entity, UserDto.class);
+    }
+
+    @Override
+    public UserDto getDto(final UserCassandraDto entity, final Set<String> fields)
+            throws RepositoryException
+	{
+        throw new NotImplementedException("method not yet implemented in Cassandra repository");
+    }
+
+    @Override
+    public UserCassandraDto getEntity(final UserDto dto) {
+        return getMapper().map(dto, UserCassandraDto.class);
+    }
+
+    @Override
+    public List<UserDto> getDtos(List<UserCassandraDto> entities) throws RepositoryException {
+        List<UserDto> dtos = new ArrayList<>();
+        for (UserCassandraDto entity : entities) {
+            dtos.add(getDto(entity));
+        }
+        return dtos;
+    }
+
+    @Override
+    public List<UserDto> getDtos(final List<UserCassandraDto> entities, final Set<String> fields)
+            throws RepositoryException {throw new NotImplementedException("method not yet implemented in Cassandra repository");
+    }
+
+    @Override
+    public List<UserCassandraDto> getEntities(final List<UserDto> dtos) {
+        List<UserCassandraDto> entities = new ArrayList<>();
+        for (UserDto dto : dtos) {
+            entities.add(getEntity(dto));
+        }
+        return entities;
+    }
+}

FlashCards_Repository/FlashCards_Repository_Cassandra/src/main/java/org/robbins/flashcards/cassandra/repository/domain/TagCassandraDto.java

@@ -0,0 +1,32 @@
+package org.robbins.flashcards.cassandra.repository.domain;
+
+import org.springframework.data.cassandra.mapping.PrimaryKey;
+import org.springframework.data.cassandra.mapping.Table;
+
+import java.io.Serializable;
+import java.util.UUID;
+
+@Table(value = "tag")
+public class TagCassandraDto implements Serializable {
+
+    @PrimaryKey
+    private UUID id;
+
+    private String name;
+
+    public UUID getId() {
+        return id;
+    }
+
+    public void setId(UUID id) {
+        this.id = id;
+    }
+
+    public String getName() {
+        return name;
+    }
+
+    public void setName(String name) {
+        this.name = name;
+    }
+}