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

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

Source:CampaignDAO.java Github

copy

Full Screen

...115 ResultSet resultSet = preStat.executeQuery();116 try {117 //gets the data118 while (resultSet.next()) {119 objectList.add(this.loadFromResultSet(resultSet));120 }121 //get the total number of rows122 resultSet = preStat.executeQuery("SELECT FOUND_ROWS()");123 int nrTotalRows = 0;124 if (resultSet != null && resultSet.next()) {125 nrTotalRows = resultSet.getInt(1);126 }127 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.128 LOG.error("Partial Result in the query.");129 msg = new MessageEvent(MessageEventEnum.DATA_OPERATION_WARNING_PARTIAL_RESULT);130 msg.setDescription(msg.getDescription().replace("%DESCRIPTION%", "Maximum row reached : " + MAX_ROW_SELECTED));131 response = new AnswerList(objectList, nrTotalRows);132 } else if (objectList.size() <= 0) {133 msg = new MessageEvent(MessageEventEnum.DATA_OPERATION_NO_DATA_FOUND);134 response = new AnswerList(objectList, nrTotalRows);135 } else {136 msg = new MessageEvent(MessageEventEnum.DATA_OPERATION_OK);137 msg.setDescription(msg.getDescription().replace("%ITEM%", OBJECT_NAME).replace("%OPERATION%", "SELECT"));138 response = new AnswerList(objectList, nrTotalRows);139 }140 } catch (SQLException exception) {141 LOG.error("Unable to execute query : " + exception.toString());142 msg = new MessageEvent(MessageEventEnum.DATA_OPERATION_ERROR_UNEXPECTED);143 msg.setDescription(msg.getDescription().replace("%DESCRIPTION%", exception.toString()));144 } finally {145 if (resultSet != null) {146 resultSet.close();147 }148 }149 } catch (SQLException exception) {150 LOG.error("Unable to execute query : " + exception.toString());151 msg = new MessageEvent(MessageEventEnum.DATA_OPERATION_ERROR_UNEXPECTED);152 msg.setDescription(msg.getDescription().replace("%DESCRIPTION%", exception.toString()));153 } finally {154 if (preStat != null) {155 preStat.close();156 }157 }158 } catch (SQLException exception) {159 LOG.error("Unable to execute query : " + exception.toString());160 msg = new MessageEvent(MessageEventEnum.DATA_OPERATION_ERROR_UNEXPECTED);161 msg.setDescription(msg.getDescription().replace("%DESCRIPTION%", exception.toString()));162 } finally {163 try {164 if (!this.databaseSpring.isOnTransaction()) {165 if (connection != null) {166 connection.close();167 }168 }169 } catch (SQLException exception) {170 LOG.warn("Unable to close connection : " + exception.toString());171 }172 }173 response.setResultMessage(msg);174 response.setDataList(objectList);175 return response;176 }177 @Override178 public AnswerItem readByKey(String key) {179 AnswerItem<Campaign> ans = new AnswerItem<>();180 MessageEvent msg = null;181 StringBuilder query = new StringBuilder();182 query.append("SELECT * FROM campaign cpg WHERE campaign = ?");183 try (Connection connection = databaseSpring.connect();184 PreparedStatement preStat = connection.prepareStatement(query.toString())) {185 // Prepare and execute query186 preStat.setString(1, key);187 188 try(ResultSet resultSet = preStat.executeQuery();) {189 while (resultSet.next()) {190 ans.setItem(loadFromResultSet(resultSet));191 }192 msg = new MessageEvent(MessageEventEnum.DATA_OPERATION_OK).resolveDescription("ITEM", OBJECT_NAME)193 .resolveDescription("OPERATION", "SELECT");194 }catch (SQLException exception) {195 LOG.error("Unable to execute query : " + exception.toString());196 msg = new MessageEvent(MessageEventEnum.DATA_OPERATION_ERROR_UNEXPECTED);197 msg.setDescription(msg.getDescription().replace("%DESCRIPTION%", exception.toString()));198 }199 } catch (Exception e) {200 LOG.warn("Unable to execute query : " + e.toString());201 msg = new MessageEvent(MessageEventEnum.DATA_OPERATION_ERROR_UNEXPECTED).resolveDescription("DESCRIPTION",202 e.toString());203 } finally {204 // We always set the result message205 ans.setResultMessage(msg);206 }207 return ans;208 }209 @Override210 public AnswerItem readByKeyTech(int key) {211 AnswerItem<Campaign> ans = new AnswerItem<>();212 MessageEvent msg = null;213 StringBuilder query = new StringBuilder();214 query.append("SELECT * FROM campaign cpg WHERE campaignid = ?");215 try (Connection connection = databaseSpring.connect();216 PreparedStatement preStat = connection.prepareStatement(query.toString())) {217 // Prepare and execute query218 preStat.setInt(1, key);219 try(ResultSet resultSet = preStat.executeQuery()){220 while (resultSet.next()) {221 ans.setItem(loadFromResultSet(resultSet));222 }223 msg = new MessageEvent(MessageEventEnum.DATA_OPERATION_OK).resolveDescription("ITEM", OBJECT_NAME)224 .resolveDescription("OPERATION", "SELECT");225 }catch (SQLException exception) {226 LOG.error("Unable to execute query : " + exception.toString());227 msg = new MessageEvent(MessageEventEnum.DATA_OPERATION_ERROR_UNEXPECTED);228 msg.setDescription(msg.getDescription().replace("%DESCRIPTION%", exception.toString()));229 } 230 } catch (Exception e) {231 LOG.warn("Unable to execute query : " + e.toString());232 msg = new MessageEvent(MessageEventEnum.DATA_OPERATION_ERROR_UNEXPECTED).resolveDescription("DESCRIPTION",233 e.toString());234 } finally {235 // We always set the result message236 ans.setResultMessage(msg);237 }238 return ans;239 }240 @Override241 public AnswerList<String> readDistinctValuesByCriteria(String searchTerm, Map<String, List<String>> individualSearch, String columnName) {242 AnswerList answer = new AnswerList();243 MessageEvent msg = new MessageEvent(MessageEventEnum.DATA_OPERATION_ERROR_UNEXPECTED);244 msg.setDescription(msg.getDescription().replace("%DESCRIPTION%", ""));245 List<String> distinctValues = new ArrayList<>();246 StringBuilder searchSQL = new StringBuilder();247 List<String> individalColumnSearchValues = new ArrayList<String>();248 StringBuilder query = new StringBuilder();249 query.append("SELECT distinct ");250 query.append(columnName);251 query.append(" as distinctValues FROM campaign cpg");252 query.append(" WHERE 1=1");253 if (!StringUtil.isNullOrEmpty(searchTerm)) {254 searchSQL.append(" and (campaign like ?");255 searchSQL.append(" or distriblist like ?");256 searchSQL.append(" or description like ?)");257 }258 if (individualSearch != null && !individualSearch.isEmpty()) {259 searchSQL.append(" and ( 1=1 ");260 for (Map.Entry<String, List<String>> entry : individualSearch.entrySet()) {261 searchSQL.append(" and ");262 searchSQL.append(SqlUtil.getInSQLClauseForPreparedStatement(entry.getKey(), entry.getValue()));263 individalColumnSearchValues.addAll(entry.getValue());264 }265 searchSQL.append(" )");266 }267 query.append(searchSQL);268 query.append(" group by ifnull(").append(columnName).append(",'')");269 query.append(" order by ").append(columnName).append(" asc");270 // Debug message on SQL.271 if (LOG.isDebugEnabled()) {272 LOG.debug("SQL : " + query.toString());273 }274 try (Connection connection = databaseSpring.connect();275 PreparedStatement preStat = connection.prepareStatement(query.toString());276 Statement stm = connection.createStatement();) {277 int i = 1;278 if (!StringUtil.isNullOrEmpty(searchTerm)) {279 preStat.setString(i++, "%" + searchTerm + "%");280 preStat.setString(i++, "%" + searchTerm + "%");281 preStat.setString(i++, "%" + searchTerm + "%");282 }283 for (String individualColumnSearchValue : individalColumnSearchValues) {284 preStat.setString(i++, individualColumnSearchValue);285 }286 try(ResultSet resultSet = preStat.executeQuery();287 ResultSet rowSet = stm.executeQuery("SELECT FOUND_ROWS()");) {288 //gets the data289 while (resultSet.next()) {290 distinctValues.add(resultSet.getString("distinctValues") == null ? "" : resultSet.getString("distinctValues"));291 }292 293 int nrTotalRows = 0;294 if (rowSet != null && rowSet.next()) {295 nrTotalRows = rowSet.getInt(1);296 }297 if (distinctValues.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.298 LOG.error("Partial Result in the query.");299 msg = new MessageEvent(MessageEventEnum.DATA_OPERATION_WARNING_PARTIAL_RESULT);300 msg.setDescription(msg.getDescription().replace("%DESCRIPTION%", "Maximum row reached : " + MAX_ROW_SELECTED));301 answer = new AnswerList(distinctValues, nrTotalRows);302 } else if (distinctValues.size() <= 0) {303 msg = new MessageEvent(MessageEventEnum.DATA_OPERATION_NO_DATA_FOUND);304 answer = new AnswerList(distinctValues, nrTotalRows);305 } else {306 msg = new MessageEvent(MessageEventEnum.DATA_OPERATION_OK);307 msg.setDescription(msg.getDescription().replace("%ITEM%", OBJECT_NAME).replace("%OPERATION%", "SELECT"));308 answer = new AnswerList(distinctValues, nrTotalRows);309 }310 }catch (SQLException exception) {311 LOG.error("Unable to execute query : " + exception.toString());312 msg = new MessageEvent(MessageEventEnum.DATA_OPERATION_ERROR_UNEXPECTED);313 msg.setDescription(msg.getDescription().replace("%DESCRIPTION%", exception.toString()));314 }315 } catch (Exception e) {316 LOG.warn("Unable to execute query : " + e.toString());317 msg = new MessageEvent(MessageEventEnum.DATA_OPERATION_ERROR_UNEXPECTED).resolveDescription("DESCRIPTION",318 e.toString());319 } finally {320 // We always set the result message321 answer.setResultMessage(msg);322 }323 answer.setResultMessage(msg);324 answer.setDataList(distinctValues);325 return answer;326 }327 @Override328 public Answer create(Campaign object) {329 MessageEvent msg = null;330 StringBuilder query = new StringBuilder();331 query.append("INSERT INTO campaign (`campaign`, `DistribList`, `NotifyStartTagExecution`, `NotifyEndTagExecution`, `Description`) ");332 query.append("VALUES (?,?,?,?,?)");333 // Debug message on SQL.334 if (LOG.isDebugEnabled()) {335 LOG.debug("SQL : " + query.toString());336 }337 Connection connection = this.databaseSpring.connect();338 try {339 PreparedStatement preStat = connection.prepareStatement(query.toString());340 try {341 int i = 1;342 preStat.setString(i++, object.getCampaign());343 preStat.setString(i++, object.getDistribList());344 preStat.setString(i++, object.getNotifyStartTagExecution());345 preStat.setString(i++, object.getNotifyEndTagExecution());346 preStat.setString(i++, object.getDescription());347 preStat.executeUpdate();348 msg = new MessageEvent(MessageEventEnum.DATA_OPERATION_OK);349 msg.setDescription(msg.getDescription().replace("%ITEM%", OBJECT_NAME).replace("%OPERATION%", "INSERT"));350 } catch (SQLException exception) {351 LOG.error("Unable to execute query : " + exception.toString());352 if (exception.getSQLState().equals(SQL_DUPLICATED_CODE)) { //23000 is the sql state for duplicate entries353 msg = new MessageEvent(MessageEventEnum.DATA_OPERATION_ERROR_DUPLICATE);354 msg.setDescription(msg.getDescription().replace("%ITEM%", OBJECT_NAME).replace("%OPERATION%", "INSERT").replace("%REASON%", exception.toString()));355 } else {356 msg = new MessageEvent(MessageEventEnum.DATA_OPERATION_ERROR_UNEXPECTED);357 msg.setDescription(msg.getDescription().replace("%DESCRIPTION%", exception.toString()));358 }359 } finally {360 preStat.close();361 }362 } catch (SQLException exception) {363 LOG.error("Unable to execute query : " + exception.toString());364 msg = new MessageEvent(MessageEventEnum.DATA_OPERATION_ERROR_UNEXPECTED);365 msg.setDescription(msg.getDescription().replace("%DESCRIPTION%", exception.toString()));366 } finally {367 try {368 if (connection != null) {369 connection.close();370 }371 } catch (SQLException exception) {372 LOG.error("Unable to close connection : " + exception.toString());373 }374 }375 return new Answer(msg);376 }377 @Override378 public Answer update(Campaign object) {379 MessageEvent msg = null;380 final String query = "UPDATE campaign cpg SET campaign = ?, DistribList = ?, NotifyStartTagExecution = ?, NotifyEndTagExecution = ?, Description = ? WHERE campaignID = ?";381 // Debug message on SQL.382 if (LOG.isDebugEnabled()) {383 LOG.debug("SQL : " + query);384 }385 Connection connection = this.databaseSpring.connect();386 try {387 PreparedStatement preStat = connection.prepareStatement(query);388 try {389 int i = 1;390 preStat.setString(i++, object.getCampaign());391 preStat.setString(i++, object.getDistribList());392 preStat.setString(i++, object.getNotifyStartTagExecution());393 preStat.setString(i++, object.getNotifyEndTagExecution());394 preStat.setString(i++, object.getDescription());395 preStat.setInt(i++, object.getCampaignID());396 preStat.executeUpdate();397 msg = new MessageEvent(MessageEventEnum.DATA_OPERATION_OK);398 msg.setDescription(msg.getDescription().replace("%ITEM%", OBJECT_NAME).replace("%OPERATION%", "UPDATE"));399 } catch (SQLException exception) {400 LOG.error("Unable to execute query : " + exception.toString());401 msg = new MessageEvent(MessageEventEnum.DATA_OPERATION_ERROR_UNEXPECTED);402 msg.setDescription(msg.getDescription().replace("%DESCRIPTION%", exception.toString()));403 } finally {404 preStat.close();405 }406 } catch (SQLException exception) {407 LOG.error("Unable to execute query : " + exception.toString());408 msg = new MessageEvent(MessageEventEnum.DATA_OPERATION_ERROR_UNEXPECTED);409 msg.setDescription(msg.getDescription().replace("%DESCRIPTION%", exception.toString()));410 } finally {411 try {412 if (connection != null) {413 connection.close();414 }415 } catch (SQLException exception) {416 LOG.warn("Unable to close connection : " + exception.toString());417 }418 }419 return new Answer(msg);420 }421 @Override422 public Answer delete(Campaign object) {423 MessageEvent msg = null;424 final String query = "DELETE FROM campaign WHERE campaignID = ? ";425 // Debug message on SQL.426 if (LOG.isDebugEnabled()) {427 LOG.debug("SQL : " + query);428 }429 Connection connection = this.databaseSpring.connect();430 try {431 PreparedStatement preStat = connection.prepareStatement(query);432 try {433 preStat.setInt(1, object.getCampaignID());434 preStat.executeUpdate();435 msg = new MessageEvent(MessageEventEnum.DATA_OPERATION_OK);436 msg.setDescription(msg.getDescription().replace("%ITEM%", OBJECT_NAME).replace("%OPERATION%", "DELETE"));437 } catch (SQLException exception) {438 LOG.error("Unable to execute query : " + exception.toString());439 msg = new MessageEvent(MessageEventEnum.DATA_OPERATION_ERROR_UNEXPECTED);440 msg.setDescription(msg.getDescription().replace("%DESCRIPTION%", exception.toString()));441 } finally {442 preStat.close();443 }444 } catch (SQLException exception) {445 LOG.error("Unable to execute query : " + exception.toString());446 msg = new MessageEvent(MessageEventEnum.DATA_OPERATION_ERROR_UNEXPECTED);447 msg.setDescription(msg.getDescription().replace("%DESCRIPTION%", exception.toString()));448 } finally {449 try {450 if (connection != null) {451 connection.close();452 }453 } catch (SQLException exception) {454 LOG.warn("Unable to close connection : " + exception.toString());455 }456 }457 return new Answer(msg);458 }459 @Override460 public Campaign loadFromResultSet(ResultSet rs) throws SQLException {461 int campID = ParameterParserUtil.parseIntegerParam(rs.getString("cpg.campaignID"), 0);462 String camp = ParameterParserUtil.parseStringParam(rs.getString("cpg.campaign"), "");463 String distribList = ParameterParserUtil.parseStringParam(rs.getString("cpg.DistribList"), "");464 String notifyStartTagExecution = ParameterParserUtil.parseStringParam(rs.getString("cpg.NotifyStartTagExecution"), "N");465 String notifyEndTagExecution = ParameterParserUtil.parseStringParam(rs.getString("cpg.NotifyEndTagExecution"), "N");466 String desc = ParameterParserUtil.parseStringParam(rs.getString("cpg.description"), "");467 return factoryCampaign.create(campID, camp, distribList, notifyStartTagExecution, notifyEndTagExecution, desc);468 }469}...

Full Screen

Full Screen

loadFromResultSet

Using AI Code Generation

copy

Full Screen

1public static Campaign loadFromResultSet(ResultSet rs) throws SQLException {2 String campaign = ParameterParserUtil.parseStringParam(rs.getString("Campaign"), "");3 String campaignName = ParameterParserUtil.parseStringParam(rs.getString("CampaignName"), "");4 String dateCreated = ParameterParserUtil.parseStringParam(rs.getString("DateCreated"), "");5 String dateStart = ParameterParserUtil.parseStringParam(rs.getString("DateStart"), "");6 String dateEnd = ParameterParserUtil.parseStringParam(rs.getString("DateEnd"), "");7 String active = ParameterParserUtil.parseStringParam(rs.getString("Active"), "");8 String description = ParameterParserUtil.parseStringParam(rs.getString("Description"), "");9 String campaignType = ParameterParserUtil.parseStringParam(rs.getString("CampaignType"), "");10 String campaignMode = ParameterParserUtil.parseStringParam(rs.getString("CampaignMode"), "");11 String campaignStatus = ParameterParserUtil.parseStringParam(rs.getString("CampaignStatus"), "");12 String campaignProgress = ParameterParserUtil.parseStringParam(rs.getString("CampaignProgress"), "");13 String campaignWeight = ParameterParserUtil.parseStringParam(rs.getString("CampaignWeight"), "");14 String campaignValue = ParameterParserUtil.parseStringParam(rs.getString("CampaignValue"), "");15 String campaignValue1 = ParameterParserUtil.parseStringParam(rs.getString("CampaignValue1"), "");16 String campaignValue2 = ParameterParserUtil.parseStringParam(rs.getString("CampaignValue2"), "");17 String campaignValue3 = ParameterParserUtil.parseStringParam(rs.getString("CampaignValue3"), "");18 String campaignValue4 = ParameterParserUtil.parseStringParam(rs.getString("CampaignValue4"), "");19 String campaignValue5 = ParameterParserUtil.parseStringParam(rs.getString("CampaignValue5"), "");20 String campaignValue6 = ParameterParserUtil.parseStringParam(rs.getString("CampaignValue6"), "");21 String campaignValue7 = ParameterParserUtil.parseStringParam(rs.getString("CampaignValue7"), "");22 String campaignValue8 = ParameterParserUtil.parseStringParam(rs.getString("CampaignValue8"), "");23 String campaignValue9 = ParameterParserUtil.parseStringParam(rs.getString("CampaignValue9"), "");24 String campaignValue10 = ParameterParserUtil.parseStringParam(rs.getString("CampaignValue10"), "");25 String campaignValue11 = ParameterParserUtil.parseStringParam(rs.getString("CampaignValue11"), "");26 String campaignValue12 = ParameterParserUtil.parseStringParam(rs.getString("CampaignValue12"), "");27 String campaignValue13 = ParameterParserUtil.parseStringParam(rs.getString("CampaignValue

Full Screen

Full Screen

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.

LambdaTest Learning Hubs:

YouTube

You could also refer to video tutorials over LambdaTest YouTube channel to get step by step demonstration from industry experts.

Run Cerberus-source automation tests on LambdaTest cloud grid

Perform automation testing on 3000+ real desktop and mobile devices online.

Try LambdaTest Now !!

Get 100 minutes of automation test minutes FREE!!

Next-Gen App & Browser Testing Cloud

Was this article helpful?

Helpful

NotHelpful