Spring MVCで演算をした後にJDBCTemplateのメソッドupdateを使うとうまくいきません

Question

Spring MVCを使い簡易的なバンクシステムで作っています。
'預かりメソッド'と'引き出しメソッド'を作成したのですが、うまくいきません。
例えば、4万円の残高があり、最初に1万円引き出すと残高は3万円になるのですが、その次に2万円引き出すと残高は2万円になります。なぜでしょうか？

package com.banksystem.controller;

import javax.servlet.http.HttpSession;

import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Controller;
import org.springframework.ui.Model;
import org.springframework.web.bind.annotation.RequestMapping;
import org.springframework.web.bind.annotation.RequestMethod;

import com.banksystem.model.User;
import com.banksystem.model.UserInput;
import com.banksystem.service.BSService;

@Controller
public class UserController {
	
	@Autowired
	BSService service;
	
	@Autowired
	HttpSession session;
	
	/*
	 ******************
	 **Deposit Method**
	 ******************
	 */
	@RequestMapping(value = "/deposit", method = RequestMethod.GET)
	public String toDeposit(Model model) {
		UserInput userInput = new UserInput();
		model.addAttribute("userInput", userInput);
		return "deposit";
	}
	@RequestMapping(value = "/deposit_p", method = RequestMethod.POST)
	public String deposit(Model model, UserInput userInput) {
		
		User user = new User();
		int inputNum;
		Integer amount;
		inputNum = userInput.getInputNum();
		user = (User) session.getAttribute("User");
		amount = user.getAmount();
		//初回利用時
		if(amount == null) {
			amount = 0;
		}
		amount = amount + inputNum;
		Integer id = user.getId();
		int numRow = service.deposit(amount, id);
		//failed
		if(numRow > 1) {
			session.invalidate();
			model.addAttribute("message", "エラーが発生しました。もう一度最初からやり直してください。");
			return "end";
		}
		model.addAttribute("message", "預け入れが完了しました");
		return "topMain";
	}
	
	/*
	 *******************
	 **Withdraw Method**
	 *******************
	 */
	@RequestMapping(value = "/withdraw", method = RequestMethod.GET)
	public String toWithdraw(Model model) {
		UserInput userInput = new UserInput();
		model.addAttribute("userInput", userInput);
		return "withdraw";
	}
	@RequestMapping(value = "withdraw_p", method = RequestMethod.POST)
	public String withdraw(Model model, UserInput userInput) {
		
		User user = new User();
		int inputNum;
		Integer amount;
		inputNum = userInput.getInputNum();
		user = (User) session.getAttribute("User");
		amount = user.getAmount();
		//初回利用時
		if(amount == null) {
			amount = 0;
		}
		//be negative
		if(amount <= inputNum) {
			model.addAttribute("message", "残高が不足しています");
			UserInput userInput1 = new UserInput();
			model.addAttribute("userInput", userInput1);
			return "withdraw";
		}
		amount = amount - inputNum;
		Integer id = user.getId();
		int numRow = service.withdraw(amount, id);
		//failed
		if(numRow > 1) {
			session.invalidate();
			model.addAttribute("message", "エラーが発生しました。もう一度最初からやり直してください。");
			return "end";
		}
		model.addAttribute("message", "お引き出しが完了しました");
		return "topMain";
	}
}

package com.banksystem.dao;

import org.springframework.dao.DataAccessException;
import org.springframework.stereotype.Repository;

import com.banksystem.model.Contact;
import com.banksystem.model.User;

@Repository
public interface Dao {
	//login method
	public User login(String loginId, String loginPass) throws DataAccessException;
	
	//register method
	public int register(User user) throws DataAccessException;
	
	//contact method
	public int contact(Contact contact) throws DataAccessException;
	
	//deposit method
	public int deposit(int id, int sum) throws DataAccessException;
	
	//withdraw method
	public int withdraw(int id, int sum) throws DataAccessException;
}

package com.banksystem.dao;

import java.util.Map;

import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.dao.DataAccessException;
import org.springframework.jdbc.core.JdbcTemplate;
import org.springframework.stereotype.Repository;

import com.banksystem.model.Contact;
import com.banksystem.model.User;

@Repository
public class JdbcDao implements Dao{

	@Autowired JdbcTemplate jdbc;
	
	@Override
	public User login(String loginId, String loginPass) throws DataAccessException {
		User user = new User();
		try {
			String sql = "SELECT * FROM users_info WHERE loginId = ? AND loginPass = ?";
			Map<String, Object> map = jdbc.queryForMap(sql, loginId, loginPass);
			user.setId((Integer) map.get("id"));
			user.setName((String) map.get("name"));
			user.setPhone((String)map.get("phone"));
			user.setEmail((String)map.get("email"));
			user.setLoginId((String)map.get("loginId"));
			user.setLoginPass((String)map.get("loginPass"));
			user.setAmount((Integer)map.get("amount"));
		}catch(Exception e) {
			e.printStackTrace();
		}
		return user;
	}

	@Override
	public int register(User user) throws DataAccessException {
		int rowNum = -1;
		try {
			String sql = "INSERT INTO users_info(name, phone, email, loginId, loginPass) VALUES(?, ?, ?, ?, ?)";
			rowNum = jdbc.update(sql, user.getName(), user.getPhone(), user.getEmail(), user.getLoginId(), user.getLoginPass());
		}catch(Exception e) {
			e.printStackTrace();
		}
		return rowNum;
	}

