Method RunStep

apps/gdalalg_vector_create.cpp:121–402

/************************************************************************/

bool GDALVectorCreateAlgorithm::RunStep(GDALPipelineStepRunContext &)
{

    const std::string &datasetName = m_outputDataset.GetName();
    const std::string outputLayerName =
        m_outputLayerName.empty() ? CPLGetBasenameSafe(datasetName.c_str())
                                  : m_outputLayerName;

    std::unique_ptr<GDALDataset> poDstDS;
    poDstDS.reset(GDALDataset::Open(datasetName.c_str(),
                                    GDAL_OF_VECTOR | GDAL_OF_UPDATE, nullptr,
                                    nullptr, nullptr));

    if (poDstDS && !m_update)
    {
        ReportError(CE_Failure, CPLE_AppDefined,
                    "Dataset %s already exists. Specify the "
                    "--%s option to open it in update mode.",
                    datasetName.c_str(), GDAL_ARG_NAME_UPDATE);
        return false;
    }

    GDALDataset *poSrcDS = m_inputDataset.empty()
                               ? nullptr
                               : m_inputDataset.front().GetDatasetRef();

    OGRSchemaOverride oSchemaOverride;

    const auto loadJSON = [this,
                           &oSchemaOverride](const std::string &source) -> bool
    {
        // This error count is necessary because LoadFromJSON tries to load
        // the content as a file first (and set an error it if fails) then tries
        // to load as a JSON string but even if it succeeds an error is still
        // set and not cleared.
        const auto nErrorCount = CPLGetErrorCounter();
        if (!oSchemaOverride.LoadFromJSON(source,
                                          /* allowGeometryFields */ true))
        {
            // Get the last error message and report it, since LoadFromJSON doesn't do it itself.
            if (nErrorCount != CPLGetErrorCounter())
            {
                const std::string lastErrorMsg = CPLGetLastErrorMsg();
                CPLErrorReset();
                ReportError(CE_Failure, CPLE_AppDefined,
                            "Cannot parse OGR_SCHEMA: %s.",
                            lastErrorMsg.c_str());
            }
            else
            {
                ReportError(CE_Failure, CPLE_AppDefined,
                            "Cannot parse OGR_SCHEMA (unknown error).");
            }
            return false;
        }
        else if (nErrorCount != CPLGetErrorCounter())
        {
            CPLErrorReset();