我今天终于用MVC完成了一个项目，再次分享

先是数据库（我用的orcal）
create table ACCOUNTINFO
(
id number(11) primary key not null,
account_number varchar2(16) not null,
account_password varchar2(6) not null,
account_money number(11) not null,
account_stutus number(11) not null--0可用，1不可用
);

create sequence seq_accountinfo;

insert into ACCOUNTINFO values(seq_accountinfo.nextval,'6221000000000001','123456',6000,0);
insert into ACCOUNTINFO values(seq_accountinfo.nextval,'6221000000000002','222222',8000,0);
insert into ACCOUNTINFO values(seq_accountinfo.nextval,'6221000000000003','333333',1000,1);
insert into ACCOUNTINFO values(seq_accountinfo.nextval,'6221000000000004','444444',2000,0);

action类：
package cn.account.action;

import cn.account.bean.AccountInfo;
import cn.account.service.AccoutInfoService;

import com.opensymphony.xwork2.Action;
import com.opensymphony.xwork2.ActionContext;
import com.opensymphony.xwork2.ActionSupport;

/**
* 核心控制器
*
*
*
*/
public class AccountInfoAction extends ActionSupport {

/**
   *
   */
private static final long serialVersionUID = -8436508189819715435L;
private String accountNumber; // 卡号
private String accountPwd; // 密码
private AccountInfo account; // 卡
private Integer money;// 取钱数
private String message; // 消息
private AccoutInfoService accountService; // 业务

public String getAccountNumber() {
return accountNumber;
}

public void setAccountNumber(String accountNumber) {
this.accountNumber = accountNumber;
}

public String getAccountPwd() {
return accountPwd;
}

public void setAccountPwd(String accountPwd) {
this.accountPwd = accountPwd;
}

public AccountInfo getAccount() {
return account;
}

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

public Integer getMoney() {
return money;
}

public void setMoney(Integer money) {
this.money = money;
}

public String getMessage() {
return message;
}

public void setMessage(String message) {
this.message = message;
}

public void setAccountService(AccoutInfoService accountService) {
this.accountService = accountService;
}

public String validateAccount() {
   account = this.accountService.getAccountByNumPwd(accountNumber, accountPwd);
if (account != null) {
ActionContext.getContext().getSession().put("account", account);
return Action.SUCCESS;
} else {
this.message = "卡号或密码错误!";
return Action.INPUT;
}
}

public String updateAccount(){
account = this.accountService.updateAccount(account, money);
if(account != null){
return Action.SUCCESS;
}else{
this.message = "取款金额不能超过余额!";
return Action.INPUT;
}
}
}
bean类：
package cn.account.bean;

/**
* AccountInfo entity. @author MyEclipse Persistence Tools
*/

public class AccountInfo implements java.io.Serializable {

// Fields

/**
   *
   */
private static final long serialVersionUID = 2800588973146481870L;
private Integer id;
private String accountNumber;
private String accountPassword;
private Integer accountMoney;
private Integer accountStutus;

// Constructors

/** default constructor */
public AccountInfo() {
}

/** full constructor */
public AccountInfo(String accountNumber, String accountPassword,
Integer accountMoney, Integer accountStutus) {
this.accountNumber = accountNumber;
this.accountPassword = accountPassword;
this.accountMoney = accountMoney;
this.accountStutus = accountStutus;
}

// Property accessors

public Integer getId() {
return this.id;
}

public void setId(Integer id) {
this.id = id;
}

public String getAccountNumber() {
return this.accountNumber;
}

public void setAccountNumber(String accountNumber) {
this.accountNumber = accountNumber;
}

public String getAccountPassword() {
return this.accountPassword;
}

public void setAccountPassword(String accountPassword) {
this.accountPassword = accountPassword;
}

public Integer getAccountMoney() {
return this.accountMoney;
}

public void setAccountMoney(Integer accountMoney) {
this.accountMoney = accountMoney;
}

public Integer getAccountStutus() {
return this.accountStutus;
}

public void setAccountStutus(Integer accountStutus) {
this.accountStutus = accountStutus;
}

}

dao类：
package cn.account.dao;

import cn.account.bean.AccountInfo;

/**
* 数据库访问接口
*
*/
public interface AccountInfoDao {
/**
   * 根据卡号和密码得到卡
   * @param accountNumber
   * @param accountPwd
   * @return 卡对象AccountInfo
   */
public AccountInfo getAccountByNumPwd(String accountNumber,String accountPwd);

/**
   * 修改卡内数据
   * @param account
   * @return 卡对象AccountInfo
   */
public AccountInfo updateAccount(AccountInfo account,Integer money);
}
daoimpl类：
package cn.account.dao.impl;

import org.springframework.orm.hibernate3.support.HibernateDaoSupport;

import cn.account.bean.AccountInfo;
import cn.account.dao.AccountInfoDao;

