스프링 프레임워크 - [Spring] DB연동 / 실습:은행(Bank) 프로그램

DB 연동을 위한 라이브러리 추가

 

 

mybatis-spring 추가

https://github.com/mybatis/spring/releases

Releases · mybatis/spring

.zip파일 다운로드

 

압축 풀어서 .jar파일을 dbLib(workspace에 dbLib폴더를 생성해주었다)폴더 안에 추가해준다.

mybatis-3.5.5.jar

1.66MB

mybatis-spring-1.3.2.jar

0.05MB

ojdbc6.jar

2.05MB

 

Window> Preference > User Libraries 에 SpringDB로 추가해주었다. 

 

Add External JARs... workspace의 dbLib에 있는 .jar파일들 선택

Apply and Close하고 닫기

 

BankPro 프로젝트 폴더에 Build Path > User Library 한 후 선택하고 Finish

 

 

 

 

 

 

mybatis-spring API

http://mybatis.org/spring/

mybatis-spring – MyBatis-Spring | Introduction

 

Spring Framework

https://spring.io/projects/spring-framework#learn

Spring Framework

---

[Oracle Sql Developer : 데이터베이스]

BANK테이블

[프로젝트 파일 리스트]

전체 프로젝트 파일

BankDto.java

package com.java.bank.dto;

public class BankDto {
	private int num;
	private String id;
	private String name;
	private long balance;
	
	public BankDto() {}
	
	public BankDto(int num, String id, String name, long balance) {
		super();
		this.num = num;
		this.id = id;
		this.name = name;
		this.balance = balance;
	}
	
	public int getNum() {
		return num;
	}
	
	public void setNum(int num) {
		this.num = num;
	}
	
	public String getId() {
		return id;
	}
	
	public void setId(String id) {
		this.id = id;
	}
	
	public String getName() {
		return name;
	}
	
	public void setName(String name) {
		this.name = name;
	}
	
	public long getBalance() {
		return balance;
	}
	
	public void setBalance(long balance) {
		this.balance = balance;
	}

	@Override
	public String toString() {
		return "BankDto [num=" + num + ", id=" + id + ", name=" + name + ", balance=" + balance + "]";
	}	
}

 

[interface] BankDao.java

package com.java.bank.dao;

import java.util.List;

import com.java.bank.dto.BankDto;

public interface BankDao {
	public int makeAccount(BankDto bankDto);
	
	public List<BankDto> showData();
	
	public BankDto select(String id);

	public int update(BankDto bankDto);
	
	public long viewData(String id);
	
}

 

BankDaoImp.java

package com.java.bank.dao;

import java.util.List;

import org.mybatis.spring.SqlSessionTemplate;

import com.java.bank.dto.BankDto;

public class BankDaoImp implements BankDao {
	private SqlSessionTemplate sqlSessionTemplate;
	
	public BankDaoImp() {}
	
	public BankDaoImp(SqlSessionTemplate sqlSessionTemplate) {
		this.sqlSessionTemplate = sqlSessionTemplate;
	}

	public void setSqlSessionTemplate(SqlSessionTemplate sqlSessionTemplate) {
		this.sqlSessionTemplate = sqlSessionTemplate;
	}

	@Override
	public int makeAccount(BankDto bankDto) {
		System.out.println(bankDto.toString());
		
		// 리턴값: 0(실패) 아니면 1(성공)
		return sqlSessionTemplate.insert("bank_insert", bankDto);
	}

	@Override
	public List<BankDto> showData() {
		return sqlSessionTemplate.selectList("bank_select_list");
	}

	@Override
	public BankDto select(String id) {		
		return sqlSessionTemplate.selectOne("dao.BankMapper.bank_select", id);
	}

	@Override
	public int update(BankDto bankDto) {
		return sqlSessionTemplate.update("dao.BankMapper.update", bankDto);
	}

	@Override
	public long viewData(String id) {
		return sqlSessionTemplate.selectOne("bank_select_change", id);
	}
}

 

[interface] BankUI.java

package com.java.bank.ui;

public interface BankUI {
	public void execute();
}

​

BankView.java

package com.java.bank.ui;

import java.util.List;
import java.util.Scanner;

import com.java.bank.aop.LogAspect;
import com.java.bank.dao.BankDao;
import com.java.bank.dto.BankDto;

public class BankView implements BankUI {
	private BankDto bankDto;
	private BankDao bankDao;
	
	//DI하기 위해 생성자와 setter메소드 생성	
	public BankView() {}
		
	public BankView(BankDto bankDto, BankDao bankDao) {
		super();
		this.bankDto = bankDto;
		this.bankDao = bankDao;
	}

