자바 mysql 의 binlog 로그 읽 기

import java.io.File;
import java.io.FileOutputStream;
import java.io.IOException;

import com.github.shyiko.mysql.binlog.BinaryLogFileReader;
import com.github.shyiko.mysql.binlog.event.Event;
import com.github.shyiko.mysql.binlog.event.deserialization.ChecksumType;
import com.github.shyiko.mysql.binlog.event.deserialization.EventDeserializer;

class Sample {
	public static void main(String[] args) throws IOException {
		String filePath = "D:\\mysql-bin.000345";
		File binlogFile = new File(filePath);
		EventDeserializer eventDeserializer = new EventDeserializer();
		eventDeserializer.setChecksumType(ChecksumType.CRC32);
		BinaryLogFileReader reader = new BinaryLogFileReader(binlogFile,
				eventDeserializer);
		try {
			//          
			/*
			 * File f1 = new File("D:\\mysql-bin.000845.sql"); if
			 * (f1.exists()==false){ f1.getParentFile().mkdirs(); }
			 */
			FileOutputStream fos = new FileOutputStream(
					"D:\\mysql-bin.000345.sql", true);
			for (Event event; (event = reader.readEvent()) != null;) {
				System.out.println(event.toString());

				//          
				fos.write(event.toString().getBytes());
			}
			//      
			fos.close();
			System.out.println("    ");
		} finally {
			reader.close();
		}

	}
}

그리고 pom 에 다음 과 같은 의존 적 인 jar 패 키 지 를 설정 합 니 다.

    com.github.shyiko
    mysql-binlog-connector-java
    0.13.0