Optimize method listColumnPOsByTableIdAndVersion to make it more efficient.

yuqi1129 · yuqi1129 · commit 7707a3e9f30a · 2025-03-08T10:54:41.000+08:00
diff --git a/core/src/main/java/org/apache/gravitino/storage/relational/mapper/provider/base/TableColumnBaseSQLProvider.java b/core/src/main/java/org/apache/gravitino/storage/relational/mapper/provider/base/TableColumnBaseSQLProvider.java
@@ -44,7 +44,8 @@ public String listColumnPOsByTableIdAndVersion(
         + TableColumnMapper.COLUMN_TABLE_NAME
         + " WHERE table_id = #{tableId} AND table_version <= #{tableVersion} AND deleted_at = 0"
         + " GROUP BY column_id) t2"
-        + " ON t1.column_id = t2.column_id AND t1.table_version = t2.max_table_version";
+        + " ON t1.column_id = t2.column_id AND t1.table_version = t2.max_table_version"
+        + " AND table_id = #{tableId}";
   }
 
   public String insertColumnPOs(@Param("columnPOs") List<ColumnPO> columnPOs) {

Original file line number	Diff line number	Diff line change
`@@ -44,7 +44,8 @@ public String listColumnPOsByTableIdAndVersion(`
`44`	`44`	`+ TableColumnMapper.COLUMN_TABLE_NAME`
`45`	`45`	`+ " WHERE table_id = #{tableId} AND table_version <= #{tableVersion} AND deleted_at = 0"`
`46`	`46`	`+ " GROUP BY column_id) t2"`
`47`		`- + " ON t1.column_id = t2.column_id AND t1.table_version = t2.max_table_version";`
	`47`	`+ + " ON t1.column_id = t2.column_id AND t1.table_version = t2.max_table_version"`
	`48`	`+ + " AND table_id = #{tableId}";`
`48`	`49`	`}`
`49`	`50`
`50`	`51`	`public String insertColumnPOs(@Param("columnPOs") List<ColumnPO> columnPOs) {`