pretreatment.java

数据库连接池的写法

/*
 * 创建日期 2005-11-3
 *
 * TODO 要更改此生成的文件的模板，请转至
 * 窗口 － 首选项 － Java － 代码样式 － 代码模板
 */
package databaseConnectPool;

import databaseConnectPool.Buffer.*;
import java.io.*;

public class Pretreatment {
  private String tmpString;
  private String outputString;
  private int BUFFER_SIZE = 100;
  private AccidenceAnalyser aa;
  public InputBuffer inputBuffer; //输入缓冲区--共享
  private java.io.File SourceFile; //文件对象
  private java.io.RandomAccessFile randomAFile; //随机文件对象
  public static int fileRow = 0;
  /**
   * @roseuid 3DAB7C530399
   */
  public Pretreatment(File SourceFile, AccidenceAnalyser aa) {
    try {
      this.SourceFile = SourceFile;
      this.randomAFile = new java.io.RandomAccessFile(this.SourceFile, "r");
    }
    catch (FileNotFoundException e) {
      e.printStackTrace(System.err);
    }
    this.aa = aa;
    inputBuffer = aa.csbFactory.createInputBuffer(BUFFER_SIZE);
    System.out.println("[INFOR]预处理器已经创建!");
  }

  /**
   * @roseuid 3D9BAFE20331
   */
  public void putSourceToINBuffer(String tmpString) {
    this.inputBuffer.Data = tmpString.toCharArray();
  }

  /**
   * @roseuid 3D9BB0400169
   */
  public void putFinToSCBuffer(String filtratedString) {
    aa.scaner.scanBuffer.Data = filtratedString.toCharArray();
  }

  /**
   * @roseuid 3D9BB05E00A4
   */
  public void controlThread() {
    int intLength;
    int resCounter = 0;
    String tmpString;
    String filtratedString;
    System.out.println("[INFOR]开始单词分析////////////////////////////////////////");
    try {
      if (SourceFile.exists()) { //文件存在
        //读文件内容到缓冲区
        while ( (tmpString = this.randomAFile.readLine()) != null) {
          ++fileRow;
          //分割符
          System.out.println("...................begin row " + this.fileRow +
                             ".......................");
          //开始这一行分析
          System.out.println("[INFOR]正在处理行: " + String.valueOf(fileRow));
          //放入输入缓冲区
          this.putSourceToINBuffer(tmpString);
          //处理字符串
          filtratedString = this.filtrateSource(this.inputBuffer.Data);
          System.out.println("[INFOR]已过滤句子: " + filtratedString);
          //放入扫描缓冲区
          this.putFinToSCBuffer(filtratedString);
          aa.controlThread();
        }
        System.out.println(
            "[INFOR]分析完毕////////////////////////////////////////////");
      }
      else { //文件不存在
        System.err.println("[ERROR]源文件不存在!");
      }
    }
    catch (Exception e) {
      e.printStackTrace(System.err);
    }
  }

  /**
   * @roseuid 3D9BB07D0239
   */
  public String filtrateSource(char[] Data) {
    String filtratedString = String.valueOf(Data).trim();
    return filtratedString;
  }

  /**
   * @roseuid 3D9BB9350315
   */
  public void startPretreatment() {
    this.controlThread();
  }
}