/*

Navicat MySQL Data Transfer

Source Server         : mysql

Source Server Version : 50549

Source Host           : localhost:3306

Source Database       : ooxx

Target Server Type    : MYSQL

Target Server Version : 50549

File Encoding         : 65001

Date: 2019-08-16 09:22:04

*/

SET FOREIGN_KEY_CHECKS=0;

-- ----------------------------

-- Table structure for account

-- ----------------------------

DROP TABLE IF EXISTS `account`;

CREATE TABLE `account` (

`aid` int(11) NOT NULL,

`abalance` double DEFAULT NULL,

PRIMARY KEY (`aid`)

) ENGINE=InnoDB DEFAULT CHARSET=utf8;

-- ----------------------------

-- Records of account

-- ----------------------------

INSERT INTO `account` VALUES ('1', '8000');

INSERT INTO `account` VALUES ('2', '9000');

-- ----------------------------

-- Table structure for user

-- ----------------------------

DROP TABLE IF EXISTS `user`;

CREATE TABLE `user` (

`uid` int(11) NOT NULL AUTO_INCREMENT,

`uname` varchar(255) DEFAULT NULL,

`upwd` varchar(255) DEFAULT NULL,

PRIMARY KEY (`uid`),

CONSTRAINT `user_ibfk_1` FOREIGN KEY (`uid`) REFERENCES `account` (`aid`)

) ENGINE=InnoDB AUTO_INCREMENT=3 DEFAULT CHARSET=utf8;

-- ----------------------------

-- Records of user

-- ----------------------------

INSERT INTO `user` VALUES ('1', '李斌', '123456');

INSERT INTO `user` VALUES ('2', '乔治大哥', '123456');

<?xml version="1.0" encoding="UTF-8"?>

<c3p0-config>

<default-config>
        <property name="driverClass">com.mysql.jdbc.Driver</property>
        <property name="jdbcUrl">jdbc:mysql://localhost:3306/ooxx</property>
        <property name="user">root</property>
        <property name="password">123456</property>

<property name="acquireIncrement">5</property>
        <property name="initialPoolSize">10</property>
        <property name="minPoolSize">5</property>
        <property name="maxPoolSize">20</property>
    </default-config>

</c3p0-config>

package com.henu.util;

import com.mchange.v2.c3p0.ComboPooledDataSource;

import java.sql.Connection;
import java.sql.ResultSet;
import java.sql.SQLException;
import java.sql.Statement;

public class JdbcUtil {

private static ComboPooledDataSource ds = null;

//在静态代码块中创建数据库连接池
    static{
        try{
            ds = new ComboPooledDataSource("c3p0-config");//使用C3P0的命名配置来创建数据源

        }catch (Exception e) {
            throw new ExceptionInInitializerError(e);
        }
    }

public static ComboPooledDataSource getDataSourse(){
        return ds;
    }

public static Connection getConnection() throws SQLException{
        //从数据源中获取数据库连接
        return ds.getConnection();
    }

public static void close(Connection conn,Statement st,ResultSet rs){
        if(rs!=null){
            try{
                rs.close();
            }catch (Exception e) {
                e.printStackTrace();
            }
        }
        if(st!=null){
            try{
                st.close();
            }catch (Exception e) {
                e.printStackTrace();
            }
        }

if(conn!=null){
            try{
                conn.close();
            }catch (Exception e) {
                e.printStackTrace();
            }
        }
    }
}

package com.henu.bean;

public class Account {
    private int aid;
    private double abalance;

public Account() {
    }

public Account(int aid, int abalance) {
        this.aid = aid;
        this.abalance = abalance;
    }

public int getAid() {
        return aid;
    }

public void setAid(int aid) {
        this.aid = aid;
    }

public double getAbalance() {
        return abalance;
    }

public void setAbalance(double abalance) {
        this.abalance = abalance;
    }

@Override
    public String toString() {
        return "Account{" +
                "aid=" + aid +
                ", abalance=" + abalance +
                '}';
    }
}

package com.henu.bean;

public class User {
    private int uid;
    private String uname;
    private String upwd;
    private Account account;//将account放进user中以便多表查询

    public User() {
    }

public User(String uname, String upwd) {
        this.uname = uname;
        this.upwd = upwd;
    }

public User(String uname, String upwd, Account account) {
        this.uname = uname;
        this.upwd = upwd;
        this.account = account;
    }

public User(int uid, String uname, String upwd, Account account) {
        this.uid = uid;
        this.uname = uname;
        this.upwd = upwd;
        this.account = account;
    }

public int getUid() {
        return uid;
    }

public void setUid(int uid) {
        this.uid = uid;
    }

public String getUname() {
        return uname;
    }

public void setUname(String uname) {
        this.uname = uname;
    }

public String getUpwd() {
        return upwd;
    }

public void setUpwd(String upwd) {
        this.upwd = upwd;
    }

public Account getAccount() {
        return account;
    }

public void setAccount(Account account) {
        this.account = account;
    }

@Override
    public String toString() {
        return "User{" +
                "uid=" + uid +
                ", uname='" + uname + '\'' +
                ", upwd='" + upwd + '\'' +
                ", account=" + account +
                '}';
    }
}

