Linq更新不工作

Question

我试了很多，但都是徒劳的。
我写了一个LINQ代码，但不能在数据库中保存更改。
它没有给出错误，也没有更新记录。

class Program
{
    [Table(Name = "mainframe_replication")]
    public class mainframe_replication
    {
        private string _REPL_GUID;
        [Column(IsPrimaryKey = true, Storage = "_REPL_GUID")]
        public string REPL_GUID
        {
            get { return this._REPL_GUID; }
            set { this._REPL_GUID = value; }
        }
        private string _REPL_TYPE;
        [Column(Storage = "_REPL_TYPE")]
        public string REPL_TYPE
        {
            get { return this._REPL_TYPE; }
            set { this._REPL_TYPE = value; }
        }
        private string _RPT_ID;
        [Column(Storage = "_RPT_ID")]
        public string RPT_ID
        {
            get { return this._RPT_ID; }
            set { this._RPT_ID = value; }
        }
        private string _RPT_VERS;
        [Column(Storage = "_RPT_VERS")]
        public string RPT_VERS
        {
            get { return this._RPT_VERS; }
            set { this._RPT_VERS = value; }
        }
        private string _RPT_BYTES;
        [Column(Storage = "_RPT_BYTES")]
        public string RPT_BYTES
        {
            get { return this._RPT_BYTES; }
            set { this._RPT_BYTES = value; }
        }
        private string _REPL_DTM;
        [Column(Storage = "_REPL_DTM")]
        public string REPL_DTM
        {
            get { return this._REPL_DTM; }
            set { this._REPL_DTM = value; }
        }
        private string _NOTIF_ID;
        [Column(Storage = "_NOTIF_ID")]
        public string NOTIF_ID
        {
            get { return this._NOTIF_ID; }
            set { this._NOTIF_ID = value; }
        }
    }
    public class MyPoco
    {
        public string ReportId { get; set; }
        public string Reportversion { get; set; }
        public string ReportBytes { get; set; }
        public string ReportDate { get; set; }
        public string NotifId { get; set; }
        public string RecipAdd { get; set; }
    }
    public static string loglocation;
    static void Main(string[] args)
    {
        try
        {
            using (DataClasses1DataContext db = new DataClasses1DataContext())
            {
                Table<NOTIF_RECIP> NOTIF_RECIP_alias = db.GetTable<NOTIF_RECIP>();
                Table<NOTIF_SCHED> NOTIF_SCHED_alias = db.GetTable<NOTIF_SCHED>();
                Table<mainframe_replication> mainframe_replication_alias = db.GetTable<mainframe_replication>();
                var ids = NOTIF_SCHED_alias.Select(x => x.NOTIF_RPT_ID).ToArray();
                foreach (string notif_sched_data in ids)
                {
                    var repljoinmf = mainframe_replication_alias
                        .Join(NOTIF_RECIP_alias, mfr => mfr.RPT_ID, nr => nr.NOTIF_RECIP_ID, (mfr, nr)
                            => new MyPoco { ReportId = mfr.RPT_ID, Reportversion = mfr.RPT_VERS, ReportBytes = mfr.RPT_BYTES.ToString(), ReportDate = mfr.REPL_DTM.ToString(), NotifId = mfr.NOTIF_ID, RecipAdd = nr.NOTIF_RECIP_ADDR });
                    foreach (var repljoinmf_data in repljoinmf)
                    {
                        repljoinmf_data.NotifId = "abc";
                        //DO STUFF 
                        //  repljoinmf_data.NotifId = "Changedxyz";
                    }
                    db.SubmitChanges();
                }
            }
        }
        catch (Exception e)
        {
            Console.WriteLine(e.ToString());
        }
    }
}

在提交更改时没有任何错误。
我需要改变什么?
任何建议都会有帮助的。

Answer 1

如果希望将更改保存回原始数据源，则需要使用实际实体而不是那些实体的投影。由于要连接两个表，一种选择是将这些实例放入匿名类型并更新它们:

foreach (string notif_sched_data in ids)
{
    var repljoinmf = mainframe_replication_alias
        .Join(NOTIF_RECIP_alias, 
              mfr => mfr.RPT_ID, 
              nr => nr.NOTIF_RECIP_ID, 
              (mfr, nr) => new {mfr, nr});
    foreach (var repljoinmf_data in repljoinmf)
    {
        //DO STUFF 
        repljoinmf_data.mfr.NotifId = "Changedxyz";
    }
    db.SubmitChanges();

在前面的问题中，您被告知匿名类型不能更新，但是在本例中，您正在修改由匿名类型引用的实例。所以你没有更新匿名类型本身，只是更新匿名类型引用的对象

Answer 2

您正在修改MyPoco对象的属性。这只是表的一个表示。这就是为什么数据库没有更新。

你可以发送你的MyPoco给你的客户端。它将执行一些更改。然后，您可以重新创建实体并从Poco对象复制属性。然后，需要将修改后的实体附加到表上，然后保存更改。

如果您直接修改实体，则不需要附加，因为它将保留到数据库的链接(假设您使用相同的Databasecontext这样做)。