existsfiledba.java

电信的网厅的整站代码

package com.doone.upload;

import java.util.Map;
import java.util.HashMap;
import com.doone.util.FileLogger;
import com.doone.data.DacClient;
import com.doone.data.DataTable;
import com.doone.data.DataSet;
import com.doone.iossp.EMessage;
import com.doone.data.DataRow;


/**
 *
 * <p>Title:上传文件后对数据库的操作 </p>
 *
 * <p>Description: </p>
 *
 * <p>Copyright: Copyright (c) 2005</p>
 *
 * <p>Company: New Doone</p>
 *
 * @author wull
 * @version 1.0
 */
public class ExistsFileDBA {

    private DacClient _dac = null;
    private DataTable _dataTable = null;

    private int time = 1000;
    private static String Sql_upload = "SELECT COUNT(FILEID) COUNTFILEID FROM TD_UPLOAD WHERE PATH=?";

    private static String Sql_insert_upload = "INSERT INTO TD_UPLOAD(FILEID,FILENAME,PATH,CONTENTTYPE,STATE) VALUES(SEQ_UPLOADID.nextval,?,?,?,'E')";

    public ExistsFileDBA() {
        try {
            _dac = new DacClient();
            FileLogger.getLogger().debug("ExistsFileDBA数据库链接：" + _dac);
        } catch (Exception ex) {
            FileLogger.getLogger().debug("ExistsFileDBA数据库链接出错：" +
                                         ex.getMessage());
        }

    }


    /**
     * 查看上传的文件有没有同名
     * 可用传入字符串，中间用逗号间隔
     * @return String
     */
    public  boolean SearchFileName(String filename){
        boolean result = false;
        Object[] values = new Object[1];
            values[0] = filename;
        try {
            _dataTable = _dac.executeQuery(Sql_upload,values);
            for( int i = 0; i < _dataTable.getRows ().getCount (); i++ ) {
                DataRow dr = _dataTable.getRow(i);
                String count = dr.getString("COUNTFILEID");
                //只有当为0条时才可以插入上传的数据
                if("0".equals(count))result = true;
            }

        } catch (Exception ex) {
               FileLogger.getLogger().warn("SearchFileName error："+ex.getMessage());
        }

     return result;
    }

