Author: gdusbabek Date: Wed Mar 30 14:30:48 2011 New Revision: 1086966 URL: http://svn.apache.org/viewvc?rev=1086966&view=rev Log: compress utf8 bytes and not platform bytes.
Modified: cassandra/trunk/drivers/java/src/org/apache/cassandra/cql/jdbc/Utils.java Modified: cassandra/trunk/drivers/java/src/org/apache/cassandra/cql/jdbc/Utils.java URL: http://svn.apache.org/viewvc/cassandra/trunk/drivers/java/src/org/apache/cassandra/cql/jdbc/Utils.java?rev=1086966&r1=1086965&r2=1086966&view=diff ============================================================================== --- cassandra/trunk/drivers/java/src/org/apache/cassandra/cql/jdbc/Utils.java (original) +++ cassandra/trunk/drivers/java/src/org/apache/cassandra/cql/jdbc/Utils.java Wed Mar 30 14:30:48 2011 @@ -28,6 +28,7 @@ import java.sql.Types; import java.util.UUID; import java.util.zip.Deflater; +import com.google.common.base.Charsets; import org.apache.cassandra.db.marshal.AbstractType; import org.apache.cassandra.db.marshal.BytesType; import org.apache.cassandra.db.marshal.IntegerType; @@ -42,7 +43,7 @@ class Utils public static ByteBuffer compressQuery(String queryStr, Compression compression) { - byte[] data = queryStr.getBytes(); + byte[] data = queryStr.getBytes(Charsets.UTF_8); Deflater compressor = new Deflater(); compressor.setInput(data); compressor.finish();