[#471] Fix table name truncate: make jdbc table 63 charter (#473)

Valery Kharseko

03.30.2025 6c4ab89100805914e68699bf78f7c4ca70e972d7

[#471] Fix table name truncate: make jdbc table 63 charter (#473)

 opendj-server-legacy/src/main/java/org/opends/server/backends/jdbc/Storage.java

@@ -11,10 +11,13 @@
 * Header, with the fields enclosed by brackets [] replaced by your own identifying
 * information: "Portions Copyright [year] [name of copyright owner]".
 *
 * Copyright 2024 3A Systems, LLC.
 * Copyright 2024-2025 3A Systems, LLC.
 */
package org.opends.server.backends.jdbc;

import com.google.common.cache.CacheBuilder;
import com.google.common.cache.CacheLoader;
import com.google.common.cache.LoadingCache;
import org.forgerock.i18n.LocalizableMessage;
import org.forgerock.i18n.slf4j.LocalizedLogger;
import org.forgerock.opendj.config.server.ConfigChangeResult;
@@ -31,8 +34,11 @@
import org.opends.server.types.RestoreConfig;
import org.opends.server.util.BackupManager;

import java.math.BigInteger;
import java.security.MessageDigest;
import java.sql.*;
import java.util.*;
import java.util.concurrent.ExecutionException;

import static org.opends.server.backends.pluggable.spi.StorageUtils.addErrorMessage;
import static org.opends.server.util.StaticUtils.stackTraceToSingleLineString;
@@ -108,9 +114,28 @@
        storageStatus = StorageStatus.lockedDown(LocalizableMessage.raw("closed"));
    }

    LoadingCache<TreeName,String> tree2table= CacheBuilder.newBuilder()
            .build(new CacheLoader<TreeName, String>() {
                @Override
                public String load(TreeName treeName) throws Exception {
                    final MessageDigest md = MessageDigest.getInstance("SHA-224");
                    final byte[] messageDigest = md.digest(treeName.toString().getBytes());
                    final BigInteger no = new BigInteger(1, messageDigest);
                    String hashtext = no.toString(16);
                    while (hashtext.length() < 32) {
                        hashtext = "0" + hashtext;
                    }
                    return "opendj_"+hashtext;
                }
            });

    String getTableName(TreeName treeName) {
        return "\"OpenDJ"+treeName.toString()+"\"";
    }
        try {
            return tree2table.get(treeName);
        } catch (ExecutionException e) {
            throw new RuntimeException(e);
        }
    }

    @Override
    public void removeStorageFiles() throws StorageRuntimeException {
@@ -215,10 +240,23 @@
            isReadOnly=false;
        }

        boolean isExistsTable(TreeName treeName) {
            try(final ResultSet rs = con.getMetaData().getTables(null, null, tree2table.get(treeName), new String[]{"TABLE"})) {
                while (rs.next()) {
                    if (tree2table.get(treeName).equals(rs.getString("TABLE_NAME"))){
                        return true;
                    }
                }
            } catch (Exception e) {
                throw new StorageRuntimeException(e);
            }
            return false;
        }

        @Override
        public void openTree(TreeName treeName, boolean createOnDemand) {
            if (createOnDemand) {
                try (final PreparedStatement statement=con.prepareStatement("create table if not exists "+getTableName(treeName)+" (k bytea primary key,v bytea)")){
            if (createOnDemand && !isExistsTable(treeName)) {
                try (final PreparedStatement statement=con.prepareStatement("create table "+getTableName(treeName)+" (k bytea primary key,v bytea)")){
                    execute(statement);
                    con.commit();
                }catch (SQLException e) {
@@ -238,11 +276,13 @@

        @Override
        public void deleteTree(TreeName treeName) {
            try (final PreparedStatement statement=con.prepareStatement("drop table "+getTableName(treeName))){
                execute(statement);
                con.commit();
            }catch (SQLException e) {
                throw new StorageRuntimeException(e);
            if (isExistsTable(treeName)) {
                try (final PreparedStatement statement = con.prepareStatement("drop table " + getTableName(treeName))) {
                    execute(statement);
                    con.commit();
                } catch (SQLException e) {
                    throw new StorageRuntimeException(e);
                }
            }
        }

@@ -459,18 +499,8 @@
    
    @Override
    public Set<TreeName> listTrees() {
        final Set<TreeName> res=new HashSet<>();
        try(final Connection con=getConnection();
            final ResultSet rs = con.getMetaData().getTables(null, null, "OpenDJ%", new String[]{"TABLE"})) {
            while (rs.next()) {
                res.add(TreeName.valueOf(rs.getString("TABLE_NAME").substring(6)));
            }
        } catch (Exception e) {
            throw new StorageRuntimeException(e);
        }
        return res;
        return tree2table.asMap().keySet();
    }
	

    private final class ImporterImpl implements Importer {
        final Connection con;