package com.henu.dao;

import com.henu.bean.User;

import java.sql.Connection;

public interface UserDao {
    User findUserByunameAndupwd(String uanme, String upwd);
    int updateUserAbalance(Connection conn, double d, String uname, String upwd);
    User findUserByUid(int uid);
    int updateToUserAbalance(Connection conn,double d,int aid);
}

package com.henu.dao.impl;

import com.henu.bean.Account;
import com.henu.bean.User;
import com.henu.dao.UserDao;
import com.henu.util.JdbcUtil;
import org.apache.commons.dbutils.QueryRunner;
import org.apache.commons.dbutils.handlers.MapHandler;

import java.sql.Connection;
import java.sql.SQLException;
import java.util.Map;
import java.util.Set;

public class UserDaoImpl implements UserDao {

@Override
    public User findUserByunameAndupwd(String uanme, String upwd) {
        QueryRunner qr = new QueryRunner(JdbcUtil.getDataSourse());
        User user = new User();
        Account account = new Account();
        Map<String,Object> map = null;
        String sql = "select * from user,account where uid=aid and uname=? and upwd=? ";
        try {
            map = qr.query(sql,new MapHandler(),uanme,upwd);
            Set<Map.Entry<String,Object>> entries = map.entrySet();
            for (Map.Entry<String,Object> e : entries
                 ) {
                if ("uid".equals(e.getKey())){
                    user.setUid((int)e.getValue());
                }else if ("uname".equals(e.getKey())){
                    user.setUname((String)e.getValue());
                }else if ("upwd".equals(e.getKey())){
                    user.setUpwd((String)e.getValue());
                }else if ("aid".equals(e.getKey())){
                    account.setAid((int)e.getValue());
                }else if ("abalance".equals(e.getKey())){
                    account.setAbalance((double)e.getValue());
                }
            }
            user.setAccount(account);
        } catch (SQLException e) {
            e.printStackTrace();
        }
        return user;
    }

@Override
    public int updateUserAbalance(Connection conn, double d, String uname, String upwd) {
        User user = findUserByunameAndupwd(uname,upwd);
        QueryRunner qr = new QueryRunner(JdbcUtil.getDataSourse());
        int res = 0;
        int aid = user.getUid();
        double dd = user.getAccount().getAbalance() - d;
        if (dd > 0) {
            Account account = new Account();
            String sql = "update account set abalance=? where aid = ?";
            try {
                res = qr.update(sql, new Object[]{dd, aid});
            } catch (SQLException e) {
                e.printStackTrace();
            }
            user.setAccount(account);
            return res;
        }else{
            return 0;
        }

}

@Override
    public User findUserByUid(int uid) {
        QueryRunner qr = new QueryRunner(JdbcUtil.getDataSourse());
        User user = new User();
        Account account = new Account();
        Map<String,Object> map = null;
        String sql = "select * from user,account where uid = aid and uid = ?";
        try {
            map = qr.query(sql,new MapHandler(),uid);
            Set<Map.Entry<String,Object>> entries = map.entrySet();
            for (Map.Entry<String,Object> e: entries
                 ) {
                if ("uid".equals(e.getKey())){
                    user.setUid((int)e.getValue());
                }else if("uname".equals(e.getKey())){
                    user.setUname((String)e.getValue());
                }else if("upwd".equals(e.getKey())){
                    user.setUpwd((String)e.getValue());
                }else if("aid".equals(e.getKey())){
                    account.setAid((int)e.getValue());
                }else if ("abalance".equals(e.getKey())){
                    account.setAbalance((double)e.getValue());
                }
                user.setAccount(account);
            }

} catch (SQLException e) {
            e.printStackTrace();
        }
        return user;
    }

@Override
    public int updateToUserAbalance(Connection conn,double d, int aid) {
        User user2 = findUserByUid(aid);
        QueryRunner qr = new QueryRunner(JdbcUtil.getDataSourse());
        int res = 0;
        double dd = user2.getAccount().getAbalance()+d;
        Account account = new Account();
        String sql = "update account set abalance=? where aid=?";
        try {
            res = qr.update(sql,new Object[]{dd,aid});
            user2.setAccount(account);
        } catch (SQLException e) {
            e.printStackTrace();
        }
        return res;
    }

}

package com.henu.service;

import com.henu.bean.User;

import java.sql.Connection;

public interface UserService {
    User serviceLogin(String uname, String upwd);
    double QueryBalance(User user);
    int withdrawal(Connection conn,double d, String uname, String upwd);
    User serviceLoginByUid(int uid);
    int receiveTransfer(Connection conn,double dd,int uid);
}

package com.henu.service.impl;

