Package com.dotmarketing.common.db

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

759
760
761
762
763
764
765
766
767
768
769
            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;
        } else if(DbConnectionFactory.isMsSql()) {
            dc.setSQL("SELECT COUNT(*) as exist FROM sysobjects WHERE name = '"+tableName+"'");
            int existTable = (Integer)dc.loadObjectResults().get(0).get("exist");
            return existTable > 0;
View Full Code Here
763
764
765
766
767
768
769
770
771
772
773
            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;
        } else if(DbConnectionFactory.isMsSql()) {
            dc.setSQL("SELECT COUNT(*) as exist FROM sysobjects WHERE name = '"+tableName+"'");
            int existTable = (Integer)dc.loadObjectResults().get(0).get("exist");
            return existTable > 0;
        }  else if(DbConnectionFactory.isH2()) {
            dc.setSQL("SELECT COUNT(1) as exist FROM information_schema.tables WHERE Table_Name = '"+tableName.toUpperCase()+"' ");
            long existTable = (Long)dc.loadObjectResults().get(0).get("exist");
            return existTable > 0;
View Full Code Here
767
768
769
770
771
772
773
774
775
776
777
            dc.setSQL("SELECT COUNT(*) as exist FROM sysobjects WHERE name = '"+tableName+"'");
            int existTable = (Integer)dc.loadObjectResults().get(0).get("exist");
            return existTable > 0;
        }  else if(DbConnectionFactory.isH2()) {
            dc.setSQL("SELECT COUNT(1) as exist FROM information_schema.tables WHERE Table_Name = '"+tableName.toUpperCase()+"' ");
            long existTable = (Long)dc.loadObjectResults().get(0).get("exist");
            return existTable > 0;
        }

        return false;
    }
View Full Code Here
278
279
280
281
282
283
284
285
286
287
288
      dc.addParam(PublishAuditStatus.Status.BUNDLE_SENT_SUCCESSFULLY.getCode());
      dc.addParam(PublishAuditStatus.Status.FAILED_TO_SEND_TO_SOME_GROUPS.getCode());
      dc.addParam(PublishAuditStatus.Status.FAILED_TO_SEND_TO_ALL_GROUPS.getCode());
      dc.addParam(PublishAuditStatus.Status.RECEIVED_BUNDLE.getCode());
      dc.addParam(PublishAuditStatus.Status.PUBLISHING_BUNDLE.getCode());
      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
814
815
816
817
818
819
820
821
822
823
824
           // lets remove from the index all the content under each conflicted folder

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

            for (Map<String, Object> result : results) {
              String oldFolderInode = (String) result.get("local_inode");
              String newFolderInode = (String) result.get("remote_inode");
              String oldFolderIdentifier = (String) result.get("local_identifier");
View Full Code Here
883
884
885
886
887
888
889
890
891
892
893
                // 3.1) delete old FOLDER row
                // lets save old folder columns values first
                dc.setSQL("select * from folder where inode = ?");
                dc.addParam(oldFolderInode);
                Map<String, Object> oldFolderRow = dc.loadObjectResults().get(0);
                String name = (String) oldFolderRow.get("name");
                String title = (String) oldFolderRow.get("title");
                Boolean showOnMenu = DbConnectionFactory.isDBTrue(oldFolderRow.get("show_on_menu").toString());

                    Integer sortOrder = 0;
View Full Code Here
900
901
902
903
904
905
906
907
908
909
910
                Date modDate = (Date) oldFolderRow.get("mod_date");

                // lets save old identifier columns values first
                dc.setSQL("select * from identifier where id = ?");
                dc.addParam(oldFolderIdentifier);
                Map<String, Object> oldIdentifierRow = dc.loadObjectResults().get(0);
                String parentPath = (String) oldIdentifierRow.get("parent_path");
                String assetName = (String) oldIdentifierRow.get("asset_name");
                String hostId = (String) oldIdentifierRow.get("host_inode");
                String assetType = (String) oldIdentifierRow.get("asset_type");
                Date syspublishDate = (Date) oldIdentifierRow.get("syspublish_date");
View Full Code Here
918
919
920
921
922
923
924
925
926
927
928
                // 3.2) delete old INODE row

                dc.setSQL("select * from inode where inode = ?");
                dc.addParam(oldFolderInode);
                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 = '" + oldFolderInode + "'");
View Full Code Here
42
43
44
45
46
47
48
49
50
51
52
      //get the previous version
      dc.setSQL("select * from file_asset, identifier where identifier = identifier.id and identifier = ? and mod_date < ? order by mod_date desc");
      dc.setMaxRows(1);
      dc.addParam(newFile.getIdentifier());
      dc.addParam(newFile.getModDate());
      Map<String, Object> map = dc.loadObjectResults().get(0);
      if(map.size() ==0){
        return true;
      }
      boolean oldShowOnMenu = (DbConnectionFactory.isDBTrue(map.get("show_on_menu").toString()));
      String oldTitle = (String) map.get("title");
View Full Code Here
77
78
79
80
81
82
83
84
85
86
87
      //get the previous version
      dc.setSQL("select * from htmlpage, identifier where identifier = identifier.id and identifier = ? and mod_date < ? order by mod_date desc");
      dc.setMaxRows(1);
      dc.addParam(newFile.getIdentifier());
      dc.addParam(newFile.getModDate());
      Map<String, Object> map = dc.loadObjectResults().get(0);
      if(map.size() ==0){
        return true;
      }
      boolean oldShowOnMenu = (DbConnectionFactory.isDBTrue(map.get("show_on_menu").toString()));
      String oldTitle = (String) map.get("title");
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.