csvファイルを読み取り、中身をDBにINSERTしたいのですが、どこで処理の不具合が起きているのかがわかりません。

Question

前提・実現したいこと

今回作成しているプログラムは、Java（Servlet＆jsp）で、
WEBとしてcsvファイルをアップロード可能な画面を用意し、
上記のcsvファイルをサーバ側のJAVAプログラムで読み込み
DBに保存して、完了画面をクライアントに返すプログラムです。

環境は、Linuxサーバー（VPS）にApache, Tomcat, MySQLをインストールし、
作成したServletとjspのファイルはTomcatに配置しております。

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

アプリを実行した際、
DBにINSERTされていないのに完了画面が返って来てしまいます。

途中に
ファイルが選択されていないエラー、
ファイルが正常に読み込めていないエラー、
DBに接続されていないエラー、
INSERTがされていないエラー、
などをcatchするように例外処理も書いているのですが、
どの例外にも引っかからずに成功画面がフォワードされてしまいます。

どこで不具合が起きているのかわかりません。
お力添えいただけますでしょうか？

該当のソースコード

アプリ実行サーブレットクラス
ファイルとパスを取得し、
それらを引数にファイルを読み込むロジッククラスのメソッドを呼び出し。
例外処理に引っかからない場合に成功画面をフォワード。

package servlet;

import java.io.IOException;
import java.sql.SQLException;

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 logic.CsvFileReadLogic;


/**
 * 
 * csvファイルアップロードの実行Servletの具象クラス
 * @author 
 *
 */
@WebServlet("/CsvFileReadServlet")
@MultipartConfig(maxFileSize = 20971520, maxRequestSize = 20971520, fileSizeThreshold = 1048576, location = "/opt/apache-tomcat-8.5.61/temp")
public class CsvFileReadServlet extends HttpServlet {
	private static final long serialVersionUID = 1L;

	/**
	 * csvファイル選択画面をフォワード
	 * @throws IOException 
	 * @throws ServletException 
	 */
	protected void doGet(HttpServletRequest request, HttpServletResponse response) throws ServletException, IOException {

		// ファイル選択画面をフォワード
		RequestDispatcher dispatcher = request.getRequestDispatcher("/jsp/csvFileUpload.jsp");
		dispatcher.forward(request, response);
	}


	/**
	 * ファイルアップロードアプリの処理を実行
	 * @throws IOException 
	 * @throws ServletException 
	 */
	protected void doPost(HttpServletRequest request, HttpServletResponse response) throws ServletException, IOException {



		// 文字コード指定
		response.setContentType("text/html; charset=UTF-8");

		Part part = null;

		try {
			// Partオブジェクトの取得
			part = request.getPart("uploadFile");
			// ファイルが選択されていない時のエラーをキャッチ
		} catch (IOException e) {
			printFileSelectErrorScreen(request, response);
			return;
		}


		// アップロードされたファイル名の取得
		String fileName = getFileName(part);

		// 仮保存先のパスを指定
		String filePath = "/uploaded";

		// 絶対パスの定義
		String absolutePath = getServletContext().getRealPath(filePath + "/" + fileName);

		try {
			// ファイルを読み込みDBに保存するアプリの実行
			execute(part, absolutePath);
			// アプリの実行に関するエラーのキャッチ
		} catch (Exception e) {
			e.printStackTrace();
			return;
		}

		// 成功画面をフォワード
		RequestDispatcher dispatcher = request.getRequestDispatcher("/jsp/success.jsp");
		dispatcher.forward(request, response);


	}

	/**
	 * 警告画面をフォワード
	 */
	private void printFileSelectErrorScreen(HttpServletRequest request, HttpServletResponse response) throws ServletException, IOException {
		// 警告画面をフォワード
		RequestDispatcher dispatcher = request.getRequestDispatcher("/jsp/notCorrectFile.jsp");
		dispatcher.forward(request, response);
	}
	
	/**
	 * csvファイルを読み込みDBに保存するアプリの実行
	 * @throws IOException 
	 */
	protected void execute(Part part, String absolutePath) throws IOException, InstantiationException, IllegalAccessException, ClassNotFoundException, SQLException {
		
		// CsvFileReadLogicをインスタンス化
		CsvFileReadLogic csvFile = new CsvFileReadLogic();
						
		// ファイル関連の処理を実行
		csvFile.executeReadFile(part, absolutePath);
	}


