Method fetchAndSetEnumCases

client/schema.go:257–307

(table *metaCom.Table)

}

func (cf *CachedSchemaHandler) fetchAndSetEnumCases(table *metaCom.Table) error {
	enumMappings := make(map[int]enumDict)
	enumDefaultValueMappings := make(map[int]int)
	for columnID, column := range table.Columns {
		if column.Deleted {
			continue
		}
		enumMappings[columnID] = make(enumDict)
		caseInsensitive := column.CaseInsensitive
		var defValuePtr *string

		if column.DefaultValue != nil {
			var defValue = *column.DefaultValue
			if caseInsensitive {
				defValue = strings.ToLower(defValue)
			}
			defValuePtr = &defValue
		}

		if column.IsEnumColumn() {
			enumCases, err := cf.schemaFetcher.FetchAllEnums(table.Name, column.Name)
			if err == nil {
				for enumID, enumCase := range enumCases {
					// Convert to lower case for comparison during ingestion.
					if caseInsensitive {
						enumCase = strings.ToLower(enumCase)
					}
					// all mapping should be pre created
					enumMappings[columnID][enumCase] = enumID

					if defValuePtr != nil {
						if *defValuePtr == enumCase {
							enumDefaultValueMappings[columnID] = enumID
						}
					}
				}
			} else {
				cf.metricScope.Tagged(map[string]string{
					"table":    table.Name,
					"columnID": strconv.Itoa(columnID),
				}).Counter("err_fetch_enum_dict").Inc(1)
				return utils.StackError(err, "Failed to fetch enum cases for table: %s, column: %d", table.Name, columnID)
			}
		}
	}
	cf.Lock()
	cf.enumMappings[table.Name] = enumMappings
	cf.enumDefaultValueMappings[table.Name] = enumDefaultValueMappings
	cf.Unlock()
	return nil
}

func (cf *CachedSchemaHandler) setTable(table *metaCom.Table) *TableSchema {
	columnDict := make(map[string]int)