如何在测试自己的适配器时使用CalciteAssert？

import org.apache.calcite.adapter.java.ReflectiveSchema;
import org.apache.calcite.jdbc.CalciteConnection;
import org.apache.calcite.schema.SchemaPlus;
import org.apache.calcite.test.CalciteAssert;
import org.junit.Test;

public class AdapterTest {

    @Test
    public void testAdapter() {
        // 创建Schema
        CalciteAssert.SchemaSpec schemaSpec = CalciteAssert.SchemaSpec.newBuilder()
                .name("mySchema")
                .tableSpec("myTable", "id INT, name VARCHAR")
                .build();

        // 注册Schema
        SchemaPlus rootSchema = CalciteAssert.that()
                .withSchema("mySchema", new ReflectiveSchema(new MySchema()))
                .getSchema();

        // 构建查询
        CalciteAssert.QueryBuilder queryBuilder = CalciteAssert.that()
                .withConnection(connection -> {
                    CalciteConnection calciteConnection = connection.unwrap(CalciteConnection.class);
                    calciteConnection.getRootSchema().add("mySchema", rootSchema);
                })
                .query("SELECT * FROM myTable");

        // 执行查询
        CalciteAssert.ResultSetValidator resultSetValidator = queryBuilder.execute();

        // 断言结果
        resultSetValidator.hasRowCount(1);
        resultSetValidator.columnNames().containsExactly("id", "name");
        resultSetValidator.rows().contains(1, "John");
    }

    // 自定义Schema
    public static class MySchema {
        public final MyTable myTable = new MyTable();
    }

    // 自定义Table
    public static class MyTable {
        public final int id = 1;
        public final String name = "John";
    }
}