Package com.dotmarketing.common.db

Examples of com.dotmarketing.common.db.DotConnect.loadObjectResults()

626
627
628
629
630
631
632
633
634
635
636
            }

            dc.setSQL("select * from " + resultsTableName + " where endpoint_id = ?");
            dc.addParam(endpointId);

            return dc.loadObjectResults();

        } catch(Exception e) {
            throw new Exception("Error running the "+type.name()+" Integrity Check", e);
        }
    }
View Full Code Here
174
175
176
177
178
179
180
181
182
183
184
      DotConnect dc = new DotConnect();
      dc.setSQL(SELECTSQL);
     
      dc.addParam(bundleId);
     
      List<Map<String, Object>> res = dc.loadObjectResults();
      if(res.size() > 1)
        throw new DotPublisherException("Found duplicate bundle status");
      else {
        if(!res.isEmpty())
          return mapper.mapObject(res.get(0));
View Full Code Here
199
200
201
202
203
204
205
206
207
208
209
  public List<PublishAuditStatus> getAllPublishAuditStatus() throws DotPublisherException {
    try{
      DotConnect dc = new DotConnect();
      dc.setSQL(SELECTSQLALL);
     
      return mapper.mapRows(dc.loadObjectResults());
    }catch(Exception e){
      Logger.debug(PublisherUtil.class,e.getMessage(),e);
      throw new DotPublisherException("Unable to get list of elements with error:"+e.getMessage(), e);
    }finally{
      DbConnectionFactory.closeConnection();
View Full Code Here
216
217
218
219
220
221
222
223
224
225
226
      dc.setSQL(SELECTSQLALL);
     
      dc.setStartRow(offset);
      dc.setMaxRows(limit);
     
      return mapper.mapRows(dc.loadObjectResults());
    }catch(Exception e){
      Logger.debug(PublisherUtil.class,e.getMessage(),e);
      throw new DotPublisherException("Unable to get list of elements with error:"+e.getMessage(), e);
    }
  }
View Full Code Here
734
735
736
737
738
739
740
741
742
743
744
        DotConnect dc = new DotConnect();
        dc.setSQL("SELECT 1 FROM " + folderTable+ " where endpoint_id = ?");
        dc.addParam(endpointId);

        boolean isThereFolderData = !dc.loadObjectResults().isEmpty();

        dc.setSQL("SELECT 1 FROM " + structuresTable+ " where endpoint_id = ?");
        dc.addParam(endpointId);

        boolean isThereStructureData = !dc.loadObjectResults().isEmpty();
View Full Code Here
739
740
741
742
743
744
745
746
747
748
749
        boolean isThereFolderData = !dc.loadObjectResults().isEmpty();

        dc.setSQL("SELECT 1 FROM " + structuresTable+ " where endpoint_id = ?");
        dc.addParam(endpointId);

        boolean isThereStructureData = !dc.loadObjectResults().isEmpty();

        dc.setSQL("SELECT 1 FROM " + schemesTable+ " where endpoint_id = ?");
        dc.addParam(endpointId);

        boolean isThereSchemaData = !dc.loadObjectResults().isEmpty();
View Full Code Here
236
237
238
239
240
241
242
243
244
245
246
      DotConnect dc = new DotConnect();
      dc.setSQL(SELECTSQLMAXDATE);
     
      dc.addParam(Status.BUNDLING.getCode());
     
      List<Map<String, Object>> res = dc.loadObjectResults();
     
      if(!res.isEmpty())
        return (Date) res.get(0).get("max_date");
      return null;
     
View Full Code Here
744
745
746
747
748
749
750
751
752
753
754
        boolean isThereStructureData = !dc.loadObjectResults().isEmpty();

        dc.setSQL("SELECT 1 FROM " + schemesTable+ " where endpoint_id = ?");
        dc.addParam(endpointId);

        boolean isThereSchemaData = !dc.loadObjectResults().isEmpty();

        return isThereFolderData || isThereStructureData || isThereSchemaData;

    }
View Full Code Here
256
257
258
259
260
261
262
263
264
265
266
 
  public Integer countAllPublishAuditStatus() throws DotPublisherException {
    try{
      DotConnect dc = new DotConnect();
      dc.setSQL(SELECTSQLALLCOUNT);
      return Integer.parseInt(dc.loadObjectResults().get(0).get("count").toString());
    }catch(Exception e){
      Logger.debug(PublisherUtil.class,e.getMessage(),e);
      throw new DotPublisherException("Unable to get list of elements with error:"+e.getMessage(), e);
    }
  }
View Full Code Here
755
756
757
758
759
760
761
762
763
764
765
    private boolean doesTableExist(String tableName) throws DotDataException {
        DotConnect dc = new DotConnect();

        if(DbConnectionFactory.isOracle()) {
            dc.setSQL("SELECT COUNT(*) as exist FROM user_tables WHERE table_name='"+tableName.toUpperCase()+"'");
            BigDecimal existTable = (BigDecimal)dc.loadObjectResults().get(0).get("exist");
            return existTable.longValue() > 0;
        } else if(DbConnectionFactory.isPostgres() || DbConnectionFactory.isMySql()) {
            dc.setSQL("SELECT COUNT(table_name) as exist FROM information_schema.tables WHERE Table_Name = '"+tableName+"' ");
            long existTable = (Long)dc.loadObjectResults().get(0).get("exist");
            return existTable > 0;
View Full Code Here
TOP
Copyright © 2018 www.massapi.com. All rights reserved.
All source code are property of their respective owners. Java is a trademark of Sun Microsystems, Inc and owned by ORACLE Inc. Contact coftware#gmail.com.