我运行的是Cassandra1.2.0(cql3),我使用的是hector 1.0.5。以下是我的表定义:
CREATE TABLE group_profiles (
profile_id text,
time timeuuid,
document text,
PRMARY KEY (profile_id, time)
) WITH COMPACT STORAGE;
我不知道如何连接到cassandra集群并创建一行。赫克托的文件到处都是,或者cql3的文件不完整。我似乎找不到使用现有表连接到现有键空间并使用cql3添加记录的完整示例。
更新
经过更多的挖掘和诅咒,我发现这个例子项目使用Cassandra驱动核心。我会好好玩玩的,不过这是我想的。目前,它只是在beta2,但由于这只是个人学习,我会给这个机会,看看它如何进行。
1条答案
按热度按时间lfapxunr1#
我就是这样做连接部分的(我使用spring/maven):
在一个
data-access.properties
:在一个
data-Source-config.xml
```<jdbc:initialize-database data-source="dataSource">
<jdbc:script location="${jdbc.initLocation}"/>
<jdbc:script location="${jdbc.dataLocation}"/>
</jdbc:initialize-database>
import me.prettyprint.hector.api.Cluster;
import me.prettyprint.hector.api.Keyspace;
import me.prettyprint.hector.api.factory.HFactory;
import org.apache.cassandra.cql.jdbc.UtilsProxy;
import org.apache.tomcat.jdbc.pool.DataSourceProxy;
public class KeyspaceManagerImpl implements KeyspaceManager {
}
// and this other class that was needed to proxy some very interesting but not visible (package visible) one
package org.apache.cassandra.cql.jdbc; // <- package is very important here !
import java.sql.SQLException;
import java.util.HashMap;
import java.util.Map;
import java.util.Properties;
import org.apache.tomcat.jdbc.pool.DataSourceProxy;
import org.apache.tomcat.jdbc.pool.PoolConfiguration;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
/**
*/
public class UtilsProxy extends Utils {
}