domainobjectfactory.java

利用java反射机制

    /** Getter for property removedCount.
     * @return Value of property removedCount.
     *
     */
    public int getRemovedCount() {
        if (dataWriter == null){
            throw new NullPointerException("DataWriter not initialized");
        }        
        return dataWriter.getRemovedCount();
    }
    
    /** Getter for property createdCount.
     * @return Value of property createdCount.
     *
     */
    public int getCreatedCount() {
        if (dataWriter == null){
            throw new NullPointerException("DataWriter not initialized");
        }        
        return dataWriter.getCreatedCount();
    }
    
    /** Getter for property modifiedCount.
     * @return Value of property modifiedCount.
     *
     */
    public int getModifiedCount() {
        if (dataWriter == null){
            throw new NullPointerException("DataWriter not initialized");
        }        
        return dataWriter.getModifiedCount();
    }
    
    /** Getter for property dataWriter.
     * @return Value of property dataWriter.
     *
     */
    public DataWriter getDataWriter() {
        return dataWriter;
    }
    
    /** Setter for property dataWriter.
     * @param dataWriter New value of property dataWriter.
     *
     */
    public void setDataWriter(DataWriter dataWriter) {
        this.dataWriter = dataWriter;
    }
    
    /** Getter for property synchronizedAccess.
     * @return Value of property synchronizedAccess.
     *
     */
    public boolean isSynchronizedAccess() {
        return synchronizedAccess;
    }
    
    /** Setter for property synchronizedAccess.
     * @param synchronizedAccess New value of property synchronizedAccess.
     *
     */
    protected void setSynchronizedAccess(boolean synchronizedAccess) {
        if (synchronizedAccess){
            //this.objectProperties = Collections.synchronizedMap(objectProperties);
            this.removedObjects = Collections.synchronizedList(removedObjects);
            this.objectList = Collections.synchronizedList(objectList);
            this.synchronizedAccess = synchronizedAccess;
        }
    }
    
    /** Getter for property lazyLoading.
     * @return Value of property lazyLoading.
     *
     */
    public boolean isLazyLoading() {
        return lazyLoading;
    }
    
    /** Setter for property lazyLoading.
     * @param lazyLoading New value of property lazyLoading.
     *
     */
    public void setLazyLoading(boolean lazyLoading) {
        this.lazyLoading = lazyLoading;
    }
    
    /** Getter for property pageSize.
     * @return Value of property pageSize.
     *
     */
    public int getPageSize() {
        return pageSize;
    }
    
    /** Setter for property pageSize.
     * @param pageSize New value of property pageSize.
     *
     */
    public void setPageSize(int pageSize) {
        if (pageSize < 0){
            throw new IllegalArgumentException("Invalid Page size: " + pageSize);
        }
        this.pageSize = pageSize;
    }
    
    public PageHolder getPage(int pageNumber) {
        PageHolder pageHolder = new PageHolder();
        pageHolder.setObjectsTotal(this.objectList.size());
        if (getPageSize() == 0){
            pageHolder.setPageNumber(1);
            pageHolder.setPagesTotal(1);
            pageHolder.setPage(this.objectList);
        }else{
            List page = new ArrayList();
            if (this.objectList.isEmpty()){
                pageHolder.setPageNumber(0);
                pageHolder.setPagesTotal(0);
                pageHolder.setPage(page);
            }else{
                double d1 = new Integer(this.objectList.size()).doubleValue();
                double d2 = new Integer(this.pageSize).doubleValue();
                double d3 = java.lang.Math.ceil(d1 / d2);
                int pagesTotal = (new Double(d3)).intValue();
                pageHolder.setPagesTotal(pagesTotal);
                if (pageNumber > pagesTotal){
                    pageNumber = pagesTotal;
                }else if (pageNumber < 1){
                    pageNumber = 1;
                }else{
                    //
                }
                pageHolder.setPageNumber(pageNumber);
                ListIterator li = this.objectList.listIterator((pageNumber - 1) * getPageSize());
                int count = 0;
                while (li.hasNext() && count < getPageSize()){
                    Object obj = li.next();
                    page.add(obj);
                    count ++;
                }
                pageHolder.setPage(page);
            }
        }
        return pageHolder;
    }
    
    /**
     *  return true if row exists in DB
     *
     */
    public boolean exists(List seachList) {
        if (getCount(seachList) > 0){
            return true;
        }
        return false;
    }
    
    public int getCount(List seachList) {
        if (this.metaData == null){
            populateMetaData();
        }
        //if (schema == null) {
        //throw new NullPointerException("Schema name is missing");
        //}
        if (this.table == null) {
            throw new NullPointerException("Table name is missing");
        }
        ResultSet rs = null;
        int count = -1;
        try{
            List arg = new ArrayList(seachList.size());
            StringBuffer sql = new StringBuffer("SELECT COUNT(*) FROM ");
            String fullTableName = this.table;
            if (this.schema != null){
                fullTableName = this.schema + "." + fullTableName;
            }
            if (this.catalog != null){
                fullTableName = this.catalog + "." + fullTableName;
            }
            sql.append(fullTableName);
            sql.append(" WHERE ");
            Iterator iter = seachList.iterator();
            while (iter.hasNext()){
                SearchCriteriaHolder entry = (SearchCriteriaHolder) iter.next();
                String fieldName = entry.getFieldName();
                String functionName = entry.getFunctionName();
                String operator = entry.getOperator();
                String bool = entry.getBooleanCondition();
                Object value = entry.getSearchValue();
                
                int idx = this.metaData.getColumnIndexByFieldName(fieldName);
                String colName = this.metaData.getFullColumnName(idx);
                if (functionName != null){
                    sql.append(functionName);
                    sql.append("(");
                    sql.append(colName);
                    sql.append(")");
                }else{
                    sql.append(colName);
                }
                if (value == null){
                    sql.append(" IS NULL ");
                }else{
                    sql.append(" ").append(operator).append(" ? ");
                    arg.add(value);
                }
                sql.append(bool).append(" ");
            }
            int len = sql.length();
            sql = sql.delete(len - 4, len - 1);
            rs = dbServices.getResultSet(sql.toString(), arg);
            if (rs.next()){
                count = rs.getInt(1);
            }
        }catch(SQLException sqle){
            throw new RuntimeException(sqle);
        }finally{
            try{
                if (rs != null){
                    rs.close();
                }
                dbServices.release(false);
            }catch(SQLException sqle){
                throw new RuntimeException(sqle);
            }
        }
        return count;
    }
    
    /** Getter for property generateSQLOnly.
     * @return Value of property generateSQLOnly.
     *
     */
    public boolean isGenerateSQLOnly() {
        return generateSQLOnly;
    }
    
    /** Setter for property generateSQLOnly.
     * @param generateSQLOnly New value of property generateSQLOnly.
     *
     */
    public void setGenerateSQLOnly(boolean generateSQLOnly) {
        this.generateSQLOnly = generateSQLOnly;
    }
    
    public java.util.List getGeneratedSQL() {
        if (dataWriter == null){
            throw new NullPointerException("DataWriter not initialized");
        }        
        return this.dataWriter.getGeneratedSQL();
    }
    
    public java.lang.String getGeneratedSQLasXML() {
        if (dataWriter == null){
            throw new NullPointerException("DataWriter not initialized");
        }
        return this.dataWriter.getGeneratedSQLasXML();
    }    
    
    /** Getter for property append.
     * @return Value of property append.
     *
     */
    public boolean isAppend() {
        return append;
    }
    
    /** Setter for property append.
     * @param append New value of property append.
     *
     */
    public void setAppend(boolean append) {
        this.append = append;
    }
    
    public java.lang.Throwable getWhatIsWrong() {
        if (this.dataWriter == null){
            return null;
        }
        return this.dataWriter.getWhatIsWrong();
    }
    
    /** Getter for property catalog.
     * @return Value of property catalog.
     *
     */
    public java.lang.String getCatalog() {
        return catalog;
    }
    
    /** Setter for property catalog.
     * @param catalog New value of property catalog.
     *
     */
    public void setCatalog(java.lang.String catalog) {
        this.catalog = catalog;
    }
    
    /** Getter for property noFullColumnName.
     * @return Value of property noFullColumnName.
     *
     */
    public boolean isNoFullColumnName() {
        return noFullColumnName;
    }
    
    /** Setter for property noFullColumnName.
     * @param noFullColumnName New value of property noFullColumnName.
     *
     */
    public void setNoFullColumnName(boolean noFullColumnName) {
        this.noFullColumnName = noFullColumnName;
    }
    
}