struts+spring+hibernate的web应用 Dao层代码编写

前一篇文章 (struts+spring+hibernate的web应用<一> 架构搭建) 让我们打好了架子，接下来就来编写代码了。在编码之前，我们需要先自行了解 strust,spring,hibernate 基础知识，后面的文章将不会过多的介绍这些框架的基础知识。整个项目由 Dao,Services,Web 三层组成， Dao 层主要通过 hibernate 来操作数据库， Service 层主要体现了业务，事务的处理， Web 层由 struts 来控制。整个项目的控制交由 spring 管理。

现在的这个小项目除了完成基本的添删改查，还有一个简单的分页功能。这个分页功能不仅前台分页，而且在后台数据库也进行了分页处理。

现在就来编写 Dao 层的代码。

首先写好 pojo 的代码：

在 com.game.products.model 中新建 products.hbm.xml 类，代码如下：

<? xmlversion="1.0"encoding="GB2312" ?>
<! DOCTYPEhibernate-mappingPUBLIC"-//Hibernate/HibernateMappingDTD3.0//EN"
"http://hibernate.sourceforge.net/hibernate-mapping-3.0.dtd" >

< hibernate-mapping >
< class name ="com.game.products.model.Products" table ="products" >
< id name ="gameId" type ="string" >
< column name ="game_id" length ="5" />
< generator class ="assigned" />
</ id >
< property name ="gameNameCn" type ="string" >
< column name ="game_name_cn" length ="100" />
</ property >
< property name ="gameNameEn" type ="string" >
< column name ="game_name_en" length ="100" />
</ property >
< property name ="gameCapacity" type ="string" >
< column name ="game_capacity" length ="4" />
</ property >
< property name ="gameVersion" type ="string" >
< column name ="game_version" length ="4" />
</ property >
< property name ="gameMedia" type ="string" >
< column name ="game_media" length ="4" />
</ property >
< property name ="gameCopyright" type ="string" >
< column name ="game_copyright" length ="4" />
</ property >
< property name ="gamePrice" type ="string" >
< column name ="game_price" length ="4" />
</ property >
< property name ="gameContent" type ="string" >
< column name ="game_content" length ="100" />
</ property >
</ class >
</ hibernate-mapping >

注意这里的 ID 不是数据库自动生成的，而是根据需要由程序生成，一般项目中的主键 ID 都是采取这种方式。

然后在这个包中再新建 Products 类，代码如下：

package com.game.products.model;

public class Products {
// Fields
private StringgameId; // 编号
private StringgameNameCn; // 中文名称
private StringgameNameEn; // 英文名称
private StringgameCapacity; // 碟数
private StringgameVersion; // 版本
private StringgameMedia; // 介质
private StringgameCopyright; // 版权
private StringgamePrice; // 价格
private StringgameContent; // 攻略

// Constructors
public Products() {}

// Propertyaccessors
public StringgetGameCapacity() {
return gameCapacity;
}

public void setGameCapacity(StringgameCapacity) {
this .gameCapacity = gameCapacity;
}

public StringgetGameId() {
return gameId;
}

public void setGameId(StringgameId) {
this .gameId = gameId;
}

public StringgetGameNameCn() {
return gameNameCn;
}

public void setGameNameCn(StringgameNameCn) {
this .gameNameCn = gameNameCn;
}

public StringgetGameNameEn() {
return gameNameEn;
}

public void setGameNameEn(StringgameNameEn) {
this .gameNameEn = gameNameEn;
}

public StringgetGameVersion() {
return gameVersion;
}

public void setGameVersion(StringgameVersion) {
this .gameVersion = gameVersion;
}

public StringgetGameMedia() {
return gameMedia;
}

public void setGameMedia(StringgameMedia) {
this .gameMedia = gameMedia;
}

public StringgetGameCopyright() {
return gameCopyright;
}

public void setGameCopyright(StringgameCopyright) {
this .gameCopyright = gameCopyright;
}

public StringgetGameContent() {
return gameContent;
}

public void setGameContent(StringgameContent) {
this .gameContent = gameContent;
}

public StringgetGamePrice() {
return gamePrice;
}

public void setGamePrice(StringgamePrice) {
this .gamePrice = gamePrice;
}

}

需要注意的是，我这里都是采用了 string 类型，因为在项目中传递数据，用 string 类型最为方便，同时也便于代码的编写。只是在前台需要编写验证代码，免得有字符数据插入整数字段而造成数据库异常。

在 com.game.products.dao.iface 包中新建ProductsDao接口。

代码如下所示：

package com.game.products.dao.iface;

import java.util.List;

import com.game.products.model.Products;

public interface ProductsDao {
ListgetProducts(); // 获得所有记录
ListgetProducts( int pageSize, int startRow); // 获得一段记录
int getRows(); // 获得总行数
int getRows(Stringfieldname,Stringvalue); // 获得总行数
ListqueryProducts(Stringfieldname,Stringvalue); // 根据条件查询的所有记录
ListqueryProducts(Stringfieldname,Stringvalue, int pageSize, int startRow); // 根据条件查询的一段记录
ProductsgetProduct(StringgameId); // 根据ID获得记录
StringgetMaxID(); // 获得最大ID值
void addProduct(Productspd); // 添加记录
void updateProductd(Productspd); // 修改记录
void deleteProduct(Productspd); // 删除记录
}

在com.game.products.dao.hibernate包中新建继承HibernateDaoSupport的ProductsMapDao类，并实现了ProductsDao接口。

代码如下：

package com.game.products.dao.hibernate;

