Method fetchTable

memstore/schema.go:67–95

(tableName string)

}

func (m *memStoreImpl) fetchTable(tableName string) error {
	table, err := m.metaStore.GetTable(tableName)
	if err != nil {
		if err != metaCom.ErrTableDoesNotExist {
			return utils.StackError(err, "Failed to get table schema for table %s from meta", tableName)
		}
	} else {
		tableSchema := memCom.NewTableSchema(table)
		for columnID, column := range table.Columns {
			if !column.Deleted {
				if column.IsEnumColumn() {
					enumCases, err := m.metaStore.GetEnumDict(tableName, column.Name)
					if err != nil {
						if err != metaCom.ErrTableDoesNotExist && err != metaCom.ErrColumnDoesNotExist {
							return utils.StackError(err, "Failed to fetch enum cases for table: %s, column: %s", tableName, column.Name)
						}
					} else {
						tableSchema.CreateEnumDict(column.Name, enumCases)
					}
				}
			}
			tableSchema.SetDefaultValue(columnID)
		}
		m.Lock()
		m.TableSchemas[tableName] = tableSchema
		m.Unlock()
	}
	return nil
}

// watch enumCases will setup watch channels for each enum column.
func (m *memStoreImpl) watchEnumCases(tableName, columnName string, startCase int) error {