如何使用scala slick 3发送纯SQL查询(并检索结果)

Question

我正在尝试创建一个类,该类具有可以使用纯SQL查询向SQLite数据库发送和获取数据的方法.遗憾的是,这不起作用.我不想使用withSession隐式部分.

import slick.driver.SQLiteDriver.api._
import slick.lifted.TableQuery
import slick.jdbc.JdbcBackend.Database;
import scala.concurrent.ExecutionContext.Implicits.global
import scala.concurrent._
import ExecutionContext.Implicits.global

    class DBops {
  val db = Database.forURL("jdbc:sqlite:S:/testing/testdb.sql",driver = "org.sqlite.JDBC")

def getData(TableName: String):Future[(Int,Double,String)]={
    db.run(sql"""select * from $TableName """.as[(Int,Double,String)])

}

}

抛出以下错误:

类型不匹配; 发现:slick.profile.SqlStreamingAction [Vector [(Int,Double,String)],(Int,Double,String),slick.dbio.Effect]必需:slick.dbio.DBIOAction [(Int,Double,String),slick .dbio.NoStream,Nothing] DBops.scala

Answer 1

您可以使用以下sql"..."任何String内容#$tableName:

db.run(sql"SELECT * FROM #$tableName").as[(Int, Double, String)])

请记住:不要将其tableName作为用户输入 - 否则SQL注入的风险很大.正常$value解决了这些问题.

阅读Slick手册(http://slick.typesafe.com/doc/3.0.0/sql.html#splicing-literal-values)

...有时你需要将文字值直接拼接到语句中,例如抽象表名...你可以在所有内插器中使用#$而不是$来实现这个目的......

Answer 2

我意识到我在返回类型中缺少一个 Seq：

def getData(TableName: String): Future[Seq[(Int,Double,String)]] = {
  db.run(sql"""SELECT * FROM $TableName """.as[(Int, Double, String)])
}