	public void setBankDao(BankDao bankDao) {
		this.bankDao = bankDao;
	}

	public void setBankDto(BankDto bankDto) {
		this.bankDto = bankDto;
	}

	@Override
	public void execute() {
		printMenu();
		
		Scanner sc = new Scanner(System.in);
		
		System.out.print("선택하세요: ");
		int choice = sc.nextInt();
		
		switch (choice) {
		case 1: {
			makeAccount();
			break;
		}
		case 2: {
			deposit();
			break;
		}
		case 3: {
			withdraw();
			break;
		}
		case 4: {
			viewChange();
			break;
		}
		case 5: {
			showAccount();
			break;
		}
		default:
			System.out.println("잘못입력하셨습니다.");
		}
		sc.close();
	}
	
	public void printMenu() {
		System.out.println("~~~ MENU ~~~");
		System.out.println("1.계좌개설");
		System.out.println("2.입금");
		System.out.println("3.출금");
		System.out.println("4.잔액조회");
		System.out.println("5.전체출력");
	}
	
	public void makeAccount() {
		Scanner sc = new Scanner(System.in);
		
		System.out.print("계좌번호: ");
		bankDto.setId(sc.next());
		
		System.out.print("이름: ");
		bankDto.setName(sc.next());
		
		System.out.print("입금액: ");
		bankDto.setBalance(sc.nextLong());
		
		int check = bankDao.makeAccount(bankDto);
		LogAspect.logger.info(LogAspect.logMsg + check);
		
		sc.close();
	}
	
	public void showAccount() {
		List<BankDto> bankList = bankDao.showData();
		LogAspect.logger.info(LogAspect.logMsg + bankList.size());
		
		for(int i=0; i<bankList.size(); i++) {
			BankDto dto = bankList.get(i);
			System.out.println(dto.toString());
		}
	}
	
	public void deposit() {
		Scanner sc = new Scanner(System.in);
		
		System.out.print("계좌번호: ");
		String id = sc.next();
		
		bankDto = bankDao.select(id);
		LogAspect.logger.info(LogAspect.logMsg + bankDto);
		
		if(bankDto!=null) {
			System.out.print("입금액: ");
			long money = sc.nextLong();
			
			bankDto.setBalance(bankDto.getBalance() + money);
			int check = bankDao.update(bankDto);
			//LogAspect.logger.info(LogAspect.logMsg + bankDto);
			
			if(check > 0) {
				System.out.println("입금 완료했습니다.");
			}else {
				System.out.println("입금 되지 않았습니다. \n다시 시도해주세요.");
			}
			
		}else {
			System.out.println("계좌번호가 존재하지 않습니다.");
		}
		sc.close();
	}
	
	public void withdraw() {
		Scanner sc = new Scanner(System.in);
		
		System.out.print("계좌번호:");
		String id = sc.next();
		
		bankDto = bankDao.select(id);
		LogAspect.logger.info(LogAspect.logMsg + bankDto);
		
		if(bankDto!=null) {
			System.out.print("출금액: ");
			long money = sc.nextLong();
			
			if(money <= bankDto.getBalance()) {
				bankDto.setBalance(bankDto.getBalance() - money);
				int check = bankDao.update(bankDto);
				
				if(check > 0) {
					System.out.println("출금 완료했습니다.");
				}else {
					System.out.println("출금 되지 않았습니다. \n 다시 시도해주세요.");
				}
			}else {
				System.out.println("잔액이 부족합니다.");
			}
		}
		sc.close();
	}
	
	public void viewChange() {
		Scanner sc = new Scanner(System.in);
		
		System.out.print("계좌번호:");
		String id = sc.next();
		
		long balance = bankDao.viewData(id);
		
		System.out.println("남은 잔액은 " + balance + "원 입니다.");
	}
}

 

BankMapper.xml

