2017-04-16 62 views
1

有什么方法可以在Scala对象中注入play数据库依赖关系?我知道我们可以做类似注入数据库依赖关系scala对象

class MyClass @Inject() (db: Database) = { 
} 

但我想注入依赖关系,而实际上没有使用Play插件。

我build.sbt看起来像这样

scalaVersion := "2.11.8" 

lazy val sparkVersion = "2.1.0" 

lazy val hadoopVersion = "2.7.0" 

lazy val jacksonVersion = "2.8.7" 

libraryDependencies ++= Seq(
    "org.apache.spark" %% "spark-core" % sparkVersion, 
    "org.apache.spark" %% "spark-sql" % sparkVersion, 
    "org.apache.hadoop" % "hadoop-common" % hadoopVersion, 
    "com.databricks" %% "spark-csv" % "1.5.0", 
    "org.codehaus.janino" % "janino" % "3.0.7", 
    "com.databricks" % "spark-redshift_2.11" % "3.0.0-preview1", 
    "com.amazonaws" % "aws-java-sdk-s3" % "1.11.34", 
    "com.typesafe" % "config" % "1.3.1", 
    "com.typesafe.play" % "play-json_2.11" % "2.4.6", 
    "com.typesafe.play" %% "play" % "2.5.9", 
    "com.typesafe.play" % "play-jdbc_2.11" % "2.5.14", 
    "com.amazon.redshift" % "jdbc42" % "1.2.1.1001" from "https://s3.amazonaws.com/redshift-downloads/drivers/RedshiftJDBC42-1.2.1.1001.jar" 
) 

fork in Test := true 

assemblyMergeStrategy in assembly := { 
    case ".gitkeep" => MergeStrategy.discard 
    case "META-INF/groovy-release-info.properties" => MergeStrategy.discard 
    case "META-INF/MANIFEST.MF" => MergeStrategy.discard 
    //case "log4j.properties" => MergeStrategy.deduplicate 
    case x: String if x.matches("""META-INF/.*\.(SF|DSA|RSA)""") => MergeStrategy.discard 
    case x: String if x.startsWith("META-INF/services/org.apache.lucene") => MergeStrategy.concat 
    case x => MergeStrategy.first 
} 

我试图

object MyObject { 
@Inject() 
var db: Database = _ 
} 

,但它不能为空指针异常

+0

从我的卑微经验:通常你不想在'对象'中存储状态。因此,您不希望注入状态来以其他方式反对,而不仅仅是在方法调用中传递它。这样你就没有初始化问题,没有任何问题改变注入依赖和行为的行为仍然是可测试的。 –

回答

2

@Inject不会在这种情况下工作。 Object在语言级别上作为单例使用,而依赖注入是由配置驱动的,在Playframework的情况下,使用底层的Guice引擎构建。有效的DI只适用于由DI创建或插入其中的对象,因此Guice应该至少知道MyObject的存在。

最佳选择是使用类@Inject注释

case class MyObject @Inject() (db: Database) 

如果不是这种情况,你可以从应用程序对象Injector引用(这是弃用,应避免使用)

object MyObject { 
    lazy val db: Database = Play.unsafeApplication.injector.instanceOf[Database] 
} 
+0

正如你所说的那样,当我使用Injector时,它会引发错误,因为“应用程序未启动” – hlagvankar

+0

您需要运行一个应用程序。 val db之前你有懒吗? – mavarazy

+0

是的。实际上它是没有Play插件的Spark应用程序。但是我想使用Play特定的功能,如注入数据库,配置来读取application.conf,Environment等,而不需要在build.sbt中启用Play插件。到目前为止阅读application.conf我正在使用ConfigFactory I/O配置。有没有什么方法可以在不使用Play插件的情况下使用它们? – hlagvankar