How to use loadFromResultSet method of org.cerberus.crud.dao.impl.CountryEnvironmentParametersDAO class

Best Cerberus-source code snippet using org.cerberus.crud.dao.impl.CountryEnvironmentParametersDAO.loadFromResultSet

Source:CountryEnvironmentParametersDAO.java

...87                preStat.setString(4, application);88                ResultSet resultSet = preStat.executeQuery();89                try {90                    if (resultSet.first()) {91                        result = loadFromResultSet(resultSet);92                        msg = new MessageEvent(MessageEventEnum.DATA_OPERATION_OK);93                        msg.setDescription(msg.getDescription().replace("%ITEM%", OBJECT_NAME).replace("%OPERATION%", "SELECT"));94                        ans.setItem(result);95                    } else {96                        msg = new MessageEvent(MessageEventEnum.DATA_OPERATION_NO_DATA_FOUND);97                    }98                } catch (SQLException exception) {99                    LOG.error("Unable to execute query : " + exception.toString());100                    msg = new MessageEvent(MessageEventEnum.DATA_OPERATION_ERROR_UNEXPECTED);101                    msg.setDescription(msg.getDescription().replace("%DESCRIPTION%", exception.toString()));102                } finally {103                    resultSet.close();104                }105            } catch (SQLException exception) {106                LOG.error("Unable to execute query : " + exception.toString());107                msg = new MessageEvent(MessageEventEnum.DATA_OPERATION_ERROR_UNEXPECTED);108                msg.setDescription(msg.getDescription().replace("%DESCRIPTION%", exception.toString()));109            } finally {110                preStat.close();111            }112        } catch (SQLException exception) {113            LOG.error("Unable to execute query : " + exception.toString());114            msg = new MessageEvent(MessageEventEnum.DATA_OPERATION_ERROR_UNEXPECTED);115            msg.setDescription(msg.getDescription().replace("%DESCRIPTION%", exception.toString()));116        } finally {117            try {118                if (connection != null) {119                    connection.close();120                }121            } catch (SQLException exception) {122                LOG.warn("Unable to close connection : " + exception.toString());123            }124        }125        //sets the message126        ans.setResultMessage(msg);127        return ans;128    }129    @Override130    public List<String[]> getEnvironmentAvailable(String country, String application) {131        List<String[]> list = null;132        final String query = "SELECT cev.Environment Environment, cev.Build Build, cev.Revision Revision "133                + "FROM countryenvironmentparameters cea, countryenvparam cev, invariant inv "134                + "WHERE cev.system = cea.system AND cev.country = cea.country AND cev.environment = cea.environment "135                + "AND cea.Application = ? AND cea.country= ? "136                + "AND cev.active='Y' AND inv.idname = 'ENVIRONMENT' AND inv.Value = ce.Environment "137                + "ORDER BY inv.sort";138        // Debug message on SQL.139        if (LOG.isDebugEnabled()) {140            LOG.debug("SQL : " + query);141            LOG.debug("SQL.param.application : " + application);142            LOG.debug("SQL.param.country : " + country);143        }144        Connection connection = this.databaseSpring.connect();145        try {146            PreparedStatement preStat = connection.prepareStatement(query);147            try {148                preStat.setString(1, application);149                preStat.setString(2, country);150                ResultSet resultSet = preStat.executeQuery();151                try {152                    list = new ArrayList<String[]>();153                    while (resultSet.next()) {154                        String[] array = new String[3];155                        array[0] = resultSet.getString("Environment");156                        array[1] = resultSet.getString("Build");157                        array[2] = resultSet.getString("Revision");158                        list.add(array);159                    }160                } catch (SQLException exception) {161                    LOG.warn("Unable to execute query : " + exception.toString());162                } finally {163                    resultSet.close();164                }165            } catch (SQLException exception) {166                LOG.warn("Unable to execute query : " + exception.toString());167            } finally {168                preStat.close();169            }170        } catch (SQLException exception) {171            LOG.warn("Unable to execute query : " + exception.toString());172        } finally {173            try {174                if (connection != null) {175                    connection.close();176                }177            } catch (SQLException e) {178                LOG.warn(e.toString());179            }180        }181        return list;182    }183    @Override184    public List<CountryEnvironmentParameters> findCountryEnvironmentParametersByCriteria(CountryEnvironmentParameters countryEnvironmentParameter) throws CerberusException {185        List<CountryEnvironmentParameters> result = new ArrayList<CountryEnvironmentParameters>();186        boolean throwex = false;187        StringBuilder query = new StringBuilder();188        query.append("SELECT * FROM countryenvironmentparameters cea ");189        query.append(" WHERE cea.`system` LIKE ? AND cea.country LIKE ? AND cea.environment LIKE ? AND cea.Application LIKE ? ");190        query.append("AND cea.IP LIKE ? AND cea.URL LIKE ? AND cea.URLLOGIN LIKE ? AND cea.domain like ? ");191        // Debug message on SQL.192        if (LOG.isDebugEnabled()) {193            LOG.debug("SQL : " + query);194            LOG.debug("SQL.param.system : " + ParameterParserUtil.wildcardIfEmpty(countryEnvironmentParameter.getSystem()));195            LOG.debug("SQL.param.country : " + ParameterParserUtil.wildcardIfEmpty(countryEnvironmentParameter.getCountry()));196            LOG.debug("SQL.param.environment : " + ParameterParserUtil.wildcardIfEmpty(countryEnvironmentParameter.getEnvironment()));197            LOG.debug("SQL.param.application : " + ParameterParserUtil.wildcardIfEmpty(countryEnvironmentParameter.getApplication()));198        }199        Connection connection = this.databaseSpring.connect();200        try {201            PreparedStatement preStat = connection.prepareStatement(query.toString());202            try {203                preStat.setString(1, ParameterParserUtil.wildcardIfEmpty(countryEnvironmentParameter.getSystem()));204                preStat.setString(2, ParameterParserUtil.wildcardIfEmpty(countryEnvironmentParameter.getCountry()));205                preStat.setString(3, ParameterParserUtil.wildcardIfEmpty(countryEnvironmentParameter.getEnvironment()));206                preStat.setString(4, ParameterParserUtil.wildcardIfEmpty(countryEnvironmentParameter.getApplication()));207                preStat.setString(5, ParameterParserUtil.wildcardIfEmpty(countryEnvironmentParameter.getIp()));208                preStat.setString(6, ParameterParserUtil.wildcardIfEmpty(countryEnvironmentParameter.getUrl()));209                preStat.setString(7, ParameterParserUtil.wildcardIfEmpty(countryEnvironmentParameter.getUrlLogin()));210                preStat.setString(8, ParameterParserUtil.wildcardIfEmpty(countryEnvironmentParameter.getDomain()));211                ResultSet resultSet = preStat.executeQuery();212                try {213                    while (resultSet.next()) {214                        result.add(loadFromResultSet(resultSet));215                    }216                } catch (SQLException exception) {217                    LOG.warn("Unable to execute query : " + exception.toString());218                } finally {219                    resultSet.close();220                }221            } catch (SQLException exception) {222                LOG.warn("Unable to execute query : " + exception.toString());223            } finally {224                preStat.close();225            }226        } catch (SQLException exception) {227            LOG.warn("Unable to execute query : " + exception.toString());228        } finally {229            try {230                if (connection != null) {231                    connection.close();232                }233            } catch (SQLException e) {234                LOG.warn(e.toString());235            }236        }237        if (throwex) {238            throw new CerberusException(new MessageGeneral(MessageGeneralEnum.NO_DATA_FOUND));239        }240        return result;241    }242    @Override243    public AnswerList<CountryEnvironmentParameters> readByVariousByCriteria(String system, String country, String environment, String application, int start, int amount, String column, String dir, String searchTerm, String individualSearch) {244        AnswerList<CountryEnvironmentParameters> response = new AnswerList<>();245        MessageEvent msg = new MessageEvent(MessageEventEnum.DATA_OPERATION_ERROR_UNEXPECTED);246        msg.setDescription(msg.getDescription().replace("%DESCRIPTION%", ""));247        List<CountryEnvironmentParameters> objectList = new ArrayList<>();248        StringBuilder searchSQL = new StringBuilder();249        StringBuilder query = new StringBuilder();250        //SQL_CALC_FOUND_ROWS allows to retrieve the total number of columns by disrearding the limit clauses that 251        //were applied -- used for pagination p252        query.append("SELECT SQL_CALC_FOUND_ROWS * FROM countryenvironmentparameters cea");253        searchSQL.append(" where 1=1 ");254        if (!StringUtil.isNullOrEmpty(searchTerm)) {255            searchSQL.append(" and (cea.`system` like ?");256            searchSQL.append(" or cea.`country` like ?");257            searchSQL.append(" or cea.`environment` like ?");258            searchSQL.append(" or cea.`application` like ?");259            searchSQL.append(" or cea.`ip` like ?");260            searchSQL.append(" or cea.`domain` like ?");261            searchSQL.append(" or cea.`URL` like ?");262            searchSQL.append(" or cea.`URLLOGIN` like ?)");263        }264        if (!StringUtil.isNullOrEmpty(individualSearch)) {265            searchSQL.append(" and (`?`)");266        }267        if (!StringUtil.isNullOrEmpty(system)) {268            searchSQL.append(" and (cea.`System` = ? )");269        }270        if (!StringUtil.isNullOrEmpty(country)) {271            searchSQL.append(" and (cea.`country` = ? )");272        }273        if (!StringUtil.isNullOrEmpty(environment)) {274            searchSQL.append(" and (cea.`environment` = ? )");275        }276        if (!StringUtil.isNullOrEmpty(application)) {277            searchSQL.append(" and (cea.`application` = ? )");278        }279        query.append(searchSQL);280        if (!StringUtil.isNullOrEmpty(column)) {281            query.append(" order by `").append(column).append("` ").append(dir);282        }283        if ((amount <= 0) || (amount >= MAX_ROW_SELECTED)) {284            query.append(" limit ").append(start).append(" , ").append(MAX_ROW_SELECTED);285        } else {286            query.append(" limit ").append(start).append(" , ").append(amount);287        }288        // Debug message on SQL.289        if (LOG.isDebugEnabled()) {290            LOG.debug("SQL : " + query.toString());291            LOG.debug("SQL.param.system : " + system);292            LOG.debug("SQL.param.country : " + country);293            LOG.debug("SQL.param.environment : " + environment);294            LOG.debug("SQL.param.application : " + application);295        }296        Connection connection = this.databaseSpring.connect();297        try {298            PreparedStatement preStat = connection.prepareStatement(query.toString());299            try {300                int i = 1;301                if (!StringUtil.isNullOrEmpty(searchTerm)) {302                    preStat.setString(i++, "%" + searchTerm + "%");303                    preStat.setString(i++, "%" + searchTerm + "%");304                    preStat.setString(i++, "%" + searchTerm + "%");305                    preStat.setString(i++, "%" + searchTerm + "%");306                    preStat.setString(i++, "%" + searchTerm + "%");307                    preStat.setString(i++, "%" + searchTerm + "%");308                    preStat.setString(i++, "%" + searchTerm + "%");309                    preStat.setString(i++, "%" + searchTerm + "%");310                }311                if (!StringUtil.isNullOrEmpty(individualSearch)) {312                    preStat.setString(i++, individualSearch);313                }314                if (!StringUtil.isNullOrEmpty(system)) {315                    preStat.setString(i++, system);316                }317                if (!StringUtil.isNullOrEmpty(country)) {318                    preStat.setString(i++, country);319                }320                if (!StringUtil.isNullOrEmpty(environment)) {321                    preStat.setString(i++, environment);322                }323                if (!StringUtil.isNullOrEmpty(application)) {324                    preStat.setString(i++, application);325                }326                ResultSet resultSet = preStat.executeQuery();327                try {328                    //gets the data329                    while (resultSet.next()) {330                        objectList.add(this.loadFromResultSet(resultSet));331                    }332                    //get the total number of rows333                    resultSet = preStat.executeQuery("SELECT FOUND_ROWS()");334                    int nrTotalRows = 0;335                    if (resultSet != null && resultSet.next()) {336                        nrTotalRows = resultSet.getInt(1);337                    }338                    if (objectList.size() >= MAX_ROW_SELECTED) { // Result of SQl was limited by MAX_ROW_SELECTED constrain. That means that we may miss some lines in the resultList.339                        LOG.error("Partial Result in the query.");340                        msg = new MessageEvent(MessageEventEnum.DATA_OPERATION_WARNING_PARTIAL_RESULT);341                        msg.setDescription(msg.getDescription().replace("%DESCRIPTION%", "Maximum row reached : " + MAX_ROW_SELECTED));342                        response = new AnswerList<>(objectList, nrTotalRows);343                    } else if (objectList.size() <= 0) {344                        msg = new MessageEvent(MessageEventEnum.DATA_OPERATION_NO_DATA_FOUND);345                        response = new AnswerList<>(objectList, nrTotalRows);346                    } else {347                        msg = new MessageEvent(MessageEventEnum.DATA_OPERATION_OK);348                        msg.setDescription(msg.getDescription().replace("%ITEM%", OBJECT_NAME).replace("%OPERATION%", "SELECT"));349                        response = new AnswerList<>(objectList, nrTotalRows);350                    }351                } catch (SQLException exception) {352                    LOG.error("Unable to execute query : " + exception.toString());353                    msg = new MessageEvent(MessageEventEnum.DATA_OPERATION_ERROR_UNEXPECTED);354                    msg.setDescription(msg.getDescription().replace("%DESCRIPTION%", exception.toString()));355                } finally {356                    if (resultSet != null) {357                        resultSet.close();358                    }359                }360            } catch (SQLException exception) {361                LOG.error("Unable to execute query : " + exception.toString());362                msg = new MessageEvent(MessageEventEnum.DATA_OPERATION_ERROR_UNEXPECTED);363                msg.setDescription(msg.getDescription().replace("%DESCRIPTION%", exception.toString()));364            } finally {365                if (preStat != null) {366                    preStat.close();367                }368            }369        } catch (SQLException exception) {370            LOG.error("Unable to execute query : " + exception.toString());371            msg = new MessageEvent(MessageEventEnum.DATA_OPERATION_ERROR_UNEXPECTED);372            msg.setDescription(msg.getDescription().replace("%DESCRIPTION%", exception.toString()));373        } finally {374            try {375                if (!this.databaseSpring.isOnTransaction()) {376                    if (connection != null) {377                        connection.close();378                    }379                }380            } catch (SQLException exception) {381                LOG.warn("Unable to close connection : " + exception.toString());382            }383        }384        response.setResultMessage(msg);385        response.setDataList(objectList);386        return response;387    }388    @Override389    public Answer create(CountryEnvironmentParameters object) {390        MessageEvent msg = null;391        StringBuilder query = new StringBuilder();392        query.append("INSERT INTO `countryenvironmentparameters` (`system`, `country`, `environment`, `application`, `ip`, `domain`, `url`, `urllogin`, `Var1`, `Var2`, `Var3`, `Var4`, `poolSize`, `mobileActivity`, `mobilePackage`) ");393        query.append("VALUES (?,?,?,?,?,?,?,?,?,?,?,?,?,?,?)");394        // Debug message on SQL.395        if (LOG.isDebugEnabled()) {396            LOG.debug("SQL : " + query.toString());397        }398        Connection connection = this.databaseSpring.connect();399        try {400            PreparedStatement preStat = connection.prepareStatement(query.toString());401            try {402                preStat.setString(1, object.getSystem());403                preStat.setString(2, object.getCountry());404                preStat.setString(3, object.getEnvironment());405                preStat.setString(4, object.getApplication());406                preStat.setString(5, object.getIp());407                preStat.setString(6, object.getDomain());408                preStat.setString(7, object.getUrl());409                preStat.setString(8, object.getUrlLogin());410                preStat.setString(9, object.getVar1());411                preStat.setString(10, object.getVar2());412                preStat.setString(11, object.getVar3());413                preStat.setString(12, object.getVar4());414                preStat.setInt(13, object.getPoolSize());415                preStat.setString(14, object.getMobileActivity());416                preStat.setString(15, object.getMobilePackage());417                preStat.executeUpdate();418                msg = new MessageEvent(MessageEventEnum.DATA_OPERATION_OK);419                msg.setDescription(msg.getDescription().replace("%ITEM%", OBJECT_NAME).replace("%OPERATION%", "INSERT"));420            } catch (SQLException exception) {421                LOG.error("Unable to execute query : " + exception.toString(),exception);422                if (exception.getSQLState().equals(SQL_DUPLICATED_CODE)) { //23000 is the sql state for duplicate entries423                    msg = new MessageEvent(MessageEventEnum.DATA_OPERATION_ERROR_DUPLICATE);424                    msg.setDescription(msg.getDescription().replace("%ITEM%", OBJECT_NAME).replace("%OPERATION%", "INSERT").replace("%REASON%", exception.toString()));425                } else {426                    msg = new MessageEvent(MessageEventEnum.DATA_OPERATION_ERROR_UNEXPECTED);427                    msg.setDescription(msg.getDescription().replace("%DESCRIPTION%", exception.toString()));428                }429            } finally {430                preStat.close();431            }432        } catch (SQLException exception) {433            LOG.error("Unable to execute query : " + exception.toString());434            msg = new MessageEvent(MessageEventEnum.DATA_OPERATION_ERROR_UNEXPECTED);435            msg.setDescription(msg.getDescription().replace("%DESCRIPTION%", exception.toString()));436        } finally {437            try {438                if (connection != null) {439                    connection.close();440                }441            } catch (SQLException exception) {442                LOG.error("Unable to close connection : " + exception.toString());443            }444        }445        return new Answer(msg);446    }447    @Override448    public Answer delete(CountryEnvironmentParameters object) {449        MessageEvent msg = null;450        final String query = "DELETE FROM `countryenvironmentparameters` WHERE `system`=? and `country`=? and `environment`=? and `application`=? ";451        // Debug message on SQL.452        if (LOG.isDebugEnabled()) {453            LOG.debug("SQL : " + query);454        }455        Connection connection = this.databaseSpring.connect();456        try {457            PreparedStatement preStat = connection.prepareStatement(query);458            try {459                preStat.setString(1, object.getSystem());460                preStat.setString(2, object.getCountry());461                preStat.setString(3, object.getEnvironment());462                preStat.setString(4, object.getApplication());463                preStat.executeUpdate();464                msg = new MessageEvent(MessageEventEnum.DATA_OPERATION_OK);465                msg.setDescription(msg.getDescription().replace("%ITEM%", OBJECT_NAME).replace("%OPERATION%", "DELETE"));466            } catch (SQLException exception) {467                LOG.error("Unable to execute query : " + exception.toString());468                msg = new MessageEvent(MessageEventEnum.DATA_OPERATION_ERROR_UNEXPECTED);469                msg.setDescription(msg.getDescription().replace("%DESCRIPTION%", exception.toString()));470            } finally {471                preStat.close();472            }473        } catch (SQLException exception) {474            LOG.error("Unable to execute query : " + exception.toString());475            msg = new MessageEvent(MessageEventEnum.DATA_OPERATION_ERROR_UNEXPECTED);476            msg.setDescription(msg.getDescription().replace("%DESCRIPTION%", exception.toString()));477        } finally {478            try {479                if (connection != null) {480                    connection.close();481                }482            } catch (SQLException exception) {483                LOG.warn("Unable to close connection : " + exception.toString());484            }485        }486        return new Answer(msg);487    }488    @Override489    public Answer update(CountryEnvironmentParameters object) {490        MessageEvent msg = null;491        final String query = "UPDATE `countryenvironmentparameters` SET `IP`=?, `URL`=?, `URLLOGIN`=?, `domain`=?, Var1=?, Var2=?, Var3=?, Var4=?, poolSize=?, mobileActivity=?, mobilePackage=?  where `system`=? and `country`=? and `environment`=? and `application`=? ";492        // Debug message on SQL.493        if (LOG.isDebugEnabled()) {494            LOG.debug("SQL : " + query);495        }496        Connection connection = this.databaseSpring.connect();497        try {498            PreparedStatement preStat = connection.prepareStatement(query);499            try {500                int i=1;501                preStat.setString(i++, object.getIp());502                preStat.setString(i++, object.getUrl());503                preStat.setString(i++, object.getUrlLogin());504                preStat.setString(i++, object.getDomain());505                preStat.setString(i++, object.getVar1());506                preStat.setString(i++, object.getVar2());507                preStat.setString(i++, object.getVar3());508                preStat.setString(i++, object.getVar4());509                preStat.setInt(i++, object.getPoolSize());510                preStat.setString(i++, object.getMobileActivity());511                preStat.setString(i++, object.getMobilePackage());512                preStat.setString(i++, object.getSystem());513                preStat.setString(i++, object.getCountry());514                preStat.setString(i++, object.getEnvironment());515                preStat.setString(i++, object.getApplication());516                preStat.executeUpdate();517                msg = new MessageEvent(MessageEventEnum.DATA_OPERATION_OK);518                msg.setDescription(msg.getDescription().replace("%ITEM%", OBJECT_NAME).replace("%OPERATION%", "UPDATE"));519            } catch (SQLException exception) {520                LOG.error("Unable to execute query : " + exception.toString());521                msg = new MessageEvent(MessageEventEnum.DATA_OPERATION_ERROR_UNEXPECTED);522                msg.setDescription(msg.getDescription().replace("%DESCRIPTION%", exception.toString()));523            } finally {524                preStat.close();525            }526        } catch (SQLException exception) {527            LOG.error("Unable to execute query : " + exception.toString());528            msg = new MessageEvent(MessageEventEnum.DATA_OPERATION_ERROR_UNEXPECTED);529            msg.setDescription(msg.getDescription().replace("%DESCRIPTION%", exception.toString()));530        } finally {531            try {532                if (connection != null) {533                    connection.close();534                }535            } catch (SQLException exception) {536                LOG.warn("Unable to close connection : " + exception.toString());537            }538        }539        return new Answer(msg);540    }541    private CountryEnvironmentParameters loadFromResultSet(ResultSet resultSet) throws SQLException {542        String system = resultSet.getString("cea.System");543        String count = resultSet.getString("cea.Country");544        String env = resultSet.getString("cea.Environment");545        String application = resultSet.getString("cea.application");546        String ip = resultSet.getString("cea.ip");547        String domain = resultSet.getString("cea.domain");548        String url = resultSet.getString("cea.url");549        String urllogin = resultSet.getString("cea.urllogin");550        String var1 = resultSet.getString("cea.Var1");551        String var2 = resultSet.getString("cea.Var2");552        String var3 = resultSet.getString("cea.Var3");553        String var4 = resultSet.getString("cea.Var4");554        String mobileActivity = resultSet.getString("cea.mobileActivity");555        if(mobileActivity == null) mobileActivity="";...

