如何解决Spark单元测试-模拟Azure SQLJDBC连接
我想对下面的代码进行单元测试,以便获得良好的代码覆盖率。我正在将 FunSuite与Mockito一起使用。您能告诉我如何模拟数据库连接并进行单元测试吗?
def getSummaryConfig() : Config = {
Config(Map(
"url" -> configUtil.getProperty("azure.host.name"),"databaseName" -> configUtil.getProperty("azure.database.name"),"dbTable" -> configUtil.getProperty("azure.summary.table"),"user" -> configUtil.getProperty("azure.user.name"),"password" -> configUtil.getProperty("azure.database.password")
))
}
def getSummaryDF(summaryConfig : Config) : DataFrame = {
val summaryDF = spark.read.option("driver","com.microsoft.sqlserver.jdbc.SQLServerDriver").sqlDB(summaryConfig)
summaryDF
}
val summaryConfig = getSummaryConfig()
val summaryDF = getSummaryDF(summaryConfig)
版权声明:本文内容由互联网用户自发贡献,该文观点与技术仅代表作者本人。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。如发现本站有涉嫌侵权/违法违规的内容, 请发送邮件至 dio@foxmail.com 举报,一经查实,本站将立刻删除。