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

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;

    }

}