diff --git a/pom.xml b/pom.xml index 329129ee..0b144b42 100644 --- a/pom.xml +++ b/pom.xml @@ -4,7 +4,7 @@ com.github.shyiko mysql-binlog-connector-java - 0.1.0 + 0.1.2-SNAPSHOT mysql-binlog-connector-java MySQL Binary Log connector diff --git a/readme.md b/readme.md index c9bf1cc0..a302cd37 100644 --- a/readme.md +++ b/readme.md @@ -8,21 +8,31 @@ Initially project was started as a fork of [open-replicator](https://code.google - resumable disconnects - plugable failover strategies - JMX exposure (optionally with statistics) -- availability in Maven Central (deferred until everything is thoroughly tested) +- availability in Maven Central - no third-party dependencies - binlog_checksum support (for MySQL 5.6.2+ users) - test suite over different versions of MySQL releases ## Usage -The latest development version always available through Sonatype Snapshots repository (see example below). +Get the latest JAR(s) from [here](http://search.maven.org/#search%7Cga%7C1%7Cg%3A%22com.github.shyiko%22%20AND%20a%3A%22mysql-binlog-connector-java%22). Alternatively you can include following Maven dependency (available through Maven Central): + +``` + + com.github.shyiko + mysql-binlog-connector-java + 0.1.0 + +``` + +The latest development version always available through Sonatype Snapshots repository (as shown below). ```xml com.github.shyiko mysql-binlog-connector-java - 0.1.0-SNAPSHOT + 0.1.1-SNAPSHOT diff --git a/src/main/java/com/github/shyiko/mysql/binlog/event/deserialization/AbstractRowsEventDataDeserializer.java b/src/main/java/com/github/shyiko/mysql/binlog/event/deserialization/AbstractRowsEventDataDeserializer.java index 5f259950..1f2b1d03 100644 --- a/src/main/java/com/github/shyiko/mysql/binlog/event/deserialization/AbstractRowsEventDataDeserializer.java +++ b/src/main/java/com/github/shyiko/mysql/binlog/event/deserialization/AbstractRowsEventDataDeserializer.java @@ -68,8 +68,8 @@ protected Serializable[] deserializeRow(long tableId, BitSet includedColumns, By TableMapEventData tableMapEvent = tableMapEventByTableId.get(tableId); byte[] types = tableMapEvent.getColumnTypes(); int[] metadata = tableMapEvent.getColumnMetadata(); - BitSet nullColumns = inputStream.readBitSet(types.length, true); Serializable[] result = new Serializable[numberOfBitsSet(includedColumns)]; + BitSet nullColumns = inputStream.readBitSet(result.length, true); for (int i = 0, numberOfSkippedColumns = 0; i < types.length; i++) { int typeCode = types[i] & 0xFF, meta = metadata[i], length = 0; if (typeCode == ColumnType.STRING.getCode() && meta > 256) { diff --git a/supplement/vagrant/mysql-5.5.27-sandbox-prepackaged/vagrantfile b/supplement/vagrant/mysql-5.5.27-sandbox-prepackaged/vagrantfile index 1964f50a..cd55110c 100644 --- a/supplement/vagrant/mysql-5.5.27-sandbox-prepackaged/vagrantfile +++ b/supplement/vagrant/mysql-5.5.27-sandbox-prepackaged/vagrantfile @@ -1,6 +1,6 @@ Vagrant.configure("2") do |config| config.vm.box = 'mysql-5.5.27-sandbox' - config.vm.box_url = 'http://ubuntuone.com/2h49wr0eoPQfJkfnvgoS0s' + config.vm.box_url = 'https://copy.com/sixlvBAee4er' config.vm.network :forwarded_port, guest: 33061, host: 33061 config.vm.network :forwarded_port, guest: 33062, host: 33062 end \ No newline at end of file diff --git a/supplement/vagrant/mysql-5.6.12-sandbox-prepackaged/vagrantfile b/supplement/vagrant/mysql-5.6.12-sandbox-prepackaged/vagrantfile index e7e130ca..6230bb0a 100644 --- a/supplement/vagrant/mysql-5.6.12-sandbox-prepackaged/vagrantfile +++ b/supplement/vagrant/mysql-5.6.12-sandbox-prepackaged/vagrantfile @@ -1,6 +1,6 @@ Vagrant.configure("2") do |config| config.vm.box = 'mysql-5.6.12-sandbox' - config.vm.box_url = 'http://ubuntuone.com/62BEcve12HJELIcZyER9qK' + config.vm.box_url = 'https://copy.com/vEWdkjoceRC2' config.vm.network :forwarded_port, guest: 33061, host: 33061 config.vm.network :forwarded_port, guest: 33062, host: 33062 end \ No newline at end of file