Skip to content

Commit 82682dd

Browse files
committed
fix(TableColumnBaseSQLProvider): fix wrong sql in listColumnPOsByColumnIds
1 parent e81946d commit 82682dd

File tree

1 file changed

+9
-9
lines changed

1 file changed

+9
-9
lines changed

core/src/main/java/org/apache/gravitino/storage/relational/mapper/provider/base/TableColumnBaseSQLProvider.java

+9-9
Original file line numberDiff line numberDiff line change
@@ -49,15 +49,15 @@ public String listColumnPOsByTableIdAndVersion(
4949

5050
public String listColumnPOsByColumnIds(@Param("columnIds") List<Long> columnIds) {
5151
return "<script>"
52-
+ " SELECT t1.column_id AS columnId, t1.column_name AS columnName,"
53-
+ " t1.column_position AS columnPosition,"
54-
+ " t1.metalake_id AS metalakeId, t1.catalog_id AS catalogId,"
55-
+ " t1.schema_id AS schemaId, t1.table_id AS tableId,"
56-
+ " t1.table_version AS tableVersion, t1.column_type AS columnType,"
57-
+ " t1.column_comment AS columnComment, t1.column_nullable AS nullable,"
58-
+ " t1.column_auto_increment AS autoIncrement,"
59-
+ " t1.column_default_value AS defaultValue, t1.column_op_type AS columnOpType,"
60-
+ " t1.deleted_at AS deletedAt, t1.audit_info AS auditInfo"
52+
+ " SELECT column_id AS columnId, column_name AS columnName,"
53+
+ " column_position AS columnPosition,"
54+
+ " metalake_id AS metalakeId, catalog_id AS catalogId,"
55+
+ " schema_id AS schemaId, table_id AS tableId,"
56+
+ " table_version AS tableVersion, column_type AS columnType,"
57+
+ " column_comment AS columnComment, column_nullable AS nullable,"
58+
+ " column_auto_increment AS autoIncrement,"
59+
+ " column_default_value AS defaultValue, column_op_type AS columnOpType,"
60+
+ " deleted_at AS deletedAt, audit_info AS auditInfo"
6161
+ " FROM "
6262
+ TableColumnMapper.COLUMN_TABLE_NAME
6363
+ " WHERE deleted_at = 0"

0 commit comments

Comments
 (0)