過去ログ検索システム不具合

import comm.Fileuse;

public class log_create_mainbbs {

　public static void main(String[] args) {
　　
　　String inputPath = "D:\\dummy\\midilin\\log\\input\\";//取得元
　　String outputPath = "D:\\dummy\\midilin\\log\\output\\";//書き出し先
　　
　　//ファイル一覧取得
　　Fileuse fu = new Fileuse();
　　ArrayList fileichiran = fu.getFileIchiran(inputPath);

　　fileCreate(inputPath,outputPath,fileichiran,"0","SJIS");
　　
　}
　
　
　public static void fileCreate(String inputPath,String outputPath,ArrayList
fileichiran,String outputname ,String moji_code){
　　int i=0;
　　int debug_count = 0;
　　String debugstr = "";
　　try{
　　　
　　　for(i=0;i<fileichiran.size();i++){

　　　　//ファイル解析
　　　　File file = new File(inputPath + "\\" +fileichiran.get(i).toString());
　　　　FileInputStream fs = new FileInputStream(file);
　　　　InputStreamReader ir = new InputStreamReader(fs,moji_code);
　　　　BufferedReader br = new BufferedReader(ir);
　　　　StringBuffer buffer = new StringBuffer();
　　　　char[] readBuffer = new char[8192];
　　　　int length = br.read(readBuffer, 0, 8192);
　　　
　　　　while(length>=0){
　　　　　buffer.append(readBuffer,0,length);
　　　　　length = br.read(readBuffer, 0, 8192);
　　　　}
　　　　String out = buffer.toString();
　　　
　　　　String search_start_text = "<center>[";
　　　　String search_end_text = "] <font color";
　　　　
　　　　String hr_endtext = "</table><hr width=95% color=#a0e0f6 size=1>";
　　　　
　　　　int searchStartNo = 0;
　　　　int searchEndNo = 0;
　　　　
　　　　while((out.indexOf(search_start_text))!=-1){
　　　　
　　　　　searchStartNo = out.indexOf(search_start_text) + search_start_text.length();
　　　　　searchEndNo = out.indexOf(search_end_text);

　　　　　String indexNo = out.substring(searchStartNo,searchEndNo);//No
　　　　　
　　　　　//String outnext = out.substring(searchEndNo+1);//次の対象テキスト
　　　　　String outnext = out.substring(out.indexOf(hr_endtext)+hr_endtext.length()+1);//次の対象テキスト
　　　　　
　　　　　int searchStartNoNext = outnext.indexOf(search_start_text) + search_start_text.length();　　

　　　　　String outputText =out.substring(out.indexOf(search_start_text),out.length()-outnext.length()
+ searchStartNoNext – search_start_text.length());

　　　　　outputText = headHtml() + outputText + footer();
　　　　　//ファイル書き込み開始
　　　　　File outfile = new File(outputPath + outputname + indexNo + ".html");
　　　　　outfile.createNewFile();

　　　　　FileOutputStream outfs = new FileOutputStream(outfile);
　　　　　OutputStreamWriter ow = new OutputStreamWriter(outfs,"SJIS");
　　　　　BufferedWriter bw = new BufferedWriter(ow);
　　　　　
　　　　　StringBuffer outbuffer = new StringBuffer(outputText);
　　　　　bw.write(outbuffer.toString(), 0, outbuffer.length());//書き出し
　　　　　bw.flush();
　　　　　bw.close();
　　　　　ow.close();
　　　　　
　　　　　out = outnext;
　　　　　
　　　　　debug_count++;
　　　　　debugstr = indexNo;

　　　　}　　　　
　　　　
　　　　fs.close();//ファイル読み込み1つ終了
　　　
　　　}
　　　System.out.print("ファイル出力正常終了\n");
　　}catch (Exception e){
　　　　e.printStackTrace();
　　　　System.out.print("i="+ i + "\n");
　　　　System.out.print("debug_count = " + debug_count + "\n");
　　　　System.out.print("index=" + debugstr + "\n");
　　}

　}
　

package comm;

import java.io.File;
import java.text.SimpleDateFormat;
import java.util.ArrayList;
import java.util.Date;

public class Fileuse {
　/**
　 * <DL>
　 * <DT><b>メソッド概要：</b><DD>
　 * ファイル一覧取得<BR>
　 * <BR>
　 * @param pass
　 * @return
　 * </DD><BR>
　 * </DL>
　 */
　public ArrayList getFileIchiran(String pass){
　　ArrayList array = new ArrayList();

　　File f = new File( pass );
　　String files[] = f.list();
　　int N = files.length;
　　int k;

　　for( k=0; k<N; k++ )
　　{
　　　//System.out.println( pass + "/" + files[k] );
　　　array.add(files[k]);
　　}
　　
　　return array;
　}

package log;
import java.sql.*;
import java.util.ArrayList;
import java.io.BufferedReader;
import java.io.BufferedWriter;
import java.io.File;
import java.io.FileInputStream;
import java.io.FileOutputStream;
import java.io.InputStreamReader;
import java.io.OutputStreamWriter;

import org.apache.xml.utils.Trie;

import comm.Fileuse;
import comm.Struse;
/**
* <UL>
* <LI>ProjectName :</LI>
* <LI>SystemName :</LI>
* <LI>PackageName :</LI>
* <LI>@author :<BR>
* </UL>
* <DL>
* <DT><b>クラス概要：</b></DT><DD>
* 雑談掲示板の過去ログをDBに登録するプログラム]<BR>
* </DD><BR>
* </DL>
*/
public class log_mainbbs_insert {
　private static String DBname = "●●●";//DB名
　private static String userid = "●●●";//ID
　private static String password = "●●●";//PASSWORD
　private static String sv = "●●●";//ホスト名
　private static String encode = "Shift_JIS";//文字コード
　private Connection conn;
　
　public static void main(String[] args) throws Exception {
　　log_mainbbs_insert app = new log_mainbbs_insert();
　　String r[] ={DBname,userid,password,sv,encode};
　　app.init(r);
　}
　private void setParameter(String[] args) {
　　// 引数の数チェック
　　if (args == null || args.length < 3) {
　　　System.out.println("引数の数が足りません。");
　　　System.exit(1);
　　}
　　DBname = args[0];
　　userid = args[1];
　　password = args[2];
　　sv = args[3];
　　encode = args[4];
　}
　
　private void init(String[] args) throws Exception {
　　int i=0;
　　String sql = "";
　　try {
　　　
　　　String inputPath = "C:\\data\\log\\mainbbs\\";//取得元
　　
　　　//ファイル一覧取得
　　　Fileuse fu = new Fileuse();
　　　ArrayList fileichiran = fu.getFileIchiran(inputPath);
　　　
　　　// 引数よりパラメータをセットします。
　　　setParameter(args);

　　　Class.forName("com.mysql.jdbc.Driver").newInstance();
　　　
　　　//DB接続
　　　//conn =DriverManager.getConnection("jdbc:mysql:///" + DBname,
userid, password);
　　　String db_url = "jdbc:mysql://" + sv + "/" + DBname
　　　　　　+ "?user=" + userid
　　　　　　+ "&password=" + password
　　　　　　+ "&useUnicode=true&characterEncoding=" + encode;
　　　conn =DriverManager.getConnection(db_url);
　　　
　　　
　　　conn.setAutoCommit(false);//Autocommit解除
　　　
　　　for(i=0;i<fileichiran.size();i++){

　　　　//ファイル解析
　　　　File file = new File(inputPath + "\\" +fileichiran.get(i).toString());
　　　　FileInputStream fs = new FileInputStream(file);
　　　　InputStreamReader ir = new InputStreamReader(fs,"SJIS");
　　　　BufferedReader br = new BufferedReader(ir);
　　　　StringBuffer buffer = new StringBuffer();
　　　　char[] readBuffer = new char[8192];
　　　　int length = br.read(readBuffer, 0, 8192);
　　　
　　　　while(length>=0){
　　　　　buffer.append(readBuffer,0,length);
　　　　　length = br.read(readBuffer, 0, 8192);
　　　　}
　　　
　　　
　　　　String out = buffer.toString();
　　　
　　　　String index_search_start_text = "<center>[";
　　　　String index_search_end_text = "] <font color";
　　　　String txt_search_end_text = "</div>";
　　　　
　　　　
　　　　int searchStartNo = 0;
　　　　int searchEndNo = 0;
　　　　　　　
　　　　　　　
　　　　searchStartNo = out.indexOf(index_search_start_text) + index_search_start_text.length();
　　　　searchEndNo = out.indexOf(index_search_end_text);
　　　　
　　　　String indexNo = out.substring(searchStartNo,searchEndNo);//No

　　　　　　　
　　　　//String outnext = out.substring(searchEndNo+1);//次の対象テキスト
　　　　//int searchStartNoNext = outnext.indexOf(index_search_start_text) + index_search_start_text.length();
　　　　int searchEndNo_text = out.indexOf(txt_search_end_text);
　　　　
　　　　String outputText =out.substring(searchStartNo-1,searchEndNo_text);
　　　　outputText = outputText.trim();
　　　　　
　　　　//ステートメントオブジェクトを生成
　　　　Statement stmt = conn.createStatement();
　　　　Statement stmt_in = conn.createStatement();
　　　　
　　　　sql = "select id from mainbbs where id = ‘" + indexNo + "’";
　　　　//クエリーを実行
　　　　ResultSet rs = stmt.executeQuery(sql);

　　　　//検索された行数分ループする
　　　　int rs_cnt=0;
　　　　while(rs.next()) {
　　　　　String temp = rs.getString("id");//Maxid取得
　　　　　rs_cnt++;
　　　　}

　　　　//レコードが存在しなかったらinsert作業
　　　　if(rs_cnt == 0){
　　　　　//String del_str[] = {"&nbsp;"," ","%",".","’","\\"};
　　　　　Struse stru = new Struse();
　　　　　outputText = stru.conv_text(outputText,"’","\\’");//文字列置換
　　　　　//outputText = stru.delete_text(del_str, outputText);
　　　　　sql = "INSERT INTO mainbbs(id,comment) values (" + indexNo +
",’" + outputText + "’)";
　　　　　stmt_in.executeUpdate(sql);
　　　　}
　　　}

　　　conn.commit();
　　　System.out.print("正常終了しました");
　　} catch (InstantiationException e) {
　　　rollbackAndPrint(sql, e);
　　} catch (IllegalAccessException e) {
　　　rollbackAndPrint(sql, e);
　　} catch (ClassNotFoundException e) {
　　　rollbackAndPrint(sql, e);
　　} catch (SQLException e) {
　　　rollbackAndPrint(sql, e);
　　} catch(Exception e){
　　　rollbackAndPrint(sql, e);
　　}
　　finally{
　　　conn.close();//切断
　　}
　　
　}
　private void rollbackAndPrint(String sql, Exception e) throws SQLException
{
　　e.printStackTrace();
　　System.out.print(sql);
　　conn.rollback();
　}