数据库

本类阅读TOP10

·SQL语句导入导出大全
·SQL Server日期计算
·SQL语句导入导出大全
·SQL to Excel 的应用
·Oracle中password file的作用及说明
·MS SQLServer OLEDB分布式事务无法启动的一般解决方案
·sqlserver2000数据库置疑的解决方法
·一个比较实用的大数据量分页存储过程
·如何在正运行 SQL Server 7.0 的服务器之间传输登录和密码
·SQL中两台服务器间使用连接服务器

分类导航
VC语言Delphi
VB语言ASP
PerlJava
Script数据库
其他语言游戏开发
文件格式网站制作
软件工程.NET开发
解决两相同数据库数据同步的问题

作者:未知 来源:月光软件站 加入时间:2005-2-28 月光软件站

为用户组建一套SQL Server应用系统时,用户经常提到这样的要求:
 
  如果其中一台服务器坏了,怎样才能防止数据丢失,并在最短的时间内恢复系统?

要解决这个问题,肯定需要两台服务器,并在两台服务器上装有相同的数据库,保持两台服务器中的数据同步,当主服务器坏了时,将另外一台服务器更改一下计算机名称,从而使得工作站可以继续运行.

那么如何保持两台数据库中的数据同步呢? SQL Server提供了出版-定阅机制,可以将数据实时的拷贝到定阅服务器中. 但在实际应用中,发现一旦建立起了出版-定阅关系,在定阅服务器数据库中的触发器,主键等东西都不见了!!! 当主服务器不能正常工作时,要想让另一台服务器转变为主服务器,除更改计算机名外,还需建立触发器,索引等,过程比较烦琐.特别当用户对数据库维护不熟悉时,这种操作更加麻烦.

Sql Server做为一种数据库管理系统,它与客户的接口都是通过SQL语句进行的, 用户在插入一条记录时,SQL Server会接收到Insert语句;更改一条记录时,会接收到 Update命令...
那么如果我们能在SQL Server中跟踪到所有发给SQL Server的SQL语句,那么我们就可以知道数据库发生了哪些改变,并可以将这种改变发给另外一到服务器,从而实现数据实时同步的功能.

值得高兴的是,SQL Server 提供了跟踪功能 ,它们是以 xp_trace_XXXXXX的一系列存储过程,
你可以设置过滤条件,从而只跟踪影响你的数据库 变化的SQL 语句,将这些SQL 语句存放在本地表中,再从本地表中读出,发送给另外一台服务器 ,从而实现数据同步功能. 这种方法可以跟踪任何类型的变化,包括Image类型数据的改变.

以下面是用BCB5.0语句实现建立跟踪过程:
bool TForm1 :: BuildTrace(int DBID,
                        AnsiString AppFilter,
                        AnsiString SQLFilter,
                        AnsiString DstTable,
                        int &TraceHandle)
{
    char tempBuf[512];

    Query1 -> Close();
    Query1 -> SQL -> Clear();
    TStrings *pSQL = Query1 -> SQL;


    pSQL -> Add("USE master");
    pSQL -> Add("DECLARE @queue_handle int");
    pSQL -> Add("DECLARE @column_value int");
    pSQL -> Add("SET @column_value = 67108864|1|512|1024|10384");
    pSQL -> Add("EXEC  xp_trace_addnewqueue 1000,5,95,90,@column_value,@queue_handle OUTPUT");
    pSQL -> Add("EXEC xp_trace_seteventclassrequired @queue_handle, 41,1 ");
  
    wsprintf(tempBuf,"EXEC xp_trace_setappfilter @queue_handle,'%s',NULL", AppFilter.c_str());
    pSQL -> Add(AnsiString(tempBuf));

    wsprintf(tempBuf,"EXEC xp_trace_setdbidfilter @queue_handle,%d",DBID);
    pSQL -> Add( AnsiString(tempBuf));

    wsprintf( tempBuf,"Exec xp_trace_settextfilter @queue_handle,'%s',NULL", SQLFilter.c_str());
    pSQL -> Add(AnsiString(tempBuf));

 

   

    wsprintf( tempBuf,
              "EXEC xp_trace_setqueuedestination @queue_handle,4,1,NULL,'%s'",
              DstTable.c_str()
            );
    pSQL -> Add( AnsiString(tempBuf));

    pSQL -> Add("EXEC xp_trace_startconsumer @queue_handle");
    pSQL -> Add("SELECT @queue_handle QueueHandle");

    try
    {
        Query1 -> Open();
    }
    catch(...)
    {
        return false;
    }
    TraceHandle = Query1 -> FieldByName("QueueHandle") -> AsInteger;
    return true;
}


 




相关文章

相关软件