• 设为首页
  • 点击收藏
  • 手机版
    手机扫一扫访问
    迪恩网络手机版
  • 关注官方公众号
    微信扫一扫关注
    公众号

Scala DBApi类代码示例

原作者: [db:作者] 来自: [db:来源] 收藏 邀请

本文整理汇总了Scala中play.api.db.DBApi的典型用法代码示例。如果您正苦于以下问题:Scala DBApi类的具体用法?Scala DBApi怎么用?Scala DBApi使用的例子?那么恭喜您, 这里精选的类代码示例或许可以为您提供帮助。



在下文中一共展示了DBApi类的16个代码示例,这些例子默认根据受欢迎程度排序。您可以为喜欢或者感觉有用的代码点赞,您的评价将有助于我们的系统推荐出更棒的Scala代码示例。

示例1: FileRepository

//设置package包名称以及导入依赖的类
package repositories.filesystem

import javax.inject.Inject

import models.{FileMetadata, Account, File, Path}
import play.api.db.DBApi
import repositories.ValidationError

import scala.concurrent.ExecutionContext

class FileRepository @Inject()(
  dbApi: DBApi,
  nodeRepository: FsNodeRepository,
  fileSourceRepository: FileSourceRepository,
  fileMetadataRepository: FileMetadataRepository
)(
 implicit ec: ExecutionContext
){

  
  def delete(file: File)(implicit account: Account): Either[ValidationError, Unit] = {
    nodeRepository.delete(file.node) match {
      case Left(error) => Left(error)
      case Right(_) => Right(Unit)
    }
  }

  // TODO Search file by name/path, content ?
} 
开发者ID:Cumulus-Cloud,项目名称:cumulus,代码行数:30,代码来源:FileRepository.scala


示例2: insertNonAtomic

//设置package包名称以及导入依赖的类
package repositories.filesystem

import java.sql.Connection
import java.util.UUID
import javax.inject.Inject

import anorm.SqlParser._
import anorm._
import models.{FsNode, Permission}
import play.api.db.DBApi

import scala.concurrent.ExecutionContext

class [email protected]()(
  dbApi: DBApi
)(
  implicit ec: ExecutionContext
) {

  import PermissionRepository._

  private[filesystem] def insertNonAtomic(fileSystemElement: FsNode, permission: Permission)(implicit c: Connection) = {
    insertPermission(fileSystemElement, permission).execute()
  }

}

object PermissionRepository {

  val table = "permission"

  val parser = {
    get[UUID]("account_id") ~
    get[Array[String]]("permissions")  map {
      case account_id ~ permissions
        => Permission(account_id, permissions)
    }
  }

  private def insertPermission(fileSystemElement: FsNode, permission: Permission) = SQL"""
     INSERT INTO #$table (
       account_id,
       directory_id,
       permissions)
     VALUES (
       ${permission.accountId}::uuid,
       ${fileSystemElement.id}::uuid,
       ${permission.permissions.toArray[String]}
     );
    """
} 
开发者ID:Cumulus-Cloud,项目名称:cumulus,代码行数:52,代码来源:PermissionRepository.scala


示例3: DirectoryRepository

//设置package包名称以及导入依赖的类
package repositories.filesystem

import javax.inject.Inject

import models.{File, Account, Directory, Path}
import play.api.db.DBApi
import repositories.ValidationError

import scala.concurrent.ExecutionContext

class DirectoryRepository @Inject()(
  dbApi: DBApi,
  nodeRepository: FsNodeRepository
)(
  implicit ec: ExecutionContext
){

  
  def delete(directory: Directory)(implicit account: Account): Either[ValidationError, Unit] = {
    nodeRepository.delete(directory.node) match {
      case Left(error) => Left(error)
      case Right(_) => Right(Unit)
    }
  }

  // TODO Search directory by name/path
} 
开发者ID:Cumulus-Cloud,项目名称:cumulus,代码行数:28,代码来源:DirectoryRepository.scala


示例4: User

