Method deleteEnum

controller/mutators/etcd/schema_mutator.go:180–208

(namespace string, table *metaCom.Table)

}

func (m *tableSchemaMutator) deleteEnum(namespace string, table *metaCom.Table) {
	logger := m.logger.With("namespace", namespace, "table", table.Name, "incarnation", table.Incarnation)
	for columnID, column := range table.Columns {
		if column.IsEnumColumn() {
			value, err := m.txnStore.Get(utils.EnumNodeListKey(namespace, table.Name, table.Incarnation, columnID))
			if err != nil {
				logger.With("column", column.Name, "columnID", columnID, "error", err.Error()).Error("failed to get enum node list")
				continue
			}
			var nodeList pb.EnumNodeList
			err = value.Unmarshal(&nodeList)
			if err != nil {
				logger.With("column", column.Name, "columnID", columnID, "error", err.Error()).Error("failed to get enum node list")
				continue
			}
			for nodeID := 0; nodeID < int(nodeList.NumEnumNodes); nodeID++ {
				_, err = m.txnStore.Delete(utils.EnumNodeKey(namespace, table.Name, table.Incarnation, columnID, nodeID))
				if err != nil {
					logger.With("column", column.Name, "columnID", columnID, "node", nodeID, "error", err.Error()).Error("failed to delete enum node")
					continue
				}
			}
			_, err = m.txnStore.Delete(utils.EnumNodeListKey(namespace, table.Name, table.Incarnation, columnID))
			if err != nil {
				logger.With("column", column.Name, "columnID", columnID, "error", err.Error()).Error("failed to delete enum node list")
			}
		}
	}
}

func (m *tableSchemaMutator) UpdateTable(namespace string, table metaCom.Table, force bool) (err error) {
	tableListProto, tableListVersion, err := readEntityList(m.txnStore, utils.SchemaListKey(namespace))