public void renameColumn()

in paimon-prestosql-common/src/main/java/org/apache/paimon/prestosql/PrestoSqlMetadataBase.java [307:325]

19 lines of code
2 McCabe index (conditional complexity)


    public void renameColumn(
            ConnectorSession session,
            ConnectorTableHandle tableHandle,
            ColumnHandle source,
            String target) {
        PrestoSqlTableHandle prestosqlTableHandle = (PrestoSqlTableHandle) tableHandle;
        Identifier identifier =
                new Identifier(
                        prestosqlTableHandle.getSchemaName(), prestosqlTableHandle.getTableName());
        PrestoSqlColumnHandle prestosqlColumnHandle = (PrestoSqlColumnHandle) source;
        List<SchemaChange> changes = new ArrayList<>();
        changes.add(SchemaChange.renameColumn(prestosqlColumnHandle.getColumnName(), target));
        try {
            catalog.alterTable(identifier, changes, false);
        } catch (Exception e) {
            throw new RuntimeException(
                    format("table not exists: '%s'", prestosqlTableHandle.getTableName()));
        }
    }