Clr编写Insert Triggr

public static void tri_RetrieveJustInsertedData()
    {  
        SqlCommand command;
        SqlTriggerContext triggContext = SqlContext.TriggerContext;
        SqlPipe pipe = SqlContext.Pipe;
        SqlDataReader sdr;

        switch (triggContext.TriggerAction)
        {
            case TriggerAction.Insert:
                using (SqlConnection connection = new SqlConnection(@"context connection=true"))
                {
                    connection.Open();
                    command = new SqlCommand(@"SELECT [Fruit_nbr],[FruitKind_nbr],[FruitName] FROM INSERTED;",
                       connection);
                    sdr = command.ExecuteReader(CommandBehavior.SingleRow);
                    while (sdr.Read())
                    {
                        string result = (byte)sdr["Fruit_nbr"] + " " + (byte)sdr["FruitKind_nbr"] + " " + (string)sdr["FruitName"];
                         pipe.Send(result);
                    }                   
                }
                break;
        }
    }