ImportBinlogHandler导入BinLog日志¶
创建ImportBinlogHandler¶
建立了到备机数据库的连接之后,就可以使用该连接发送BINLOG IMPORT语句。ImportBinlogHandler对象可以通过如下方式来创建:
Connection conn = DriverManager.getConnection(url,username,password);
ImportBinlogHandler importBinlogHandler = new OscarImportBinlogHandler(
(BaseConnection) conn, fileName, 0);
上面的创建方式,需要三个参数:与备机数据库的连接;BinLog日志文件;BinLog日志在文件的当前位移。
使用ImportBinlogHandler导入BinLog日志¶
ImportBinlogHandler对象导入BinLog日志的用法较简单,执行如下语句即可:
importBinlogHandler.execute();
execute()方法中,包含了驱动与数据库后台关于导入BinLog日志的网络通讯协议。执行完该操作后,BinLog日志文件fileName中的内容,即被导入到备机数据库中,从而完成了与主机数据库进行数据同步的过程。
关闭ImportBinlogHandler对象¶
尽管当Connection关闭时,会将由它创建的ImportBinlogHandler对象关闭,但是作为一种好的编程风格,对于不再使用的ImportBinlogHandler对象应显式地关闭它们,这可以使ImportBinlogHandler对象使用的外部资源立即被释放。当一个对象不需要时,应该尽早地释放他们。