	/**
	 * ファイル名を取得するメソッド
	 */
	public String getFileName(Part part) {
		String name = null;
		for (String dispotion : part.getHeader("Content-Disposition").split(";")) {
			if(dispotion.trim().startsWith("filename")) {
				name = dispotion.substring(dispotion.indexOf("=") + 1).replace("\"", "").trim();
				name = name.substring(name.lastIndexOf("\") + 1);
				break;
			}
		}
		return name;
	}	

}

package logic;

import java.io.BufferedReader;
import java.io.File;
import java.io.FileInputStream;
import java.io.FileNotFoundException;
import java.io.IOException;
import java.io.InputStreamReader;
import java.sql.SQLException;

import javax.servlet.http.Part;

import dao.UploadedCsvFileDao;
import model.AddressBookInfo;


/**
 * 
 * csvファイル関連の処理クラス
 * @author 
 *
 */
public class CsvFileReadLogic {

	/**
	 * Fileクラスのオブジェクトを生成
	 * @param filePath
	 * @throws IOException 
	 * @throws SQLException 
	 * @throws ClassNotFoundException 
	 * @throws IllegalAccessException 
	 * @throws InstantiationException 
	 */
	public void executeReadFile(Part part, String absolutePath) throws IOException, InstantiationException, IllegalAccessException, ClassNotFoundException, SQLException {

		// 指定されたパスにファイルを保存
		part.write(absolutePath);

		// ファイルオブジェクトの生成
		File file = new File(absolutePath);

		// ファイルを読み込んでINSERTするテキストを抽出
		getFileString(file);

	}

	/**
	 * @throws FileNotFoundException 
	 * 
	 */
	protected void getFileString(File file) {

		FileInputStream fi = null;
		try {
			fi = new FileInputStream(file);
		} catch (FileNotFoundException e1) {
			e1.printStackTrace();
			return;
		}

		InputStreamReader is = new InputStreamReader(fi);

		BufferedReader br = new BufferedReader(is);

		// データを格納するクラスのインスタンスを生成
		AddressBookInfo addrBookInfo = new AddressBookInfo();

		String line = null;
		try {
			while((line = br.readLine()) != null) {

				//カンマで分割した内容を配列に格納する
				String[] data = line.split(",");

				// AddressBookInfoに値を格納
				addrBookInfo.setName(data[0]);
				addrBookInfo.setAddr(data[1]);
				addrBookInfo.setTelNum(data[2]);

				// INSERT実行処理の呼び出し
				// UploadedTextFileDaoをインスタンス化
				UploadedCsvFileDao csvFileDao = new UploadedCsvFileDao();

				// DB関連の処理実行
				csvFileDao.executeInsert(addrBookInfo);

			}
			br.close();
		} catch (IOException e) {
			e.printStackTrace();
			return;
		}
	}


}

package dao;

import java.sql.Connection;
import java.sql.DriverManager;
import java.sql.PreparedStatement;
import java.sql.SQLException;

import model.AddressBookInfo;

public class UploadedCsvFileDao {

	// DB接続に使用する情報
	private final String url = "jdbc:mariadb://localhost/upload_db";
	private final String user = "＊＊＊＊";
	private final String password = "＊＊＊＊";

	/**
	 * DB関連の処理を実行するメソッド
	 * @param contentStr 
	 * @throws SQLException 
	 * @throws ClassNotFoundException 
	 * @throws IllegalAccessException 
	 * @throws InstantiationException 
	 */	
	public void executeInsert(AddressBookInfo addrBookInfo) {
		
　　　　　// JDBCドライバをロード
		try {
			Class.forName("org.mariadb.jdbc.Driver").newInstance();
		} catch (InstantiationException | IllegalAccessException | ClassNotFoundException e) {
			// TODO 自動生成された catch ブロック
			e.printStackTrace();
			return;
		}

		// DB接続
		Connection conn = null;
		try {
			conn = DriverManager.getConnection(url, user, password);
		} catch (SQLException e) {
			// TODO 自動生成された catch ブロック
			e.printStackTrace();
			return;
		}

		String insertSql = "INSERT INTO `address_book` (`name`, `addr`, `telNum`) VALUES (?, ?, ?)"; 
		PreparedStatement ps;
		try {
			ps = conn.prepareStatement(insertSql);
			ps.setString(1, "山田");
			ps.setString(2, "tokyo");
			ps.setString(3, "090-****-****");
			ps.executeUpdate();
			conn.commit();
		} catch (SQLException e) {
			e.printStackTrace();
			return;
		}

		// DB切断
		finally {
			try {
				conn.close();
			} catch (SQLException e) {
				e.printStackTrace();	
				return;
			}
		}

	}
}

Answer 1

例外をことごとく catch して return しているので、
例外が発生していないような挙動になってませんかね。

return のかわりに throw e などとするとどうですか?

Comments

[kjrk]

御回答ありがとうございます。
検証してみます。

[kjrk]

throwしているのですが、例外をcatchしてくれません、、

[68user]

エラーなのに正常終了という画面が出るのがおかしいんですよね。catch するのはいいですが、上位に全部 throw してください。catch 内で return は厳禁です。握りつぶしているだけです。その結果エラー発生時に 500エラーとかになってもよし (エラー時にエラー画面が出るようになったのは進歩です)。

その次は最上位である doGET や doPost で try～catch して、エラー発生時に「エラーが発生しました」などという jsp にリダイレクトすることです。

[kjrk]

正常に動作が確認できました。
どうやら、ソースに問題があるのではなく、
テーブルの設計に問題がありました。
電話番号のデータサイズが小さいことが原因でINSERTされなかったようです。

それにしても、この際になぜ例外でエラーをthrowしてくれなかったのかが未だにわかっておりません。

Answer 2

テーブルの設計に問題がありました。
電話番号のデータサイズが小さいことが原因でINSERTされなかったようです。

Comments

[68user]

テーブル設計の問題はあったのかもしれませんが、
エラーが発生しているにも関わらずそれを検知できない方が大問題です。
この機会にエラーハンドリングを正しくできるようにすることをおすすめします。
修正方針は先に書いたとおり、子メソッドで catch したら throw し、最上位まで例外を伝えることです。