sql – 为什么Slick在调用take()方法时会生成子查询

我用 Slick 1.0.0-RC1.我有这个表对象的定义:
object ProductTable extends Table[(Int,String,Double,java.sql.Date,Int,Option[Int],Boolean)]("products") {
  def id = column[Int]("productId",O.PrimaryKey,O.AutoInc)
  def title = column[String]("title")
  def description = column[String]("description")
  def shortDescription = column[String]("shortDescription")
  def price = column[Double]("price")
  def addedDate = column[java.sql.Date]("addedDate")
  def brandId = column[Int]("brandId")
  def defaultImageId = column[Option[Int]]("defaultImageId")
  def visitCounter = column[Int]("visitCounter")
  def archived = column[Boolean]("archived")
  def * = id ~ title ~ description ~ shortDescription ~ price ~ addedDate ~ brandId ~ defaultImageId ~ visitCounter ~ archived
}
@H_404_4@我需要一个简单的查询,从数据库中选择8行:

ProductTable.filter(_.title === "something")
  .sortBy(_.visitCounter)
  .map(_.title)
  .take(8)
  .selectStatement
@H_404_4@输出是:

select x2.x3 from 
   (select x4.`title` as x3 from `products` x4 
     where x4.`title` = 'something' 
     order by x4.`visitCounter` limit 8) x2
@H_404_4@如果我摆脱了take()方法

ProductTable.filter(_.title === "something")
 .sortBy(_.visitCounter)
 .map(_.title)
 .selectStatement
@H_404_4@然后输出是:

select x2.`title` from `products` x2 
where x2.`title` = 'something' 
order by x2.`visitCounter`
@H_404_4@所以我的问题是:为什么Slick在使用take()方法构造查询对象时会生成查询

@H_404_4@附:如果它可以相关,我使用MysqL驱动程序与所有这些

解决方法

有一个简短的答案和一个很长的答案.简短的一个是:子查询是存在的,因为到目前为止没有人愿意删除它. @H_404_4@更长的答案与交换“map”和“take”没有任何区别的事实有关,这是由于查询的编译完全是简单和直接的.

@H_404_4@在查询编译器的早期阶段,存在一个“forceOuterBinds”阶段,它引入(可能)许多额外的Bind(a.k.a. flatMap)操作,这些操作在语义上是等效的并且是冗余的.我们的想法是采用一些具有集合类型的x并将其转换为Bind(s,x,Pure(s)),其中s是一个新的符号.如果x已经是Pure(y)形状,我们将其转换为Bind(s,Pure(ProductNode()),Pure(y)).在Scala代码中,将此视为将x:List [T]转换为x.flatMap(s => List(s))或将List(y)转换为List(()).flatMap(s => List (Y)).此转换的目的是通过在我们可能想要执行此操作的所有位置为我们提供修改投影(作为标识映射创建)的位置,使后续编译器阶段中的树重写更容易.

@H_404_4@稍后,在“convertToComprehensions”中,来自monadic形式的所有节点(Bind,Pure,Filter,Take,Drop等)将单独转换为Comprehension节点(表示sql select语句).结果仍然不是合法的sqlsql理解不是monad理解.它们具有非常有限的范围规则,这些规则不允许from子句引用由前一个from子句引入的变量(在相同的理解或封闭的理解中).

@H_404_4@这就是为什么我们需要下一个阶段“fuseComprehensions”,它可能看起来纯粹像乍看之下的优化,但实际上需要生成正确的代码.这个阶段试图尽可能地融合个人理解,以避免这些非法引用.我们已经取得了一些进展,我们可以融合但是100%的范围问题解决方案并不在眼前(事实上,我很确定无法解决).

@H_404_4@重申一下,这一阶段的进展主要取决于对正确性的需求,而不仅仅是生成更好的代码.那么我们可以删除那个额外的子查询吗?是的,当然,但还没有人实现它.

@H_404_4@如果您想尝试实现这样的优化,请注意以下几点:

@H_404_4@>您是否满足于删除纯粹的别名投影(即理解,其中选择槽的形式为Some(ProductNode(ch)),其中ch的每个元素都是Path)?
>或者你可能认为选择x 1来自(…… limit …))也应融合.你可以允许什么样的表达方式?例如. RowNum会好吗?
>子查询需要具有什么样的形状?例如,它可能包含groupBy或orderBy子句吗?

@H_404_4@(还有一些让我思考的问题:与解释为什么它还不存在相比,实施优化需要多长时间?)

相关文章

(一)日志传送架构 (1.1)相关服务器 主服务器 :用于生产的服务器,上面运行这生产SQL Server数据库...
(一)事故背景 最近在SQL Server 2012生产数据库上配置完事物复制(发布订阅)后,生产数据库业务出现了...
(一)测试目的 目前公司使用的SQL SERVER 2012高可用环境为主备模式,其中主库可执行读写操作,备库既...
(一)背景个人在使用sql server时,用到了sql server的发布订阅来做主从同步,类似MySQL的异步复制。在...
UNION和OR谓词 找出 product 和 product2 中售价高于 500 的商品的基本信息. select * from product wh...
datawhale组队学习task03