Update Kuzu from branch master (#121)

Co-authored-by: mewim <14037726+mewim@users.noreply.github.com>

Author: mewim

Sources/cxx-kuzu/kuzu/src/common/arrow/arrow_converter.cpp

@@ -261,9 +261,11 @@ void ArrowConverter::setArrowFormat(ArrowSchemaHolder& rootHolder, ArrowSchema&
  rootHolder.nestedChildrenPtr.back().push_back(&rootHolder.nestedChildren.back()[0]);
  initializeChild(rootHolder.nestedChildren.back()[0]);
  child.children = &rootHolder.nestedChildrenPtr.back()[0];
- child.children[0]->name = "l";
+ child.children[0]->name = "entries";
  setArrowFormat(rootHolder, **child.children, ListType::getChildType(dataType),
  fallbackExtensionTypes);
+ child.children[0]->children[0]->flags &=
+ ~ARROW_FLAG_NULLABLE; // Map's keys must be non-nullable
  } break;
  case LogicalTypeID::STRUCT:
  case LogicalTypeID::NODE:

Sources/cxx-kuzu/kuzu/src/common/arrow/arrow_row_batch.cpp

@@ -379,6 +379,13 @@ void ArrowRowBatch::templateCopyNonNullValue<LogicalTypeID::ARRAY>(ArrowVector*
 template<>
 void ArrowRowBatch::templateCopyNonNullValue<LogicalTypeID::MAP>(ArrowVector* vector,
  const LogicalType& type, const Value& value, std::int64_t pos, bool fallbackExtensionTypes) {
+ // Verify all keys are not null
+ for (auto i = 0u; i < value.childrenSize; ++i) {
+ if (value.children[i]->children[0]->isNull()) {
+ throw RuntimeException{
+ stringFormat("Cannot convert map with null key to Arrow: {}", value.toString())};
+ }
+ }
  return templateCopyNonNullValue<LogicalTypeID::LIST>(vector, type, value, pos,
  fallbackExtensionTypes);
 }
@@ -712,7 +719,9 @@ void ArrowRowBatch::copyNullValue(ArrowVector* vector, const Value& value, std::
  case LogicalTypeID::INTERVAL: {
  templateCopyNullValue<LogicalTypeID::INTERVAL>(vector, pos);
  } break;
- case LogicalTypeID::UUID:
+ case LogicalTypeID::UUID: {
+ templateCopyNullValue<LogicalTypeID::UUID>(vector, pos);
+ } break;
  case LogicalTypeID::BLOB:
  case LogicalTypeID::STRING: {
  templateCopyNullValue<LogicalTypeID::STRING>(vector, pos);

Sources/cxx-kuzu/kuzu/src/main/query_result.cpp

@@ -99,6 +99,9 @@ void QueryResult::setQuerySummary(std::unique_ptr<QuerySummary> summary) {
 void QueryResult::setDBLifeCycleManager(
  std::shared_ptr<DatabaseLifeCycleManager> dbLifeCycleManager) {
  this->dbLifeCycleManager = dbLifeCycleManager;
+ if (nextQueryResult) {
+ nextQueryResult->setDBLifeCycleManager(dbLifeCycleManager);
+ }
 }
 
 std::unique_ptr<QueryResult> QueryResult::getQueryResultWithError(const std::string& errorMessage) {