loadFromResultSet

Using AI Code Generation

1package org.cerberus.crud.dao.impl;2import java.sql.ResultSet;3import java.sql.SQLException;4import org.cerberus.crud.entity.CountryEnvironmentParameters;5import org.springframework.jdbc.core.RowMapper;6public class CountryEnvironmentParametersDAO implements RowMapper<CountryEnvironmentParameters> {7    private final String[] databaseColumsName = {8    };9    public CountryEnvironmentParameters mapRow(ResultSet rs, int i) throws SQLException {10        CountryEnvironmentParameters cep = this.loadFromResultSet(rs);11        return cep;12    }13    private CountryEnvironmentParameters loadFromResultSet(ResultSet rs) throws SQLException {14        CountryEnvironmentParameters cep = new CountryEnvironmentParameters();15        cep.setSystem(rs.getString(databaseColumsName[0]));16        cep.setCountry(rs.getString(databaseColumsName[1]));17        cep.setEnvironment(rs.getString(databaseColumsName[2]));18        cep.setParameter(rs.getString(databaseColumsName[3]));19        cep.setValue(rs.getString(databaseColumsName[4]));20        cep.setType(rs.getString(databaseColumsName[5]));21        cep.setDescription(rs.getString(databaseColumsName[6]));22        cep.setDatabase(rs.getString(databaseColumsName[7]));23        cep.setActive(rs.getString(databaseColumsName[8]));24        cep.setDateCreated(rs.getTimestamp(databaseColumsName[9]));25        cep.setUsrCreated(rs.getString(databaseColumsName[10]));26        cep.setDateModif(rs.getTimestamp(databaseColumsName[11]));27        cep.setUsrModif(rs.getString(databaseColumsName[12]));28        return cep;29    }30}

Automation Testing Tutorials

Learn to execute automation testing from scratch with LambdaTest Learning Hub. Right from setting up the prerequisites to run your first automation test, to following best practices and diving deeper into advanced test scenarios. LambdaTest Learning Hubs compile a list of step-by-step guides to help you be proficient with different test automation frameworks i.e. Selenium, Cypress, TestNG etc.