import java.sql.SQLException;
import java.util.Iterator;
import java.util.List;

import org.hibernate.HibernateException;
import org.hibernate.Query;
import org.hibernate.Session;
import org.springframework.orm.hibernate3.HibernateCallback;
import org.springframework.orm.hibernate3.support.HibernateDaoSupport;

import com.game.products.dao.iface.ProductsDao;
import com.game.products.model.Products;


/***/ /**
* @author cwf
*
*/
public class ProductsMapDao extends HibernateDaoSupport implements ProductsDao {

public ProductsMapDao() {}

/***/ /**
*函数说明：添加信息
*参数说明：对象
*返回值：
*/
public void addProduct(Productspd) {
this .getHibernateTemplate().save(pd);
}

/***/ /**
*函数说明：删除信息
*参数说明：对象
*返回值：
*/
public void deleteProduct(Productspd) {
this .getHibernateTemplate().delete(pd);
}

/***/ /**
*函数说明：获得所有的信息
*参数说明：
*返回值：信息的集合
*/
public ListgetProducts() {
Stringsql = " FROMProductsORDERBYgameNameCn " ;
return this .getHibernateTemplate().find(sql);
}

/***/ /**
*函数说明：获得总行数
*参数说明：
*返回值：总行数
*/
public int getRows() {
Stringsql = " FROMProductsORDERBYgameNameCn " ;
Listlist = this .getHibernateTemplate().find(sql);
return list.size();
}

/***/ /**
*函数说明：获得一段记录信息
*参数说明：
*返回值：信息的集合
*/
public ListgetProducts( int pageSize, int startRow) throws HibernateException {
final int pageSize1 = pageSize;
final int startRow1 = startRow;
return this .getHibernateTemplate().executeFind( new HibernateCallback() {

public ListdoInHibernate(Sessionsession) throws HibernateException,SQLException {
Queryquery = session.createQuery( " FROMProductsORDERBYgameNameCn " );
query.setFirstResult(startRow1);
query.setMaxResults(pageSize1);
return query.list();
}
} );
}

/***/ /**
*函数说明：获得一条的信息
*参数说明：ID
*返回值：对象
*/
public ProductsgetProduct(StringgameId) {
return (Products) this .getHibernateTemplate().get(Products. class ,gameId);
}

/***/ /**
*函数说明：获得最大ID
*参数说明：
*返回值：最大ID
*/
public StringgetMaxID() {
Stringsql = " SELECTMAX(gameId)+1FROMProducts " ;
StringnoStr = null ;
Listll = (List) this .getHibernateTemplate().find(sql);
Iteratoritr = ll.iterator();
if (itr.hasNext()) {
Objectnoint = itr.next();
if (noint == null ) {
noStr = " 1 " ;
} else {
noStr = noint.toString();
}
}

if (noStr.length() == 1 ) {
noStr = " 000 " + noStr;
} else if (noStr.length() == 2 ) {
noStr = " 00 " + noStr;
} else if (noStr.length() == 3 ) {
noStr = " 0 " + noStr;
} else {
noStr = noStr;
}
return noStr;
}

/***/ /**
*函数说明：修改信息
*参数说明：对象
*返回值：
*/
public void updateProductd(Productspd) {
this .getHibernateTemplate().update(pd);
}

/***/ /**
*函数说明：查询的所有信息
*参数说明：集合
*返回值：
*/
public ListqueryProducts(Stringfieldname,Stringvalue) {
System.out.println( " value: " + value);
Stringsql = " FROMProductswhere " + fieldname + " like'% " + value + " %' " + " ORDERBYgameNameCn " ;
return this .getHibernateTemplate().find(sql);
}

/***/ /**
*函数说明：获得总行数
*参数说明：
*返回值：总行数
*/
public int getRows(Stringfieldname,Stringvalue) {
Stringsql = " FROMProductswhere " + fieldname + " like'% " + value + " %' " + " ORDERBYgameNameCn " ;
Listlist = this .getHibernateTemplate().find(sql);
return list.size();
}

/***/ /**
*函数说明：查询的一段信息
*参数说明：集合
*返回值：
*/
public ListqueryProducts(Stringfieldname,Stringvalue, int pageSize, int startRow) {
final int pageSize1 = pageSize;
final int startRow1 = startRow;
final Stringsql = " FROMProductswhere " + fieldname + " like'% " + value + " %' " + " ORDERBYgameNameCn " ;
return this .getHibernateTemplate().executeFind( new HibernateCallback() {

public ListdoInHibernate(Sessionsession) throws HibernateException,SQLException {
Queryquery = session.createQuery(sql);
query.setFirstResult(startRow1);
query.setMaxResults(pageSize1);
return query.list();
}
} );
}

}

在com.game.bean.hibernate包中新建hibernate.cfg.xml，代码如下：

<? xmlversion="1.0"encoding="GB2312" ?>
<! DOCTYPEhibernate-configurationPUBLIC
"-//Hibernate/HibernateConfigurationDTD3.0//EN"
"http://hibernate.sourceforge.net/hibernate-configuration-3.0.dtd" >
< hibernate-configuration >
< session-factory >
< property name ="dialect" > org.hibernate.dialect.SQLServerDialect </ property >
< property name ="show_sql" > true </ property >

< mapping resource ="com/game/products/model/products.hbm.xml" ></ mapping >
</ session-factory >
</ hibernate-configuration >

至此，DAO层的代码已经编写完成。下一篇，将编写service层代码。

struts+spring+hibernate 的 web 应用 < 三 > Service 层代码编写