如何使用Microsoft Sync Framework与过滤器数据同步

debugcn 发表于 Dev

用户3863513

我正在使用SQL Server 2008的Microsoft Sync Framework进行唤醒，下面的C＃是我的代码

public static void SetUp(string _pScopeName, DbSyncTableDescription _pDbSyncTable, SqlConnection serverConn, SqlConnection clientConn)
        {
            // Create a scope named "_ITEM" and add tables to it.
            DbSyncScopeDescription productScope = new DbSyncScopeDescription(_pScopeName);

            // Define the Products table.
            // Add the Table to the scope object.    
            productScope.Tables.Add(_pDbSyncTable);
            // Create a provisioning object for "_ITEM" and apply it to the on-premise database if one does not exist.
            SqlSyncScopeProvisioning serverProvision = new SqlSyncScopeProvisioning(serverConn, productScope);
            serverProvision.ObjectSchema = ".dbo";
            string _tblName = _pDbSyncTable.LocalName.Replace("[", "").Replace("]", "");
            serverProvision.SetCreateTableDefault(DbSyncCreationOption.Skip);
            serverProvision.Tables[_tblName].AddFilterColumn("_WORKGROUPNAME");
            serverProvision.Tables[_pDbSyncTable.LocalName].FilterClause = "[" + _tblName + "].[_WORKGROUPNAME] = " + _CCompanyVar._WORKGROUPNAME;
            //Skip create Sync Framework objects because we have already created them on the previous step
                serverProvision.SetCreateTableDefault(DbSyncCreationOption.Skip);

                //Create new select changes procedure for our scope
serverProvision.SetCreateProceduresForAdditionalScopeDefault(DbSyncCreationOption.Create);
                if (_CPubVar._Stop_bool)
                {
                    return;
                }
            if (!serverProvision.ScopeExists(_pScopeName))
                serverProvision.Apply();

            // Provision the SQL client database from the on-premise SQL Server database if one does not exist.
            SqlSyncScopeProvisioning clientProvision = new SqlSyncScopeProvisioning(clientConn, productScope);

            if (_CPubVar._Stop_bool)
            {
                return;
            }
            if (!clientProvision.ScopeExists(_pScopeName))
                clientProvision.Apply();    
        }

我收到错误消息：

The multi-part identifier "_ATTENDANCESTATUS._WORKGROUPNAME" could not be bound.
Invalid column name 'FPR'.

在第：行

serverProvision.Apply();

如果我删除以下行，则我的同步过程无需过滤器即可正常运行

string _tblName = _pDbSyncTable.LocalName.Replace("[", "").Replace("]", "");
            serverProvision.SetCreateTableDefault(DbSyncCreationOption.Skip);
            serverProvision.Tables[_tblName].AddFilterColumn("_WORKGROUPNAME");
            serverProvision.Tables[_pDbSyncTable.LocalName].FilterClause = "[" + _tblName + "].[_WORKGROUPNAME] = " + _CCompanyVar._WORKGROUPNAME;
            //Skip create Sync Framework objects because we have already created them on the previous step
            serverProvision.SetCreateTableDefault(DbSyncCreationOption.Skip);
            //Create new select changes procedure for our scope
            serverProvision.SetCreateProceduresForAdditionalScopeDefault(DbSyncCreationOption.Create);

_WORKGROUPNAME是我所有表中的一个公用字段，我想过滤_WORKGROUPNAME我在_CCompanyVar._WORKGROUPNAME（字符串变量）中传递值的数据...

我错了，请指出...

伊姆兰·阿里·汗（Imran Ali Khan）

用这个 ...

public static void SetUp(string _pScopeName, DbSyncTableDescription _pDbSyncTable, SqlConnection serverConn, SqlConnection clientConn)
        {
            // Create a scope named "_ITEM" and add tables to it.
            DbSyncScopeDescription productScope = new DbSyncScopeDescription(_pScopeName);

            // Define the Products table.
            // Add the Table to the scope object.    
            Collection<string> includeColumns = new Collection<string>();
            for (int i = 0; i < _pDbSyncTable.Columns.Count; i++)
            {
                includeColumns.Add(_pDbSyncTable.Columns[i].UnquotedName);
            }
            DbSyncTableDescription productDescription = SqlSyncDescriptionBuilder.GetDescriptionForTable(_pScopeName, includeColumns, serverConn);
            productScope.Tables.Add(productDescription);

            // Create a provisioning object for "_ITEM" and apply it to the on-premise database if one does not exist.
            SqlSyncScopeProvisioning serverProvision = new SqlSyncScopeProvisioning(serverConn, productScope);
            serverProvision.ObjectSchema = ".dbo";                
            // Filter Rows for the ListPrice column
            serverProvision.Tables[ _pDbSyncTable.LocalName].AddFilterColumn("_WORKGROUPNAME");
            serverProvision.Tables[ _pDbSyncTable.LocalName].FilterClause = "[side].[_WORKGROUPNAME] = '" + _CCompanyVar._WORKGROUPNAME + "'";

            if (_CPubVar._Stop_bool)
            {
                return;
            }
            if (!serverProvision.ScopeExists(_pScopeName))
                serverProvision.Apply();

            // Provision the SQL client database from the on-premise SQL Server database if one does not exist.
            SqlSyncScopeProvisioning clientProvision = new SqlSyncScopeProvisioning(clientConn, productScope);

            if (_CPubVar._Stop_bool)
            {
                return;
            }
            if (!clientProvision.ScopeExists(_pScopeName))
                clientProvision.Apply();

        }

本文收集自互联网，转载请注明来源。

如有侵权，请联系[email protected] 删除。