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对象使用的外部资源立即被释放。当一个对象不需要时,应该尽早地释放他们。