This is an automated email from the ASF dual-hosted git repository.
lidavidm pushed a commit to branch main
in repository https://gitbox.apache.org/repos/asf/arrow-adbc.git
The following commit(s) were added to refs/heads/main by this push:
new 0c04472 fix(c/validation): free schema in partitioning test (#141)
0c04472 is described below
commit 0c0447286110069c2f2379be71f3b53bb5376cd7
Author: David Li <[email protected]>
AuthorDate: Mon Sep 26 13:07:34 2022 -0400
fix(c/validation): free schema in partitioning test (#141)
---
c/validation/adbc_validation.cc | 14 +++++++-------
1 file changed, 7 insertions(+), 7 deletions(-)
diff --git a/c/validation/adbc_validation.cc b/c/validation/adbc_validation.cc
index 9878170..6de2e79 100644
--- a/c/validation/adbc_validation.cc
+++ b/c/validation/adbc_validation.cc
@@ -1450,26 +1450,26 @@ void StatementTest::TestSqlPartitionedInts() {
ADBCV_ASSERT_OK(&error, AdbcStatementNew(&connection, &statement, &error));
ADBCV_ASSERT_OK(&error, AdbcStatementSetSqlQuery(&statement, "SELECT 42",
&error));
- struct ArrowSchema schema;
+ Handle<struct ArrowSchema> schema;
Handle<struct AdbcPartitions> partitions;
int64_t rows_affected = 0;
if (!quirks()->supports_partitioned_data()) {
ADBCV_ASSERT_FAILS_WITH(
NOT_IMPLEMENTED, &error,
- AdbcStatementExecutePartitions(&statement, &schema, &partitions.value,
+ AdbcStatementExecutePartitions(&statement, &schema.value,
&partitions.value,
&rows_affected, &error));
return;
}
- ADBCV_ASSERT_OK(&error,
- AdbcStatementExecutePartitions(&statement, &schema,
&partitions.value,
- &rows_affected, &error));
+ ADBCV_ASSERT_OK(
+ &error, AdbcStatementExecutePartitions(&statement, &schema.value,
&partitions.value,
+ &rows_affected, &error));
// Assume only 1 partition
ASSERT_EQ(1, partitions->num_partitions);
ASSERT_THAT(rows_affected, ::testing::AnyOf(::testing::Eq(1),
::testing::Eq(-1)));
- ASSERT_NE(nullptr, schema.release);
- ASSERT_EQ(1, schema.n_children);
+ ASSERT_NE(nullptr, schema->release);
+ ASSERT_EQ(1, schema->n_children);
Handle<struct AdbcConnection> connection2;
StreamReader reader;