Lean 函数式编程

7.3. 实际案例:类型化查询🔗

类型族在构建一个模仿其他语言的 API 时非常有用。 它们可以用来编写一个保证生成合法页面的 HTML 生成器,或者编码某种文件格式的配置,或是用来建模复杂的业务约束。 本节描述了如何在 Lean 中使用索引族对关系代数的一个子集进行编码,然而本节的展示的技术完全可以被用来构建一个更加强大的数据库查询语言。

这个子集使用类型系统来保证某些要求,比如字段名称的不相交性,并使用类型上的计算将数据库模式(Schema)反映到从查询返回的值的类型中。 它并不是一个实际的数据库系统——数据库用链表的链表表示;类型系统比 SQL 的简单得多;关系代数的运算符与 SQL 的运算符并不完全匹配。 然而,它足够用来展示使用索引族的一些有用的原则和技术。

7.3.1. 一个数据的宇宙🔗

在这个关系代数中,保存在列中的基本数据的类型包括 IntStringBool,并由宇宙 DBType 描述:

inductive DBType where | int | string | bool abbrev DBType.asType : DBType Type | .int => Int | .string => String | .bool => Bool

使用 DBType.asType 将这些编码转化为类型。 例如:

"Mount Hood"#eval ("Mount Hood" : DBType.string.asType)
"Mount Hood"

可以对三种类型的任何两个值都判断是否相等。 然而,向 Lean 解释这一点需要一些工作。 直接使用 BEq 会失败:

def DBType.beq (t : DBType) (x y : t.asType) : Bool := failed to synthesize BEq t.asType Hint: Additional diagnostic information may be available using the `set_option diagnostics true` command.x == y
failed to synthesize
  BEq t.asType

Hint: Additional diagnostic information may be available using the `set_option diagnostics true` command.

就像在嵌套对的宇宙中一样,类型类搜索不会自动检查 t 的值的每种可能性。 解决方案是使用模式匹配来细化 xy 的类型:

def DBType.beq (t : DBType) (x y : t.asType) : Bool := match t with | .int => x == y | .string => x == y | .bool => x == y

在这个版本的函数中,xy 在三种情形下的类型分别为 IntStringBool,这些类型都有 BEq 实例。 DBType.beq 的定义可以用来为 DBType 编码的类型定义一个 BEq 实例:

instance {t : DBType} : BEq t.asType where beq := t.beq

这个实例与编码本身的实例不同:

instance : BEq DBType where beq | .int, .int => true | .string, .string => true | .bool, .bool => true | _, _ => false

前一个实例允许比较编码描述的类型中的值,而后一个实例允许比较编码本身。

一个 Repr 实例可以使用相同的技术编写。 Repr 类的方法被称为 reprPrec,因为它在显示值时考虑了操作符优先级等因素。 通过依值模式匹配细化类型,可以使用 IntStringBoolRepr 实例的 reprPrec 方法:

instance {t : DBType} : Repr t.asType where reprPrec := match t with | .int => reprPrec | .string => reprPrec | .bool => reprPrec

7.3.2. 数据库模式和表🔗

一个数据库模式描述了数据库中每一列的名称和类型:

structure Column where name : String contains : DBType abbrev Schema := List Column

事实上,数据库模式可以看作是描述表中行的宇宙。 空数据库模式描述了 Unit 类型,具有单个列的数据库模式描述了那个值本身,具有至少两个列的数据库模式可以有由元组表示:

abbrev Row : Schema Type | [] => Unit | [col] => col.contains.asType | col1 :: col2 :: cols => col1.contains.asType × Row (col2::cols)

正如在积类型的起始节中描述的那样,Lean 的积类型和元组是右结合的。 这意味着嵌套对等同于普通的展平元组。

表是一个共享数据库模式的行的列表:

abbrev Table (s : Schema) := List (Row s)

例如,可以用数据库模式 peak 表示对山峰的拜访日记:

abbrev peak : Schema := [ "name", .string, "location", .string, "elevation", .int, "lastVisited", .int ]

本书作者拜访过的部分山峰以元组的列表呈现:

def mountainDiary : Table peak := [ ("Mount Nebo", "USA", 3637, 2013), ("Moscow Mountain", "USA", 1519, 2015), ("Himmelbjerget", "Denmark", 147, 2004), ("Mount St. Helens", "USA", 2549, 2010) ]

另一个例子包括瀑布和对它们的拜访日记:

abbrev waterfall : Schema := [ "name", .string, "location", .string, "lastVisited", .int ]def waterfallDiary : Table waterfall := [ ("Multnomah Falls", "USA", 2018), ("Shoshone Falls", "USA", 2014) ]

7.3.2.1. 回顾递归和宇宙🔗

将行结构化为元组的方便性是有代价的:Row 将其两个基情形的分开处理意味着在类型中使用 Row 和在编码(即数据库模式)上递归定义的函数需要做出相同的区分。 一个具体的例子是一个通过对数据库模式递归检查行是否相等的函数。 下面的实现无法通过 Lean 的类型检查:

