svn commit: r1086966 - /cassandra/trunk/drivers/java/src/org/apache/cassandra/cql/jdbc/Utils.java

[gdusbabek]

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();