Build High-Performance Apps with Ignite

                                
// Connect to the cluster
IgniteClient client = IgniteClient.builder()
.addresses("127.0.0.1:10800")
.build();

// Create a table
String createTableSql = "CREATE TABLE IF NOT EXISTS Person ("
+ "id INT PRIMARY KEY,"
+ "name VARCHAR,"
+ "age INT"
+ ")";
client.sql().execute(null, createTableSql);

// Insert data
String insertSql = "INSERT INTO Person (id, name, age) VALUES (?, ?, ?)";
client.sql().execute(null, insertSql, 1, "John Doe", 30);
client.sql().execute(null, insertSql, 2, "Jane Smith", 28);

// Query data
client.sql().execute(null, "SELECT * FROM Person WHERE age > ?", 25)
.forEachRemaining(row -> {
System.out.println("ID: " + row.intValue("id") +
", Name: " + row.stringValue("name") +
", Age: " + row.intValue("age"));
});

// Close the client
client.close();
                                
                                
// Connect to the cluster
var config = new IgniteClientConfiguration("127.0.0.1:10800");
using var client = await IgniteClient.StartAsync(config);

// Create a table
var createTableSql = "CREATE TABLE IF NOT EXISTS Person (" +
    "id INT PRIMARY KEY," +
    "name VARCHAR," +
    "age INT" +
    ")";
await client.Sql.ExecuteAsync(null, createTableSql);

// Insert data
var insertSql = "INSERT INTO Person (id, name, age) VALUES (?, ?, ?)";
await client.Sql.ExecuteAsync(null, insertSql, 1, "John Doe", 30);
await client.Sql.ExecuteAsync(null, insertSql, 2, "Jane Smith", 28);

// Query data
await using var resultSet = await client.Sql.ExecuteAsync(null, 
    "SELECT * FROM Person WHERE age > ?", 25);
await foreach (var row in resultSet)
{
    Console.WriteLine($"ID: {row["id"]}, Name: {row["name"]}, Age: {row["age"]}");
}
                                
                                
# Connect to the cluster
import pyignite_dbapi

conn = pyignite_dbapi.connect(address="127.0.0.1:10800")
cursor = conn.cursor()

# Create a table
create_table_sql = """CREATE TABLE IF NOT EXISTS Person (
    id INT PRIMARY KEY,
    name VARCHAR,
    age INT
)"""
cursor.execute(create_table_sql)

# Insert data
insert_sql = "INSERT INTO Person (id, name, age) VALUES (?, ?, ?)"
cursor.execute(insert_sql, (1, "John Doe", 30))
cursor.execute(insert_sql, (2, "Jane Smith", 28))

# Query data
cursor.execute("SELECT * FROM Person WHERE age > ?", (25,))
for row in cursor.fetchall():
    print(f"ID: {row[0]}, Name: {row[1]}, Age: {row[2]}")

# Close the connection
cursor.close()
conn.close()
                                
                                
// Connect to the cluster
ignite_client_configuration cfg{"127.0.0.1:10800"};
auto client = ignite_client::start(cfg, std::chrono::seconds{30});

// Create a table
std::string createTableSql = "CREATE TABLE IF NOT EXISTS Person ("
    "id INT PRIMARY KEY,"
    "name VARCHAR,"
    "age INT"
    ")";
client.get_sql().execute(nullptr, nullptr, {createTableSql}, {});

// Insert data
std::string insertSql = "INSERT INTO Person (id, name, age) VALUES (?, ?, ?)";
client.get_sql().execute(nullptr, nullptr, {insertSql}, {1, "John Doe", 30});
client.get_sql().execute(nullptr, nullptr, {insertSql}, {2, "Jane Smith", 28});

// Query data
auto result = client.get_sql().execute(nullptr, nullptr, 
    {"SELECT * FROM Person WHERE age > ?"}, {25});
while (result->has_row_set() && result->next()) {
    std::cout  "ID: "  result->get_value("id")
               ", Name: "  result->get_value("name")
               ", Age: "  result->get_value("age")  std::endl;
}