Ignite内存数据库创建Schema遇AssertionError，单元测试场景求助

咱们先把核心困惑点掰明白：Ignite里的「Schema」确实和传统SQL里的「Database」概念几乎一致，但它的语法规则有自己的一套——这也是你用CREATE DATABASE无效的原因，Ignite只认CREATE SCHEMA语句。接下来咱们一步步解决你的AssertionError和单元测试表名问题。

一、先搞定Schema创建的基础问题 #

首先纠正一个关键误区：Ignite不支持CREATE DATABASE，必须用CREATE SCHEMA来创建你说的“数据库”。如果你直接执行CREATE DATABASE my_database，Ignite会直接忽略或者报错，这是语法不兼容导致的。

避免AssertionError的核心操作 #

AssertionError通常是因为代码里的前置判断不成立，针对Schema场景常见的触发原因和解决方法：

• 重复创建Schema：如果你的代码没判断Schema是否已存在就执行创建，第二次运行就会触发断言失败。解决方法是用CREATE SCHEMA IF NOT EXISTS my_database，这样即使Schema已存在也不会报错。
• SQL配置未开启：如果你的Ignite节点没启用SQL支持，执行Schema操作会触发异常。检查你的Ignite配置，确保开启了SQL：

  IgniteConfiguration cfg = new IgniteConfiguration();
  cfg.setSqlEnabled(true);
  

• 堆栈信息定位：把AssertionError的完整堆栈打出来，看具体是哪一行触发的——比如是不是表创建时Schema的引用路径写错了（比如写成my_database..my_table这种格式错误）。

二、单元测试中带Schema表名的替换方案 #

你提到原表带有Schema，没法单独替换表名，这里给你几个实用的解决思路：

方法1：动态拼接带Schema的SQL语句 #

在单元测试里定义一个测试专用的Schema名称（比如test_schema），然后用字符串格式化把Schema名注入到SQL中，比如：

// 测试类中定义测试Schema
private static final String TEST_SCHEMA = "test_db";

// 动态生成SQL
String query = String.format("SELECT * FROM %s.user_table", TEST_SCHEMA);
SqlFieldsQuery sqlQuery = new SqlFieldsQuery(query);

这样不管原SQL里的Schema是什么，测试时都能替换成测试专用的Schema，完全隔离测试环境。

方法2：测试前后自动创建/销毁测试Schema #

在单元测试的setUp方法中创建测试Schema，tearDown方法中销毁，确保每个测试用例都是干净的环境：

private Ignite ignite;

@BeforeEach
void setUp() {
    // 启动测试专用Ignite节点
    IgniteConfiguration cfg = new IgniteConfiguration();
    cfg.setSqlEnabled(true);
    ignite = Ignition.start(cfg);
    
    // 创建测试Schema
    SqlFieldsQuery createSchema = new SqlFieldsQuery("CREATE SCHEMA IF NOT EXISTS " + TEST_SCHEMA);
    ignite.context().query().querySqlFields(createSchema, false);
    
    // 创建测试表（和原表结构一致，但用测试Schema）
    String createTableSql = String.format("CREATE TABLE %s.user_table (id INT PRIMARY KEY, name VARCHAR)", TEST_SCHEMA);
    ignite.context().query().querySqlFields(new SqlFieldsQuery(createTableSql), false);
}

@AfterEach
void tearDown() {
    // 清理测试表和Schema
    String dropTableSql = String.format("DROP TABLE IF EXISTS %s.user_table", TEST_SCHEMA);
    ignite.context().query().querySqlFields(new SqlFieldsQuery(dropTableSql), false);
    
    String dropSchemaSql = String.format("DROP SCHEMA IF EXISTS %s", TEST_SCHEMA);
    ignite.context().query().querySqlFields(new SqlFieldsQuery(dropSchemaSql), false);
    
    ignite.close();
}

方法3：利用Ignite的内存表特性临时替换 #

如果你的表是内存表（默认就是内存模式），可以在测试时直接创建带测试Schema的临时表，测试结束后自动销毁——完全不会影响原有的Schema和表结构。

三、最后再提几个容易踩的坑 #

• 别再用CREATE DATABASE了，Ignite不认这个语法，老老实实用CREATE SCHEMA
• 单元测试一定要隔离环境：每个测试用例启动独立的Ignite节点，避免多个测试用例共用Schema导致数据污染
• 如果是集群模式，确保所有节点都开启了SQL支持，不然会出现部分节点无法识别Schema的情况

内容的提问来源于stack exchange，提问作者Mulgard