.net站内搜索hubble.net使用详解之同步流程
2021-12-01Append only 模式
Append only 模式下，自动同步设置非常简单，只需要在Table Info 中将 TableSynchronization 设置为ture。就可以了。
同步流程
如上图所示，用户在执行Hubble.SqlClient 提供的类TableSynchronization 的Synchronize方法后，会先判断目前是否正在同步，如果正在同步，将返回False，用户可以在等待本次同步完成后，再执行这个方法触发同步。触发同步成功后，HubbleDotNet 的Server 端将扫描数据库中未建立索引的新增记录，对这些记录进行索引，索引完成后，按照用户指定的优化方案对索引进行优化。
HubbleDotNet 的查询分析器(QueryAnalyzer) 提供了同步数据调用的界面，这个也作为同步数据的示例代码供使用者参考。
下面给出一个简单的例子，表结构如下：
同步设置如下：
执行同步操作
点 Start 开始同步
参数说明：
Step: 表示同步时每次从数据库读取多少条记录。假如设置为5000，待同步的记录为12000条，则开始同步后，Server 端会进行3次批量索引，前两次每次批量索引5000条，最后一次2000条。批量索引完所有待同步的记录后开始优化。如果搞不清这个地方是干什么的，请保持这个数值不变，5000是我测试过的一个比较理想的数值。
Optimize option：指明优化策略。默认按最小方式优化。如果索引文件较大，按最小方式优化会比较耗时，可以选择按这种方式优化，即 Middle 方式。
点 Start 后，同步操作就开始执行，你可以点 Stop 去停止同步。
同步完成
Updatable 模式
Updatable 模式即原来的 Append, update, delete 模式。这种模式由于存在删除和更改操作，同步工作会比较复杂一些。我们需要建立一个辅助表来实现
下面以具体例子来说明：
要索引的表结构
创建辅助触发表 (TriggerTable)
create table HBTrigger_EnglishNews
(
Serial bigint identity(1,1) not null primary key,
Id int not null,
Opr char(16),
Fields nvarchar(4000) null,
)
go
create index ITriggerOprSerial on HBTrigger_EnglishNews(Opr, Serial)
表结构如上所述，辅助触发表必须遵照这个表结构创建，表名可以随便设置。
Id 字段对于索引表中Docid Field 这个字段，这里对于索引表中的Id 字段。如果索引表中DocId Field 字段是 bigint ，这里需要指定为bigin。
Opr 字段告诉hubbledotnet 改动是更新，还是删除。
Fields 字段只有更新(Update)时有效，告诉hubbledotnet 更新操作修改了哪几个字段。
如果你的数据库不是SQL SERVER ，请按照这个表结构创建对应数据库的辅助触发表。
注意：辅助触发表必须和主表在同一个数据库中。 由于要用到对Opr 和 Serial 同时查询，所以建议按上述SQL建一个复合索引。
设置 TableInfo
按下图所示设置 TableSynchronization 设置为ture 并指定辅助触发表的表名。
创建一个更新触发器
如果你的现有表有更新操作，你就必须创建更新触发器，数据更新时，更新触发器会把哪些Id，哪些字段更新的信息写入到辅助触发表中。
凡是Tokenized 和 Untokenized 类型的字段都需要在更新触发器中设置，更新触发器的示例代码如下：
Create Trigger HBTrigger_EnglishNews_Update On EnglishNews
for Update
As
DECLARE @updateFields nvarchar(4000) set @updateFields = ''
if Update(GroupId)
begin
set @updateFields = @updateFields + 'GroupId,'
end
if Update(SiteId)
begin
set @updateFields = @updateFields + 'SiteId,'
end
if Update(Time)
begin
set @updateFields = @updateFields + 'Time,'
end
if Update(Title)
begin
set @updateFields = @updateFields + 'Title,'
end
if Update(Content)
begin
set @updateFields = @updateFields + 'Content,'
end
if @updateFields <> ''
begin
insert into HBTrigger_EnglishNews select id, 'Update', @updateFields from Inserted end
其中EnglishNews 是主表的表名，HBTrigger_EnglishNews 是辅助触发表的表名。
GroupId， SiteId 等等是主表中 untokenized 和 tokenized 字段，这个触发器的工作就是记录表更新时哪些字段发生了变化。
在对具体表实现这个触发器时不可以照搬这个代码，需要根据具体表的索引字段对Time,Title, Content 等等这些地方进行修改。
同样如果数据库不是 SQL SERVER ，请按照对应数据库的触发器语法建立触发器。
创建一个删除触发器
如果你的现有表有删除操作，你就必须创建删除触发器，数据被删除时，删除触发器会把哪些被删除的Id信息写入到辅助触发表中。
Create Trigger HBTrigger_EnglishNews_Delete
On EnglishNews
for Delete
As
insert into HBTrigger_EnglishNews select id, 'Delete', '' from Deleted
增量的同步
对于增量(Insert)数据的同步，Updatable 和 Append only 的方式类似，不需要通过触发器来实现，所以如果你的表频繁增量，你完全没有比较担心触发器对数据插入性能的影响，因为增量时不会触发任何触发器。
执行同步操作
点 Start 开始同步
参数说明：
Step: 表示同步时每次从数据库读取多少条记录。假如设置为5000，待同步的记录为12000条，则开始同步后，Server 端会进行3次批量索引，前两次每次批量索引5000条，最后一次2000条。批量索引完所有待同步的记录后开始优化。如果搞不清这个地方是干什么的，请保持这个数值不变，5000是我测试过的一个比较理想的数值。
Optimize option：指明优化策略。默认按最小方式优化。如果索引文件较大，按最小方式优化会比较耗时，可以选择按这种方式优化，即 Middle 方式。
点 Start 后，同步操作就开始执行，你可以点 Stop 去停止同步。
同步完成
同步流程
触发器对性能的影响
触发器只对更改和删除操作的性能造成影响，由于触发器只记录更改或删除的ID号和更改字段，而不记录更改的实际内容，所以即使有影响，这个影响也是有限的。如果某些应用中，使用者觉得这种影响无法接受，那么只能参照这篇文章通过程序和现有表或视图同步 通过程序手动同步数据了。
通过后台任务自动定时同步
你可以有两种方式来触发同步，一种是通过 HubbleDotNet 的后台任务自动来实现定时同步，见下面文章
你也可以通过自己写程序来触发同步操作，下面是程序调用方法
程序调用
可参考 QueryAnalyzer 下的 FormTableSynchronization.cs
引用 Hubble.SQLClient
TableSynchronization 的实例化
TableSynchronization _TableSync;
TableSynchronization.OptimizeOption option = TableSynchronization.OptimizeOption.Minimum;
int step = (int)numericUpDownStep.Value;
HubbleConnection conn = new HubbleConnection(connectString);
conn.Open();
_TableSync = new TableSynchronization(DataAccess.Conn, TableName, step, option);
触发同步：
_TableSync.Synchronize();
这个函数返回True ，表示触发同步成功。
获取同步进度：
double progress = _TableSync.GetProgress();
这个函数会返回同步进度的百分比，如果返回 100， 表示同步完成。
停止同步
_TableSync.Stop();
如果当前表正在同步，这些这个函数，同步操作将被终止。