<?xml version="1.0" encoding="UTF-8"?>
<!DOCTYPE mapper
  PUBLIC "-//mybatis.org//DTD Config 3.0//EN"
  "http://mybatis.org/dtd/mybatis-3-mapper.dtd">
  
  <mapper namespace="dao.BankMapper">
  	<insert id="bank_insert" parameterType="com.java.bank.dto.BankDto">
  		insert into bank values(bank_num_seq.nextval, #{id}, #{name}, #{balance})
  	</insert>
  	
  	<select id="bank_select_list" resultType="com.java.bank.dto.BankDto">
  		select * from bank
  	</select>
  	
  	<select id="bank_select" resultType="com.java.bank.dto.BankDto" parameterType="String">
  		select * from bank where id = #{id}
  	</select>
  	
  	<update id ="update" parameterType="com.java.bank.dto.BankDto">
  		update bank set balance = #{balance} where id=#{id}
  	</update>
  	
  	<select id ="bank_select_change" resultType="long" parameterType="String">
  		select balance from bank where id = #{id}
  	</select>
  </mapper>

 

LogAspect.java

package com.java.bank.aop;

import java.util.logging.Logger;

import org.aspectj.lang.ProceedingJoinPoint;

public class LogAspect {
	public static Logger logger = Logger.getLogger(LogAspect.class.getName());
	public static final String logMsg = "LogMsg ~~~~~~~~~~~";
	
	public Object advice(ProceedingJoinPoint joinPoint) {
		Object obj = null;
		
		try {
			logger.info(logMsg + joinPoint.getTarget().getClass().getName() + "\t" + joinPoint.getSignature().getName());
			obj = joinPoint.proceed(); 
		} catch (Throwable e) {
			e.printStackTrace();
		} //자동으로 close해주기 때문에 .close()하지 않아도 된다.
		
		return obj;
	}
}

 

appCTX.xml

appCTX.xml에 경로추가한다.

<?xml version="1.0" encoding="UTF-8"?>
<beans xmlns="http://www.springframework.org/schema/beans"
	xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
	xmlns:aop="http://www.springframework.org/schema/aop"
	xsi:schemaLocation="http://www.springframework.org/schema/beans http://www.springframework.org/schema/beans/spring-beans.xsd
		http://www.springframework.org/schema/aop http://www.springframework.org/schema/aop/spring-aop-3.1.xsd">

	<!-- DB 설정 -->
	<bean id="dataSource" class="org.springframework.jdbc.datasource.DriverManagerDataSource">
		<property name="driverClassName" value="oracle.jdbc.driver.OracleDriver"/>
		<property name="url" value="jdbc:oracle:thin:@localhost:1521:xe"/>
		<property name="username" value="java"/>
		<property name="password" value="1234"/>
	</bean>
	
	<!-- MyBatis / WEBMVC SqlSessionFactoryBuilder - SqlSessionFactory - Session설정 -->
	<bean id="sqlSessionFactoryBean" class="org.mybatis.spring.SqlSessionFactoryBean">
		<property name="dataSource" ref="dataSource"/>
		<property name="mapperLocations" value="classpath:com/java/bank/dao/mapper/BankMapper.xml"/>
	</bean>
	
	<bean id="sqlSessionTemplate" class="org.mybatis.spring.SqlSessionTemplate">
		<constructor-arg ref="sqlSessionFactoryBean"/>
	</bean>
	
	<!-- BankDto 생성 -->
	<bean id="bankDto" class="com.java.bank.dto.BankDto"/>
	
	<!-- BankDao 생성 -->
	<bean id="bankDaoImp" class="com.java.bank.dao.BankDaoImp">
		<constructor-arg ref="sqlSessionTemplate"/>
	</bean>
	
	<!-- UI생성 -->
	<bean id="bankView" class="com.java.bank.ui.BankView">
		<property name="bankDto" ref="bankDto"/>
		<property name="bankDao" ref="bankDaoImp"/>
	</bean>
	
	<!-- 공통클래스 -->
	<bean id="logAspect" class="com.java.bank.aop.LogAspect"/>
	
	<!-- AOP 설정 -->
	<aop:config>
		<aop:aspect id="exAspect" ref="logAspect">
			<aop:pointcut expression="within(com.java.bank.dao.*)" id="pMethod"/>
			<aop:around method="advice" pointcut-ref="pMethod"/>
		</aop:aspect>
	</aop:config>
</beans>

​

MainClass.java

package com.java.bank.main;

import org.springframework.context.support.GenericXmlApplicationContext;

import com.java.bank.ui.BankUI;

public class MainClass {
	public static void main(String[] args) {
		GenericXmlApplicationContext ctx = new GenericXmlApplicationContext("appCTX.xml");
		
		BankUI bankUI = (BankUI) ctx.getBean("bankView");
		bankUI.execute();
		
		ctx.close();
	}
}

 

BankMapper.xml 

<?xml version="1.0" encoding="UTF-8"?>
<!DOCTYPE mapper
  PUBLIC "-//mybatis.org//DTD Config 3.0//EN"
  "http://mybatis.org/dtd/mybatis-3-mapper.dtd">
  
  <mapper namespace="dao.BankMapper">
  	<insert id="bank_insert" parameterType="com.java.bank.dto.BankDto">
  		insert into bank values(bank_num_seq.nextval, #{id}, #{name}, #{balance})
  	</insert>
  </mapper>

 

1. 계좌개설

2. 입금

출금

5. 전체조회