import java.sql.Connection;
import java.sql.DriverManager;
import java.sql.SQLException;
public class KineticaJDBCExample {
public static void main(String[] args) {
Connection connection = null;
try {
// Register JDBC driver
Class.forName("com.kinetica.jdbc.Driver");
// Open a connection
connection = DriverManager.getConnection("jdbc:kinetica://localhost:9191;URL='http://localhost:9191';")
// Perform database operations
// Close the connection
connection.close();
} catch (ClassNotFoundException e) {
e.printStackTrace();
} catch (SQLException e) {
e.printStackTrace();
}
}
}
import java.sql.Connection;
import java.sql.DriverManager;
import java.sql.ResultSet;
import java.sql.SQLException;
import java.sql.Statement;
public class KineticaJDBCExample {
public static void main(String[] args) {
Connection connection = null;
Statement statement = null;
ResultSet resultSet = null;
try {
// Register JDBC driver
Class.forName("com.kinetica.jdbc.Driver");
// Open a connection
connection = DriverManager.getConnection("jdbc:kinetica://localhost:9191;URL='http://localhost:9191';");
// Create a statement
statement = connection.createStatement();
// Execute a query
String sql = "SELECT * FROM my_table";
resultSet = statement.executeQuery(sql);
// Process the result set
while (resultSet.next()) {
// Retrieve data from each row
int id = resultSet.getInt("id");
String name = resultSet.getString("name");
// Do something with the retrieved data
System.out.println("ID: " + id + ", Name: " + name);
}
// Close the result set, statement, and connection
resultSet.close();
statement.close();
connection.close();
} catch (ClassNotFoundException e) {
e.printStackTrace();
} catch (SQLException e) {
e.printStackTrace();
}
}
}