import com.henu.bean.User;
import com.henu.dao.UserDao;
import com.henu.dao.impl.UserDaoImpl;
import com.henu.service.UserService;

import java.sql.Connection;

public class UserServiceImpl implements UserService {
    UserDao userDao = new UserDaoImpl();
    @Override
    public User serviceLogin(String uname, String upwd) {
        return userDao.findUserByunameAndupwd(uname,upwd);
    }

@Override
    public double QueryBalance(User user) {

double balance = user.getAccount().getAbalance();
        return balance;
    }

@Override
    public int withdrawal(Connection conn, double d, String uname, String upwd) {
        return userDao.updateUserAbalance(conn,d,uname,upwd);
    }

@Override
    public User serviceLoginByUid(int uid) {
        return userDao.findUserByUid(uid);
    }

@Override
    public int receiveTransfer(Connection conn,double dd, int uid) {
        return userDao.updateToUserAbalance(conn,dd,uid);
    }

}

package com.henu;

import com.henu.bean.User;
import com.henu.service.UserService;
import com.henu.service.impl.UserServiceImpl;
import com.henu.util.JdbcUtil;

import java.sql.Connection;
import java.sql.SQLException;
import java.util.Scanner;

public class MainClass {
    public static void main(String[] args) {

Scanner sc = new Scanner(System.in);
        System.out.println("Welcome to mengdong bank!");
        System.out.println("Please enter your name:");
        String uname = sc.nextLine();
        System.out.println("Please enter your pwd:");
        String upwd = sc.nextLine();

UserService uService = new UserServiceImpl();
        User user = new User();
        try {
            user = uService.serviceLogin(uname, upwd);
        }catch (NullPointerException e){
            throw new RuntimeException("No such user!Please restart the program!");
        }

boolean flag = true;
        while(flag){
            System.out.println("--------------------------------");
            menu();
            System.out.println("--------------------------------");
            System.out.println("Please enter your choose:");
            String choose = sc.nextLine();
            switch (choose){
                case "1" :
                    User newUser = uService.serviceLogin(uname,upwd);
                    double d1 = uService.QueryBalance(newUser);
                    System.out.println("********************************");
                    System.out.println("Your Balance is:" + d1);
                    System.out.println("********************************");
                    flag = true;
                    break;
                case "2" :
                    System.out.println("Please enter your withdrawal amount:");
                    String str = sc.nextLine();
                    double d2 = Double.parseDouble(str);
                    Connection conn1 = null;
                    try {
                        conn1 = JdbcUtil.getConnection();
                        conn1.setAutoCommit(false);
                        uService.withdrawal(conn1,d2,uname,upwd);
                        conn1.commit();
                    } catch (SQLException e) {
                        e.printStackTrace();
                        try {
                            conn1.rollback();
                        } catch (SQLException e1) {
                            e1.printStackTrace();
                        }
                    }
                    System.out.println("********************************");
                    System.out.println("You withdraw "+ d2 + " yuan in cash.");
                    System.out.println("********************************");
                    flag = true;
                    break;
                case "3" :
                    System.out.println("Please enter the user id you want to transfer:");
                    String str2 = sc.nextLine();
                    System.out.println("Please enter your transfer amount:");
                    String str3 = sc.nextLine();
                    int to = Integer.parseInt(str2);
                    double d3 = Double.parseDouble(str3);
                    if (to == user.getUid()){
                        System.out.println("********************************");
                        System.err.println("Here is your account number!");
                        System.out.println("********************************");
                    }else {
                        User user2 = null;
                        try {
                            user2 = uService.serviceLoginByUid(to);
                        } catch (NullPointerException r) {
                            System.err.println("********************************");
                            System.err.println("There is no such user id!");
                            System.err.println("********************************");
                        }
                        if (user2 != null) {
                            Connection conn = null;
                            try {
                                conn = JdbcUtil.getConnection();
                                conn.setAutoCommit(false);
                                uService.withdrawal(conn, d3, uname, upwd);
                                uService.receiveTransfer(conn, d3, user2.getUid());
                                conn.commit();
                            } catch (Exception e) {
                                System.err.println("System error!");
                                try {
                                    conn.rollback();
                                } catch (SQLException e1) {
                                    e1.printStackTrace();
                                }
                            }
                            System.out.println("********************************");
                            System.out.println("Transfer Success!");
                            System.out.println("********************************");
                        } else {
                            System.err.println("********************************");
                            System.err.println("There is no such user id!");
                            System.err.println("********************************");
                        }
                    }
                    flag=true;
                    break;
                case "4" :
                    flag = false;
                    System.exit(0);
                    break;
                default:
                    System.err.println("Your input error!!!");
                    flag = true;
                    break;
            }
        }

}
    public static void menu(){
        System.out.println("Welcome to the homepage!!!");
        System.out.println("We provide the following functionality!");
        System.out.println("1.Query balance");
        System.out.println("2.withdrawal");
        System.out.println("3.transfer accounts");
        System.out.println("4.exit");
    }

}