Apache calcite: сбой синтаксического анализа: обнаружен "от \""
В настоящее время я пытаюсь подключиться MySQL с помощью кальцита. Однако у меня были проблемы с выполнением операторов SQL
Когда я использую этот sql для оправдания, это работает.
ResultSet resultSet = Statement.executeQuery( "select * from ex.depts");
Но я хотел бы получить доступ к таблице с именем как "primary_test", это не удалось.
Исключение в потоке "main" java.sql.SQLException: ошибка при выполнении SQL "select * from ex.primary_test": от строки 1, столбца 15 до строки 1, столбца 29: объект 'primary_test' не найден в пределах 'ex' в организации.apache.calcite.avatica.Helper.createException(Helper.java:56) в org.apache.calcite.avatica.Helper.createException(Helper.java:41) в org.apache.calcite.avatica.AvaticaStatement.executeInternal(Avatica.java:163) at org.apache.calcite.avatica.AvaticaStatement.executeQuery(AvaticaStatement.java:227) в CalciteMysqlConnectionIns.main(CalciteMysqlConnectionIns.java:44). 1, столбец 15 - строка 1, столбец 29: объект "primary_test" не найден внутри "ex" в sun.reflect.NativeConstructorAccessorImpl.newInstance0(собственный метод) в sun.reflect.NativeConstructorAccessorImpl.newInstance(NativeConstructorAccessorImpl.java:62 at).reflect.DelegatingConstructorAccessorImpl.newInstance(DelegatingConstructorAccessorImpl.java:45) в java.lang.reflect.Constructor.newInstance(Constructor.java:423) в org.apache.calcite.runtime.Resources$ExInstWithCause.ex(Resources.java:463) в org.apache.calcite.sql Исключение) в org.apache.calcite.sql.validate.IdentifierNamespace.resolveImpl(IdentifierNamespace.java:166) в org.apache.calcite.sql.validate.IdentifierNamespace.validateImpl(IdentifierNamespace.java:1apiteite.al.alc. org.sql.validate.AbstractNamespace.validate(AbstractNamespace.java:84) в org.apache.calcite.sql.validate.SqlValidatorImpl.validateNamespace(SqlValidatorImpl.java:977) в org.apache.calmpid.lididatelatelateate SqlValidatorImpl.java:953) в org.apache.calcite.sql.validate.SqlValidatorImpl.validateFrom(SqlValidatorImpl.java:3050) в org.apache.calcite.sql.validate.SqlValidatorImpl.validateFrom(SqlValidatorImpl.java:3032) по адресу org.apache.calcite.sql.validate.SqlValidatorImpl.validateSelect(SqlValidatorImpl.java:3302) по адресу org.apache.calspatel. 60) в org.apache.calcite.sql.validate.AbstractNamespace.validate(AbstractNamespace.java:84) в org.apache.calcite.sql.validate.SqlValidatorImpl.validateNamespace (SqlValidatorImpl.jitegap.77): 977.sql.validate.SqlValidatorImpl..java:928) at org.apache.calcite.sql.validate.SqlValidatorImpl.validate(SqlValidatorImpl.java:632) в org.apache.calcite.sql2rel.SqlToRelConverter.convertQuery(Sql6). orv.calcite.prepare.Prepare.prepareSql(Prepare.java:265) в org.apache.calcite.prepare.Prepare.prepareSql(Prepare.java:231) at org.apache.calcite.prepare.CalcitePrepareImpl.prepare2_(CalcitePrepareImpl.java:772) в org.apache.calcite.prepare.CalcitePrepareImpl.prepare_(CalcitePrepareImpl.jareparep.pare.parepcal.parepcalpc. (CalcitePrepareImpl.java:606) в org.apache.calcite.jdbc.CalciteConnectionImpl.parseQuery(CalciteConnectionImpl.java:229) в org.apache.calcite.jdbc.CalciteMetaImpl.prepache.eta.eta. calcite.avatica..SqlValidatorException: объект "primary_test" не найден в пределах "ex" в sun.reflect.NativeConstructorAccessorImpl.newInstance0(собственный метод) в sun.reflect.NativeConstructorAccessorImpl.newInstance (NativeConstructorAccessorImpl.jewstorConject.jpg). ructorAccessorImpl.java:45) в java.lang.reflect.Constructor.newInstance(Constructor.java:423) в org.apache.calcite.runtime.Resources$ExInstWithCause.ex(Resources.java:463) в org.apache.calcite.runtime.Resources$ExInst.ex(Resources.java:572) ... еще 30
Я использовал много разных запросов, таких как
ResultSet resultSet = Statement.executeQuery( "select * from ex.\" Primary_test\"");
но это не работает Может ли кто-нибудь помочь мне с этим вопросом?
мой код выглядит следующим образом:
import java.io.PrintStream;
import java.sql.Connection;
import java.sql.DatabaseMetaData;
import java.sql.DriverManager;
import java.sql.ResultSet;
import java.sql.ResultSetMetaData;
import java.sql.SQLException;
import java.sql.Statement;
import java.util.Properties;
import org.apache.calcite.adapter.jdbc.JdbcSchema;
import org.apache.calcite.jdbc.CalciteConnection;
import org.apache.calcite.schema.Schema;
import org.apache.calcite.schema.SchemaPlus;
import org.apache.commons.dbcp2.BasicDataSource;
public class CalciteMysqlConnectionIns {
public static void main(String[] args) throws ClassNotFoundException, SQLException {
Class.forName("org.apache.calcite.jdbc.Driver");
Properties info = new Properties();
info.setProperty("lex", "JAVA");
Connection connection = DriverManager.getConnection("jdbc:calcite:", info);
CalciteConnection calciteConnection = connection.unwrap(CalciteConnection.class);
SchemaPlus rootSchema = calciteConnection.getRootSchema();
// 本地Schema.
// Schema schema = ReflectiveSchema.create(calciteConnection, rootSchema, "hr",
// new HrSchema());
Class.forName("com.mysql.jdbc.Driver");
BasicDataSource dataSource = new BasicDataSource();
dataSource.setUrl("jdbc:mysql://192.168.130.7/hr");
dataSource.setUsername("root");
dataSource.setPassword("123456");
Schema schema = JdbcSchema.create(rootSchema, "ex", dataSource, null, "sql_learn");
rootSchema.add("ex", schema);
// System.out.println(calciteConnection.getMetaData());
DatabaseMetaData databaseMetaData = calciteConnection.getMetaData();
// ResultSet rs = databaseMetaData.getTables(null, null, "%", new String[]{"TABLE"});
Statement statement = calciteConnection.createStatement();
ResultSet resultSet = statement.executeQuery(
"select * from ex.\"primary_test\"");
output(resultSet, System.out);
resultSet.close();
statement.close();
connection.close();
}
private static void output(ResultSet resultSet, PrintStream out) throws SQLException {
final ResultSetMetaData metaData = resultSet.getMetaData();
final int columnCount = metaData.getColumnCount();
// out.println(metaData.getColumnLabel(1) + " " + metaData.getColumnLabel(2));
// out.println(metaData.getColumnTypeName(1) + " " + metaData.getColumnTypeName(2));
while (resultSet.next()) {
for (int i = 1; ; i++) {
out.print(resultSet.getString(i));
if (i < columnCount) {
out.print(", ");
} else {
out.println();
break;
}
}
}
}
}