sql上报数据4

/**
     * 获取文件头
     *
     * @param path
     * @param tabName
     * @return 返回文件头信息
     * @throws IOException
     */
    public String getColumn(String path) throws IOException
    {
        BufferedReader brFile = null;
        File file = null;
        String line = null;
        try
        {
            file = new File(path);
            brFile = new BufferedReader(new InputStreamReader(
                    new FileInputStream(file)));
            line = brFile.readLine();
        }
        finally
        {
            if (brFile != null)
                brFile.close();
        }

        return line;
    }

    /**
     * 获取ORACLE数据库网络服务名
     * @return
     */
    public String getOraNetServerName()
    {
        String netServerName = host.replace('.', '_');
        // String netServerName = host;
        return DASProperties.getPreOraNetServer() + netServerName;
    }

    /**
     * 配置Oracle LOG文件
     * @return
     */
    public String configOracleLogFile()
    {
        StringBuffer logFile = new StringBuffer();

        // 以后要移除下面一行，此处是便于调试
        logFile.append(getSqlLoadDirectory()).append("/").append(
                fileName.substring(0, fileName.lastIndexOf(".")));

        logFile.append("_" + (new Date()).getTime() + ".log");

        return logFile.toString();
    }

    /**
     * 配置Oracle Bad文件
     * @return
     */
    public String configOracleBadFile()
    {
        StringBuffer badFile = new StringBuffer();

        badFile.append(getSqlLoadDirectory()).append("/").append(
                DASProperties.getOracleBadFileName());

        return badFile.toString();
    }

    /**
     * 从request请求中获取是否要删除SqlLoad日志文件的参数
     * @see com.security.dpi.basic.debug.DebugBean#processDebugRequest(java.util.Map)
     */
    public String processDebugRequest(Map<String, Object> paramMap)
    {
        StringBuilder out = new StringBuilder();
        String scanDirectroy = null;
        if(configerServer.getServiceType() == DASProperties.DAS_TYPE)
        {
            scanDirectroy = DASProperties.getDas_SqlLoadDirect();
        }
        else if(configerServer.getServiceType() == DASProperties.ETL_TYPE)
        {
            scanDirectroy = DASProperties.getEtl_SqlLoadDirect();
        }
        else
        {
            out.append("serviceType " + configerServer.getServiceType() + " ERROR!");
            return out.toString();
        }
        if (paramMap != null && paramMap.size() > 0)
        {
            if (paramMap.containsKey(FileUtil.backup))
            {
                setNeedDelLogFile(false);
                setCurrentBackupFileState(FileUtil.backup);
                out.append("Start to backup DAS sqlload log files! Those files store in " + scanDirectroy);
            }
            else if (paramMap.containsKey(FileUtil.stopBackup))
            {
                setNeedDelLogFile(true);
                setCurrentBackupFileState(FileUtil.stopBackup);
                out.append("Stop to backup DAS sqlload log files!");
            }
            else if (paramMap.containsKey(FileUtil.delBackupFile))
            {
                // 删除备份文件
                String[] suffixs = {".log"};
                File[] files = FileUtil.findFiles(scanDirectroy, null, null, suffixs, null);
                if(null != files)
                {
                    FileUtil.deleteFiles(files);
                }
                out.append("delete DAS sqlload log files!");
            }
        }
        out.append("<br/><br/><a href=\"debug/help\">return</a>");
        return out.toString();
    }