Skip to content
This repository has been archived by the owner on Jan 8, 2023. It is now read-only.
/ zio-cassandra Public archive

Just alternative wrapper for zio, inspired by akka(alpakka)-cassandra

License

Notifications You must be signed in to change notification settings

jsfwa/zio-cassandra

Folders and files

NameName
Last commit message
Last commit date

Latest commit

 

History

32 Commits
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 

Repository files navigation

Release Artifacts Snapshot Artifacts

zio-cassandra

scala = 2.13.6
cassandra-driver = 4.13.0
zio = 1.0.12

Inspired by akka/alpakka-cassandra

Usage

Dependency:

libraryDependencies += "io.github.jsfwa" %% "zio-cassandra" % "1.0.6"

Check driver config documentation on datastax

// Cassandra Session:
  val session = CassandraSession.make(config)
//OR
  val session = CassandraSession.make(cqlSessionBuilder)

// Use:
  val job = for {
    session  <- ZIO.service[CassandraSession]
    _        <- session.execute("insert ...")
    prepared <- session.prepare("select ...")
    select   <- session.bind(prepared, Seq(args))
    row      <- session.selectOne(select, profileName = "oltp")
  } yield row
  
  job.provideCustomLayer(CassandraSession.make(config).toLayer)

About

Just alternative wrapper for zio, inspired by akka(alpakka)-cassandra

Resources

License

Stars

Watchers

Forks

Packages

No packages published

Contributors 4

  •  
  •  
  •  
  •  

Languages