使用scala：

import scala.io.Source
import org.apache.spark.sql.SparkSession
 val spark = SparkSession.builder
    .appName("execute-query-files") 
    .master("local[*]") //since the jar will be executed locally
    .getOrCreate()

val sqlQuery = Source.fromFile("path/to/data.sql").mkString //read file
spark.sql(sqlQuery) //execute query

其中spark是您的spark会话，已经创建。