This is an automated email from the ASF dual-hosted git repository.
jerryshao pushed a commit to branch branch-1.3
in repository https://gitbox.apache.org/repos/asf/gravitino.git
The following commit(s) were added to refs/heads/branch-1.3 by this push:
new cf42ea2740 [Cherry-pick to branch-1.3] [#8384] fix(catalog-oceanbase):
Wrap column names with backticks (#11768) (#11773)
cf42ea2740 is described below
commit cf42ea27409fc5b32760489429a27177b7f148f4
Author: github-actions[bot]
<41898282+github-actions[bot]@users.noreply.github.com>
AuthorDate: Tue Jun 23 11:15:09 2026 -0700
[Cherry-pick to branch-1.3] [#8384] fix(catalog-oceanbase): Wrap column
names with backticks (#11768) (#11773)
**Cherry-pick Information:**
- Original commit: 5fa0bfc910edad59b8fdf44c23e1151cbd7fe7f8
- Target branch: `branch-1.3`
- Status: ✅ Clean cherry-pick (no conflicts)
Co-authored-by: Jandy <[email protected]>
Co-authored-by: Jerry Shao <[email protected]>
---
.../oceanbase/operation/OceanBaseTableOperations.java | 15 ++++++++++-----
1 file changed, 10 insertions(+), 5 deletions(-)
diff --git
a/catalogs-contrib/catalog-jdbc-oceanbase/src/main/java/org/apache/gravitino/catalog/oceanbase/operation/OceanBaseTableOperations.java
b/catalogs-contrib/catalog-jdbc-oceanbase/src/main/java/org/apache/gravitino/catalog/oceanbase/operation/OceanBaseTableOperations.java
index 8c61a03069..aa9a49cf53 100644
---
a/catalogs-contrib/catalog-jdbc-oceanbase/src/main/java/org/apache/gravitino/catalog/oceanbase/operation/OceanBaseTableOperations.java
+++
b/catalogs-contrib/catalog-jdbc-oceanbase/src/main/java/org/apache/gravitino/catalog/oceanbase/operation/OceanBaseTableOperations.java
@@ -543,18 +543,23 @@ public class OceanBaseTableOperations extends
JdbcTableOperations {
String col = updateColumnPosition.fieldName()[0];
JdbcColumn column = getJdbcColumnFromTable(jdbcTable, col);
StringBuilder columnDefinition = new StringBuilder();
- columnDefinition.append(MODIFY_COLUMN).append(col);
+
columnDefinition.append(MODIFY_COLUMN).append(BACK_QUOTE).append(col).append(BACK_QUOTE);
appendColumnDefinition(column, columnDefinition);
if (updateColumnPosition.getPosition() instanceof TableChange.First) {
columnDefinition.append("FIRST");
} else if (updateColumnPosition.getPosition() instanceof
TableChange.After) {
TableChange.After afterPosition = (TableChange.After)
updateColumnPosition.getPosition();
- columnDefinition.append(AFTER).append(afterPosition.getColumn());
+ columnDefinition
+ .append(AFTER)
+ .append(BACK_QUOTE)
+ .append(afterPosition.getColumn())
+ .append(BACK_QUOTE);
} else {
Arrays.stream(jdbcTable.columns())
.reduce((column1, column2) -> column2)
.map(Column::name)
- .ifPresent(s -> columnDefinition.append(AFTER).append(s));
+ .ifPresent(
+ s ->
columnDefinition.append(AFTER).append(BACK_QUOTE).append(s).append(BACK_QUOTE));
}
return columnDefinition.toString();
}
@@ -588,7 +593,7 @@ public class OceanBaseTableOperations extends
JdbcTableOperations {
}
String col = updateColumnDefaultValue.fieldName()[0];
JdbcColumn column = getJdbcColumnFromTable(jdbcTable, col);
- StringBuilder sqlBuilder = new StringBuilder(MODIFY_COLUMN + col);
+ StringBuilder sqlBuilder = new StringBuilder(MODIFY_COLUMN + BACK_QUOTE +
col + BACK_QUOTE);
JdbcColumn newColumn =
JdbcColumn.builder()
.withName(col)
@@ -607,7 +612,7 @@ public class OceanBaseTableOperations extends
JdbcTableOperations {
}
String col = updateColumnType.fieldName()[0];
JdbcColumn column = getJdbcColumnFromTable(jdbcTable, col);
- StringBuilder sqlBuilder = new StringBuilder(MODIFY_COLUMN + col);
+ StringBuilder sqlBuilder = new StringBuilder(MODIFY_COLUMN + BACK_QUOTE +
col + BACK_QUOTE);
JdbcColumn newColumn =
JdbcColumn.builder()
.withName(col)
