Skip to content

Commit 4bfd307

Browse files
committed
Java-Exec Now Passing. Fixed precision errors in JDBC plugin
1 parent 97a6092 commit 4bfd307

File tree

3 files changed

+16
-10
lines changed

3 files changed

+16
-10
lines changed

contrib/storage-jdbc/src/test/java/org/apache/drill/exec/store/jdbc/TestJdbcPluginWithMSSQL.java

Lines changed: 6 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -207,14 +207,16 @@ public void testExpressionsWithoutAlias() throws Exception {
207207

208208
DirectRowSet results = queryBuilder().sql(sql).rowSet();
209209

210+
// Calcite 1.35: COUNT(*) returns BIGINT, integer expressions return INT, SQRT returns DOUBLE
211+
// Types are REQUIRED not OPTIONAL for literals and aggregates
210212
TupleMetadata expectedSchema = new SchemaBuilder()
211-
.addNullable("EXPR$0", MinorType.INT, 10)
212-
.addNullable("EXPR$1", MinorType.INT, 10)
213-
.addNullable("EXPR$2", MinorType.FLOAT8, 15)
213+
.add("EXPR$0", MinorType.BIGINT)
214+
.add("EXPR$1", MinorType.INT)
215+
.add("EXPR$2", MinorType.FLOAT8)
214216
.build();
215217

216218
RowSet expected = client.rowSetBuilder(expectedSchema)
217-
.addRow(4L, 88L, 1.618033988749895)
219+
.addRow(4L, 88, 1.618033988749895)
218220
.build();
219221

220222
RowSetUtilities.verify(expected, results);

contrib/storage-jdbc/src/test/java/org/apache/drill/exec/store/jdbc/TestJdbcPluginWithMySQLIT.java

Lines changed: 4 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -277,7 +277,8 @@ public void testExpressionsWithoutAlias() throws Exception {
277277
.sqlQuery(query)
278278
.unOrdered()
279279
.baselineColumns("EXPR$0", "EXPR$1", "EXPR$2")
280-
.baselineValues(4L, 88, BigDecimal.valueOf(1.618033988749895))
280+
// Calcite 1.35: SQRT returns DOUBLE, so (1+sqrt(5))/2 returns DOUBLE not DECIMAL
281+
.baselineValues(4L, 88, 1.618033988749895)
281282
.go();
282283
}
283284

@@ -290,7 +291,8 @@ public void testExpressionsWithoutAliasesPermutations() throws Exception {
290291
.sqlQuery(query)
291292
.ordered()
292293
.baselineColumns("EXPR$1", "EXPR$0", "EXPR$2")
293-
.baselineValues(BigDecimal.valueOf(1.618033988749895), 88, 4L)
294+
// Calcite 1.35: SQRT returns DOUBLE, so (1+sqrt(5))/2 returns DOUBLE not DECIMAL
295+
.baselineValues(1.618033988749895, 88, 4L)
294296
.go();
295297
}
296298

contrib/storage-jdbc/src/test/java/org/apache/drill/exec/store/jdbc/TestJdbcPluginWithPostgres.java

Lines changed: 6 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -190,14 +190,16 @@ public void testExpressionsWithoutAlias() throws Exception {
190190

191191
DirectRowSet results = queryBuilder().sql(sql).rowSet();
192192

193+
// Calcite 1.35: COUNT(*) returns BIGINT, integer expressions return INT, SQRT returns DOUBLE
194+
// Types are REQUIRED not OPTIONAL for literals and aggregates
193195
TupleMetadata expectedSchema = new SchemaBuilder()
194-
.addNullable("EXPR$0", MinorType.BIGINT, 19)
195-
.addNullable("EXPR$1", MinorType.INT, 10)
196-
.addNullable("EXPR$2", MinorType.FLOAT8, 17, 17)
196+
.add("EXPR$0", MinorType.BIGINT)
197+
.add("EXPR$1", MinorType.INT)
198+
.add("EXPR$2", MinorType.FLOAT8)
197199
.build();
198200

199201
RowSet expected = client.rowSetBuilder(expectedSchema)
200-
.addRow(4L, 88L, 1.618033988749895)
202+
.addRow(4L, 88, 1.618033988749895)
201203
.build();
202204

203205
RowSetUtilities.verify(expected, results);

0 commit comments

Comments
 (0)