shardingsphere-scaling/shardingsphere-scaling-dialect/shardingsphere-scaling-opengauss/src/main/java/org/apache/shardingsphere/scaling/opengauss/wal/OpenGaussLogicalReplication.java
/**
     * Drop replication slot by connection.
     *
     * @param conn the database connection
     * @throws SQLException drop sql with error
     */
Drop replication slot by connection.
@param conn the database connection
@throws SQLException drop sql with error
Drop replication slot by connection . @param conn the database connection @throws SQLException drop sql with error
public static void dropSlot(final Connection conn) throws SQLException {
        String sql = String.format("select * from pg_drop_replication_slot('%s')", getUniqueSlotName(conn));
        try (CallableStatement cs = conn.prepareCall(sql)) {
            cs.execute();
        }
    }
public static void dropSlot ( final Connection conn ) throws SQLException { String sql = String . format ( "select * from pg_drop_replication_slot('%s')" , getUniqueSlotName ( conn ) ) ; try ( CallableStatement cs = conn . prepareCall ( sql ) ) { cs . execute ( ) ; } }
Drop replication slot by connection.
Drop replication slot by connection .