Method handleZeroDelete

delta/controller.go:361–401

(
	ctx *sql.Context,
	conn *stdsql.Conn,
	tx *stdsql.Tx,
	table tableIdentifier,
	appender *DeltaAppender,
	stats *FlushStats,
)

}

func (c *DeltaController) handleZeroDelete(
	ctx *sql.Context,
	conn *stdsql.Conn,
	tx *stdsql.Tx,
	table tableIdentifier,
	appender *DeltaAppender,
	stats *FlushStats,
) error {
	viewName, release, err := c.prepareArrowView(ctx, conn, table, appender, 0, nil)
	if err != nil {
		return err
	}
	defer release()

	condenseDeltaSQL := buildCondenseDeltaSQL(viewName, appender)

	insertSQL := "INSERT OR REPLACE INTO " +
		catalog.ConnectIdentifiersANSI(table.dbName, table.tableName) +
		" SELECT * EXCLUDE (" + AugmentedColumnList + ") FROM (" + condenseDeltaSQL + ")"
	result, err := tx.ExecContext(ctx, insertSQL)
	if err != nil {
		return err
	}

	affected, err := result.RowsAffected()
	if err != nil {
		return err
	}
	stats.Insertions += affected
	stats.DeltaSize += affected

	if log := ctx.GetLogger(); log.Logger.IsLevelEnabled(logrus.DebugLevel) {
		log.WithFields(logrus.Fields{
			"db":    table.dbName,
			"table": table.tableName,
			"rows":  affected,
		}).Debug("Upserted")
	}

	return nil
}

// Materialize the condensed delta view as a temporary table.
func (c *DeltaController) materializeCondensedDelta(