如何在Scala中读取Databricks仓库中的.sql文件（非笔记本）为字符串？

既然你已经确认%sh cat /absolute/path/to/file/in/repo能正常输出内容，说明文件路径和权限都没问题，问题出在Scala/JVM的文件读取方式和当前环境（大概率是Databricks）的适配性上，试试以下几种方法：

• 用Scala原生IO工具读取：确保在%scala单元格中执行，代码如下：

import scala.io.Source

val fileContent = Source.fromFile("/absolute/path/to/file/in/repo").mkString
println(fileContent)

如果还是报错，可能是JVM层面的文件系统访问限制，换用Databricks提供的工具类。

• 用Databricks dbutils读取：这是Databricks环境下最可靠的文件读取方式，能绕过JVM的环境隔离问题：

// 读取文件前N行，适合快速查看内容
val headContent = dbutils.fs.head("/absolute/path/to/file/in/repo")
println(headContent)

// 读取完整文件内容
val fullContent = dbutils.fs.read("/absolute/path/to/file/in/repo").mkString
println(fullContent)

• 用Spark API读取：如果是大文件，推荐用Spark的文本读取API，同时兼容集群环境：

// 读取为DataFrame
val textDF = spark.read.text("/absolute/path/to/file/in/repo")
textDF.show()

// 转换为完整字符串
val contentStr = textDF.collect().map(_.getString(0)).mkString("\n")
println(contentStr)

如果你的代码是在普通Scala脚本而非Databricks Notebook中运行，重点检查scala.io.Source的路径拼写，同时确认运行用户拥有文件读取权限。

内容的提问来源于stack exchange，提问作者hello_friend