开发Spring MVC应用程序(4-1)

王朝java/jsp·作者佚名  2006-01-09
窄屏简体版  字體: |||超大  

4、实现数据库持久

(23)建立数据库表

(译者:原文采用的是HSQL,在这里使用MySQL,版本号是4.0.20a)

下面是创建数据库表products的SQL脚本,使用的数据库是test:

/*!40014 SET @OLD_UNIQUE_CHECKS=@@UNIQUE_CHECKS, UNIQUE_CHECKS=0 */;

/*!40014 SET @OLD_FOREIGN_KEY_CHECKS=@@FOREIGN_KEY_CHECKS, FOREIGN_KEY_CHECKS=0 */;

/*!40101 SET @OLD_SQL_MODE=@@SQL_MODE, SQL_MODE=NO_AUTO_VALUE_ON_ZERO */;

CREATE DATABASE /*!32312 IF NOT EXISTS*/ `test`;

USE `test`;

CREATE TABLE `products` (

`id` int(11) NOT NULL default '0',

`description` varchar(255) default '',

`price` decimal(15,2) default '0.00',

PRIMARY KEY (`id`),

KEY `products_description` (`description`)

) TYPE=MyISAM;

INSERT INTO `products` (`id`,`description`,`price`) VALUES (1,'Lamp','5.78'),(2,'Table','75.29'),(3,'Chair','22.81');

/*!40101 SET SQL_MODE=@OLD_SQL_MODE */;

/*!40014 SET FOREIGN_KEY_CHECKS=@OLD_FOREIGN_KEY_CHECKS */;

/*!40014 SET UNIQUE_CHECKS=@OLD_UNIQUE_CHECKS */;

不同的数据库SQL语句的学法上会有些不同,请做适当调整

(24)创建实现JDBC的DAO

l 首先是DAO接口ProductManagerDao,提供了列表产品和增长产品价格的功能

package db;

import bus.Product;

import java.util.List;

public interface ProductManagerDao {

public List getProductList();

public void increasePrice(Product prod, int pct);

}

l ProductManagerDaoJdbc类实现ProductManagerDao接口

package db;

import bus.Product;

import java.util.List;

import java.sql.ResultSet;

import java.sql.SQLException;

import java.sql.Types;

import javax.sql.DataSource;

import org.apache.commons.logging.Log;

import org.apache.commons.logging.LogFactory;

import org.springframework.jdbc.object.MappingSqlQuery;

import org.springframework.jdbc.object.SqlUpdate;

import org.springframework.jdbc.core.SqlParameter;

public class ProductManagerDaoJdbc implements ProductManagerDao {

/** Logger for this class and subclasses */

protected final Log logger = LogFactory.getLog(getClass());

private DataSource ds;

public List getProductList() {

logger.info("Getting products!");

ProductQuery pq = new ProductQuery(ds);

return pq.execute();

}

public void increasePrice(Product prod, int pct) {

logger.info("Increasing price by " + pct + "%");

SqlUpdate su =

new SqlUpdate(ds, "update products set price = price * (100 + ?) / 100 where id = ?");

su.declareParameter(new SqlParameter("increase", Types.INTEGER));

su.declareParameter(new SqlParameter("ID", Types.INTEGER));

su.compile();

Object[] oa = new Object[2];

oa[0] = new Integer(pct);

oa[1] = new Integer(prod.getId());

int count = su.update(oa);

logger.info("Rows affected: " + count);

}

public void setDataSource(DataSource ds) {

this.ds = ds;

}

class ProductQuery extends MappingSqlQuery {

ProductQuery(DataSource ds) {

super(ds, "SELECT id, description, price from products");

compile();

}

protected Object mapRow(ResultSet rs, int rowNum) throws SQLException {

Product prod = new Product();

prod.setId(rs.getInt("id"));

prod.setDescription(rs.getString("description"));

prod.setPrice(new Double(rs.getDouble("price")));

return prod;

}

}

}

l 这里使用了Spring JDBC框架,其好处是不需要担心连接和语句的打开和关闭,不需要捕捉异常(除非你想要这么做)

l ProductQuery是一个内类,扩展MappingSqlQuery类,封装SQL查询;在构造方法中传递DataSource(在Bean配置中定义)和查询SQL语句给父类;通过实现mapRow()方法,可以将查询结果的每一行数据映射到表示实体(通常是JavaBean)

l getProductList()方法的实现是创建一个查询对象ProductQuery,通过调用其execute()方法返回查询结果:映射好的Product对象列表

l 在increasePrice()方法中,使用SqlUpdate创建带参数的更新语句(需要传递DataSource);这里需要调用declareParameter()方法定义参数类型,并以对象数组的形式传递参数值给update()方法来执行更新语句,并返回影响的行数

l Product类需要增加id属性来保存主键值

package bus;

import java.io.Serializable;

public class Product implements Serializable {

private int id;

private String description;

private Double price;

public void setId(int i) {

id = i;

}

public int getId() {

return id;

}

public void setDescription(String s) {

description = s;

}

public String getDescription() {

return description;

}

public void setPrice(Double d) {

price = d;

}

public Double getPrice() {

return price;

}

}

 
 
 
免责声明:本文为网络用户发布,其观点仅代表作者个人观点,与本站无关,本站仅提供信息存储服务。文中陈述内容未经本站证实,其真实性、完整性、及时性本站不作任何保证或承诺,请读者仅作参考,并请自行核实相关内容。
 
 
© 2005- 王朝網路 版權所有 導航