2013-02-22 76 views
4

当我使用卡桑德拉-jdbc我得到错误java.sql.SQLSyntaxErrorException惰性数据转换成表:无法解析“ANI”作为十六进制字节插入错误

连在localhost来测试集群:9160。 [cqlsh 2.3.0 | Cassandra 1.2.0 | CQL规范3.0.0 |节俭协议19.35.0] 使用CQL3创建表

cqlsh:testkeyspace> create columnfamily login(
       ... key varchar primary key, 
       ... name varchar, 
       ... password varchar); 


package com.bsmart; 

import java.sql.Connection; 
import java.sql.DriverManager; 
import java.sql.PreparedStatement; 
import java.sql.ResultSet; 

public class InsertCass { 

     public static void main(String[] args) { 
      try 
      { 
       Class.forName("org.apache.cassandra.cql.jdbc.CassandraDriver"); 
       Connection con =DriverManager.getConnection("jdbc:cassandra://localhost:9160/testkeyspace"); 

       String qry = "INSERT INTO login (KEY, name, password) VALUES ('t', 'ani','agrawal');"; 
       PreparedStatement smt = con.prepareStatement(qry); 
       smt.execute(); 
       // int i=smt.executeUpdate(); 

       System.out.println("records inserted>>>>"); 



      } 
      catch(Exception e) 
      { 
       System.out.println(" error: "+e.getMessage()); 
       e.printStackTrace(); 
      } 

    } 

但ERROR-

log4j:WARN No appenders could be found for logger (org.apache.cassandra.cql.jdbc.CassandraDriver). 
log4j:WARN Please initialize the log4j system properly. 
log4j:WARN See http://logging.apache.org/log4j/1.2/faq.html#noconfig for more info. 
java.sql.SQLSyntaxErrorException: cannot parse 'ani' as hex bytes 
    at org.apache.cassandra.cql.jdbc.CassandraPreparedStatement.doExecute(CassandraPreparedStatement.java:155) 
    at org.apache.cassandra.cql.jdbc.CassandraPreparedStatement.execute(CassandraPreparedStatement.java:191) 
    at com.bsmart.InsertCass.main(InsertCass.java:18) 
error: cannot parse 'ani' as hex bytes 

请帮助我。 谢谢

+0

适当的版本不知道......似乎问题用U用来创建表的DDL语句。你必须正确指定验证类和所有.. – 2013-02-22 12:03:15

回答

1

您需要创建name列为textvarchar。您收到的错误表明它创建为blob

+0

我创建名称列为varchar。但错误没有解决。 cqlsh:testkeyspace>创建columnfamily登录( ... key varchar主键, ... name varchar, ... password varchar); – Rani 2013-02-25 05:35:32

0

自己有这个问题,但在我的情况下,它是从double类型。

在蟒蛇的情况下,确保指定定制列表

cql.connect(cluster_address, port, keyspace, cql_version='3.1.1')