Method getMaterializedViews

backend/plugin/db/starrocks/sync.go:148–194

getMaterializedViews returns the materialized views of the current database keyed by table name. Doris and StarRocks expose them through different catalogs, so the query and projection are engine-specific. The query is best-effort: an engine/version that does not support it is logged and yields an e

(ctx context.Context)

// and projection are engine-specific. The query is best-effort: an engine/version that
// does not support it is logged and yields an empty set rather than failing the sync.
func (d *Driver) getMaterializedViews(ctx context.Context) (map[db.TableKey]*storepb.MaterializedViewMetadata, error) {
	materializedViewMap := make(map[db.TableKey]*storepb.MaterializedViewMetadata)

	var query string
	switch d.dbType {
	case storepb.Engine_DORIS:
		// Doris exposes materialized views via the mv_infos() table-valued function.
		// https://doris.apache.org/docs/sql-manual/sql-functions/table-valued-functions/mv_infos
		query = fmt.Sprintf(`SELECT Name, QuerySql FROM mv_infos("database"="%s")`, d.databaseName)
	case storepb.Engine_STARROCKS:
		// StarRocks exposes materialized views via information_schema.materialized_views.
		// REFRESH_TYPE separates async MVs from synchronous rollups, which are excluded.
		// IFNULL guards the bare-string scans below: database/sql errors on a NULL->string scan.
		query = fmt.Sprintf(`SELECT TABLE_NAME, IFNULL(REFRESH_TYPE, ''), IFNULL(MATERIALIZED_VIEW_DEFINITION, '') FROM information_schema.materialized_views WHERE TABLE_SCHEMA = '%s'`, d.databaseName)
	default:
		return materializedViewMap, nil
	}

	rows, err := d.db.QueryContext(ctx, query)
	if err != nil {
		// The catalog may be unavailable on older engine versions; log and continue.
		slog.Debug("failed to query materialized views, might not be supported in this version", log.BBError(err))
		return materializedViewMap, nil
	}
	defer rows.Close()

	for rows.Next() {
		materializedView := &storepb.MaterializedViewMetadata{}
		if d.dbType == storepb.Engine_STARROCKS {
			var refreshType string
			if err := rows.Scan(&materializedView.Name, &refreshType, &materializedView.Definition); err != nil {
				return nil, err
			}
			if isSyncRollup(refreshType) {
				continue
			}
		} else if err := rows.Scan(&materializedView.Name, &materializedView.Definition); err != nil {
			return nil, err
		}
		key := db.TableKey{Schema: "", Table: materializedView.Name}
		materializedViewMap[key] = materializedView
	}
	if err := rows.Err(); err != nil {
		return nil, util.FormatErrorWithQuery(err, query)
	}
	return materializedViewMap, nil
}

// SyncDBSchema syncs a single database schema.
func (d *Driver) SyncDBSchema(ctx context.Context) (*storepb.DatabaseSchemaMetadata, error) {