Method handleDeleteOnly

delta/controller.go:317–359

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

}

func (c *DeltaController) handleDeleteOnly(
	ctx *sql.Context,
	conn *stdsql.Conn,
	tx *stdsql.Tx,
	table tableIdentifier,
	appender *DeltaAppender,
	stats *FlushStats,
) error {
	// Ignore all but the primary key fields
	viewName, release, err := c.prepareArrowView(ctx, conn, table, appender, 0, getPrimaryKeyIndices(appender))
	if err != nil {
		return err
	}
	defer release()

	qualifiedTableName := catalog.ConnectIdentifiersANSI(table.dbName, table.tableName)
	pk := getPrimaryKeyStruct(appender.BaseSchema())

	// Perform direct DELETE without deduplication
	deleteSQL := "DELETE FROM " + qualifiedTableName +
		" WHERE " + pk + " IN (SELECT " + pk + " FROM " + viewName + ")"
	result, err := tx.ExecContext(ctx, deleteSQL)
	if err != nil {
		return err
	}

	affected, err := result.RowsAffected()
	if err != nil {
		return err
	}
	stats.Deletions += 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("Deleted")
	}

	return nil
}

func (c *DeltaController) handleZeroDelete(
	ctx *sql.Context,