Я пытаюсь использовать ApacheIgnite для выполнения запросов SQL.
В основном я не могу подключиться к своему порту, который выполняется в IP-адресе док: 172.17.0.1, и к порту SQL: 3606
Конфигурации POM следующие:
Ignite-core:2.7.6
ignite-indexing: 2.7.6
mysql-connector-java: 8.0.17
private static Connection igniteConnection;
private static Statement sql;
private static ResultSet rs;
public static void main(String[] args) throws Exception
{
Class.forName("org.apache.ignite.IgniteJdbcThinDriver");
IgniteConfiguration conf = new IgniteConfiguration();
Ignite ignite = Ignition.start(conf);
igniteConnection = DriverManager.getConnection("jdbc:ignite:thin://localhost:3606/test;user=root;password=root");
sql = igniteConnection.createStatement();
sql.executeUpdate("CREATE TABLE Employee (" +
" id LONG PRIMARY KEY, name VARCHAR(30), country VARCHAR(30))");
PreparedStatement sql = igniteConnection.prepareStatement("INSERT INTO Employee (id, name, country) VALUES (?, ?, ?)");
sql.setLong(1, 1);
sql.setString(2, "James");
sql.setString(3, "EEUU");
sql.executeUpdate();
rs = sql.executeQuery("SELECT e.name, e.country FROM Employee");
while(rs.next()){
String name = rs.getString(1);
String country = rs.getString(2);
System.out.println(name+"\t"+country);
}
ignite.close();
igniteConnection.close();
rs.close();
}
}