Scala、Sangria和Scalatra

Question

我们有一个使用Scalatra (http://scalatra.org/)作为我们的web框架的Scala应用程序。我想知道在如何使用Sangria ( GraphQL )和Scalatra实现一个http://sangria-graphql.org/端点方面是否有任何好的(或者仅仅是任何)资源？

我是Scala新手，希望能在这方面有任何帮助。

Answer 1

据我所知，这里没有任何东西，但是由于Scalatra使用json4s，所以您可以使用sangria的json4s 编组员。

否则，如果sangria对您更清楚，这里有一个scala工作表，其中包含一个基于play + sangria的非常简单的示例--在本例中，您只需交换json库即可。

数据库被嘲弄了(也许你用的是Slick?)还有http服务器，但这是函数定义中交换的一个简单例子。

import sangria.ast.Document
import sangria.execution.{ErrorWithResolver, Executor, QueryAnalysisError}
import sangria.macros.derive.{ObjectTypeDescription, ObjectTypeName, deriveObjectType}
import sangria.parser.{QueryParser, SyntaxError}
import sangria.renderer.SchemaRenderer
import sangria.schema.{Argument, Field, IntType, ListType, ObjectType, OptionInputType, Schema, fields}

import scala.concurrent.Await
import scala.concurrent.duration._
import scala.concurrent.ExecutionContext.Implicits.global

import scala.concurrent.Future
import scala.util.{Failure, Success}

// replace with another json lib
// eg https://github.com/sangria-graphql/sangria-json4s-jackson
import play.api.libs.json._
import sangria.marshalling.playJson._


case class User(name: String, age: Int, phone: Option[String])
class FakeDb {

  class UsersTable {
    def getUsers(limit: Int): List[User] = {
      // this would come from the db
      List(
        User("john smith", 23, None),
        User("Anne Schwazenbach", 45, Some("2134556"))
      )
    }
  }

  val usersRepo = new UsersTable

}

object MySchema {

  val limitArg: Argument[Int] = Argument("first", OptionInputType(IntType),
    description = s"Returns the first n elements from the list.",
    defaultValue = 10)

  implicit val UsersType: ObjectType[FakeDb, User] = {
    deriveObjectType[FakeDb, User](
      ObjectTypeName("Users"),
      ObjectTypeDescription("Users in the system")
    )
  }
  private val Query: ObjectType[FakeDb, Unit] = ObjectType[FakeDb, Unit](
    "Query", fields[FakeDb, Unit](
      Field("users", ListType(UsersType),
        arguments = limitArg :: Nil,
        resolve = c => c.ctx.usersRepo.getUsers(c.arg(limitArg))
      )
    ))
  val theSchema: Schema[FakeDb, Unit] = Schema(Query)
}

object HttpServer {

  def get(): String = {
    // Http GET  
    SchemaRenderer.renderSchema(MySchema.theSchema)
  }

  def post(query: String): Future[JsValue] = {
    // Http POST
    val variables = None
    val operation = None

    QueryParser.parse(query) match {
      case Success(q) => executeQuery(q, variables, operation)
      case Failure(error: SyntaxError) => Future.successful(Json.obj("error" -> error.getMessage))
      case Failure(error: Throwable) => Future.successful(Json.obj("error" -> error.getMessage))
    }
  }

  private def executeQuery(queryAst: Document, vars: Option[JsValue], operation: Option[String]): Future[JsValue] = {
    val schema: Schema[FakeDb, Unit] = MySchema.theSchema
    Executor.execute[FakeDb, Unit, JsValue](schema, queryAst, new FakeDb,
      operationName = operation,
      variables=vars.getOrElse(Json.obj()))
      .map((d: JsValue) => d)
      .recover {
        case error: QueryAnalysisError ⇒ Json.obj("error" -> error.getMessage)
        case error: ErrorWithResolver ⇒ Json.obj("error" -> error.getMessage)
      }
  }
}

HttpServer.get()

val myquery = """
  {
    users {
     name
    }
  }
  """

val res: JsValue = Await.result(HttpServer.post(myquery), 10.seconds)