【发布时间】:2017-01-25 03:23:19
【问题描述】:
我们正在使用 MyBatis-Spring 来管理 DBMS 事务 (Cassandra)。在 Cassandra 中,我们定义了一个带有映射列的表,该列用作分区键(我们的键必须是复杂类型,因此不能更改它)。
CREATE TABLE mykeyspace.mytable ( name text, level frozen<map<text,text>>, effective_ts timestamp ... PRIMARY KEY ((name, level), effective_ts))
如果我在 csqlsh 中对 Cassandra 执行如下查询,我会返回一个结果(即预期的正确结果集)。
SELECT * FROM mykeyspace.mytable where name = 'somename' and level = {'mykey','myvalue'} ;
但是,当通过 MyBatis 执行此操作时,我没有返回任何结果。该查询没有抛出任何异常,并且我可以清楚地看到来自 MyBatis 框架的日志中的查询与我在 cqlsh 提示符中使用的匹配。
01/11/2017 14:35:24:644 [DEBUG] getSetForName - ==> Preparing: SELECT * FROM mykeyspace.mytable WHERE NAME = 'somename' AND LEVEL = {'mykey':'myvalue'}
01/11/2017 14:35:24:777 [DEBUG] getValueSetForParameterSet - ==> Parameters:
01/11/2017 14:35:24:890 [DEBUG] getValueSetForParameterSet - <== Total: 0
01/11/2017 14:35:24:890 [DEBUG] SqlSessionUtils - Closing non transactional SqlSession [org.apache.ibatis.session.defaults.DefaultSqlSession@22b1651]
另一个注意事项我尝试使用 DataStax 驱动程序核心(即在没有 MyBatis 的情况下执行查询)并获得了预期的结果集。因此,我的问题必须与MyBatis有关,但我已经用尽了所有想法。有什么想法或建议吗?
供参考...映射器配置...
<?xml version="1.0" encoding="UTF-8"?>
<!DOCTYPE mapper PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN" "http://mybatis.org/dtd/mybatis-3-mapper.dtd">
<mapper namespace="com.mycompany.mapper.MyMapper">
<select id="getSetForName" resultType="string" parameterType="map">
SELECT * FROM MYKEYSPACE.MYTABLE WHERE NAME = '${name}' AND LEVEL = ${level}
</select>
</mapper>
供参考……使用DataStax核心API……
private Cluster cluster;
private Session session;
public void doQuery(String name, String level) {
String query = "select * from mykeyspace.mytable where name = '" + name + "' and level = " + level;
Session s = get Session();
ResultSet results = s.execute(query);
for(Row r: results) {
...
}
}
private Session getSession() {
cluster = connectCluster("myhost");
session = cluster.connect();
return session;
}
private Cluster connectCluster(String node) {
return Cluster.builder().addContactPoint(node).build();
}
版本信息:mybatis-spring 1.3、mybatis v3.4.1、spring 4.3.4-RELEASE
【问题讨论】: