Subsonic 3保存到不同的数据库中

Question

使用亚音速3，我有一个有点奇怪的场景的项目。我有一个.net windows服务，它需要连接到一个主数据库，该数据库存储与其他数据库服务器的连接，还需要一组用于处理自动短信的表。然后，我在其他服务器上有相同的数据库（其他数据库上的连接字符串表为空），这些数据库处理其他应用程序的消息。

因此，亚音速可以使用连接字符串/提供者名称选项调用所有数据库。

        public static List<SMSRequestWithResponseList> SMSRequestListGetAll(string applicationName)
    {
        string connStr = GetConnectionStringByApplicationName(applicationName);
        List<SMSRequestWithResponseList> response = new List<SMSRequestWithResponseList>();
        List<DAL.CDYNESMSRequest> lst = DAL.CDYNESMSRequest.All(connStr, providerName).ToList();
        foreach (DAL.CDYNESMSRequest mitm in lst)
        {
            SMSRequestWithResponseList itm = new SMSRequestWithResponseList(mitm, mitm.CDYNESMSResponses.ToList(), string.Empty);
            response.Add(itm);
        }
        return response;
    }

问题是保存。。。插入似乎正在工作。

DAL.CDYNESMSRequest itm = new DAL.CDYNESMSRequest(connStr, providerName).;
            itm.KeyCode = KeyCode;
            itm.ApplicationName = ApplicationName;
            itm.BatchTransaction = BatchTransaction;
            itm.AssignedDID = GetParameter("AssignedDID");
            itm.PhoneNumber = PhoneNumber;
            itm.MessageDetail = MessageText;
            itm.MessageCancelled = false;
            itm.MessageQueued = false;
            itm.MessageSent = false;
            itm.IsImmediate = SendImmediate;
            itm.InQueue = false;
            itm.ScheduledDateTime = ScheduledDateTime;
            itm.CreateDT = dt;
            itm.ModifiedDT = dt;
            itm.Save();

但它似乎不想更新。。。

                DAL.CDYNESMSRequest itm = DAL.CDYNESMSRequest.SingleOrDefault(x => x.RequestID == requestID, connStr, providerName);
            if (itm != null)
            {
                itm.MessageID = messageGUID;
                itm.MessageCancelled = messageCancelled;
                itm.MessageQueued = messageQueued;
                itm.ReferenceID = messageReferenceID;
                itm.MessageSent = messageSent;
                if (messageSentDT < new DateTime(1753, 1, 1, 0, 0, 0))
                    itm.MessageSentDT = null;
                else
                    itm.MessageSentDT = messageSentDT;
                itm.MessageSMSError = messageSMSError;
                itm.ModifiedDT = dt;
                itm.Save();
            }

我使用正确数据库中的连接字符串进行调用，但它不会更新记录。如果我保存错误，请告诉我。我确实尝试创建一个新的提供程序并将其设置为保存，但它对我咆哮，说它已经打开了连接。谢谢

Answer 1

不要使用ActiveRecord模式，而是使用SimpleRepository，它允许您设置多个repo，并且您可以为每个repo指定一个连接字符串。

// not sure if this is the right constructor or if it's providerName, connectionString
var repo1 = new SimpleRepository(connectionString1, providerName);
var repo2 = new SimpleRepository(connectionString2, providerName);
var item = repo1.Single<Product>(1);
if (repo2.Exists<Product>(x => x.Id == item.Id))
    repo2.Update(item);
else
    repo2.Add(item);