/**
* 数据库访问接口实现类
*
*/
public class AccountInfoDaoImpl extends HibernateDaoSupport implements
AccountInfoDao {

public AccountInfo getAccountByNumPwd(String accountNumber,
String accountPwd) {
String hql = "from AccountInfo where accountNumber=" + accountNumber + " and accountPassword=" + accountPwd;
return this.getHibernateTemplate().find(hql).size() == 0 ? null : (AccountInfo)this.getHibernateTemplate().find(hql).get(0);
}

public AccountInfo updateAccount(AccountInfo account,Integer money) {
   Integer newMoney = 0;
if(money > account.getAccountMoney())
        return null;
newMoney = account.getAccountMoney() - money;
account.setAccountMoney(newMoney);
return account;
}

}

樊占江 · 樊占江

service类：
package cn.account.service;

import cn.account.bean.AccountInfo;

/**
* 业务处理接口
*
*/
public interface AccoutInfoService {
   /**
   * 根据卡号和密码得到卡
   * @param accountNumber
   * @param accountPwd
   * @return 卡对象AccountInfo
   */
public AccountInfo getAccountByNumPwd(String accountNumber,String accountPwd);

/**
   * 修改卡内数据
   * @param account
   * @return 卡对象AccountInfo
   */
public AccountInfo updateAccount(AccountInfo account,Integer money);
}
serviceimpl类：
package cn.account.service.impl;

import cn.account.bean.AccountInfo;
import cn.account.dao.AccountInfoDao;
import cn.account.service.AccoutInfoService;

/**
* 业务处理接口实现类
*
*/
public class AccountInfoServiceImpl implements AccoutInfoService {
private AccountInfoDao accountDao;

public void setAccountDao(AccountInfoDao accountDao) {
this.accountDao = accountDao;
}

public AccountInfo getAccountByNumPwd(String accountNumber,
String accountPwd) {
return accountDao.getAccountByNumPwd(accountNumber, accountPwd);
}

public AccountInfo updateAccount(AccountInfo account, Integer money) {
return accountDao.updateAccount(account, money);
}

}
util类：
package cn.account.util;

import org.hibernate.HibernateException;
import org.hibernate.Session;
import org.hibernate.cfg.Configuration;

/**
* Configures and provides access to Hibernate sessions, tied to the
* current thread of execution.  Follows the Thread Local Session
* pattern, see {@link http://hibernate.org/42.html }.
*/
public class HibernateUtil {

/**
   * Location of hibernate.cfg.xml file.
   * Location should be on the classpath as Hibernate uses
   * #resourceAsStream style lookup for its configuration file.
   * The default classpath location of the hibernate config file is
   * in the default package. Use #setConfigFile() to update
   * the location of the configuration file for the current session.
   */
private static String CONFIG_FILE_LOCATION = "/hibernate.cfg.xml";
private static final ThreadLocal<Session> threadLocal = new ThreadLocal<Session>();
private  static Configuration configuration = new Configuration();
private static org.hibernate.SessionFactory sessionFactory;
private static String configFile = CONFIG_FILE_LOCATION;

static {
try {
configuration.configure(configFile);
sessionFactory = configuration.buildSessionFactory();
} catch (Exception e) {
System.err
.println("%%%% Error Creating SessionFactory %%%%");
e.printStackTrace();
}
}
private HibernateUtil() {
}

/**
   * Returns the ThreadLocal Session instance.  Lazy initialize
   * the <code>SessionFactory</code> if needed.
   *
   *  @return Session
   *  @throws HibernateException
   */
public static Session getSession() throws HibernateException {
      Session session = (Session) threadLocal.get();

if (session == null || !session.isOpen()) {
if (sessionFactory == null) {
rebuildSessionFactory();
}
session = (sessionFactory != null) ? sessionFactory.openSession()
: null;
threadLocal.set(session);
}

      return session;
}

/**
   *  Rebuild hibernate session factory
   *
   */
public static void rebuildSessionFactory() {
try {
configuration.configure(configFile);
sessionFactory = configuration.buildSessionFactory();
} catch (Exception e) {
System.err
.println("%%%% Error Creating SessionFactory %%%%");
e.printStackTrace();
}
}

/**
   *  Close the single hibernate session instance.
   *
   *  @throws HibernateException
   */
public static void closeSession() throws HibernateException {
      Session session = (Session) threadLocal.get();
      threadLocal.set(null);

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

/**
   *  return session factory
   *
   */
public static org.hibernate.SessionFactory getSessionFactory() {
return sessionFactory;
}

/**
   *  return session factory
   *
   * session factory will be rebuilded in the next call
   */
public static void setConfigFile(String configFile) {
HibernateUtil.configFile = configFile;
sessionFactory = null;
}

/**
   *  return hibernate configuration
   *
   */
public static Configuration getConfiguration() {
return configuration;
}

}

这是所有src 配置文件和jsp我没有发，不过谁想要全部代码，在群里找我。我传给他

帐号		自动登录	找回密码
密码			加入黑马

我今天终于用MVC完成了一个项目，再次分享

1 个回复