Scala中使用Slick动态绑定/插值构建SQL原生查询的问题

问题说明 #

在Scala中使用Slick框架构建原生SQL插入查询时，需要动态绑定rowData中的值，初始实现仅支持固定数量的元素，尝试动态生成占位符并调用bind方法时触发错误。

报错信息 #

value bind is not a member of slick.sql.SqlAction[Int,slick.dbio.NoStream,slick.dbio.Effect]    
[error] possible cause: maybe a semicolon is missing before `value bind`?
[error]                 .bind(rowData: _*)
[error]                   

相关代码 #

初始固定元素实现 #

def insertToTableSQLQuery(tableName: String, columnDefinitions: Seq[ColumnDefinition], rowData: ListBuffer[Any]): Future[Int] = db.run {
        val columns = columnDefinitions.map(_.name).mkString(", ")

        sqlu"insert into #$tableName(#$columns) values (#${rowData(0)}, #${rowData(1)}, #${rowData(2)}, #${rowData(3)}, #${rowData(4)});"
}

尝试的动态实现（触发报错） #

def insertToTableSQLQuery(tableName: String, columnDefinitions: Seq[ColumnDefinition], rowData: ListBuffer[Any]): Future[Int] = db.run {
            val columnNames = columnDefinitions.map(_.name).mkString(", ")
            val placeholders = List.fill(rowData.length)("?").mkString(", ")

            sqlu"insert into #$tableName(#$columnNames) values (#${rowData.map(_ => "?").mkString(", ")});".bind(rowData: _*)
}

正确实现方法 #

报错原因是sqlu插值器返回的SqlAction对象没有bind方法，bind属于StaticQuery的方法。以下是两种可行的动态绑定方案：

方案一：使用StaticQuery构建动态查询 #

import slick.jdbc.StaticQuery.interpolation
import scala.concurrent.Future

def insertToTableSQLQuery(tableName: String, columnDefinitions: Seq[ColumnDefinition], rowData: ListBuffer[Any]): Future[Int] = {
    val columnNames = columnDefinitions.map(_.name).mkString(", ")
    val placeholders = List.fill(rowData.length)("?").mkString(", ")
    val sqlStmt = s"insert into $tableName($columnNames) values ($placeholders)"
    
    db.run(StaticQuery.updateNA(sqlStmt).apply(rowData: _*))
}

方案二：利用sql插值器的可变参数绑定 #

def insertToTableSQLQuery(tableName: String, columnDefinitions: Seq[ColumnDefinition], rowData: ListBuffer[Any]): Future[Int] = db.run {
    val columnNames = columnDefinitions.map(_.name).mkString(", ")
    val params = rowData.map(_.asInstanceOf[AnyRef]) // 统一转换为AnyRef适配参数绑定
    
    sql"""insert into #$tableName(#$columnNames) values (${params: _*})""".asUpdate
}

关键说明 #

• sqlu是静态参数插值器，仅支持固定数量的参数；动态参数场景推荐用sql插值器配合asUpdate，或直接使用StaticQuery。
• 动态生成表名/列名时，要做好输入校验，避免SQL注入风险。
• 确保rowData元素类型与数据库列类型匹配，避免类型转换异常。

内容的提问来源于stack exchange，提问作者SM-171