Java

本类阅读TOP10

·使用MyEclipse开发Struts框架的Hello World!(录像1)
·hibernate配置笔记
·AOP编程入门--Java篇
·linux下Tomcat 5.0.20 与 Apache 2 安装/集成/配置
·在win2003下整合了整合Tomcat5.5+ apache_2.0.53+ mod_jk_2.0.47.dll
·构建Linux下IDE环境--Eclipse篇
·Jsp 连接 mySQL、Oracle 数据库备忘(Windows平台)
·ASP、JSP、PHP 三种技术比较
·Tomcat5.5.9的安装配置
·AWT GUI 设计笔记(二)

分类导航
VC语言Delphi
VB语言ASP
PerlJava
Script数据库
其他语言游戏开发
文件格式网站制作
软件工程.NET开发
开发Spring MVC应用程序(4-1)

作者:未知 来源:月光软件站 加入时间:2005-2-28 月光软件站

4、实现数据库持久

23)建立数据库表

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

下面是创建数据库表productsSQL脚本,使用的数据库是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)创建实现JDBCDAO

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;
    }
 
}



相关文章

相关软件