# -*- coding: utf-8 -*- """ *************************************************************************** DeleteColumn.py --------------------- Date : May 2010 Copyright : (C) 2010 by Michael Minn Email : pyqgis at michaelminn dot com *************************************************************************** * * * This program is free software; you can redistribute it and/or modify * * it under the terms of the GNU General Public License as published by * * the Free Software Foundation; either version 2 of the License, or * * (at your option) any later version. * * * *************************************************************************** """ __author__ = 'Michael Minn' __date__ = 'May 2010' __copyright__ = '(C) 2010, Michael Minn' # This will get replaced with a git SHA1 when you do a git archive __revision__ = '$Format:%H$' from qgis.core import (QgsApplication, QgsProcessingUtils, QgsProcessingParameterFeatureSource, QgsProcessingParameterFeatureSink, QgsProcessingParameterField, QgsProcessingOutputVectorLayer) from processing.algs.qgis.QgisAlgorithm import QgisAlgorithm class DeleteColumn(QgisAlgorithm): INPUT = 'INPUT' COLUMNS = 'COLUMN' OUTPUT = 'OUTPUT' def icon(self): return QgsApplication.getThemeIcon("/providerQgis.svg") def svgIconPath(self): return QgsApplication.iconPath("providerQgis.svg") def tags(self): return self.tr('drop,delete,remove,fields,columns,attributes').split(',') def group(self): return self.tr('Vector table tools') def __init__(self): super().__init__() self.addParameter(QgsProcessingParameterFeatureSource(self.INPUT, self.tr('Input layer'))) self.addParameter(QgsProcessingParameterField(self.COLUMNS, self.tr('Fields to delete'), None, self.INPUT, QgsProcessingParameterField.Any, True)) self.addParameter(QgsProcessingParameterFeatureSink(self.OUTPUT, self.tr('Output layer'))) self.addOutput(QgsProcessingOutputVectorLayer(self.OUTPUT, self.tr("Output layer"))) def name(self): return 'deletecolumn' def displayName(self): return self.tr('Delete column') def processAlgorithm(self, parameters, context, feedback): source = self.parameterAsSource(parameters, self.INPUT, context) fields_to_delete = self.parameterAsFields(parameters, self.COLUMNS, context) fields = source.fields() field_indices = [] # loop through twice - first we need to build up a list of original attribute indices for f in fields_to_delete: index = fields.lookupField(f) field_indices.append(index) # important - make sure we remove from the end so we aren't changing used indices as we go field_indices.sort(reverse=True) # this second time we make a cleaned version of the fields for index in field_indices: fields.remove(index) (sink, dest_id) = self.parameterAsSink(parameters, self.OUTPUT, context, fields, source.wkbType(), source.sourceCrs()) features = source.getFeatures() total = 100.0 / source.featureCount() for current, f in enumerate(features): if feedback.isCanceled(): break attributes = f.attributes() for index in field_indices: del attributes[index] f.setAttributes(attributes) sink.addFeature(f) feedback.setProgress(int(current * total)) return {self.OUTPUT: dest_id}