    /**
     * 当上传一个文件时,把文件名，或文件夹入数据库。
     * 在判断有没有重名时取整个路径最后一个“/”来取出文件名。
     * @return String
     */
    public String UploadToDataBaes(String filename,String path,String type){
        int i = 0;
        Object[] values = new Object[3];
        values[0] = filename;
        values[1] = path;
        values[2] = type;
        try {
           i = _dac.executeUpdate(Sql_insert_upload, time, values);
        } catch (Exception ex) {
             FileLogger.getLogger().warn("UploadToDataBaes error："+ex.getMessage());
        }
        return String.valueOf(i);
    }

//    /**
//     * 取出菜单树，目前暂时只有业务受理，自助服务用到。
//     * @param cityCode String
//     * @param menuCode String
//     * @return DataTable
//     */
//    public  DataTable TreeList(String cityCode, String menuCode) {
//        String sqlStr = "";
//        Object[] aParam = null;
//        if(!"MYSELF".equals(menuCode)){
//             sqlStr = "SELECT A.TREEID TREEID,A.NAMET PARENT, B.NAMET NAMET, B.URL URL,B.MENUCODE MENUCODE FROM TD_TREE A, TD_TREE B WHERE A.TREEID = B.PID  AND A.STATE='E' AND B.CITYCODE = ? AND B.MENUCODE = ? ORDER BY A.MENUCODE,B.SEQNUMBER";
//                aParam = new Object[2];
//                aParam[0] = cityCode;
//                aParam[1] = menuCode;
//         }else{
//             sqlStr = "SELECT A.TREEID TREEID,A.NAMET PARENT, B.NAMET NAMET, B.URL URL,B.MENUCODE MENUCODE FROM TD_TREE A, TD_TREE B WHERE A.TREEID = B.PID  AND A.STATE='E' AND B.CITYCODE = ? AND (B.MENUCODE = ? OR  B.MENUCODE = ?)  ORDER BY A.MENUCODE,B.SEQNUMBER";
//                 aParam = new Object[3];
//                 aParam[0] = cityCode;
//                 aParam[1] = menuCode;
//                 aParam[2] = "SELFQUERY";
//         }
//       try {
//           DacClient db = new DacClient();
//           return db.executeQuery(sqlStr,aParam);
//       } catch (Exception ex) {
//           FileLogger.getLogger().warn(ex);
//           throw new RuntimeException(ex);
//       }
//   }
    /**
     * wull 2006-2-18
     * 用来做为首页快菜单配置。
     * 并入后台权限后，取菜单树发性的改变，以后将替换上面的td_tree表。
     * 注：在取业务受理时，则同时把信息查询取出来，
     * 
     * @param cityCode String
     * @param menuCode String
     * @return DataTable
     */
    public  DataTable TreeList(String orgId, String menuCode) {
     String sqlStr = "";
     Object[] aParam = null;
     // A.TREEID TREEID,A.NAMET PARENT, B.NAMET NAMET, B.URL URL,B.MENUCODE MENUCODE


     //select t.ORGANISECODE, t.PURVIEWID, t.UPPURVIEWID, t.PURVIEWNAME, t.PURVIEWCODE,'' title, t.PURVIEWOPER, t.purvieworder from vf_stafforgpurv t
     //connect by prior purviewid = uppurviewid and t.ORGANISECODE = '001' start with uppurviewid = 553 and t.ORGANISECODE = '001'
     /*wull 2006-5-10 修改传值*/
     StringBuffer sql = new StringBuffer();
     /*t.ORGANISECODE,去掉*/
     sql.append(" select distinct  t.PURVIEWID, t.UPPURVIEWID,");
     sql.append(
             " t.PURVIEWNAME, t.PURVIEWCODE,'' TITLE, t.PURVIEWOPER, t.purvieworder");
     sql.append(" from vf_stafforgpurv t ");
     sql.append(" connect by prior purviewid = uppurviewid and ");
     sql.append(" t.ORGANISECODE like ? ");//'009591%'
     //sql.append(" t.organiseid = ? ");
     sql.append(" start with purviewcode = ? ");
      //orgId只能为591类型的三个字符
     orgId = "009"+orgId+"%";
     if(!"SLF005".equals(menuCode)){

          sqlStr = "SELECT A.PURVIEWID TREEID,A.PURVIEWNAME PARENT, B.PURVIEWNAME NAMET, B.PURVIEWOPER URL,B.PURVIEWCODE MENUCODE ,b.PURVIEWID  FROM ("+sql.toString()+") A, ("+sql.toString()+") B WHERE A.PURVIEWID = B.UPPURVIEWID";
          //System.out.print("sqlStr=="+sqlStr);
          aParam = new Object[4];
             aParam[0] = orgId;
             aParam[1] = menuCode;
             aParam[2] = orgId;
             aParam[3] = menuCode;
         	 //System.out.println("sqlStr=");
      }else{
          sql.append(" or purviewcode = ? ");
          sqlStr = "SELECT A.PURVIEWID TREEID,A.PURVIEWNAME PARENT, B.PURVIEWNAME NAMET, B.PURVIEWOPER URL,B.PURVIEWCODE MENUCODE ,b.PURVIEWID FROM ("+sql.toString()+") A, ("+sql.toString()+") B WHERE A.PURVIEWID = B.UPPURVIEWID";
          //System.out.print("sqlStr=="+sqlStr);   
          aParam = new Object[6];
              aParam[0] = orgId;
              aParam[1] = menuCode;
              aParam[2] = "SLF006";
              aParam[3] = orgId;
              aParam[4] = menuCode;
              aParam[5] = "SLF006";

      }
    try {
//    	System.out.println(sqlStr);
//      	System.out.println("orgId="+orgId);
//      	System.out.println("menuCode="+menuCode);  	
        DacClient db = new DacClient();
        return db.executeQuery(sqlStr,aParam);
    } catch (Exception ex) {
        FileLogger.getLogger().warn(ex);
        throw new RuntimeException(ex);
    }
 }

}