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;

Reply via email to