テキストファイル の読み込み

Question

前提・実現したいこと

今回実現したいプログラムは、
WEBとしてテキストファイルをアップロード可能な画面を用意する。
上記のテキストファイルをサーバ側のJAVAプログラムで読み込み
一連のルールに従って、内容をDBに保存して、完了画面をクライアントに返すプログラムの作成です。

保存するテキストは、テキストファイルから読み込んだ全ての行のテキストを保存したいです。

発生している問題・エラーメッセージ

テキストファイルを読み込んでDBに保存する際に、
テキストファイルの最初の行しか保存されていなく、
修正後のソースでは、テキストファイル の最後の行しか保存されない現象が起きており、解決できません。

該当のソースコード

package Servlet;

import java.io.BufferedReader;
import java.io.File;
import java.io.FileReader;
import java.io.IOException;

import javax.servlet.RequestDispatcher;
import javax.servlet.ServletException;
import javax.servlet.annotation.MultipartConfig;
import javax.servlet.annotation.WebServlet;
import javax.servlet.http.HttpServlet;
import javax.servlet.http.HttpServletRequest;
import javax.servlet.http.HttpServletResponse;
import javax.servlet.http.Part;

import model.FileDao;
import model.FileNameLogic;
import model.MkdirLogic;

/**
 * 
 * @author 
 *(修正前：テキストファイル の最初の1行しかDBに保存されない)
 *
 */
@WebServlet("/MainServlet")
@MultipartConfig(maxFileSize = 20971520, maxRequestSize = 20971520, fileSizeThreshold = 1048576, location = "/opt/apache-tomcat-8.5.61/temp")
public class MainServlet extends HttpServlet {
	private static final long serialVersionUID = 1L;

	/**
	 * doGet()
	 */
	@Override
	protected void doGet(HttpServletRequest request, HttpServletResponse response) throws ServletException, IOException {
		
		// フォワード
		RequestDispatcher dispatcher = request.getRequestDispatcher("/jsp/input.jsp");
		dispatcher.forward(request, response);
		
	}

	/**
	 * doPost()
	 */
	@Override
	protected void doPost(HttpServletRequest request, HttpServletResponse response) throws ServletException, IOException {
		
		// 文字コード指定
		response.setContentType("text/html; charset=UTF-8");

　　　　　Connection conn = null;
		PreparedStatement ps = null;
		
		String url = "jdbc:mariadb://localhost/upload_db";
    	String user = "****";
    	String password = "****";
    	String insertSql = "INSERT INTO `upload_file` (`contents`) VALUES (?)";  
    	
        // Partオブジェクトの取得
        Part part = request.getPart("uploadFile");
        
        // アップロードされたファイル名の取得
        FileNameLogic getFileNameLogic = new FileNameLogic();
        String fileName = getFileNameLogic.getFileName(part);
        
        // ファイルパスの指定
        String filePath = "/uploaded";
        
        // ディレクトリーの作成
        MkdirLogic mkdirLogic = new MkdirLogic();
        File uploadDir = mkdirLogic.mkdirs(filePath);
        
        // 指定されたパスにファイルを保存
        part.write(getServletContext().getRealPath(uploadDir.getPath() + "/" + fileName));
        
        // ファイルクラスの生成
        File file = new File(getServletContext().getRealPath(uploadDir.getPath() + "/" + fileName));
        
        // ファイルを1文字ずつ読み込む
        FileReader fileReader = new FileReader(file);
        
        // ファイルを1行ずつ読み込む
        @SuppressWarnings("resource")
		BufferedReader bufferedReader = new BufferedReader(fileReader); 
        String str = bufferedReader.readLine();
        	
        // DBに接続・テーブルにレコードを追加
        try {
       	　　Class.forName("org.mariadb.jdbc.Driver").newInstance();
　　　　　　　　　conn = DriverManager.getConnection(url, user, password);
      			
      	     ps = conn.prepareStatement(insertSql);
            　　ps.setString(1, str);
      		 ps.executeUpdate();
      		 out.println("アップロードされたファイルのテキストをデータベースに保存しました<br>");
      		
      		 conn.commit();
             	
        }catch (ClassNotFoundException e){
      		out.println("ClassNotFoundException:" + e.getMessage());
    	}catch (SQLException e){
      		out.println("SQLException:" + e.getMessage());
    	}catch (Exception e){
      		out.println("Exception:" + e.getMessage());
    	}finally{
      		try{
        		if (conn != null){
          			conn.close();
        		}else{
          			out.println("コネクションがありません");
        		}
      		}catch (SQLException e){
        		out.println("SQLException:" + e.getMessage());
      		}
    	}
    }
}

試したこと

readlineメソッドでテキストファイルの内容を1行ずつ読み込むメソッドを使う際に、
繰り返しreadLine（）メソッドを実行するように該当部分に繰り返しの処理を付け加えました。

