Skip to content

Commit f4ce124

Browse files
nathanfalletnathanfallet
authored
Merge pull request #1228 from geoffmacd/window-functions
Implements built-in window functions
2 parents 8b96864 + 2fc62a9 commit f4ce124

File tree

6 files changed

+325
-3
lines changed

6 files changed

+325
-3
lines changed

‎Documentation/Index.md

Lines changed: 6 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -64,6 +64,7 @@
6464
- [Other Operators](#other-operators)
6565
- [Core SQLite Functions](#core-sqlite-functions)
6666
- [Aggregate SQLite Functions](#aggregate-sqlite-functions)
67+
- [Window SQLite Functions](#window-sqlite-functions)
6768
- [Date and Time Functions](#date-and-time-functions)
6869
- [Custom SQL Functions](#custom-sql-functions)
6970
- [Custom Collations](#custom-collations)
@@ -1871,6 +1872,11 @@ Most of SQLite’s
18711872
[aggregate functions](https://www.sqlite.org/lang_aggfunc.html) have been
18721873
surfaced in and type-audited for SQLite.swift.
18731874

1875+
## Window SQLite Functions
1876+
1877+
Most of SQLite's [window functions](https://www.sqlite.org/windowfunctions.html) have been
1878+
surfaced in and type-audited for SQLite.swift. Currently only `OVER (ORDER BY ...)` windowing is possible.
1879+
18741880
## Date and Time functions
18751881

18761882
SQLite's [date and time](https://www.sqlite.org/lang_datefunc.html)

‎SQLite.xcodeproj/project.pbxproj

Lines changed: 18 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -195,6 +195,13 @@
195195
49EB68C51F7B3CB400D89D40 /* Coding.swift in Sources */ = {isa = PBXBuildFile; fileRef = 49EB68C31F7B3CB400D89D40 /* Coding.swift */; };
196196
49EB68C61F7B3CB400D89D40 /* Coding.swift in Sources */ = {isa = PBXBuildFile; fileRef = 49EB68C31F7B3CB400D89D40 /* Coding.swift */; };
197197
49EB68C71F7B3CB400D89D40 /* Coding.swift in Sources */ = {isa = PBXBuildFile; fileRef = 49EB68C31F7B3CB400D89D40 /* Coding.swift */; };
198+
64A8EE432B095FBB00F583F7 /* WindowFunctions.swift in Sources */ = {isa = PBXBuildFile; fileRef = 64A8EE422B095FBB00F583F7 /* WindowFunctions.swift */; };
199+
64A8EE442B095FBB00F583F7 /* WindowFunctions.swift in Sources */ = {isa = PBXBuildFile; fileRef = 64A8EE422B095FBB00F583F7 /* WindowFunctions.swift */; };
200+
64A8EE452B095FBB00F583F7 /* WindowFunctions.swift in Sources */ = {isa = PBXBuildFile; fileRef = 64A8EE422B095FBB00F583F7 /* WindowFunctions.swift */; };
201+
64A8EE462B095FBB00F583F7 /* WindowFunctions.swift in Sources */ = {isa = PBXBuildFile; fileRef = 64A8EE422B095FBB00F583F7 /* WindowFunctions.swift */; };
202+
64B8E1702B09748000545AFB /* WindowFunctionsTests.swift in Sources */ = {isa = PBXBuildFile; fileRef = 64B8E16F2B09748000545AFB /* WindowFunctionsTests.swift */; };
203+
64B8E1712B09748000545AFB /* WindowFunctionsTests.swift in Sources */ = {isa = PBXBuildFile; fileRef = 64B8E16F2B09748000545AFB /* WindowFunctionsTests.swift */; };
204+
64B8E1722B09748000545AFB /* WindowFunctionsTests.swift in Sources */ = {isa = PBXBuildFile; fileRef = 64B8E16F2B09748000545AFB /* WindowFunctionsTests.swift */; };
198205
997DF2AE287FC06D00F8DF95 /* Query+with.swift in Sources */ = {isa = PBXBuildFile; fileRef = 997DF2AD287FC06D00F8DF95 /* Query+with.swift */; };
199206
997DF2AF287FC06D00F8DF95 /* Query+with.swift in Sources */ = {isa = PBXBuildFile; fileRef = 997DF2AD287FC06D00F8DF95 /* Query+with.swift */; };
200207
997DF2B0287FC06D00F8DF95 /* Query+with.swift in Sources */ = {isa = PBXBuildFile; fileRef = 997DF2AD287FC06D00F8DF95 /* Query+with.swift */; };
@@ -335,6 +342,8 @@
335342
3DF7B79B2884C901005DD8CA /* Planning.md */ = {isa = PBXFileReference; lastKnownFileType = net.daringfireball.markdown; path = Planning.md; sourceTree = "<group>"; };
336343
3DFC0B862886C239001C8FC9 /* Package.swift */ = {isa = PBXFileReference; lastKnownFileType = sourcecode.swift; path = Package.swift; sourceTree = "<group>"; };
337344
49EB68C31F7B3CB400D89D40 /* Coding.swift */ = {isa = PBXFileReference; lastKnownFileType = sourcecode.swift; path = Coding.swift; sourceTree = "<group>"; };
345+
64A8EE422B095FBB00F583F7 /* WindowFunctions.swift */ = {isa = PBXFileReference; lastKnownFileType = sourcecode.swift; path = WindowFunctions.swift; sourceTree = "<group>"; };
346+
64B8E16F2B09748000545AFB /* WindowFunctionsTests.swift */ = {isa = PBXFileReference; lastKnownFileType = sourcecode.swift; path = WindowFunctionsTests.swift; sourceTree = "<group>"; };
338347
997DF2AD287FC06D00F8DF95 /* Query+with.swift */ = {isa = PBXFileReference; lastKnownFileType = sourcecode.swift; path = "Query+with.swift"; sourceTree = "<group>"; };
339348
A121AC451CA35C79005A31D1 /* SQLite.framework */ = {isa = PBXFileReference; explicitFileType = wrapper.framework; includeInIndex = 0; path = SQLite.framework; sourceTree = BUILT_PRODUCTS_DIR; };
340349
DB58B21028FB864300F8EEA4 /* SchemaReader.swift */ = {isa = PBXFileReference; fileEncoding = 4; lastKnownFileType = sourcecode.swift; path = SchemaReader.swift; sourceTree = "<group>"; };
@@ -476,6 +485,7 @@
476485
19A177EF5E2D91BA86DA4480 /* CustomAggregationTests.swift */,
477486
19A1709D5BDD2691BA160012 /* SetterTests.swift */,
478487
19A174FE5B47A97937A27276 /* RowTests.swift */,
488+
64B8E16F2B09748000545AFB /* WindowFunctionsTests.swift */,
479489
);
480490
path = Typed;
481491
sourceTree = "<group>";
@@ -607,6 +617,7 @@
607617
isa = PBXGroup;
608618
children = (
609619
EE247AFA1C3F06E900AE3E12 /* AggregateFunctions.swift */,
620+
64A8EE422B095FBB00F583F7 /* WindowFunctions.swift */,
610621
EE247AFB1C3F06E900AE3E12 /* Collation.swift */,
611622
EE247AFC1C3F06E900AE3E12 /* CoreFunctions.swift */,
612623
EE247AFD1C3F06E900AE3E12 /* CustomFunctions.swift */,
@@ -960,6 +971,7 @@
960971
3DF7B78A28842972005DD8CA /* Connection+Attach.swift in Sources */,
961972
03A65E811C6BB2FB0062603F /* CustomFunctions.swift in Sources */,
962973
03A65E7A1C6BB2F70062603F /* Statement.swift in Sources */,
974+
64A8EE452B095FBB00F583F7 /* WindowFunctions.swift in Sources */,
963975
03A65E741C6BB2DA0062603F /* Helpers.swift in Sources */,
964976
03A65E831C6BB2FB0062603F /* Operators.swift in Sources */,
965977
03A65E851C6BB2FB0062603F /* Schema.swift in Sources */,
@@ -1014,6 +1026,7 @@
10141026
19A17746150A815944A6820B /* SelectTests.swift in Sources */,
10151027
19A1766135CE9786B1878603 /* ValueTests.swift in Sources */,
10161028
19A177D5C6542E2D572162E5 /* QueryIntegrationTests.swift in Sources */,
1029+
64B8E1722B09748000545AFB /* WindowFunctionsTests.swift in Sources */,
10171030
19A178DF5A96CFEFF1E271F6 /* AggregateFunctionsTests.swift in Sources */,
10181031
19A17437659BD7FD787D94A6 /* CustomAggregationTests.swift in Sources */,
10191032
19A17F907258E524B3CA2FAE /* SetterTests.swift in Sources */,
@@ -1057,6 +1070,7 @@
10571070
19A17DC282E36C4F41AA440B /* Errors.swift in Sources */,
10581071
19A173668D948AD4DF1F5352 /* DateAndTimeFunctions.swift in Sources */,
10591072
19A17DF8D4F13A20F5D2269E /* Result.swift in Sources */,
1073+
64A8EE462B095FBB00F583F7 /* WindowFunctions.swift in Sources */,
10601074
19A17DFE05ED8B1F7C45F7EE /* SchemaChanger.swift in Sources */,
10611075
19A17D1BEABA610ABF003D67 /* SchemaDefinitions.swift in Sources */,
10621076
19A17A33EA026C2E2CEBAF36 /* Connection+Schema.swift in Sources */,
@@ -1081,6 +1095,7 @@
10811095
EE247B151C3F06E900AE3E12 /* Setter.swift in Sources */,
10821096
3DF7B78828842972005DD8CA /* Connection+Attach.swift in Sources */,
10831097
EE247B101C3F06E900AE3E12 /* CustomFunctions.swift in Sources */,
1098+
64A8EE432B095FBB00F583F7 /* WindowFunctions.swift in Sources */,
10841099
EE247B091C3F06E900AE3E12 /* FTS4.swift in Sources */,
10851100
EE247B081C3F06E900AE3E12 /* Value.swift in Sources */,
10861101
EE247B121C3F06E900AE3E12 /* Operators.swift in Sources */,
@@ -1135,6 +1150,7 @@
11351150
19A17F7977364EC8CD33C3C3 /* SelectTests.swift in Sources */,
11361151
19A17FD22EF43DF428DD93BA /* ValueTests.swift in Sources */,
11371152
19A177AA5922527BBDC77CF9 /* QueryIntegrationTests.swift in Sources */,
1153+
64B8E1702B09748000545AFB /* WindowFunctionsTests.swift in Sources */,
11381154
19A179786A6826D58A70F8BC /* AggregateFunctionsTests.swift in Sources */,
11391155
19A1793972BDDDB027C113BB /* CustomAggregationTests.swift in Sources */,
11401156
19A1773155AC2BF2CA86A473 /* SetterTests.swift in Sources */,
@@ -1161,6 +1177,7 @@
11611177
3DF7B78928842972005DD8CA /* Connection+Attach.swift in Sources */,
11621178
EE247B701C3F3FEC00AE3E12 /* CustomFunctions.swift in Sources */,
11631179
EE247B691C3F3FEC00AE3E12 /* Statement.swift in Sources */,
1180+
64A8EE442B095FBB00F583F7 /* WindowFunctions.swift in Sources */,
11641181
EE247B641C3F3FDB00AE3E12 /* Helpers.swift in Sources */,
11651182
EE247B721C3F3FEC00AE3E12 /* Operators.swift in Sources */,
11661183
EE247B741C3F3FEC00AE3E12 /* Schema.swift in Sources */,
@@ -1215,6 +1232,7 @@
12151232
19A17DE1FCDB5695702AD24D /* SelectTests.swift in Sources */,
12161233
19A1726002D24C14F876C8FE /* ValueTests.swift in Sources */,
12171234
19A173389E53CB24DFA8CEDD /* QueryIntegrationTests.swift in Sources */,
1235+
64B8E1712B09748000545AFB /* WindowFunctionsTests.swift in Sources */,
12181236
19A170C56745F9D722A73D77 /* AggregateFunctionsTests.swift in Sources */,
12191237
19A1772EBE65173EDFB1AFCA /* CustomAggregationTests.swift in Sources */,
12201238
19A17E0ABA6C415F014CD51C /* SetterTests.swift in Sources */,

‎Sources/SQLite/Typed/AggregateFunctions.swift

Lines changed: 3 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -166,7 +166,7 @@ extension ExpressionType where UnderlyingType: Value, UnderlyingType.Datatype: N
166166
/// salary.average
167167
/// // avg("salary")
168168
///
169-
/// - Returns: A copy of the expression wrapped with the `min` aggregate
169+
/// - Returns: A copy of the expression wrapped with the `avg` aggregate
170170
/// function.
171171
public var average: Expression<Double?> {
172172
Function.avg.wrap(self)
@@ -179,7 +179,7 @@ extension ExpressionType where UnderlyingType: Value, UnderlyingType.Datatype: N
179179
/// salary.sum
180180
/// // sum("salary")
181181
///
182-
/// - Returns: A copy of the expression wrapped with the `min` aggregate
182+
/// - Returns: A copy of the expression wrapped with the `sum` aggregate
183183
/// function.
184184
public var sum: Expression<UnderlyingType?> {
185185
Function.sum.wrap(self)
@@ -192,7 +192,7 @@ extension ExpressionType where UnderlyingType: Value, UnderlyingType.Datatype: N
192192
/// salary.total
193193
/// // total("salary")
194194
///
195-
/// - Returns: A copy of the expression wrapped with the `min` aggregate
195+
/// - Returns: A copy of the expression wrapped with the `total` aggregate
196196
/// function.
197197
public var total: Expression<Double> {
198198
Function.total.wrap(self)

‎Sources/SQLite/Typed/WindowFunctions.swift

Lines changed: 145 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,145 @@
1+
import Foundation
2+
3+
// see https://www.sqlite.org/windowfunctions.html#builtins
4+
private enum WindowFunction: String {
5+
// swiftlint:disable identifier_name
6+
case ntile
7+
case row_number
8+
case rank
9+
case dense_rank
10+
case percent_rank
11+
case cume_dist
12+
case lag
13+
case lead
14+
case first_value
15+
case last_value
16+
case nth_value
17+
// swiftlint:enable identifier_name
18+
19+
func wrap<T>(_ value: Int? = nil) -> Expression<T> {
20+
if let value {
21+
return self.rawValue.wrap(Expression(value: value))
22+
}
23+
return Expression(literal: "\(rawValue)()")
24+
}
25+
26+
func over<T>(value: Int? = nil, _ orderBy: Expressible) -> Expression<T> {
27+
return Expression<T>(" ".join([
28+
self.wrap(value),
29+
Expression<T>("OVER (ORDER BY \(orderBy.expression.template))", orderBy.expression.bindings)
30+
]).expression)
31+
}
32+
33+
func over<T>(valueExpr: Expressible, _ orderBy: Expressible) -> Expression<T> {
34+
return Expression<T>(" ".join([
35+
self.rawValue.wrap(valueExpr),
36+
Expression<T>("OVER (ORDER BY \(orderBy.expression.template))", orderBy.expression.bindings)
37+
]).expression)
38+
}
39+
}
40+
41+
extension ExpressionType where UnderlyingType: Value {
42+
/// Builds a copy of the expression with `lag(self, offset, default) OVER (ORDER BY {orderBy})` window function
43+
///
44+
/// - Parameter orderBy: Expression to evaluate window order
45+
/// - Returns: An expression returning `lag(self, offset, default) OVER (ORDER BY {orderBy})` window function
46+
public func lag(offset: Int = 0, default: Expressible? = nil, _ orderBy: Expressible) -> Expression<UnderlyingType> {
47+
if let defaultExpression = `default` {
48+
return Expression(
49+
"lag(\(template), \(offset), \(defaultExpression.asSQL())) OVER (ORDER BY \(orderBy.expression.template))",
50+
bindings + orderBy.expression.bindings
51+
)
52+
53+
}
54+
return Expression("lag(\(template), \(offset)) OVER (ORDER BY \(orderBy.expression.template))", bindings + orderBy.expression.bindings)
55+
}
56+
57+
/// Builds a copy of the expression with `lead(self, offset, default) OVER (ORDER BY {orderBy})` window function
58+
///
59+
/// - Parameter orderBy: Expression to evaluate window order
60+
/// - Returns: An expression returning `lead(self, offset, default) OVER (ORDER BY {orderBy})` window function
61+
public func lead(offset: Int = 0, default: Expressible? = nil, _ orderBy: Expressible) -> Expression<UnderlyingType> {
62+
if let defaultExpression = `default` {
63+
return Expression(
64+
"lead(\(template), \(offset), \(defaultExpression.asSQL())) OVER (ORDER BY \(orderBy.expression.template))",
65+
bindings + orderBy.expression.bindings)
66+
67+
}
68+
return Expression("lead(\(template), \(offset)) OVER (ORDER BY \(orderBy.expression.template))", bindings + orderBy.expression.bindings)
69+
}
70+
71+
/// Builds a copy of the expression with `first_value(self) OVER (ORDER BY {orderBy})` window function
72+
///
73+
/// - Parameter orderBy: Expression to evaluate window order
74+
/// - Returns: An expression returning `first_value(self) OVER (ORDER BY {orderBy})` window function
75+
public func firstValue(_ orderBy: Expressible) -> Expression<UnderlyingType> {
76+
WindowFunction.first_value.over(valueExpr: self, orderBy)
77+
}
78+
79+
/// Builds a copy of the expression with `last_value(self) OVER (ORDER BY {orderBy})` window function
80+
///
81+
/// - Parameter orderBy: Expression to evaluate window order
82+
/// - Returns: An expression returning `last_value(self) OVER (ORDER BY {orderBy})` window function
83+
public func lastValue(_ orderBy: Expressible) -> Expression<UnderlyingType> {
84+
WindowFunction.last_value.over(valueExpr: self, orderBy)
85+
}
86+
87+
/// Builds a copy of the expression with `nth_value(self) OVER (ORDER BY {orderBy})` window function
88+
///
89+
/// - Parameter index: Row N of the window frame to return
90+
/// - Parameter orderBy: Expression to evaluate window order
91+
/// - Returns: An expression returning `nth_value(self) OVER (ORDER BY {orderBy})` window function
92+
public func value(_ index: Int, _ orderBy: Expressible) -> Expression<UnderlyingType> {
93+
Expression("nth_value(\(template), \(index)) OVER (ORDER BY \(orderBy.expression.template))", bindings + orderBy.expression.bindings)
94+
}
95+
}
96+
97+
/// Builds an expression representing `ntile(size) OVER (ORDER BY {orderBy})`
98+
///
99+
/// - Parameter orderBy: Expression to evaluate window order
100+
/// - Returns: An expression returning `ntile(size) OVER (ORDER BY {orderBy})`
101+
public func ntile(_ size: Int, _ orderBy: Expressible) -> Expression<Int> {
102+
// Expression.ntile(size, orderBy)
103+
104+
WindowFunction.ntile.over(value: size, orderBy)
105+
}
106+
107+
/// Builds an expression representing `row_count() OVER (ORDER BY {orderBy})`
108+
///
109+
/// - Parameter orderBy: Expression to evaluate window order
110+
/// - Returns: An expression returning `row_count() OVER (ORDER BY {orderBy})`
111+
public func rowNumber(_ orderBy: Expressible) -> Expression<Int> {
112+
WindowFunction.row_number.over(orderBy)
113+
}
114+
115+
/// Builds an expression representing `rank() OVER (ORDER BY {orderBy})`
116+
///
117+
/// - Parameter orderBy: Expression to evaluate window order
118+
/// - Returns: An expression returning `rank() OVER (ORDER BY {orderBy})`
119+
public func rank(_ orderBy: Expressible) -> Expression<Int> {
120+
WindowFunction.rank.over(orderBy)
121+
}
122+
123+
/// Builds an expression representing `dense_rank() OVER (ORDER BY {orderBy})`
124+
///
125+
/// - Parameter orderBy: Expression to evaluate window order
126+
/// - Returns: An expression returning `dense_rank() OVER ('over')`
127+
public func denseRank(_ orderBy: Expressible) -> Expression<Int> {
128+
WindowFunction.dense_rank.over(orderBy)
129+
}
130+
131+
/// Builds an expression representing `percent_rank() OVER (ORDER BY {orderBy})`
132+
///
133+
/// - Parameter orderBy: Expression to evaluate window order
134+
/// - Returns: An expression returning `percent_rank() OVER (ORDER BY {orderBy})`
135+
public func percentRank(_ orderBy: Expressible) -> Expression<Double> {
136+
WindowFunction.percent_rank.over(orderBy)
137+
}
138+
139+
/// Builds an expression representing `cume_dist() OVER (ORDER BY {orderBy})`
140+
///
141+
/// - Parameter orderBy: Expression to evaluate window order
142+
/// - Returns: An expression returning `cume_dist() OVER (ORDER BY {orderBy})`
143+
public func cumeDist(_ orderBy: Expressible) -> Expression<Double> {
144+
WindowFunction.cume_dist.over(orderBy)
145+
}

‎Tests/SQLiteTests/Typed/QueryIntegrationTests.swift

Lines changed: 95 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -322,6 +322,101 @@ class QueryIntegrationTests: SQLiteTestCase {
322322
XCTAssertNotNil(row[name])
323323
XCTAssertNotNil(row[email])
324324
}
325+
326+
func test_select_ntile_function() throws {
327+
let users = Table("users")
328+
329+
try insertUser("Joey")
330+
try insertUser("Timmy")
331+
try insertUser("Jimmy")
332+
try insertUser("Billy")
333+
334+
let bucket = ntile(1, id.asc)
335+
try db.prepare(users.select(id, bucket)).forEach {
336+
XCTAssertEqual($0[bucket], 1) // only 1 window
337+
}
338+
}
339+
340+
func test_select_cume_dist_function() throws {
341+
let users = Table("users")
342+
343+
try insertUser("Joey")
344+
try insertUser("Timmy")
345+
try insertUser("Jimmy")
346+
try insertUser("Billy")
347+
348+
let cumeDist = cumeDist(email)
349+
let results = try db.prepare(users.select(id, cumeDist)).map {
350+
$0[cumeDist]
351+
}
352+
XCTAssertEqual([0.25, 0.5, 0.75, 1], results)
353+
}
354+
355+
func test_select_window_row_number() throws {
356+
let users = Table("users")
357+
358+
try insertUser("Billy")
359+
try insertUser("Jimmy")
360+
try insertUser("Joey")
361+
try insertUser("Timmy")
362+
363+
let rowNumber = rowNumber(email.asc)
364+
var expectedRowNum = 1
365+
try db.prepare(users.select(id, rowNumber)).forEach {
366+
// should retrieve row numbers in order of INSERT above
367+
XCTAssertEqual($0[rowNumber], expectedRowNum)
368+
expectedRowNum += 1
369+
}
370+
}
371+
372+
func test_select_window_ranking() throws {
373+
let users = Table("users")
374+
375+
try insertUser("Billy")
376+
try insertUser("Jimmy")
377+
try insertUser("Joey")
378+
try insertUser("Timmy")
379+
380+
let percentRank = percentRank(email)
381+
let actualPercentRank: [Int] = try db.prepare(users.select(id, percentRank)).map {
382+
Int($0[percentRank] * 100)
383+
}
384+
XCTAssertEqual([0, 33, 66, 100], actualPercentRank)
385+
386+
let rank = rank(email)
387+
let actualRank: [Int] = try db.prepare(users.select(id, rank)).map {
388+
$0[rank]
389+
}
390+
XCTAssertEqual([1, 2, 3, 4], actualRank)
391+
392+
let denseRank = denseRank(email)
393+
let actualDenseRank: [Int] = try db.prepare(users.select(id, denseRank)).map {
394+
$0[denseRank]
395+
}
396+
XCTAssertEqual([1, 2, 3, 4], actualDenseRank)
397+
}
398+
399+
func test_select_window_values() throws {
400+
let users = Table("users")
401+
402+
try insertUser("Billy")
403+
try insertUser("Jimmy")
404+
try insertUser("Joey")
405+
try insertUser("Timmy")
406+
407+
let firstValue = email.firstValue(email.desc)
408+
try db.prepare(users.select(id, firstValue)).forEach {
409+
XCTAssertEqual($0[firstValue], "Timmy@example.com") // should grab last email alphabetically
410+
}
411+
412+
let lastValue = email.lastValue(email.asc)
413+
var row = try db.pluck(users.select(id, lastValue))!
414+
XCTAssertEqual(row[lastValue], "Billy@example.com")
415+
416+
let nthValue = email.value(1, email.asc)
417+
row = try db.pluck(users.select(id, nthValue))!
418+
XCTAssertEqual(row[nthValue], "Billy@example.com")
419+
}
325420
}
326421

327422
extension Connection {

0 commit comments

Comments
 (0)