时间戳:解析MobiLink实现基于时间戳的分区同步来源: 发布时间:星期四, 2009年1月1日 浏览:65次 评论:0
="t18">
 建库及数据源
1.建立数据库
在cmd下执行,中心数据库consol
D:\mobilink>dbinit consol
两个远程数据库zhou1 zhou2
D:\mobilink>dbinit zhou1D:\mobilink>dbinit zhou2 2.启动服务 在命令行下敲dbsrv9  在弹出 对话框中选择数据库文件并敲入相应服务名, 按照这种方式启动consol zhou1 zhou2 服务
3.建立odbc数据源
consol zhou1 zhou2
2 处理中心数据库
1.dbisql 连接到consol数据库
执行以下语句:
-- 建表owner列作为分区用 active 用作逻辑删除 last_mod ied 用作时间戳同步只在中心数据库需要这 3列远程数据库不需要
create table employee(id  NOT NULL PRIMARY KEY, name varchar(128), owner varchar(128), active default 1, last_modied timestamp DEFAULT timestamp) -- 录入数据 insert o employee(id, name, owner, active ) values (1, '小桥', 'zhou1', 1) insert o employee(id, name, owner, active ) values (2, '流水', 'zhou2', 1) insert o employee(id, name, owner, active ) values (3, '人家', 'zhou1', 1) commit go -- 加入脚本版本及脚本 call ml_add_table_script( 'version1', 'employee', 'upload_insert', 'insert o employee(id, name) values (?,?)' ) go call ml_add_table_script( 'version1', 'employee', 'upload_update', 'update employee  name=? where id = ?' )go call ml_add_table_script( 'version1', 'employee', 'upload_delete', 'delete from employee where id = ?' ) go call ml_add_table_script( 'version1', 'employee', 'download_cursor','select id, name from employee where last_mod ied > ? and owner = ? and active = 1' ) go call ml_add_table_script( 'version1', 'employee', 'download_delete_cursor', 'select id from employee where last_mod ied>? and (owner !=? or active = 0)' ) go -- 注重go 前面不要有空格 为了保持格式这里是有空格执行时要注重
2.注册两个同步用户zhou1
zhou2密码分别是zhou1 zhou2 在cmd下执行
dbmluser -c "dsn=consol" -u zhou1 -p zhou1dbmluser -c "dsn=consol" -u zhou2 -p zhou2 3 处理远程数据库zhou1 用dbisql 连接到zhou1 执行以下语句:
-- 建表create table employee(id NOT NULL PRIMARY KEY,name varchar(128)) insert o employee(id, name ) values (1, '小桥')insert o employee(id, name ) values (3, '流水')commit go -- 建立发布 CREATE PUBLICATION pub_employee ( TABLE employee ) go -- 建立同步用户 CREATE SYNCHRONIZATION USER zhou1 go -- 为zhou1用户建立预定 CREATE SYNCHRONIZATION SUBSCRIPTION TO pub_employee FOR zhou1 TYPE 'tcpip' ADDRESS 'host=localhost' OPTION sv='version1'; go 4、处理远程数据库zhou2 用dbisql 连接到zhou2 执行以下语句:
create table employee(id NOT NULL PRIMARY KEY, name varchar(128))insert o employee(id, name) values (2, '孙红')commit -- 建立发布 CREATE PUBLICATION pub_employee ( TABLE employee ) -- 建立同步用户 CREATE SYNCHRONIZATION USER zhou2 -- 为zhou2用户建立预定 CREATE SYNCHRONIZATION SUBSCRIPTION TO pub_employee FOR zhou2 TYPE 'tcpip' ADDRESS 'host=localhost' OPTION sv='version1'; 5 插入并删除 做些数据,向consol数据库分别插入zhou1 zhou2 数据并删除各删除条
insert o employee(id, name, owner, active ) values (4, 'zhou1新增', 'zhou1', 1) insert o employee(id, name, owner, active ) values (5, 'zhou2新增', 'zhou2', 1) update employee active = 0 where id = 1update employee active = 0 where id = 2commit 6、启动同步服务器 dbmlsrv9 -c "dsn=consol" -o mlserver.mls -v+ -dl 7 启动客户端 dbmlsync -c "dsn=zhou1" -o dbmlsync1.out -v -u zhou1 -mp zhou1 dbmlsync -c "dsn=zhou2" -o dbmlsync2.out -v -u zhou2 -mp zhou2 8 结果 zhou1数据库 id,name 3,'人家' 4,'zhou1新增' zhou2数据库 id,name 5,'zhou2新增' 可以看到 新增zhou1数据只同步到zhou1数据库新增zhou2数据只同步到zhou2数据库,实现了分区
通过限制last_modied实现了时间戳同步有爱好可以试试在zhou1 zhou2修改数据同步到中心数据库
0
相关文章
读者评论
发表评论 |
 |
专注于互联网--专注于架构 |
最新标签 网站地图 文章索引 Rss订阅 |
