Ignite 3
Edit

Understanding Schemas

Overview

Ignite has a number of default schemas and supports creating custom schemas.

There are two schemas that are available by default:

  • The SYS schema, which contains a number of system views with information about cluster nodes. You can’t create tables in this schema. Refer to the System Views page for further information.

  • The PUBLIC schema, which is used by default whenever a schema is not specified.

Custom schemas are created in the following cases:

  • You can specify custom schemas in the cluster configuration. See Custom Schemas.

  • Ignite creates a schema for each cache created via one of the programming interfaces or XML configuration. See Cache and Schema Names.

PUBLIC Schema

The PUBLIC schema is used by default whenever a schema is required and is not specified. For example, when you connect to the cluster via JDBC without setting the schema explicitly, you will connect to the PUBLIC schema.

Custom Schemas

Custom schemas can be set via the sqlSchemas property of IgniteConfiguration. You can specify a list of schemas in the configuration before starting your cluster and then create objects in these schemas at runtime.

Below is a configuration example with two custom schemas.

<bean class="org.apache.ignite.configuration.IgniteConfiguration">
    <property name="sqlConfiguration">
        <bean class="org.apache.ignite.configuration.SqlConfiguration">
            <property name="sqlSchemas">
                <list>
                    <value>MY_SCHEMA</value>
                    <value>MY_SECOND_SCHEMA</value>
                </list>
            </property>
        </bean>
    </property>
</bean>
IgniteConfiguration cfg = new IgniteConfiguration();

SqlConfiguration sqlCfg = new SqlConfiguration();

sqlCfg.setSqlSchemas("MY_SCHEMA", "MY_SECOND_SCHEMA" );

cfg.setSqlConfiguration(sqlCfg);
var cfg = new IgniteConfiguration
{
    SqlSchemas = new[]
    {
        "MY_SCHEMA",
        "MY_SECOND_SCHEMA"
    }
};
This API is not presently available for C++. You can use XML configuration.

To connect to a specific schema via, for example, a JDBC driver, provide the schema name in the connection string:

jdbc:ignite:thin://127.0.0.1/MY_SCHEMA

Cache and Schema Names

When you create a cache with queryable fields, you can manipulate the cached data using the SQL API. In SQL terms, each such cache corresponds to a separate schema whose name equals the name of the cache.

Similarly, when you create a table via a DDL statement, you can access it as a key-value cache via Ignite’s supported programming interfaces. The name of the corresponding cache can be specified by providing the CACHE_NAME parameter in the WITH part of the CREATE TABLE statement.

CREATE TABLE City (
  ID INT(11),
  Name CHAR(35),
  CountryCode CHAR(3),
  District CHAR(20),
  Population INT(11),
  PRIMARY KEY (ID, CountryCode)
) WITH "backups=1, CACHE_NAME=City";

See the CREATE TABLE page for more details.

If you do not use this parameter, the cache name is defined in the following format (in capital letters):

SQL_<SCHEMA_NAME>_<TABLE_NAME>

Validating Data Against the Schema

Ignite can verify that values inserted into a table match the column types and constraints declared in its SQL schema. By default, Ignite performs these checks only for indexed columns. To validate all columns, enable the server-side check on every node before startup:

SqlConfiguration sqlCfg = new SqlConfiguration()
    .setValidationEnabled(true);

IgniteConfiguration cfg = new IgniteConfiguration()
    .setSqlConfiguration(sqlCfg);
<property name="sqlConfiguration">
    <bean class="org.apache.ignite.configuration.SqlConfiguration">
        <property name="validationEnabled" value="true"/>
    </bean>
</property>

When validation is enabled, Ignite runs extra checks for each SQL INSERT, MERGE, and UPDATE statement as well as cache API calls that modify SQL-managed tables and rejects data that breaks the schema. Violations raise an IgniteSQLException for SQL clients (JDBC, ODBC, REST), while key-value API callers get a CacheException whose root cause is that same IgniteSQLException. In both cases the application can handle the failure and the incorrect values are not stored. SQL DML already attempts to coerce values to the declared column types, so type mismatches typically appear when you write data through the cache API or binary objects.

// CREATE TABLE Person (id INT PRIMARY KEY, age INT);

IgniteCache<Integer, BinaryObject> cache = ignite.cache("SQL_PUBLIC_PERSON").withKeepBinary();

BinaryObject invalidPerson = ignite.binary().builder("Person")
    .setField("id", 2)
    .setField("age", "forty-two") // String instead of INT column
    .build();

cache.put(2, invalidPerson); // CacheException wrapping IgniteSQLException when validation is enabled

With the default configuration (validation disabled for non-indexed columns), the put above succeeds even though the stored BinaryObject does not match the SQL schema. Turning on validation causes Ignite to reject the update, protecting the table from malformed records.

Enable the option when you need stronger guarantees that dynamic or user-provided data cannot break the table definition, and keep it disabled when the overhead of additional checks outweighs the risk of incorrect data.