def Row.bEq (r1 r2 : Row s) : Bool := match s with | [] => true | col::cols => match r1, r2 with | Type mismatch (v1, r1') has type ?m.10 × ?m.11 but is expected to have type Row (col :: cols)(v1, r1'), (v2, r2') => v1 == v2 && bEq r1' r2'
Type mismatch
  (v1, r1')
has type
  ?m.10 × ?m.11
but is expected to have type
  Row (col :: cols)

问题在于模式 col :: cols 并没有足够细化行的类型。 这是因为 Lean 无法确定到底是 Row 定义中的哪种模式被匹配上:单例模式 [col] 或是 col1 :: col2 :: cols 模式。因此对 Row 的调用不会计算到一个有序对类型。 解决方案是在 Row.bEq 的定义中反映 Row 的结构:

def Row.bEq (r1 r2 : Row s) : Bool := match s with | [] => true | [_] => r1 == r2 | _::_::_ => match r1, r2 with | (v1, r1'), (v2, r2') => v1 == v2 && bEq r1' r2' instance : BEq (Row s) where beq := Row.bEq

不同于其他上下文,出现在类型中的函数不能仅仅考虑其输入/输出行为。 使用这些类型的程序将发现自己被迫镜像那些类型中使用到的函数所使用的算法,以便它们的结构与类型的模式匹配和递归行为相匹配。 使用依赖类型编程的技巧的一个重要部分是在类型的计算中选择具有正确计算行为函数。

7.3.2.2. 列指针🔗

如果数据库模式包含特定列,那么某些查询才有意义。 例如,一个返回海拔高于 1000 米的山的查询只在包含整数的 "elevation" 列的数据库模式中才有意义。 一种表示数据库模式包含某个列的方法是直接提供指向这个列的指针。将指针定义为一个索引族使得可以排除无效指针。

列可以出现在数据库模式的两个地方:要么在它的开头,要么在它的后面的某个地方。 如果列出现在模式的后面的某个地方,那么它也必然是某一个尾数据库模式的开头。

索引族 HasCol 将这种规范表达为 Lean 的代码:

inductive HasCol : Schema String DBType Type where | here : HasCol (name, t :: _) name t | there : HasCol s name t HasCol (_ :: s) name t

这个族的三个参数是数据库模式、列名和它的类型。 所有三个参数都是索引,但重新排列参数,将数据库模式放在列名和类型之后,可以使列名和类型成为参量。 当数据库模式以列 name, t 开头时,可以使用构造子 here:它是一个指向当前数据库模式的第一列的指针,只有当第一列具有所需的名称和类型时才能使用。 构造子 there 将一个指向较小数据库模式的指针转换为一个指向在头部包含在一个额外列的数据库模式的指针。

因为 "elevation"peak 中的第三列,所以可以通过 there 跳过前两列然后使用 here 找到它。 换句话说,要满足类型 HasCol peak "elevation" .int,使用表达式 .there (.there .here)HasCol 也可以理解为是一种带有修饰的 Nat——zero 对应于 heresucc 对应于 there。 额外的类型信息使得不可能出现列序号偏差了一位之类的错误。

指向数据库模式中的列的指针可以用来从行中提取该列的值:

def Row.get (row : Row s) (col : HasCol s n t) : t.asType := match s, col, row with | [_], .here, v => v | _::_::_, .here, (v, _) => v | _::_::_, .there next, (_, r) => get r next

第一步是对数据库模式进行模式匹配,因为这决定了行是元组还是单个值。 空模式的情形不需要考虑,因为 HasCol 的两个构造子都对应着非空的数据库模式。 如果数据库模式只有一个列,那么指针必须指向它,因此只需要匹配 HasColhere 构造子。 如果数据库模式有两个或更多列,那么必须有一个 here 的情形,此时值是行中的第一个值,以及一个 there 的情形,此时需要进行递归调用。 因为 HasCol 类型保证了列存在于行中,所以 Row.get 不需要返回一个 Option

HasCol 扮演了两个角色:

  1. 它作为证据,证明模式中存在具有特定名称和类型的列。

  2. 它作为数据,可以用来在行中找到与列关联的值。

第一个角色,即证据的角色,类似于命题的使用方式。 索引族 HasCol 的定义可以被视为一个规范,说明什么样的证据可以证明给定的列存在。 然而,与命题不同,使用 HasCol 的哪个构造子很重要。 在第二个角色中,构造子起到类似 Nat 的作用,用于在集合中查找数据。 使用索引族编程通常需要能够流畅地使用它的这两个角色。

7.3.2.3. 子数据库模式🔗

关系代数中的一个重要操作是将表或行投影到一个较小的数据库模式中。 不在这一数据库模式中的每一列都会被舍弃。 为了使投影有意义,小数据库模式必须是大数据库模式的子数据库模式:小数据库模式中的每一列都必须存在于大数据库模式中。 正如 HasCol 允许我们编写一个从行中提取某个列函数且这个函数一定不会失败一样, 将子模式关系表示为索引族允许我们编写一个不会失败的投影函数。

可以将“一个数据库模式是另一个数据库模式的子数据库模式”定义为一个索引族。 基本思想是,如果小数据库模式中的每一列都出现在大数据库模式中,那么小数据库模式就是大数据库模式的子数据库模式。 如果小数据库模式为空,则它肯定是大数据库模式的子数据库模式,由构造子 nil 表示。 如果小数据库模式有一列,那么该列必须在大数据库模式中且子数据库模式中的其余列也必须是大数据库模式的子数据库模式。 这由子 cons 表示。

inductive Subschema : Schema Schema Type where | nil : Subschema [] bigger | cons : HasCol bigger n t Subschema smaller bigger Subschema (n, t :: smaller) bigger

换句话说,Subschema 为小数据库模式的每一列分配一个 HasCol,该 HasCol 指向大数据库模式中的位置。

模式 travelDiary 表示 peakwaterfall 共有的字段:

abbrev travelDiary : Schema := ["name", .string, "location", .string, "lastVisited", .int]

正如这个例子所示,它肯定是 peak 的子数据库模式:

example : Subschema travelDiary peak := .cons .here (.cons (.there .here) (.cons (.there (.there (.there .here))) .nil))

然而,这样的代码很难阅读和维护。 改进的一种方法是指导 Lean 自动编写 SubschemaHasCol 构造子。 这可以通过使用关于命题和证明的插曲中介绍的策略特性来完成。 该插曲使用 by decideby simp 提供了各种命题的证据。

此时,两种策略是有用的:

  • constructor 策略指示 Lean 使用数据类型的构造子解决问题。

  • repeat 策略指示 Lean 重复一个策略,直到它失败或证明完成。

下一个例子中,by constructor 的效果与直接写 .nil 是一样的:

example : Subschema [] peak := Subschema [] peak All goals completed! 🐙

然而,在一个稍微复杂的类型下尝试相同的策略会失败:

example : Subschema ["location", .string] peak := unsolved goals HasCol peak "location" DBType.string Subschema [] peakSubschema [{ name := "location", contains := DBType.string }] peak HasCol peak "location" DBType.stringSubschema [] peak
unsolved goals
HasCol peak "location" DBType.string

Subschema [] peak

unsolved goals 开头的错误描述了策略未能完全构建它们应该构建的表达式。 在 Lean 的策略语言中,证明目标(goal) 是策略需要通过构造适当的表达式来实现的类型。 在这种情形下,constructor 导致应用 Subschema.cons,两个目标表示 cons 期望的两个参数。 添加另一个 constructor 实例导致第一个目标(HasCol peak "location" DBType.string)被 HasCol.there 处理,因为 peak 的第一列不是 "location"

example : Subschema ["location", .string] peak := unsolved goals HasCol [{ name := "location", contains := DBType.string }, { name := "elevation", contains := DBType.int }, { name := "lastVisited", contains := DBType.int }] "location" DBType.string Subschema [] peakSubschema [{ name := "location", contains := DBType.string }] peak HasCol peak "location" DBType.stringSubschema [] peak HasCol [{ name := "location", contains := DBType.string }, { name := "elevation", contains := DBType.int }, { name := "lastVisited", contains := DBType.int }] "location" DBType.stringSubschema [] peak
unsolved goals
HasCol
  [{ name := "location", contains := DBType.string }, { name := "elevation", contains := DBType.int },
    { name := "lastVisited", contains := DBType.int }]
  "location" DBType.string

Subschema [] peak

然而,添加第三个 constructor 解决了第一个证明目标,因为 HasCol.here 是适用的:

example : Subschema ["location", .string] peak := unsolved goals Subschema [] peakSubschema [{ name := "location", contains := DBType.string }] peak HasCol peak "location" DBType.stringSubschema [] peak HasCol [{ name := "location", contains := DBType.string }, { name := "elevation", contains := DBType.int }, { name := "lastVisited", contains := DBType.int }] "location" DBType.stringSubschema [] peak Subschema [] peak
unsolved goals
Subschema [] peak

第四个 constructor 实例解决了 Subschema peak [] 目标:

example : Subschema ["location", .string] peak := Subschema [{ name := "location", contains := DBType.string }] peak HasCol peak "location" DBType.stringSubschema [] peak HasCol [{ name := "location", contains := DBType.string }, { name := "elevation", contains := DBType.int }, { name := "lastVisited", contains := DBType.int }] "location" DBType.stringSubschema [] peak Subschema [] peak All goals completed! 🐙

事实上,一个没有使用策略的版本有四个构造子:

example : Subschema ["location", .string] peak := .cons (.there .here) .nil

不要尝试找到写 constructor 的正确次数,可以使用 repeat 策略要求 Lean 只要取得进展就继续尝试 constructor

example : Subschema ["location", .string] peak := Subschema [{ name := "location", contains := DBType.string }] peak repeat All goals completed! 🐙

这个更灵活的版本也适用于更有趣的 Subschema 问题:

example : Subschema travelDiary peak := Subschema travelDiary peak repeat All goals completed! 🐙 example : Subschema travelDiary waterfall := Subschema travelDiary waterfall repeat All goals completed! 🐙

盲目尝试构造子直到某个符合预期类型的值被构造出来的方法对于 NatList Bool 这样的类型并不是很有用。 毕竟,一个表达式的类型是 Nat 并不意味着它是正确的 Nat。 但 HasColSubschema 这样的类型受到索引的约束, 只有一个构造子适用。 这意味着程序本身是平凡的,计算机可以选择正确的构造子。

如果一个数据库模式是另一个数据库模式的子数据库模式,那么它也是扩展了一个额外列的更大数据库模式的子数据库模式。 这个事实被下列函数定义表示出来。 Subschema.addColumn 接受 smallerbigger 的子数据库模式的证据,然后返回 smallerc :: bigger 的子数据库模式的证据,即,bigger 增加了一个额外列:

def Subschema.addColumn : Subschema smaller bigger Subschema smaller (c :: bigger) | .nil => .nil | .cons col sub' => .cons (.there col) sub'.addColumn

子数据库模式描述了在大数据库模式中找到小数据库模式的每一列的位置。 Subschema.addColumn 必须将这些描述从指向原始的大数据库模式转换为指向扩展后的更大数据库模式。 在 nil 的情形下,小数据库模式是 []nil 也是 []c :: bigger 的子数据库模式的证据。 在 cons 的情形下,它描述了如何将 smaller 中的一列放入 bigger,需要使用 there 调整列的放置位置以考虑新列 c,递归调用调整其余列。

另一个思考 Subschema 的方式是它定义了两个数据库模式之间的关系——存在一个类型为 Subschema smaller bigger 的表达式意味着 (smaller, bigger) 在这个关系中。 这个关系是自反的,意味着每个数据库模式都是自己的子数据库模式:

def Subschema.reflexive : (s : Schema) Subschema s s | [] => .nil | _ :: cs => .cons .here (reflexive cs).addColumn

7.3.2.4. 投影行🔗

给定 s's 的子数据库模式的证据,可以将 s 中的行投影到 s' 中的行。 这是通过分析 s's 的子数据库模式的证据完成的:它解释了 s' 的每一列在 s 中的位置。 在 s' 中的新行是通过从旧行的适当位置检索值逐列构建的。

执行这种投影的函数 Row.project 有三种情形,分别对应于 Row 本身的三种情形。 它使用 Row.getSubschema 参数中的每个 HasCol 一起构造投影行:

def Row.project (row : Row s) : (s' : Schema) Subschema s' s Row s' | [], .nil => () | [_], .cons c .nil => row.get c | _::_::_, .cons c cs => (row.get c, row.project _ cs)

7.3.3. 条件和选取🔗

投影从表中删除不需要的列,但查询也必须能够删除不需要的行。 这个操作称为选择(selection)。 选择的前提是有一种表达“哪些行是需要的”的方式。

示例查询语言包含表达式,类似于 SQL 中可以写在 WHERE 子句中的内容。 表达式由索引族 DBExpr 表示。 表达式可以引用数据库中的列,但不同的子表达式都有相同的数据库模式。DBExpr 以数据库模式作为参量。 此外,每个表达式都有一个类型,这些类型不同,所以这是一个索引:

inductive DBExpr (s : Schema) : DBType Type where | col (n : String) (loc : HasCol s n t) : DBExpr s t | eq (e1 e2 : DBExpr s t) : DBExpr s .bool | lt (e1 e2 : DBExpr s .int) : DBExpr s .bool | and (e1 e2 : DBExpr s .bool) : DBExpr s .bool | const : t.asType DBExpr s t

col 构造子表示对数据库中的列的引用。 eq 构造子比较两个表达式是否相等,lt 检查一个是否小于另一个,and 是布尔合取,const 是某种类型的常量值。

例如,在 peak 中检查 elevation 列的值大于 1000 并且位置等于 "Denmark" 的表达式可以写为:

def tallInDenmark : DBExpr peak .bool := .and (.lt (.const 1000) (.col "elevation" (HasCol peak "elevation" DBType.int repeat All goals completed! 🐙))) (.eq (.col "location" (HasCol peak "location" ?m.16 repeat All goals completed! 🐙)) (.const "Denmark"))

这有点复杂。 特别是,对列的引用包含了重复的对 by repeat constructor 的调用。 Lean 的一个特性叫做宏(macro),可以消除这些重复代码,使表达式更易于阅读:

macro "c!" n:term : term => `(DBExpr.col $n (by repeat constructor))

这个声明为 Lean 添加了 c! 关键字,并指示 Lean 用相应的 DBExpr.col 构造替换后面跟着的任何 c! 实例。 这里,term 代表 Lean 表达式,而不是命令、策略或语言的其他部分。 Lean 宏有点像 C 预处理器宏,只是它们更好地集成到语言中,并且它们自动避免了 CPP 的一些陷阱。 事实上,它们与 Scheme 和 Racket 中的宏非常密切相关。

有了这个宏,表达式就容易阅读得多:

def tallInDenmark : DBExpr peak .bool := .and (.lt (.const 1000) (c! "elevation")) (.eq (c! "location") (.const "Denmark"))

求某行在一个表达式下的值时调用 Row.get 提取列引用,其他构造子则委托给 Lean 中对应的运算进行处理:

def DBExpr.evaluate (row : Row s) : DBExpr s t t.asType | .col _ loc => row.get loc | .eq e1 e2 => evaluate row e1 == evaluate row e2 | .lt e1 e2 => evaluate row e1 < evaluate row e2 | .and e1 e2 => evaluate row e1 && evaluate row e2 | .const v => v

对 Valby Bakke(哥本哈根地区最高的山)求值得到 false,因为 Valby Bakke 的海拔远低于 1 km:

false#eval tallInDenmark.evaluate ("Valby Bakke", "Denmark", 31, 2023)
false

对一个海拔 1230 米的虚构的山求值得到 true

true#eval tallInDenmark.evaluate ("Fictional mountain", "Denmark", 1230, 2023)
true

为美国爱达荷州最高峰求值得到 false,因为爱达荷州不是丹麦的一部分:

false#eval tallInDenmark.evaluate ("Mount Borah", "USA", 3859, 1996)
false

7.3.4. 查询🔗

查询语言基于关系代数。 除了表之外,它还包括以下运算符:

  1. 并(Union),将两个具有相同数据库模式的表达式的查询的结果行合并

  2. 差(Difference),定义在两个具有相同数据库模式的表达式,从第一个表达式的查询结果中删除同时存在于第二个表达式的查询结果的行

  3. 选择(Selection),按照某些标准,根据表达式过滤查询的结果

  4. 投影(Projection),从查询结果中删除列

  5. 笛卡尔积(Cartesian product),将一个查询的每一行与另一个查询的每一行组合

  6. 重命名(Renaming),修改查询结果中某一个列的名字

  7. 添加前缀(Prefixing),为查询中的所有列名添加一个前缀

最后一个运算符不是严格必要的,但它使语言更方便使用。

查询同样由一个索引族表示:

inductive Query : Schema Type where | table : Table s Query s | union : Query s Query s Query s | diff : Query s Query s Query s | select : Query s DBExpr s .bool Query s | project : Query s (s' : Schema) Subschema s' s Query s' | product : Query s1 Query s2 disjoint (s1.map Column.name) (s2.map Column.name) Query (s1 ++ s2) | renameColumn : Query s (c : HasCol s n t) (n' : String) !((s.map Column.name).contains n') Query (s.renameColumn c n') | prefixWith : (n : String) Query s Query (s.map fun c => {c with name := n ++ "." ++ c.name})

select 构造子要求用于选择的表达式返回一个布尔值。 product 构造子的类型包含对 disjoint 的调用,它确保两个数据库模式没有相同的列名:

def disjoint [BEq α] (xs ys : List α) : Bool := not (xs.any ys.contains || ys.any xs.contains)

Bool 类型的表达式用在期望一个类型的位置会触发从 BoolProp 的强制转换。 正如可判定命题被视为一个布尔值:命题的证据被强制转换为 true,命题的反驳被强制转换为 false,布尔值也可以反过来被强制转换为表达式等于 true 的命题。 因为预期所有库的使用将发生在数据库模式已经给定的场景下,所以这个命题可以用 by simp 证明。 类似地,renameColumn 构造子检查新名称是否已经存在于数据库模式中。 它使用辅助函数 Schema.renameColumn 来更改 HasCol 指向的列的名称:

def Schema.renameColumn : (s : Schema) HasCol s n t String Schema | c :: cs, .here, n' => {c with name := n'} :: cs | c :: cs, .there next, n' => c :: renameColumn cs next n'

7.3.5. 执行查询🔗

执行查询需要一些辅助函数。 查询的结果是一个表。 这意味着查询语言中的每个操作都需要一个可以与表一起工作的实现。

7.3.5.1. 笛卡尔积🔗

计算两个表的笛卡尔积是通过将第一个表中的每一行追加到第二个表中的每一行来完成的。 首先,由于 Row 的结构,向行添加单个列需要对其模式进行模式匹配,以确定结果是裸值还是元组。 因为这是一个常见的操作,将模式匹配提取到辅助函数中很方便:

def addVal (v : c.contains.asType) (row : Row s) : Row (c :: s) := match s, row with | [], () => v | c' :: cs, v' => (v, v')

追加两行是关于第一个模式和第一行的结构的递归,因为行的结构与模式的结构是同步进行的。 当第一行为空时,追加返回第二行。 当第一行是单元素时,该值被添加到第二行。 当第一行包含多列时,第一列的值被添加到对行剩余部分递归的结果中。

def Row.append (r1 : Row s1) (r2 : Row s2) : Row (s1 ++ s2) := match s1, r1 with | [], () => r2 | [_], v => addVal v r2 | _::_::_, (v, r') => (v, r'.append r2)

标准库中的 List.flatMap 将一个本身返回列表的函数应用于输入列表中的每个条目,并按顺序返回追加结果列表的结果:

def List.flatMap (f : α List β) : (xs : List α) List β | [] => [] | x :: xs => f x ++ xs.flatMap f

类型签名表明 List.flatMap 可用于实现 Monad List 实例。 实际上,与 pure x := [x] 一起,List.flatMap 确实实现了一个单子。 然而,它不是一个非常有用的 Monad 实例。 List 单子基本上是 Many 的一个版本,它在用户有机会请求一定数量的值之前,预先探索搜索空间中的 每条 可能路径。 由于这种性能陷阱,为 List 定义 Monad 实例通常不是一个好主意。 然而,在这里,查询语言没有用于限制返回结果数量的运算符,因此组合所有可能性正是我们想要的:

def Table.cartesianProduct (table1 : Table s1) (table2 : Table s2) : Table (s1 ++ s2) := table1.flatMap fun r1 => table2.map r1.append

就像 List.product 一样,恒等单子(Identity Monad)中带有可变状态的循环可以用作替代实现技术:

def Table.cartesianProduct (table1 : Table s1) (table2 : Table s2) : Table (s1 ++ s2) := Id.run do let mut out : Table (s1 ++ s2) := [] for r1 in table1 do for r2 in table2 do out := (r1.append r2) :: out pure out.reverse

7.3.5.2. 差🔗

从表中删除不需要的行可以使用 List.filter 完成,它接受一个列表和一个返回 Bool 的函数。 返回一个新列表,其中仅包含函数返回 true 的条目。 例如,

["Willamette", "Columbia", "Sandy", "Deschutes"].filter (·.length > 8)

求值为

["Willamette", "Deschutes"]

因为 "Columbia""Sandy" 的长度小于或等于 8。 可以使用辅助函数 List.without 删除表中的条目:

def List.without [BEq α] (source banned : List α) : List α := source.filter fun r => !(banned.contains r)

这将在解释查询时与 RowBEq 实例一起使用。

7.3.5.3. 重命名列🔗

重命名行中的列是通过一个递归函数完成的,该函数遍历行直到找到有问题的列,此时具有新名称的列获得与具有旧名称的列相同的值:

def Row.rename (c : HasCol s n t) (row : Row s) : Row (s.renameColumn c n') := match s, row, c with | [_], v, .here => v | _::_::_, (v, r), .here => (v, r) | _::_::_, (v, r), .there next => addVal v (r.rename next)

虽然此函数更改其参数的 类型,但实际返回值包含与原始参数完全相同的数据。 从运行时的角度来看,Row.rename 只不过是一个缓慢的恒等函数。 使用索引族编程的一个困难是,当性能很重要时,这种操作可能会造成阻碍。 需要非常仔细、通常是脆弱的设计才能消除这类“重新索引”函数。

7.3.5.4. 为列名添加前缀🔗

为列名添加前缀与重命名列非常相似。 prefixRow 必须处理所有列,而不是处理到所需的列然后返回:

def prefixRow (row : Row s) : Row (s.map fun c => {c with name := n ++ "." ++ c.name}) := match s, row with | [], _ => () | [_], v => v | _::_::_, (v, r) => (v, prefixRow r)

这可以与 List.map 一起使用,以便为表中的所有行添加前缀。 再一次,此函数仅用于更改值的类型。

7.3.5.5. 组合在一起🔗

定义了所有这些辅助函数后,执行查询只需要一个简短的递归函数:

def Query.exec : Query s Table s | .table t => t | .union q1 q2 => exec q1 ++ exec q2 | .diff q1 q2 => exec q1 |>.without (exec q2) | .select q e => exec q |>.filter e.evaluate | .project q _ sub => exec q |>.map (·.project _ sub) | .product q1 q2 _ => exec q1 |>.cartesianProduct (exec q2) | .renameColumn q c _ _ => exec q |>.map (·.rename c) | .prefixWith _ q => exec q |>.map prefixRow

构造子的一些参数在执行期间未被使用。 特别是,构造子 project 和函数 Row.project 都将较小的模式作为显式参数,但该模式是较大模式的子模式的 证据 的类型包含足够的信息,让 Lean 自动填充参数。 类似地,product 构造子要求的两个表具有不相交的列名这一事实,对于 Table.cartesianProduct 来说是不需要的。 一般来说,依赖类型提供了许多机会让 Lean 代表程序员填充参数。

点号表示法用于查询结果,以调用在 TableList 命名空间中定义的函数,例如 List.mapList.filterTable.cartesianProduct。 这是因为 Table 是使用 abbrev 定义的。 就像类型类搜索一样,点号表示法可以看穿用 abbrev 创建的定义。

select 的实现也非常简洁。 执行查询 q 后,使用 List.filter 删除不满足表达式的行。 List.filter 期望一个从 Row sBool 的函数,但 DBExpr.evaluate 的类型为 Row s DBExpr s t t.asType。 因为 select 构造子的类型要求表达式具有类型 DBExpr s .bool,所以在这种情况下 t.asType 实际上是 Bool

查找海拔大于 500 米的所有山峰高度的查询可以写成:

open Query in def example1 := table mountainDiary |>.select (.lt (.const 500) (c! "elevation")) |>.project ["elevation", .int] (Subschema [{ name := "elevation", contains := DBType.int }] peak repeat All goals completed! 🐙)

执行它返回预期的整数列表:

[3637, 1519, 2549]#eval example1.exec
[3637, 1519, 2549]

为了计划一次观光旅游,匹配同一地点的所有山脉和瀑布对可能是相关的。 这可以通过获取两个表的笛卡尔积,仅选择它们相等的行,然后投影出名称来完成:

open Query in def example2 := let mountain := table mountainDiary |>.prefixWith "mountain" let waterfall := table waterfallDiary |>.prefixWith "waterfall" mountain.product waterfall (mountain:Query (List.map (fun c => { name := "mountain" ++ "." ++ c.name, contains := c.contains }) peak) := Query.prefixWith "mountain" (Query.table mountainDiary)waterfall:Query (List.map (fun c => { name := "waterfall" ++ "." ++ c.name, contains := c.contains }) waterfall) := Query.prefixWith "waterfall" (Query.table waterfallDiary)disjoint (List.map Column.name (List.map (fun c => { name := "mountain" ++ "." ++ c.name, contains := c.contains }) peak)) (List.map Column.name (List.map (fun c => { name := "waterfall" ++ "." ++ c.name, contains := c.contains }) _root_.waterfall)) = true All goals completed! 🐙) |>.select (.eq (c! "mountain.location") (c! "waterfall.location")) |>.project ["mountain.name", .string, "waterfall.name", .string] (mountain:Query (List.map (fun c => { name := "mountain" ++ "." ++ c.name, contains := c.contains }) peak) := Query.prefixWith "mountain" (Query.table mountainDiary)waterfall:Query (List.map (fun c => { name := "waterfall" ++ "." ++ c.name, contains := c.contains }) waterfall) := Query.prefixWith "waterfall" (Query.table waterfallDiary)Subschema [{ name := "mountain.name", contains := DBType.string }, { name := "waterfall.name", contains := DBType.string }] (List.map (fun c => { name := "mountain" ++ "." ++ c.name, contains := c.contains }) peak ++ List.map (fun c => { name := "waterfall" ++ "." ++ c.name, contains := c.contains }) _root_.waterfall) repeat All goals completed! 🐙)

因为示例数据仅包含美国的瀑布,所以执行查询将返回美国的山脉和瀑布对:

[("Mount Nebo", "Multnomah Falls"), ("Mount Nebo", "Shoshone Falls"), ("Moscow Mountain", "Multnomah Falls"), ("Moscow Mountain", "Shoshone Falls"), ("Mount St. Helens", "Multnomah Falls"), ("Mount St. Helens", "Shoshone Falls")]#eval example2.exec
[("Mount Nebo", "Multnomah Falls"), ("Mount Nebo", "Shoshone Falls"), ("Moscow Mountain", "Multnomah Falls"),
  ("Moscow Mountain", "Shoshone Falls"), ("Mount St. Helens", "Multnomah Falls"),
  ("Mount St. Helens", "Shoshone Falls")]

7.3.5.6. 你可能会遇到的错误🔗

Query 的定义排除了许多潜在的错误。 例如,忘记在 "mountain.location" 中添加限定符会产生编译时错误,突出显示列引用 c! "location"

open Query in def example2 := let mountains := table mountainDiary |>.prefixWith "mountain" let waterfalls := table waterfallDiary |>.prefixWith "waterfall" mountains.product waterfalls (unsolved goals mountains:Query (List.map (fun c => { name := "mountain" ++ "." ++ c.name, contains := c.contains }) peak) := prefixWith "mountain" (table mountainDiary)waterfalls:Query (List.map (fun c => { name := "waterfall" ++ "." ++ c.name, contains := c.contains }) waterfall) := prefixWith "waterfall" (table waterfallDiary)disjoint ["mountain.name", "mountain.location", "mountain.elevation", "mountain.lastVisited"] ["waterfall.name", "waterfall.location", "waterfall.lastVisited"] = truemountains:Query (List.map (fun c => { name := "mountain" ++ "." ++ c.name, contains := c.contains }) peak) := Query.prefixWith "mountain" (Query.table mountainDiary)waterfalls:Query (List.map (fun c => { name := "waterfall" ++ "." ++ c.name, contains := c.contains }) waterfall) := Query.prefixWith "waterfall" (Query.table waterfallDiary)disjoint (List.map Column.name (List.map (fun c => { name := "mountain" ++ "." ++ c.name, contains := c.contains }) peak)) (List.map Column.name (List.map (fun c => { name := "waterfall" ++ "." ++ c.name, contains := c.contains }) waterfall)) = true mountains:Query (List.map (fun c => { name := "mountain" ++ "." ++ c.name, contains := c.contains }) peak) := Query.prefixWith "mountain" (Query.table mountainDiary)waterfalls:Query (List.map (fun c => { name := "waterfall" ++ "." ++ c.name, contains := c.contains }) waterfall) := Query.prefixWith "waterfall" (Query.table waterfallDiary)disjoint ["mountain.name", "mountain.location", "mountain.elevation", "mountain.lastVisited"] ["waterfall.name", "waterfall.location", "waterfall.lastVisited"] = true) |>.select (.eq (unsolved goals mountains:Query (List.map (fun c => { name := "mountain" ++ "." ++ c.name, contains := c.contains }) peak) := waterfalls:Query (List.map (fun c => { name := "waterfall" ++ "." ++ c.name, contains := c.contains }) waterfall) := HasCol (List.map (fun c => { name := "waterfall" ++ "." ++ c.name, contains := c.contains }) []) "location" ?m.31c! "location") (c! "waterfall.location")) |>.project ["mountain.name", .string, "waterfall.name", .string] (mountains:Query (List.map (fun c => { name := "mountain" ++ "." ++ c.name, contains := c.contains }) peak) := Query.prefixWith "mountain" (Query.table mountainDiary)waterfalls:Query (List.map (fun c => { name := "waterfall" ++ "." ++ c.name, contains := c.contains }) waterfall) := Query.prefixWith "waterfall" (Query.table waterfallDiary)Subschema [{ name := "mountain.name", contains := DBType.string }, { name := "waterfall.name", contains := DBType.string }] (List.map (fun c => { name := "mountain" ++ "." ++ c.name, contains := c.contains }) peak ++ List.map (fun c => { name := "waterfall" ++ "." ++ c.name, contains := c.contains }) waterfall) repeat All goals completed! 🐙)

这是极好的反馈! 另一方面,错误消息的文本很难处理:

unsolved goals
mountains:Query (List.map (fun c => { name := "mountain" ++ "." ++ c.name, contains := c.contains }) peak) := waterfalls:Query (List.map (fun c => { name := "waterfall" ++ "." ++ c.name, contains := c.contains }) waterfall) := HasCol (List.map (fun c => { name := "waterfall" ++ "." ++ c.name, contains := c.contains }) []) "location" ?m.31

类似地,忘记为两个表的名称添加前缀会导致 by decide 出错,该策略本应提供模式实际上不相交的证据:

open Query in def example2 := let mountains := table mountainDiary let waterfalls := table waterfallDiary mountains.product waterfalls (mountains:Query peak := Query.table mountainDiarywaterfalls:Query waterfall := Query.table waterfallDiarydisjoint (List.map Column.name peak) (List.map Column.name waterfall) = true Tactic `decide` proved that the proposition disjoint (List.map Column.name peak) (List.map Column.name waterfall) = true is falsemountains:Query peak := Query.table mountainDiarywaterfalls:Query waterfall := Query.table waterfallDiarydisjoint (List.map Column.name peak) (List.map Column.name waterfall) = true) |>.select (.eq (unsolved goals mountains:Query peak := waterfalls:Query waterfall := HasCol [] "mountain.location" ?m.29c! "mountain.location") (unsolved goals mountains:Query peak := waterfalls:Query waterfall := HasCol [] "waterfall.location" ?m.29c! "waterfall.location")) |>.project ["mountain.name", .string, "waterfall.name", .string] (unsolved goals mountains:Query peak := waterfalls:Query waterfall := HasCol [] "mountain.name" DBType.string mountains:Query peak := waterfalls:Query waterfall := Subschema [{ name := "waterfall.name", contains := DBType.string }] (peak ++ waterfall)mountains:Query peak := Query.table mountainDiarywaterfalls:Query waterfall := Query.table waterfallDiarySubschema [{ name := "mountain.name", contains := DBType.string }, { name := "waterfall.name", contains := DBType.string }] (peak ++ waterfall) repeat mountains:Query peak := Query.table mountainDiarywaterfalls:Query waterfall := Query.table waterfallDiaryHasCol [] "mountain.name" DBType.stringmountains:Query peak := Query.table mountainDiarywaterfalls:Query waterfall := Query.table waterfallDiarySubschema [{ name := "waterfall.name", contains := DBType.string }] (peak ++ waterfall))

此错误消息更有帮助:

Tactic `decide` proved that the proposition
  disjoint (List.map Column.name peak) (List.map Column.name waterfall) = true
is false

Lean 的宏系统包含了所需的一切,不仅可以为查询提供方便的语法,还可以安排错误消息以提供帮助。 不幸的是,提供有关使用 Lean 宏实现语言的描述超出了本书的范围。 像 Query 这样的索引族可能最适合作为类型化数据库交互库的核心,而不是其用户界面。

7.3.6. 练习🔗

7.3.6.1. 日期🔗

定义一个结构来表示日期。将其添加到 DBType 宇宙中并相应地更新其余代码。提供似乎必要的额外 DBExpr 构造子。

7.3.6.2. 可空类型🔗

通过使用以下结构表示数据库类型,为查询语言添加对可空列的支持:

structure NDBType where underlying : DBType nullable : Bool abbrev NDBType.asType (t : NDBType) : Type := if t.nullable then Option t.underlying.asType else t.underlying.asType

ColumnDBExpr 中使用此类型代替 DBType,并查找 SQL 关于 NULL 和比较运算符的规则,以确定 DBExpr 构造子的类型。

7.3.6.3. 尝试策略🔗

要求 Lean 使用 by repeat constructor 查找以下类型的值的结果是什么?解释为什么每个都会给出这样的结果。