package Servlet;

import java.io.BufferedReader;
import java.io.File;
import java.io.FileReader;
import java.io.IOException;

import javax.servlet.RequestDispatcher;
import javax.servlet.ServletException;
import javax.servlet.annotation.MultipartConfig;
import javax.servlet.annotation.WebServlet;
import javax.servlet.http.HttpServlet;
import javax.servlet.http.HttpServletRequest;
import javax.servlet.http.HttpServletResponse;
import javax.servlet.http.Part;

import model.FileDao;
import model.FileNameLogic;
import model.MkdirLogic;

/**
 * 
 * @author 
 *(修正後：テキストファイルの最後の1行しかDBに保存されない)
 *
 */
@WebServlet("/MainServlet")
@MultipartConfig(maxFileSize = 20971520, maxRequestSize = 20971520, fileSizeThreshold = 1048576, location = "/opt/apache-tomcat-8.5.61/temp")
public class MainServlet extends HttpServlet {
	private static final long serialVersionUID = 1L;

	/**
	 * doGet()
	 */
	@Override
	protected void doGet(HttpServletRequest request, HttpServletResponse response) throws ServletException, IOException {
		
		// フォワード
		RequestDispatcher dispatcher = request.getRequestDispatcher("/jsp/input.jsp");
		dispatcher.forward(request, response);
		
	}

	/**
	 * doPost()
	 */
	@Override
	protected void doPost(HttpServletRequest request, HttpServletResponse response) throws ServletException, IOException {
		
		// 文字コード指定
		response.setContentType("text/html; charset=UTF-8");
		
		Connection conn = null;
		PreparedStatement ps = null;
		
		String url = "jdbc:mariadb://localhost/upload_db";
    	String user = "****";
    	String password = "****";
    	String insertSql = "INSERT INTO `upload_file` (`contents`) VALUES (?)";  
    	
        // Partオブジェクトの取得
        Part part = request.getPart("uploadFile");
        
        // アップロードされたファイル名の取得
        FileNameLogic getFileNameLogic = new FileNameLogic();
        String fileName = getFileNameLogic.getFileName(part);
        
        // ファイルパスの指定
        String filePath = "/uploaded";
        
        // ディレクトリーの作成
        MkdirLogic mkdirLogic = new MkdirLogic();
        File uploadDir = mkdirLogic.mkdirs(filePath);
        
        // 指定されたパスにファイルを保存
        part.write(getServletContext().getRealPath(uploadDir.getPath() + "/" + fileName));
        
        // ファイルクラスの生成
        File file = new File(getServletContext().getRealPath(uploadDir.getPath() + "/" + fileName));
        
        // ファイルを1文字ずつ読み込む
        FileReader fileReader = new FileReader(file);
        
        // ファイルを1行ずつ読み込む
        @SuppressWarnings("resource")
		BufferedReader bufferedReader = new BufferedReader(fileReader); 
        String str;
        	
        // DBに接続・テーブルにレコードを追加
        try {
       	　　Class.forName("org.mariadb.jdbc.Driver").newInstance();

      		conn = DriverManager.getConnection(url, user, password);
      			
      		ps = conn.prepareStatement(insertSql);
      		
      		while((str = br.readLine()) != null) {
                　　ps.setString(1, str);
        	　}
        	　br.close();
            
      		ps.executeUpdate();
      		out.println("アップロードされたファイルのテキストをデータベースに保存しました<br>");
      		
      		conn.commit();
             	
        	}catch (ClassNotFoundException e){
      			out.println("ClassNotFoundException:" + e.getMessage());
    		}catch (SQLException e){
      			out.println("SQLException:" + e.getMessage());
    		}catch (Exception e){
      			out.println("Exception:" + e.getMessage());
    		}finally{
      			try{
        			if (conn != null){
          				conn.close();
        			}else{
          				out.println("コネクションがありません");
        			}
      			}catch (SQLException e){
        			out.println("SQLException:" + e.getMessage());
      			}
    		}
   	}
}

補足情報（FW/ツールのバージョンなど）

ここにより詳細な情報を記載してください。

Answer 1

while((str = br.readLine()) != null) {
  　　ps.setString(1, str);
}

この書き方だとパラメータ１の値を上書きし続けています。
残るのは最後のreadLineだけ。起きてる現象と一致しますね。

strを全てappendしたStringを渡せば良いのでは。

例：

String br = System.getProperty("line.separator");
StringBuilder contentStr = new StringBuilder();
while((str = br.readLine()) != null) {
  　　contentStr.append(str+br);
}
ps.setString(1,contentStr.toString());

Comments

[kjrk]

有難うございます。
解決できました。

[m.ts10806]

1行ずつ追っていけば（デバッグ）　見えてくるものもあるかと思います。