Method RenderLinearConnect

core/internal/dialect/sqlite.go:933–1054

(ctx Context, m *qcode.Mutate, qc *qcode.QCode, varName string, renderFilter func())

}

func (d *SQLiteDialect) RenderLinearConnect(ctx Context, m *qcode.Mutate, qc *qcode.QCode, varName string, renderFilter func()) {
	// Step 1: SELECT to capture IDs matching the filter
	ctx.WriteString(`SELECT json_object('id', `)
	renderPKIDExpr(ctx, m)
	ctx.WriteString(`)`)
	
	if m.IsJSON {
		ctx.WriteString(` FROM `)
		d.RenderLinearValues(ctx, m, func() {
			ctx.AddParam(Param{Name: qc.ActionVar, Type: "json"})
		})
		ctx.WriteString(`, `)
	} else {
		ctx.WriteString(` FROM `)
	}
	ctx.Quote(m.Ti.Name)
	
	ctx.WriteString(` WHERE `)
	renderFilter()
	
	ctx.WriteString(" -- @gj_ids=")
	ctx.WriteString(varName)
	ctx.WriteString("\n; ")
	
	// Step 2: Determine relationship direction and perform appropriate UPDATE
	// For recursive self-referential tables (e.g., comments.reply_to_id -> comments.id),
	// we need to update the CONNECTED row's FK to point to the PARENT.
	
	// Check if this is a recursive relationship (same table on both sides)
	isRecursive := m.Rel.Left.Col.Table == m.Rel.Right.Col.Table
	
	// Find the parent mutation this connect depends on
	var parentVar string
	var parentMut *qcode.Mutate
	for id := range m.DependsOn {
		pm := qc.Mutates[id]
		parentVar = d.getVarName(pm)
		parentMut = &pm
		break
	}
	
	if parentVar == "" || parentMut == nil {
		return
	}
	
	if isRecursive {
		// For recursive relationships (e.g., comments -> comments via reply_to_id):
		// The FK column is on the same table. We need to determine which column is the FK.
		// The non-PK column in the relationship is the FK.
		var fkColName string
		if !m.Rel.Left.Col.PrimaryKey {
			fkColName = m.Rel.Left.Col.Name
		} else if !m.Rel.Right.Col.PrimaryKey {
			fkColName = m.Rel.Right.Col.Name
		}
		
		if fkColName != "" {
			// UPDATE the connected (child) row's FK to point to the parent