Usando Riak com Scala

DBWrapper.scala

package com.softsimples.social.persistence

import scala.collection.JavaConverters._
import com.basho.riak.client.{IRiakClient, RiakFactory}
import com.basho.riak.client.bucket.Bucket
	
class DBWrapper(private val riakClient:IRiakClient) {
	
  def createHashWrapperFor( bucketName:String ): HashWrapper = {
    HashWrapper.buildTableWrapper( buildBucket( bucketName ) )
  }
	
  private def buildBucket( bucketName:String ): Bucket = {
    var bucket = riakClient.fetchBucket( bucketName ).execute()
    if (bucket == null) bucket = riakClient.createBucket(bucketName).nVal(1).execute()
    bucket
  }
	
  def listOfTables(): Set[String] = riakClient.listBuckets.asScala.toSet[String]
}
	
object DBWrapper {
  def buildDBWrapper(host:String, port:Int): DBWrapper = new DBWrapper( RiakFactory.pbcClient(host, port) )

  def buildDBWrapper(host:String): DBWrapper = new DBWrapper( RiakFactory.pbcClient(host, 8087) )
	
  def buildDBWrapper(): DBWrapper = new DBWrapper( RiakFactory.pbcClient("127.0.0.1", 8087) )
}