|
@@ -81,6 +81,13 @@ public class JsonToCalciteExample {
|
|
|
Set<String> tableNames = childrenSchema.getTableNames();
|
|
|
for (String tableName : tableNames) {
|
|
|
System.out.println("Table: " + tableName);
|
|
|
+ RelDataType rowType = childrenSchema.getTable(tableName).getRowType(calciteConnection.getTypeFactory());
|
|
|
+ List<String> columnNames = rowType.getFieldNames();
|
|
|
+ for (int i=0;i<columnNames.size();i++){
|
|
|
+ //列名
|
|
|
+ System.out.println("Columns: " + columnNames.get(i));
|
|
|
+ }
|
|
|
+
|
|
|
}
|
|
|
|
|
|
//调用张艳杰接收连接方法,传参 calciteConnection
|