struts+spring+hibernate的web应用<二> Dao层代码编写
本文共 8676 字，大约阅读时间需要 28 分钟。
前一篇文章 () 让我们打好了架子，接下来就来编写代码了。在编码之前，我们需要先自行了解 strust,spring,hibernate 基础知识，后面的文章将不会过多的介绍这些框架的基础知识。整个项目由 Dao,Services,Web 三层组成， Dao 层主要通过 hibernate 来操作数据库， Service 层主要体现了业务，事务的处理， Web 层由 struts 来控制。整个项目的控制交由 spring 管理。
现在的这个小项目除了完成基本的添删改查，还有一个简单的分页功能。这个分页功能不仅前台分页，而且在后台数据库也进行了分页处理。
现在就来编写 Dao 层的代码。
首先写好 pojo 的代码：
在 com.game.products.model 中新建 products.hbm.xml 类，代码如下：
<? xml version="1.0" encoding="GB2312" ?> <! DOCTYPE hibernate-mapping PUBLIC "-//Hibernate/Hibernate Mapping DTD 3.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 String gameId; // 编号 private String gameNameCn; // 中文名称 private String gameNameEn; // 英文名称 private String gameCapacity; // 碟数 private String gameVersion; // 版本 private String gameMedia; // 介质 private String gameCopyright; // 版权 private String gamePrice; // 价格 private String gameContent; // 攻略 // Constructors 
public Products() {} // Property accessors public String getGameCapacity() { return gameCapacity; 
} public void setGameCapacity(String gameCapacity) { this .gameCapacity = gameCapacity; } public String getGameId() { return gameId; } public void setGameId(String gameId) { this .gameId = gameId; } public String getGameNameCn() { return gameNameCn; } public void setGameNameCn(String gameNameCn) { this .gameNameCn = gameNameCn; } public String getGameNameEn() { return gameNameEn; } public void setGameNameEn(String gameNameEn) { this .gameNameEn = gameNameEn; } public String getGameVersion() { return gameVersion; } public void setGameVersion(String gameVersion) { this .gameVersion = gameVersion; } public String getGameMedia() { return gameMedia; } public void setGameMedia(String gameMedia) { this .gameMedia = gameMedia; } public String getGameCopyright() { return gameCopyright; } public void setGameCopyright(String gameCopyright) { this .gameCopyright = gameCopyright; } public String getGameContent() { return gameContent; } public void setGameContent(String gameContent) { this .gameContent = gameContent; } public String getGamePrice() { return gamePrice; } public void setGamePrice(String gamePrice) { 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 { List getProducts(); // 获得所有记录 List getProducts( int pageSize, int startRow); // 获得一段记录 int getRows(); // 获得总行数 int getRows(String fieldname,String value); // 获得总行数 List queryProducts(String fieldname,String value); // 根据条件查询的所有记录 List queryProducts(String fieldname,String value, int pageSize, int startRow); // 根据条件查询的一段记录 Products getProduct(String gameId); // 根据ID获得记录 String getMaxID(); // 获得最大ID值 void addProduct(Products pd); // 添加记录 void updateProductd(Products pd); // 修改记录 void deleteProduct(Products pd); // 删除记录 } 在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(Products pd) { this .getHibernateTemplate().save(pd); } /** */ /** * 函数说明：删除信息 * 参数说明： 对象 * 返回值： */ public void deleteProduct(Products pd) { this .getHibernateTemplate().delete(pd); } /** */ /** * 函数说明：获得所有的信息 * 参数说明： * 返回值：信息的集合 */ public List getProducts() { String sql = " FROM Products ORDER BY gameNameCn " ; return this .getHibernateTemplate().find(sql); } /** */ /** * 函数说明：获得总行数 * 参数说明： * 返回值：总行数 */ public int getRows() { String sql = " FROM Products ORDER BY gameNameCn " ; List list = this .getHibernateTemplate().find(sql); return list.size(); } /** */ /** * 函数说明：获得一段记录信息 * 参数说明： * 返回值：信息的集合 */ public List getProducts( int pageSize, int startRow) throws HibernateException { final int pageSize1 = pageSize; final int startRow1 = startRow; return this .getHibernateTemplate().executeFind( new HibernateCallback() { public List doInHibernate(Session session) throws HibernateException, SQLException { Query query = session.createQuery( " FROM Products ORDER BY gameNameCn " ); query.setFirstResult(startRow1); query.setMaxResults(pageSize1); return query.list(); } } ); } /** */ /** * 函数说明：获得一条的信息 * 参数说明： ID * 返回值：对象 */ public Products getProduct(String gameId) { return (Products) this .getHibernateTemplate().get(Products. class ,gameId); } /** */ /** * 函数说明：获得最大ID * 参数说明： * 返回值：最大ID */ public String getMaxID() { String sql = " SELECT MAX(gameId)+1 FROM Products " ; String noStr = null ; List ll = (List) this .getHibernateTemplate().find(sql); Iterator itr = ll.iterator(); if (itr.hasNext()) { Object noint = 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(Products pd) { this .getHibernateTemplate().update(pd); } /** */ /** * 函数说明：查询的所有信息 * 参数说明： 集合 * 返回值： */ public List queryProducts(String fieldname,String value) { System.out.println( " value: " + value); String sql = " FROM Products where " + fieldname + " like '% " + value + " %' " + " ORDER BY gameNameCn " ; return this .getHibernateTemplate().find(sql); } /** */ /** * 函数说明：获得总行数 * 参数说明： * 返回值：总行数 */ public int getRows(String fieldname,String value) { String sql = " FROM Products where " + fieldname + " like '% " + value + " %' " + " ORDER BY gameNameCn " ; List list = this .getHibernateTemplate().find(sql); return list.size(); } /** */ /** * 函数说明：查询的一段信息 * 参数说明： 集合 * 返回值： */ public List queryProducts(String fieldname,String value, int pageSize, int startRow) { final int pageSize1 = pageSize; final int startRow1 = startRow; final String sql = " FROM Products where " + fieldname + " like '% " + value + " %' " + " ORDER BY gameNameCn " ; return this .getHibernateTemplate().executeFind( new HibernateCallback() { public List doInHibernate(Session session) throws HibernateException, SQLException { Query query = session.createQuery(sql); query.setFirstResult(startRow1); query.setMaxResults(pageSize1); return query.list(); } } ); } } 在com.game.bean.hibernate包中新建hibernate.cfg.xml，代码如下：
<? xml version="1.0" encoding="GB2312" ?> <! DOCTYPE hibernate-configuration PUBLIC "-//Hibernate/Hibernate Configuration DTD 3.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 > 转载地址：http://kclmi.baihongyu.com/
你可能感兴趣的文章
C与C++中IO流的比较
查看>>
VS2010 警告 1 warning C4996: 'fopen': This function or variable may be unsafe. Consider using fopen_s
查看>>
vs2010 c++ 学习笔记
查看>>
C++类和new、delete操作符
查看>>
浅谈 C++ 中的 new/delete 和 new[]/delete[]
查看>>
关于“为什么delete以后指针还能被赋值”一种描述
查看>>
C++常用库（转）
查看>>
c/c++内存释放知识总结
查看>>
马云说：员工的离职原因
查看>>
dxf的DIMSTY尺寸标注格式
查看>>
C++ 中的流操作
查看>>
c++string函数详解
查看>>
VC++多线程编程
查看>>
C++内存分配秘籍—new，malloc，GlobalAlloc详解
查看>>
Code Review 代码审查 不完全整理
查看>>
结构体内存对齐详解
查看>>
关于C++兼容C，C++在linux程序设计API的调用等问题
查看>>
Linux下如何编译并运行C程序
查看>>
在linux下编译运行c语言程序
查看>>
C++/CLI,摘自百度的基本概念
查看>>