ログインロジック

import java.math.BigDecimal;
import java.sql.Connection;
import java.sql.PreparedStatement;
import java.sql.ResultSet;
import java.sql.SQLException;
import java.sql.Statement;
import com.kaishamei.data.DShainData;

public class MShainInfo extends MConnection{
	/**
	 * @param in
	 * @return
	 */
	public DShainData getShainInfo(DShainData in) {

		Connection conn = null;
		Statement stmt = null;
		ResultSet rset = null;
		PreparedStatement pstmt = null;
		DShainData info = null;

		try {
			// JBBCドライバクラスのロード
			Class.forName("com.mysql.jdbc.Driver");

			// Connectionの作成
			conn = getConnection();
			// Statementの作成
			stmt = conn.createStatement();
			// SQL
			String sql = "select   ";
			sql += "    SHAIN_ID   ";
			sql += "   ,SHAIN_NM   ";
			sql += "   ,AGE        ";
			sql += "   ,POST_NO    ";
			sql += "   ,ADDRESS_CD ";
			sql += "   ,ADDRESS2   ";
			sql += "   ,ADDRESS3   ";
			sql += "   ,PASSWORD   ";
			sql += "   ,DEL_KBN    ";
			sql += "   ,ENTRY_ID   ";
			sql += "   ,ENTRY_DAY  ";
			sql += "   ,UPDATE_ID  ";
			sql += "   ,UPDATE_DAY ";
			sql += " from SHAIN_INFO  ";
			sql += " where         ";
			sql += "    SHAIN_ID = ? ";

			// Resultsetの作成
			pstmt = conn.prepareStatement(sql);
			pstmt.setString(1,in.getShainId());
			rset = pstmt.executeQuery();

			// 取得したデータを出力する
			while (rset.next()) {
				info = new DShainData();

				info.setShainId(rset.getString("SHAIN_ID"));
				info.setShainNm(rset.getString("SHAIN_NM"));
				BigDecimal age = rset.getBigDecimal("AGE");
				int iAge = 0;
				if (age != null) {
					iAge = Integer.valueOf(age.toString());
				}
				info.setAge(iAge);
				info.setPostNo(rset.getString("POST_NO"));
				info.setAddressCd(rset.getString("ADDRESS_CD"));
				info.setAddress2(rset.getString("ADDRESS2"));
				info.setAddress3(rset.getString("ADDRESS3"));
				info.setPassword(rset.getString("PASSWORD"));
				info.setDelKbn(rset.getString("DEL_KBN"));
				info.setEntryId(rset.getString("ENTRY_ID"));
				info.setEntryDay(rset.getString("ENTRY_DAY"));
				info.setUpdateId(rset.getString("UPDATE_ID"));
				info.setUpdateDay(rset.getString("UPDATE_DAY"));
				break;
			}

		} catch (SQLException e) {
			String msg = e.toString();
			System.out.println(msg);
		} catch (Throwable e) {
			String msg = e.toString();
			System.out.println(msg);
		} finally {
			try {
				// クローズ処理
				if (rset != null) {
					rset.close();
					rset = null;
				}

				if (stmt != null) {
					stmt.close();
					stmt = null;
				}

				if (conn != null) {
					conn.close();
					conn = null;
				}
			} catch (Throwable e) {
				// nop
				String msg = e.toString();
				System.out.println(msg);
			}
		}
		return info;
	}

	public void upDateSInfo(DShainData upData) {

		Connection conn = null;
		Statement stmt = null;
		PreparedStatement pstmt = null;

		try {
			// JBBCドライバクラスのロード
			Class.forName("oracle.jdbc.driver.OracleDriver");

			// Connectionの作成
			conn = getConnection();
			conn.setAutoCommit(false);
			// Statementの作成
			stmt = conn.createStatement();
			// SQL
			String sql = " UPDATE ";
			sql += "  shain_info ";
			sql += "  set ";
			sql += "    SHAIN_ID = ? ";       // 社員ID
			sql += "   ,SHAIN_NM = ? ";      // 社員名
			sql += "   ,AGE = ? ";      // 年齢
			sql += "   ,POST_NO = ? ";          // 郵便番号
			sql += "   ,ADDRESS_CD = ? ";    // 住所コード
			sql += "   ,ADDRESS2 = ? ";   // 住所２
			sql += "   ,ADDRESS3 = ? ";        // 住所３
			sql += "   ,UPDATE_ID = 'system' ";      // 更新者ID
			sql += "   ,UPDATE_DAY = NOW() ";     // 更新年月日
			sql += "  where ";     // 更新年月日
			sql += "    SHAIN_ID = ? ";       // 社員ID


			// Resultsetの作成
			pstmt = conn.prepareStatement(sql);
			pstmt.setString(1,upData.getShainId());
			pstmt.setString(2,upData.getShainNm());
			String sAge = Integer.toString(upData.getAge());
			pstmt.setString(3,sAge);
			pstmt.setString(4,upData.getPostNo());
			pstmt.setString(5,upData.getAddressCd());
			pstmt.setString(6,upData.getAddress2());
			pstmt.setString(7,upData.getAddress3());
			pstmt.setString(8,upData.getShainId());

			// INSERT文実行
			pstmt.execute();
			// COMMIT
			conn.commit();

		} catch (ClassNotFoundException e) {
			String msg = e.toString();
			System.out.println(msg);
		} catch (SQLException e) {
			try {
				conn.rollback();
			} catch (SQLException e1) {
			}
			String msg = e.toString();
			System.out.println(msg);
		} catch (Throwable e) {
			String msg = e.toString();
			System.out.println(msg);
			throw e;
		} finally {
			try {
				// クローズ処理
				if (stmt != null) {
					stmt.close();
					stmt = null;
				}

				if (conn != null) {
					conn.close();
					conn = null;
				}
			} catch (Throwable e) {
				// nop
				String msg = e.toString();
				System.out.println(msg);
			}
		}

	}

}