shardingsphere-scaling/shardingsphere-scaling-dialect/shardingsphere-scaling-opengauss/src/main/java/org/apache/shardingsphere/scaling/opengauss/wal/OpenGaussLogicalReplication.java
/**
     * Create slots (drop existed slot before create).
     *
     * @param conn the datasource connection
     * @throws SQLException the sql exp
     */
Create slots (drop existed slot before create).
@param conn the datasource connection
@throws SQLException the sql exp
Create slots ( drop existed slot before create ) . @param conn the datasource connection @throws SQLException the sql exp
public static void createIfNotExists(final Connection conn) throws SQLException {
        if (isSlotNameExist(conn)) {
            return;
        }
        createSlotBySql(conn);
    }
public static void createIfNotExists ( final Connection conn ) throws SQLException { if ( isSlotNameExist ( conn ) ) { return ; } createSlotBySql ( conn ) ; }
Create slots (drop existed slot before create).
Create slots ( drop existed slot before create ) .