Function appendSchemaTables

backend/plugin/db/databricks/sync.go:141–186

extract tables' metadata from 'tablesInfo' and store it in 'catalogMap'.

(catalogMap databricksCatalogMap, tablesInfo []catalog.TableInfo)

// extract tables' metadata from 'tablesInfo' and store it in 'catalogMap'.
func appendSchemaTables(catalogMap databricksCatalogMap, tablesInfo []catalog.TableInfo) error {
	for _, tableInfo := range tablesInfo {
		table := tableUnion{
			typeName: tableInfo.TableType,
			name:     tableInfo.Name,
		}

		switch tableInfo.TableType {
		case catalog.TableTypeView:
			table.view = &storepb.ViewMetadata{
				Name:              table.name,
				Definition:        tableInfo.ViewDefinition,
				Comment:           tableInfo.Comment,
				DependencyColumns: convertToDependencyColumns(tableInfo.SchemaName, tableInfo.Name, tableInfo.Columns),
			}
		case catalog.TableTypeMaterializedView:
			table.materialView = &storepb.MaterializedViewMetadata{
				Name:       table.name,
				Definition: tableInfo.ViewDefinition,
				Comment:    tableInfo.Comment,
			}
		case catalog.TableTypeExternal:
			table.externalTable = &storepb.ExternalTableMetadata{
				Name: table.name,
			}
		case catalog.TableTypeManaged:
			table.table = &storepb.TableMetadata{
				Name:    table.name,
				Columns: convertToColumnMetadata(tableInfo.Columns),
				Comment: tableInfo.Comment,
			}
		default:
			// we do not sync streaming table.
			continue
		}

		// catalogMap[tableInfo.CatalogName] must not be nil.
		if tblList, ok := catalogMap[tableInfo.CatalogName][tableInfo.SchemaName]; ok {
			tblList = append(tblList, &table)
			catalogMap[tableInfo.CatalogName][tableInfo.SchemaName] = tblList
		} else {
			return errors.New("table list not initialized")
		}
	}
	return nil
}

func convertToColumnMetadata(columnInfo []catalog.ColumnInfo) []*storepb.ColumnMetadata {
	columns := []*storepb.ColumnMetadata{}