Package com.dotmarketing.common.db

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

511
512
513
514
515
516
517
518
519
520
521
  public Integer countQueueElementsGroupByBundleId() throws DotPublisherException {
    try{
      DotConnect dc = new DotConnect();
      dc.setSQL(COUNTENTRIESGROUPED);
      return Integer.parseInt(dc.loadObjectResults().get(0).get("count").toString());
    }catch(Exception e){
      Logger.error(PublisherUtil.class,e.getMessage(),e);
      throw new DotPublisherException("Unable to get list of elements with error:"+e.getMessage(), e);
    }
  }
View Full Code Here
527
528
529
530
531
532
533
534
535
536
537
      DotConnect dc = new DotConnect();
      dc.setSQL(GETENTRY);

      dc.addParam(asset);

      return mapper.mapRows(dc.loadObjectResults());
    }catch(Exception e){
      Logger.error(PublisherUtil.class,e.getMessage(),e);
      throw new DotPublisherException("Unable to get list of elements with error:"+e.getMessage(), e);
    }
  }
View Full Code Here
403
404
405
406
407
408
409
410
411
412
413
        String contentlets=
            "select identifier,inode, mod_date from " + table +
            " where working="+DbConnectionFactory.getDBFalse()+" and live="+DbConnectionFactory.getDBTrue()+
            " order by identifier asc, mod_date desc";
        dc.setSQL(contentlets);
        List<Map<String,Object>> results=dc.loadObjectResults();
        for(Map<String,Object> rr : results) {
            String identifier=(String)rr.get("identifier");
            String inode=(String)rr.get("inode");
            if(UtilMethods.isSet(identifier) && !identifier.equals(lastId)) {
                lastId=identifier;
View Full Code Here
978
979
980
981
982
983
984
985
986
987
988
            // lets reindex all the content under each fixed folder

          dc.setSQL("select remote_inode from " + tableName + " where endpoint_id = ?");
            dc.addParam(serverId);
            results = dc.loadObjectResults();

            for (Map<String, Object> result : results) {
              final String newFolderInode = (String) result.get("remote_inode");
              try {
View Full Code Here
1027
1028
1029
1030
1031
1032
1033
1034
1035
1036
1037
        try {

            dc.setSQL("select local_inode, remote_inode from " + tableName + " where endpoint_id = ?");
            dc.addParam(serverId);
            List<Map<String,Object>> results = dc.loadObjectResults();

            for (Map<String, Object> result : results) {
              String oldStructureInode = (String) result.get("local_inode");
              String newStructureInode = (String) result.get("remote_inode");
View Full Code Here
1081
1082
1083
1084
1085
1086
1087
1088
1089
1090
1091
            // 3.1) delete old STRUCTURE row
            // lets save old structure columns values first
            dc.setSQL("select * from structure where inode = ?");
            dc.addParam(oldStructureInode);
            Map<String, Object> oldFolderRow = dc.loadObjectResults().get(0);
            String name = (String) oldFolderRow.get("name");
            String description = (String) oldFolderRow.get("description");
            Boolean defaultStructure = DbConnectionFactory.isDBTrue(oldFolderRow.get("default_structure").toString());
            String reviewInterval = (String) oldFolderRow.get("review_interval");
            String reviewerRole = (String) oldFolderRow.get("reviewer_role");
View Full Code Here
1110
1111
1112
1113
1114
1115
1116
1117
1118
1119
1120
            // 3.2) delete old INODE row

            dc.setSQL("select * from inode where inode = ?");
            dc.addParam(oldStructureInode);
            Map<String, Object> oldInodeRow = dc.loadObjectResults().get(0);
            String owner = (String) oldInodeRow.get("owner");
            Date idate = (Date) oldInodeRow.get("idate");
            String type = (String) oldInodeRow.get("type");

            dc.executeStatement("delete from inode where inode = '" + oldStructureInode + "'");
View Full Code Here
1186
1187
1188
1189
1190
1191
1192
1193
1194
1195
1196
        try {

            //Delete the schemes cache
            dc.setSQL( "SELECT local_inode, remote_inode FROM " + tableName + " WHERE endpoint_id = ?" );
            dc.addParam( serverId );
            List<Map<String, Object>> results = dc.loadObjectResults();
            for ( Map<String, Object> result : results ) {

              String oldWorkflowId = (String) result.get( "local_inode" );
                String newWorkflowId = (String) result.get( "remote_inode" );
View Full Code Here
1225
1226
1227
1228
1229
1230
1231
1232
1233
1234
1235
            // 3) delete old WORKFLOW_SCHEME row
            // lets save old scheme columns values first
            dc.setSQL("select * from workflow_scheme where id = ?");
            dc.addParam(oldWorkflowId);
            Map<String, Object> oldFolderRow = dc.loadObjectResults().get(0);
            String name = (String) oldFolderRow.get("name");
            String desc = (String) oldFolderRow.get("description");
            Boolean archived = DbConnectionFactory.isDBTrue(oldFolderRow.get("archived").toString());
            Boolean mandatory = DbConnectionFactory.isDBTrue(oldFolderRow.get("mandatory").toString());
            Boolean isDefaultScheme = DbConnectionFactory.isDBTrue(oldFolderRow.get("default_scheme").toString());
View Full Code Here
26
27
28
29
30
31
32
33
34
35
36
   
    public synchronized static int getContentCountToIndex() throws DotDataException {
        try {
            DotConnect dc=new DotConnect();
            dc.setSQL("select count(*) as cc from contentlet_version_info");
            return Integer.parseInt(dc.loadObjectResults().get(0).get("cc").toString());
        }
        finally {
            HibernateUtil.closeSession();
        }
    }
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.