	@Override
	public int contact(Contact contact) throws DataAccessException {
		int rowNum = -1;
		try {
			String sql = "INSERT INTO contacts(email, message) VALUES(?, ?)";
			rowNum = jdbc.update(sql, contact.getEmail(), contact.getMessage());
		}catch(Exception e) {
			e.printStackTrace();
		}
		return rowNum;
	}

	@Override
	public int deposit(int id, int sum) throws DataAccessException{
		int rowNum = -1;
		try {
			String sql = "UPDATE users_info SET amount=? WHERE id=?";
			rowNum = jdbc.update(sql, sum, id);
		}catch(DataAccessException e) {
			e.printStackTrace();
		}
		return rowNum;
	}

	@Override
	public int withdraw(int id, int sum) throws DataAccessException {
		int rowNum = -1;
		try {
			String sql = "UPDATE users_info SET amount=? WHERE id=?";
			rowNum = jdbc.update(sql, sum, id);
		}catch(DataAccessException e) {
			e.printStackTrace();
		}
		return rowNum;
	}

}

package com.banksystem.service;

import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Service;

import com.banksystem.dao.Dao;
import com.banksystem.model.Contact;
import com.banksystem.model.User;

@Service
public class BSService {
	
	@Autowired
	Dao dao;
	
	//login
	public User login(String loginId, String loginPass) {
		User user = dao.login(loginId, loginPass);
		return user;
	}
	
	//register
	public int register(User user) {
		int rowNum = dao.register(user);
		return rowNum;
	}
	
	//contact
	public int contact(Contact contact) {
		int rowNum = dao.contact(contact);
		return rowNum;
	}
	
	//deposit
	public int deposit(int id, int sum) {
		int rowNum = dao.deposit(sum,  id);
		return rowNum;
	}
	
	//withdraw
		public int withdraw(int id, int sum) {
			int rowNum = dao.deposit(sum,  id);
			return rowNum;
		}
}

1回目のデバッグ(残高40000、引き出し10000)

DataBase
id name phone email loginId loginPass amount
"6" "Test" "09012345678" "[e-mail]" "test" "test" "30000"

---

2回目のデバッグ(残高30000、引き出し20000)(本来は10000になる)

DataBase
id name phone email loginId loginPass amount
"6" "Test" "09012345678" "[e-mail]" "test" "test" "20000"

Comments

[xebme]

if(amount <= inputNum) {
この条件は、引き出せる？　残高不足？　どちらですか。

[退会済みユーザー]

残高不足です

[xebme]

質問の文脈が分からなくなりました。
>残高は3万円になるのですが、その次に2万円引き出すと残高は変わらずに2万円になります。なぜでしょうか？
残高は3万円から2万円に変わったと読めるのですが。

[退会済みユーザー]

すみません。表記ミスです。"変わらずに"はいりません。

[xebme]

2回目のデバッグの画像を見ると、user.amount.valueが40000となっています。これが残高として使われている可能性は？
40000 - 20000 = 20000 となります。

[退会済みユーザー]

はい。そうなんです。1回目の結果がコミットされてない様に思えるのですが"自動コミット"をONにしています。何故かJDBCTemplate.updateで数値を変更した場合、数値が正しく反映されません。解決方法がわかりません。

Answer 1

検討違いのことを言っていたら申し訳ないのですが

引き出し用の
Controller.withdrawメソッド内部で引き落としの際にも
残高をDBから取得せずHttpSessionから取得しているのが原因ではないでしょうか？

// controllerのwithdrawメソッド
        user = (User) session.getAttribute("User");
        amount = user.getAmount();　// ここで一回目のデバック時/2回目のデバッグ時共に40000が取れている ※同じ情報を取ってしまっているのでは・・？ DB見に行かないと駄目なような。

        // 省略

　　　　// 上記のセッションから取得したユーザー情報のAmountから
       // リクエストのAmountの値を減算した値をDBにUpdateで更新かけている
        amount = amount - inputNum;
　　　　 Integer id = user.getId();
        int numRow = service.withdraw(amount, id);

私の見解としては DB側のデータの更新自体は出来ていると考えていて、
Service以降は問題ないように見受けられます。 Controllerのバグの認識です。
※ 1回目でDB側の残高が40000 -> 30000に更新されていることから分かる

引き出しの際はセッションからユーザーの残高を受け取るのではなく、
DBにSelectで検索をかけて取得した残高から userInputに設定された残高を引いた値をDBに登録するべきではないのでしょうか？

おそらくセッションから1回目と2回目で同じ情報を取って減算している関係で
1回目: 40000 -10000で DBに30000が登録
2回目: 40000 -20000で DBに20000が登録(30000を上書きしてしまう)

となっているのだと思います。

Comments

[xebme]

お気づきのとおり、最も疑うべきはUser.amountですが、質問には手がかりがありません。質問者の立場なら、思い込みを捨てて、User.amountをどのように取得しているのかを調べるのが、初めになすべきことです。

[dev-fjk]

ご返信ありがとうございます。
そうですね。上記の情報含め質問者様の方でもう少し調査いただけますと幸いですmm

[退会済みユーザー]

selectで持ってきた値を使ったところ無事機能しました。
セッションのamountで計算するのがまずかったようです。
みなさまご協力ありがとうございました。