//设置package包名称以及导入依赖的类
package models

import anorm._
import play.api.db.DBApi
import scala.concurrent.Future
import scala.util.Random
import javax.inject.{Inject, Singleton}

case class User(id: Option[Long] = None, username: Option[String] = None, password: Option[String] = None, token: Option[String] = None)

@Singleton
class UserCollection @Inject() (dbs: DBApi)(implicit ec: DatabaseExecutionContext) {

  private val db = dbs.database("default")
  private val parser = Macro.namedParser[User]


  def create(username: String, password: String): Unit = {
      Future {
        val token = Random.nextString(20)
        db.withConnection { implicit conn =>
          SQL("INSERT INTO users(username, password, token) VALUES ({username}, {password}, {token})").
            on('username -> username, 'password -> password, 'token -> token).
            executeInsert()
        }
      }
  }

  def delete(username: String, password: String): Unit = {
    Future {
      db.withConnection { implicit conn =>
        SQL("DELETE FROM useres WHERE username = {username} AND password = {password}").
          on('username -> username, 'password -> password).
          execute()
      }
    }
  }

  def login(username: String, password: String): Future[Option[User]] = {
    Future {
      db.withConnection { implicit conn =>
        SQL("SELECT * FROM users WHERE username = {username} AND password = {password}").
          on('username -> username, 'password -> password).
          executeQuery().as(parser.*).headOption
      }
    }
  }

  def findByToken(token: String): Future[Option[User]] = {
    Future {
      db.withConnection { implicit conn =>
        SQL("SELECT * FROM users WHERE token = {token}").
          on('token -> token).
          executeQuery().as(parser.*).headOption
      }
    }
  }

} 
开发者ID:Hu13er,项目名称:playingPlayFramework,代码行数:60,代码来源:User.scala


示例5: DBSpec

//设置package包名称以及导入依赖的类
import com.github.stonexx.play.db.slick.DB
import org.scalatestplus.play._
import play.api.db.DBApi
import play.api.test._
import play.api.test.Helpers._

import scala.concurrent.ExecutionContext


class DBSpec extends PlaySpec with guice.GuiceOneAppPerTest {

  "DB" should {
    "work as expected" in {
      import models._
      import slick.Tables._, profile.api._

      implicit val ec = app.injector.instanceOf[ExecutionContext]

      val cats = TableQuery[Cats]

      val testKitties = Seq(
        Cat("kit", "black", flag = true, Cat.State.Normal),
        Cat("garfield", "orange", flag = true, Cat.State.Good),
        Cat("creme puff", "grey", flag = true, Cat.State.VeryGood)
      )
      await(DB.run((for {
        oldCats <- cats.result
        _ <- cats.delete
        _ <- cats ++= testKitties
        _ <- cats.result.map(_ must equal(testKitties))
        _ <- cats.delete
        _ <- cats ++= oldCats
      } yield ()).transactionally))
    }

    "use the correct db settings when specified" in {
      app.injector.instanceOf[DBApi].database("specific").withConnection { implicit conn =>
        conn.getMetaData.getURL must equal("jdbc:h2:mem:veryspecialindeed")
      }
    }

    "use the default db settings when no other possible options are available" in {
      app.injector.instanceOf[DBApi].database("default").withConnection { implicit conn =>
        conn.getMetaData.getURL must equal("jdbc:h2:mem:play")
      }
    }
  }

} 
开发者ID:stonexx,项目名称:utils,代码行数:50,代码来源:DBSpec.scala


示例6: ProductService

//设置package包名称以及导入依赖的类
package models

import javax.inject.Inject

import play.api.db.DBApi
import anorm._
import anorm.SqlParser.{int, str}

@javax.inject.Singleton
class ProductService @Inject() (dbApi: DBApi) {

  private val DB = dbApi.database("default")

  val defaultParser = int("id") ~ str("name") map {
    case id ~ name  => Product(id, name)
  }

  def save(product: Product) = {
    println("Product saved!!")
    DB.withConnection { implicit c =>
      SQL("INSERT INTO Products(id, name) VALUES ({id}, {name});")
        .on('id -> product.id, 'name -> product.name).executeInsert()
    }
  }


  def update(product: Product) = {


    DB.withConnection { implicit c =>
      SQL("UPDATE Products SET name = {name} WHERE id = {id}")
        .on('name -> product.name, 'id -> product.id).executeUpdate()
    }
  }


  def delete(id: Long) = {
    DB.withConnection { implicit c =>
      SQL("DELETE FROM Products WHERE id={id};")
        .on('id -> id).executeUpdate()
    }
  }


  def get(id: Long) = {
    DB.withConnection { implicit c =>
      SQL("SELECT * FROM Products WHERE id={id};")
        .on('id -> id).executeQuery().singleOpt(defaultParser)
    }
  }

  def all = {
    DB.withConnection { implicit c =>
      SQL("SELECT * FROM Products;").executeQuery().list(defaultParser)
    }
  }
} 
开发者ID:sureshpck,项目名称:foo-scala,代码行数:58,代码来源:ProductService.scala


示例7: TourneyService

//设置package包名称以及导入依赖的类
package services

import javax.inject.Inject

import anorm.SqlParser._
import anorm._
import models.Tourney
import play.api.db.DBApi

import scala.language.postfixOps

@javax.inject.Singleton
class TourneyService @Inject()(dbapi: DBApi) {

  private val db = dbapi.database("default")

  val simple = {
    get[Option[Long]]("tourney.id") ~
      get[String]("tourney.name") map {
      case id ~ name => Tourney(id, name)
    }
  }

  def findById(id: Long): Tourney = {
    db.withConnection { implicit connection =>
      SQL(
        """
          select * from tourney where id = {id}
        """
      ).on(
        'id -> id
      ).as(simple.single)
    }
  }

  def insert(t: Tourney): Long = {
    db.withConnection { implicit connection =>
      SQL(
        """
          insert into tourney values ((select next value for tourney_seq), {name})
        """
      ).on(
        'name -> t.name
      ).executeInsert(scalar[Long].single)
    }
  }


} 
开发者ID:ToniDias,项目名称:Scalattourney,代码行数:50,代码来源:TourneyService.scala


示例8: afterEach

//设置package包名称以及导入依赖的类
package cores.test.scalatest

import org.scalatest.BeforeAndAfterEach
import org.scalatestplus.play.{OneAppPerSuite, PlaySpec}
import play.api.db.DBApi
import play.api.db.evolutions.Evolutions

import scala.util.control.Exception._



  override def afterEach(): Unit = {
    withFinally {
      super.afterEach()
    }
  }

  // Java???finally??
  // http://seratch.hatenablog.jp/entry/20111126/1322309305
  private def withFinally = {
    ultimately {
      Evolutions.cleanupEvolutions(databaseApi.database("default"))
    }
  }

  // Google Guice?injection??????????????????
  private lazy val databaseApi: DBApi = app.injector.instanceOf[DBApi] //here is the important line
} 
开发者ID:tmknom,项目名称:scala-ddd,代码行数:29,代码来源:DatabaseSpec.scala


示例9: Company

//设置package包名称以及导入依赖的类
package models

import javax.inject.Inject

import anorm.SqlParser._
import anorm._

import play.api.db.DBApi

case class Company(id: Option[Long] = None, name: String)

@javax.inject.Singleton
class CompanyService @Inject() (dbapi: DBApi) {

  private val db = dbapi.database("default")

  
  def options: Seq[(String,String)] = db.withConnection {
    implicit connection =>
      SQL("select * from company order by name").as(simple *).
        foldLeft[Seq[(String, String)]](Nil) {
          (cs, c) =>  //cs: column sets(result), c: column(each record)
            //cs: Seq[(String, String)], c: (String,String), c.id: String
            c.id.fold(cs) {  //use column's id to fold with cs
              id => //this id is c.id
                cs :+ (id.toString -> c.name) //finally gather to cs
            }
        }
  }

} 
开发者ID:zqhxuyuan,项目名称:first-player,代码行数:32,代码来源:CompanyService.scala


示例10: start

//设置package包名称以及导入依赖的类
package services

import javax.inject._

import play.api.Logger
import play.api.inject.ApplicationLifecycle

import scala.concurrent.Future
import play.api.db.DBApi
import utils.DefaultDB
import play.api.cache.CacheApi


trait LoadCache {
  def start()
}

@Singleton
class LoadCacheImpl @Inject()(appLifecycle: ApplicationLifecycle, cache:CacheApi, db:DBApi) extends LoadCache{
  
  // You can do this, or just explicitly call `hello()` at the end
  def start(): Unit = {
    val defaultDB = new DefaultDB(db)
    val shortURLs = defaultDB.findShortURLs()

    for(shortURL <- shortURLs){
      Logger.info(s"inserting url key ${shortURL.url} value $shortURL into cache.")
      cache.set(shortURL.url, shortURL)
      Logger.info(s"inserting url key ${shortURL.shortURL} value $shortURL into cache.")
      cache.set(shortURL.shortURL, shortURL)

    }

  }
  
  // Called when this singleton is constructed (could be replaced by `hello()`)
  start()
} 
开发者ID:xinvincible21,项目名称:shortURLs,代码行数:39,代码来源:LoadCache.scala


示例11: cleanup

//设置package包名称以及导入依赖的类
import org.scalatest.{BeforeAndAfterAll, Suite}
import java.util.Calendar
import java.util.concurrent.TimeUnit
import play.api.Mode
import play.api.db.DBApi
import play.api.inject.guice.GuiceApplicationBuilder

trait IntegrationDb extends BeforeAndAfterAll { this: Suite =>
  lazy val appBuilder = new GuiceApplicationBuilder().in(Mode.Test)
  lazy val injector = appBuilder.injector()
  lazy val databaseApi = injector.instanceOf[DBApi]
  lazy val db = databaseApi.database("default")
  lazy val connection = db.getConnection()
    def cleanup() = {
    connection.close()
    db.shutdown()
    databaseApi.shutdown()
  }

  override def afterAll() = {
    cleanup()
  }

  def nowAsTimestamp(daysDiff: Int = 0) = {
    val utilDate = new java.util.Date()
    val now = Calendar.getInstance()
    now.setTime(utilDate)
    now.add(Calendar.DATE, daysDiff)
    val nowDiff = new java.sql.Timestamp(now.getTimeInMillis())
    nowDiff
  }
} 
开发者ID:Jyllands-Posten,项目名称:jpmedierTemplate,代码行数:33,代码来源:IntegrationDb.scala


示例12: newAppForTest

//设置package包名称以及导入依赖的类
package helpers

import com.google.inject.AbstractModule
import com.mohiva.play.silhouette.api.Environment
import com.mohiva.play.silhouette.test.FakeEnvironment
import com.typesafe.config.ConfigFactory
import models.User
import net.codingwell.scalaguice.ScalaModule
import org.scalatest.{BeforeAndAfterEach, Suite, TestData}
import org.scalatestplus.play.{OneAppPerTest, PlaySpec}
import play.api.db.DBApi
import play.api.db.evolutions.Evolutions
import play.api.{Application, Configuration, Mode}
import play.api.inject.Injector
import play.api.inject.guice.GuiceApplicationBuilder
import utils.auth.DefaultEnv

import scala.concurrent.ExecutionContext.Implicits.global
import scala.reflect.ClassTag

trait PlogSpec extends PlaySpec with OneAppPerTest with BeforeAndAfterEach { this: Suite =>

  lazy val appBuilder: GuiceApplicationBuilder = new GuiceApplicationBuilder()
    .overrides(new FakeModule)
    .in(Mode.Test)
    .overrides(new FakeModule)
    .loadConfig(Configuration(ConfigFactory.load("application.test.conf")))

  lazy val injector: Injector = appBuilder.injector()
  lazy val databaseApi: DBApi = injector.instanceOf[DBApi]

  override def newAppForTest(testData: TestData): Application = {
    appBuilder
      .build()
  }

  override def beforeEach {
    val dbApi = databaseApi
    Evolutions.applyEvolutions(dbApi.database("default"))
  }

  override def afterEach {
    Evolutions.cleanupEvolutions(databaseApi.database("default"))
  }

  
  implicit val env: Environment[DefaultEnv] = new FakeEnvironment[DefaultEnv](
    Seq(
      barUser.loginInfo -> barUser,
      fooUser.loginInfo -> fooUser
    )
  )

  class FakeModule extends AbstractModule with ScalaModule {
    def configure() = {
      bind[Environment[DefaultEnv]].toInstance(env)
    }
  }
} 
开发者ID:edgarmueller,项目名称:plog-backend,代码行数:60,代码来源:PlogSpec.scala


示例13: beforeEach

//设置package包名称以及导入依赖的类
package com.h3poteto.ayanerer.test

import javax.inject._
import org.scalatestplus.play._
import org.scalatest._
import play.api._
import play.api.test._
import play.api.test.Helpers._
import play.api.inject.guice._
import play.api.db.{ Database, DBApi}
import play.api.db.evolutions.Evolutions

trait DatabaseSpec extends PlaySpec with OneAppPerSuite with BeforeAndAfterEach {
  implicit override lazy val app: Application = new GuiceApplicationBuilder().build

  // Prepare and clean database
  // http://stackoverflow.com/questions/33392905/how-to-apply-manually-evolutions-in-tests-with-slick-and-play-2-4
  lazy val injector = app.injector

  lazy val databaseApi = injector.instanceOf[DBApi] //here is the important line

  override def beforeEach() = {
    Evolutions.applyEvolutions(databaseApi.database("default"))
  }

  override def afterEach() = {
    Evolutions.cleanupEvolutions(databaseApi.database("default"))
  }
} 
开发者ID:h3poteto,项目名称:ayanerer-scala,代码行数:30,代码来源:DatabaseSpec.scala


示例14: Vote

//设置package包名称以及导入依赖的类
package v1.bob

import javax.inject.{Inject, Singleton}

import anorm._
import anorm.SqlParser._
import play.api.db.DBApi
import scala.concurrent.Future

case class Vote(pollId: Long, userId: String, selection: Int) {
  val userMentionStr = s"<@$userId>"
}

trait VoteRepository {
  def select(pollId: Long): Future[Seq[Vote]]

  def vote(v: Vote): Future[Int]
}

@Singleton
class VoteRepositoryImpl @Inject()(dbapi: DBApi) extends VoteRepository {
  private val logger = org.slf4j.LoggerFactory.getLogger(this.getClass)
  private val db = dbapi.database("bob")

  val simple: RowParser[Vote] =
    get[Long]("poll_id") ~ get[String]("user_id") ~ get[Int]("candidate_serial_no") map {
      case pollId ~ userId ~ candidateSerialNo => Vote(pollId, userId, candidateSerialNo)
    }

  def select(pollId: Long): Future[Seq[Vote]] = {
    Future.successful {
      db.withConnection { implicit conn =>
        SQL(
          """SELECT poll_id, user_id, candidate_serial_no
            |FROM vote_history
            |WHERE poll_id = {poll_id}
          """.stripMargin)
          .on('poll_id -> pollId)
          .as(simple.*)
      }
    }
  }

  def vote(v: Vote): Future[Int] = {
    Future.successful {
      db.withConnection { implicit conn =>
        SQL("INSERT INTO vote_history VALUES ({poll_id}, {user_id}, {candidate_serial_no})")
          .on(
            'poll_id -> v.pollId,
            'user_id -> v.userId,
            'candidate_serial_no -> v.selection
          )
          .executeUpdate
      }
    }
  }
} 
开发者ID:ridi-data,项目名称:Bob,代码行数:58,代码来源:VoteRepository.scala


示例15: Bob

//设置package包名称以及导入依赖的类
package v1.bob

import javax.inject.{Inject, Singleton}

import anorm._
import anorm.SqlParser._
import play.api.cache._
import play.api.db.DBApi

import scala.concurrent.duration._
import scala.concurrent.{Await, Future}

final case class Bob(id: Long, name: String)

trait BobRepository {
  val simple: RowParser[Bob] = {
    get[Long]("id") ~ get[String]("name") map {
      case id ~ name => Bob(id, name)
    }
  }

  def add(name: String): Future[Int]

  def getList: Future[Seq[Bob]]

  val list: Seq[Bob]

  val asMap: Map[Long, String]
}

@Singleton
class BobRepositoryImpl @Inject()(cache: CacheApi, dbapi: DBApi) extends BobRepository {
  private val logger = org.slf4j.LoggerFactory.getLogger(this.getClass)
  private val db = dbapi.database("bob")

  val list: Seq[Bob] = cache.getOrElse("bob"){
    val bob = Await.result(getList, 10 seconds)
    bob
  }

  override def getList: Future[Seq[Bob]] = {
    Future.successful {
      db.withConnection { implicit connection =>
        SQL("SELECT id, name FROM bob ORDER BY id ASC")
          .as(simple.*)
      }
    }
  }

  def add(name: String): Future[Int] = {
    Future.successful {
      db.withConnection { implicit conn =>
        SQL("INSERT INTO bob (name) values ({name})")
          .on('name -> name)
          .executeUpdate()
      }
    }
  }

  val asMap: Map[Long, String] = list.map(l => l.id -> l.name).toMap
} 
开发者ID:ridi-data,项目名称:Bob,代码行数:62,代码来源:BobRepository.scala


示例16: ImageDao

//设置package包名称以及导入依赖的类
package com.octanner.image.impl.dao

import anorm.SqlParser._
import anorm._
import com.google.inject.Inject
import com.octanner.image.api.Image
import play.api.db.DBApi

class ImageDao  @Inject() (dBApi: DBApi) {
  private val db = dBApi.database("default")

  val imageParser = get[String]("URL_SMALL") ~
    get[String]("URL_LARGE") map {
    case urlSmall ~ urlLarge => Image(urlSmall, urlLarge)
  }

  def getByUserId(userId: Long): Option[Image] = db.withConnection { implicit connection =>
    SQL(s"SELECT URL_SMALL, URL_LARGE FROM IMAGES WHERE USER_ID={userId}").on('userId -> userId).as(imageParser.singleOpt)
  }

  def isHealthy: Boolean = db.withConnection { implicit connection =>
    SQL("SELECT 2 + 2 as FOUR").as(SqlParser.int("FOUR").single) == 4
  }
} 
开发者ID:apismensky,项目名称:lagom-demo,代码行数:25,代码来源:ImageDao.scala



注:本文中的play.api.db.DBApi类示例整理自Github/MSDocs等源码及文档管理平台,相关代码片段筛选自各路编程大神贡献的开源项目,源码版权归原作者所有,传播和使用请参考对应项目的License;未经允许,请勿转载。


鲜花

握手

雷人

路过

鸡蛋
该文章已有0人参与评论

请发表评论

全部评论

专题导读
上一篇:
Scala SerializationExtension类代码示例发布时间:2022-05-23
下一篇:
Scala PersistentEntity类代码示例发布时间:2022-05-23
热门推荐
热门话题
阅读排行榜

扫描微信二维码

查看手机版网站

随时了解更新最新资讯

139-2527-9053

在线客服(服务时间 9:00~18:00)

在线QQ客服
地址:深圳市南山区西丽大学城创智工业园
电邮:jeky_zhao#qq.com
移动电话:139-2527-9053

Powered by 互联科技 X3.4© 2001-2213 极客世界.|Sitemap