Apache Calcite |HSQLDB - исключение таблицы не найдено - PullRequest
Новая
       39

Apache Calcite |HSQLDB - исключение таблицы не найдено

0 голосов
/ 05 июня 2018

Я пытаюсь изучить Apache Calcite, следуя RelBuilderExample со слоем хранения HSQLDB.К сожалению, я продолжаю получать «исключение таблицы не найдено», когда я вызываю builder.scan(tableName) API Apache Calcite.Когда я запрашиваю данные в HSQL напрямую, используя ResultSet rs = statement.executeQuery("SELECT * from file");, я могу получить данные.Вот соответствующий код: 

//I create an instance of RelBuilder using the Config defined below
RelBuilder builder = RelBuilder.create(config().build());
//This line throws me exception: org.apache.calcite.runtime.CalciteException: Table 'file' not found

            builder = builder.scan("file");

/**
  Building the configuration backed by HSQLDB
*/
public static Frameworks.ConfigBuilder config() throws Exception{

            //Getting the ConnectionSpec for the in memory HSQLDB
            //FileHSQLDB.URI = "jdbc:hsqldb:mem:intel"
            //FileHSQLDB.USER = "user"
            //FileHSQLDB.PASSWORD = "password"
            final ConnectionSpec cs = new ConnectionSpec(FileHSQLDB.URI, FileHSQLDB.USER, FileHSQLDB.PASSWORD, "org.hsqldb.jdbcDriver", "intel");

            //cs.url = "jdbc:hsqldb:mem:intel"
            //cs.driver = "org.hsqldb.jdbcDriver"
            //cs.username = "user"
            //cs.password = "password"
            DataSource dataSource = JdbcSchema.dataSource(cs.url, cs.driver, cs.username, cs.password);
            Connection connection = dataSource.getConnection();
            Statement statement = connection.createStatement();
            //This returns me 3 results
            ResultSet rs = statement.executeQuery("SELECT * from file");
            while(rs.next()) {
                String id = rs.getString("file_id");
                System.out.println(id);
            }
            // Next I create the rootSchema
            SchemaPlus rootSchema = Frameworks.createRootSchema(true);

            //I suspect that there is some issue in the below line. I think I 
            //am not using Apache Calcite APIs properly, but not sure what I 
            //am doing wrong.
            rootSchema.add("intel", JdbcSchema.create(rootSchema, "intel", dataSource, cs.catalog, cs.schema));
return Frameworks.newConfigBuilder().defaultSchema(rootSchema);

Может кто-нибудь, пожалуйста, помогите мне, что я могу делать не так.

1 Ответ

0 голосов
/ 05 июня 2018

Если ваша таблица file (в нижнем регистре), убедитесь, что вы указали имя таблицы в запросе, т.е. "SELECT * from \"file\"".

...