charmygarg

import com.outworkers.phantom.dsl._

charmygarg

import com.outworkers.phantom.dsl._

object Defaults {
  val Connector = ContactPoint.local.keySpace(KeySpace("my_keyspace")
                                              .ifNotExists().`with`(replication eqs SimpleStategy.replication_factor(1)))
}

class CassandraDatabase(override val connector: CassandraConnection) extends Database[CassandraDatabase](connector) {
  object users extends Users with Connector
}

charmygarg

case class User(
  id: String,
  email: Set[String],
  name: String
) 

charmygarg

import com.outworkers.phantom.dsl._

abstract class Users extends Table[Users, User] {
  object id extends StringColumn with PartitionKey
  object email extends SetColumn[String]
  object name extends StringColumn with PartitionKey
}

charmygarg

trait Table[T <: Table[T, R], R] extends CassandraTable[T, R] with TableAliases[T, R] with RootConnector

charmygarg

package com.outworkers.phantom.connectors
trait RootConnector extends scala.AnyRef {
  implicit def space : com.outworkers.phantom.connectors.KeySpace
  implicit def session : com.datastax.driver.core.Session
}

charmygarg

def save(user: User): Future[ResultSet] = {
    insert
      .value(_.id, user.id)
      .value(_.name, user.name)
      .value(_.email, user.email)
      .future()
  }

charmygarg

def getAllUsers: Future[List[User]] = {
    select
      .fetch()
  }

  def getByid(id: String): Future[Option[String]] = {
    select(_.name)
      .where(_.id eqs id)
      .allowFiltering()
      .one()

charmygarg

<dependencies>
    <dependency>
        <groupId>io.vavr</groupId>
        <artifactId>vavr</artifactId>
        <version>0.9.0</version>
    </dependency>
</dependencies>

charmygarg

List<String> list = List.of("Java", "PHP", "Jquery", "JavaScript", "JShell", "JAVA");