Finished the repository structures

app/repositories/CassandraRepository.scala

@@ -0,0 +1,27 @@
+package repositories
+
+import com.datastax.driver.core.querybuilder.QueryBuilder
+import com.datastax.driver.core.querybuilder.QueryBuilder._
+import com.datastax.driver.core.{Row, Session}
+
+abstract class CassandraRepository[M, I](session: Session, tablename: String, partitionKeyName: String)
+  extends Repository[M, I] {
+  def rowToModel(row: Row): M
+
+  def getOneRowBySinglePartitionKeyId(partitionKeyValue: I): Row = {
+    val selectStmt =
+      select()
+        .from(tablename)
+        .where(QueryBuilder.eq(partitionKeyName, partitionKeyValue))
+        .limit(1)
+
+    val resultSet = session.execute(selectStmt)
+    val row = resultSet.one()
+    row
+  }
+
+  override def getOneById(id: I): M = {
+    val row = getOneRowBySinglePartitionKeyId(id)
+    rowToModel(row)
+  }
+}

app/repositories/ProductsRepository.scala

@@ -0,0 +1,14 @@
+package repositories
+
+import com.datastax.driver.core.{Row, Session}
+import models.ProductModel
+
+class ProductsRepository(session: Session)
+  extends CassandraRepository[ProductModel, Int](session, "products", "id") {
+  override def rowToModel(row: Row): ProductModel = {
+    ProductModel(
+      row.getInt("id"),
+      row.getString("name")
+    )
+  }
+}