【发布时间】:2021-04-05 01:28:26
【问题描述】:
我是 cassandra 的初学者,我正在尝试连接到 cassandra 数据库并在 netbeans 中插入一些行,但在导入时出现错误:包 com.datastax.driver.core 不存在任何解决方案?
import com.datastax.driver.core.Cluster;
import com.datastax.driver.core.ResultSet;
import com.datastax.driver.core.Row;
import com.datastax.driver.core.Session;
public class CassandraConnection {
public static void main(String args[])
{
System.out.println("Cassandra Java Connection");
Cluster cluster;
Session session;
//Connect to the cluster and Keyspace ecommerce
cluster=Cluster.builder().addContactPoint("localhost").build();
session=cluster.connect("ecommerce");
System.out.println("Inserting Data in Cassandra");
session.execute("INSERT INTO products (pdt_id, cat_id, pdt_name, pdt_desc, price, shipping) VALUES (001,104, 'Danby 0.7 cu. ft. Microwave Oven', 'Capacity of 0.7 cu. ft.10 different power levels', 54.00, 'Expedited')");
String pdtid = null, pdtname = null, pdtdesc = null;
float price = 0;
ResultSet resultset=session.execute("select * from products where pdt_id=005");
for(Row row :resultset){
pdtid = Integer.toString(row.getInt("pdt_id"));
pdtname = row.getString("pdt_name");
pdtdesc = row.getString("pdt_desc");
price = row.getFloat("price");
System.out.println("Product ID: " + pdtid);
System.out.println("Name: " + pdtname);
System.out.println("Description: " + pdtdesc);
System.out.println("Price: "+ price);
}
cluster.close();
}
}```
【问题讨论】:
-
你是否将 Cassandra 依赖添加到 Maven/Gradle 中?
-
您是否将
cassandra-driver-core-X.X.X.jar(版本java-driver-core-4.X.X.jar。