Method Connect

cpp/src/arrow/flight/sql/odbc/odbc_impl/flight_sql_connection.cc:152–185

}

void FlightSqlConnection::Connect(const ConnPropertyMap& properties,
                                  std::vector<std::string_view>& missing_attr) {
  try {
    auto flight_ssl_configs = LoadFlightSslConfigs(properties);

    Location location = BuildLocation(properties, missing_attr, flight_ssl_configs);
    client_options_ =
        BuildFlightClientOptions(properties, missing_attr, flight_ssl_configs);

    std::unique_ptr<FlightClient> flight_client;
    ThrowIfNotOK(FlightClient::Connect(location, client_options_).Value(&flight_client));
    PopulateMetadataSettings(properties);
    PopulateCallOptions(properties);

    std::unique_ptr<FlightSqlAuthMethod> auth_method =
        FlightSqlAuthMethod::FromProperties(flight_client, properties);
    auth_method->Authenticate(*this, call_options_);

    sql_client_.reset(new FlightSqlClient(std::move(flight_client)));
    closed_ = false;

    // Note: This should likely come from Flight instead of being from the
    // connection properties to allow reporting a user for other auth mechanisms
    // and also decouple the database user from user credentials.

    info_.SetProperty(SQL_USER_NAME, auth_method->GetUser());
    attribute_[CONNECTION_DEAD] = static_cast<uint32_t>(SQL_FALSE);
  } catch (...) {
    attribute_[CONNECTION_DEAD] = static_cast<uint32_t>(SQL_TRUE);
    sql_client_.reset();

    throw;
  }
}

void FlightSqlConnection::PopulateMetadataSettings(
    const Connection::ConnPropertyMap& conn_property_map) {