Method inferSQLRefs

runtime/parser/parse_model.go:320–364

inferSQLRefs attempts to infer table references from the node's SQL. The provided node must have a non-empty SQL field.

(node *Node)

// inferSQLRefs attempts to infer table references from the node's SQL.
// The provided node must have a non-empty SQL field.
func (p *Parser) inferSQLRefs(node *Node) ([]ResourceName, error) {
	// Currently only supports DuckDB.
	driver, _, _ := p.driverForConnector(node.Connector)
	if driver != "duckdb" {
		return nil, nil
	}

	// Skip if the SQL is templated (because the DuckDB parser may choke on the template handlebars)
	if node.SQLUsesTemplating {
		return nil, nil
	}

	// Parse the SQL
	ast, err := duckdbsql.Parse(node.SQL)
	if err != nil {
		path := node.SQLPath
		if path == "" {
			path = node.YAMLPath
		}

		var posError duckdbsql.PositionError
		if errors.As(err, &posError) {
			return nil, pathError{
				path: path,
				err: locationError{
					err: posError.Err(),
					location: &runtimev1.CharLocation{
						Line: uint32(findLineNumber(node.SQL, posError.Position)),
					},
				},
			}
		}
		return nil, pathError{path: path, err: newDuckDBError(err)}
	}

	// Scan SQL for table references, tracking references in refs
	var refs []ResourceName
	for _, t := range ast.GetTableRefs() {
		if !t.LocalAlias && t.Name != "" && t.Function == "" && len(t.Paths) == 0 {
			refs = append(refs, ResourceName{Name: t.Name})
		}
	}

	return refs, nil
}

func (p *Parser) trackResourceNamesForDataPaths(ctx context.Context, name ResourceName, inputProps map[string]any) error {
	c, ok := inputProps["invalidate_on_change"].(bool)