您可以将 Scala 中的数据框插入到 Teradata 存储过程中吗？

Question

我正在尝试实现获取数据框并将其用作 teradata 中存储过程的输入。这是代码

def dfToStoredProc(store_id : String) = {
var connection:Connection = null

Class.forName(driver)
connection = DriverManager.getConnection(url, username, password)

val statement = connection.prepareCall("CALL DB.STORED_PROC(?);")
  
statement.setString(1, store_id)
statement.execute()

}

val dataFrame = df.toDF()

dataFrame.map(m => dfToStoredProc(m.getLong(0).toString))

但是出现错误，有人可以帮忙吗？

Answer 1

我意识到我的错误，我忘记添加 collect() 语句

dataFrame.map(m => dfToStoredProc(m.getLong(0).toString)).collect()

一个空的数据帧被传递给引发错误的存储过程

您可以将 Scala 中的数据框插入到 Teradata 存储过程中吗？

Can you insert data frame from scala into Teradata stored proc?

stored-procedures

scala

apache-spark-sql