【发布时间】:2017-11-20 19:27:17
【问题描述】:
我需要与 cassandra 进行演示+连接以进行课程。经过一番大闹之后,我留下了其他类型的错误,但我被困在这里,似乎没有得到 Keyspace 的地址。
import com.datastax.driver.core.Cluster;
import com.datastax.driver.core.ResultSet;
import com.datastax.driver.core.Row;
import com.datastax.driver.core.Session;
import com.datastax.driver.core.exceptions.NoHostAvailableException;
public class conectaradb {
public static void main(String[] args) {
try {
Cluster cluster;
Session sesion;
cluster = Cluster.builder().addContactPoint("127.0.0.1").withPort(9042).build();
sesion= cluster.connect("ejemplodb");
ResultSet resultado= sesion.execute("select * from empleados");
String nombreemp,fecha,cargo;
double comision,salario;
int empno;
for (Row row:resultado) {
empno=row.getInt("empno");
cargo=row.getString("cargo");
comision=row.getDouble("comision");
fecha=row.getString("fechaing");
nombreemp=row.getString("nombreempno");
salario=row.getDouble("salario");
System.out.println(empno+" "+cargo+" "+comision+" "+fecha+" "+nombreemp+" "+salario);
}
cluster.close();
}catch(NoHostAvailableException e) {
System.out.println(e.getErrors());
}
}
}
如果有人能确定错误在哪里,我会很高兴,我想我的 yaml 文件是正确的。当代码到达 addcontactpoint 上的 localhost 时出现错误:“所有主机都尝试查询失败”。 在 .getError 之后,我得到一个“TransportException”。我不知道如何进一步。
【问题讨论】: