spring mvc持久层浅析实例项目



spring mvc持久层浅析实例项目介绍。

这里将用到以下几个包:

引用
aopalliance-1.0.jar
commons-collections.jar
commons-dbcp.jar
commons-logging-1.1.1.jar
commons-pool.jar
jstl.jar
log4j-1.2.15.jar
mysql-connector-java-5.1.6-bin.jar
spring-beans-2.5.6.jar
spring-context-2.5.6.jar
spring-context-support-2.5.6.jar
spring-core-2.5.6.jar
spring-jdbc-2.5.6.jar
spring-tx-2.5.6.jar
spring-web-2.5.6.jar
spring-webmvc-2.5.6.jar
standard.jar

主要增加了commons-collections.jar、commons-dbcp.jar、commons-pool.jar、mysql-connector-java-5.1.6-bin.jar和spring-jdbc-2.5.6.jar
先弄个数据库,这里使用MySQL,我的最爱! 可惜前途未卜!
建库:

Sql代码 复制代码
  1. CREATE DATABASE `spring` /*!40100 DEFAULT CHARACTER SET utf8 */;
[sql] view plaincopy

  1. CREATE DATABASE `spring` /*!40100 DEFAULT CHARACTER SET utf8 */;

建表:

Sql代码 复制代码
  1. DROP TABLE IF EXISTS `spring`.`account`;
  2. CREATE TABLE  `spring`.`account` (
  3.   `id` int(10) unsigned NOT NULL AUTO_INCREMENT,
  4.   `username` varchar(45) NOT NULL,
  5.   `passwordvarchar(45) NOT NULL,
  6.   `birthday` datetime NOT NULL,
  7.   `email` varchar(45) NOT NULL,
  8.   PRIMARY KEY (`id`)
  9. ) ENGINE=InnoDB AUTO_INCREMENT=2 DEFAULT CHARSET=utf8;
[sql] view plaincopy

  1. DROP TABLE IF EXISTS `spring`.`account`;
  2. CREATE TABLE  `spring`.`account` (
  3.   `id` int(10) unsigned NOT NULL AUTO_INCREMENT,
  4.   `username` varchar(45) NOT NULL,
  5.   `password` varchar(45) NOT NULL,
  6.   `birthday` datetime NOT NULL,
  7.   `email` varchar(45) NOT NULL,
  8.   PRIMARY KEY (`id`)
  9. ) ENGINE=InnoDB AUTO_INCREMENT=2 DEFAULT CHARSET=utf8;

插入默认数据:

Sql代码 复制代码
  1. INSERT INTO `spring`.`account`(
  2.  `username`,
  3.  `password`,
  4.  `birthday`,
  5.  `email`)
  6. VALUES(
  7.  ’snowolf’,
  8.  ’zlex’,
  9.  ’2010-01-01′,
  10.  ’snowolf@zlex.org’);
[sql] view plaincopy

  1. INSERT INTO `spring`.`account`(
  2.  `username`,
  3.  `password`,
  4.  `birthday`,
  5.  `email`)
  6. VALUES(
  7.  ’snowolf’,
  8.  ’zlex’,
  9.  ’2010-01-01′,
  10.  ’snowolf@zlex.org’);

给出一个数据库查询的结果:

很不巧,为了能让数据查询更有意义,我又要改动Account类:
Account.java

Java代码 复制代码
  1. public class Account implements Serializable {
  2.     /**
  3.      * 主键
  4.      */
  5.     private int id;
  6.     /**
  7.      * 用户名
  8.      */
  9.     private String username;
  10.     /**
  11.      * 密码
  12.      */
  13.     private String password;
  14.     /**
  15.      * 生日
  16.      */
  17.     private Date birthday;
  18.     /**
  19.      * Email
  20.      */
  21.     private String email;
  22.         // get方法set方法省略
  23. }
[java] view plaincopy

  1. public class Account implements Serializable {
  2.     /**
  3.      * 主键
  4.      */
  5.     private int id;
  6.     /**
  7.      * 用户名
  8.      */
  9.     private String username;
  10.     /**
  11.      * 密码
  12.      */
  13.     private String password;
  14.     /**
  15.      * 生日
  16.      */
  17.     private Date birthday;
  18.     /**
  19.      * Email
  20.      */
  21.     private String email;
  22.         // get方法set方法省略
  23. }

这样,域对象与数据库表将完成一一对应绑定关系。
再建立一个用于构建数据源配置的文件database.properties
database.properties:

Properties代码 复制代码
  1. dataSource.driverClassName=com.mysql.jdbc.Driver
  2. dataSource.url=jdbc:mysql://localhost:3306/spring
  3. dataSource.username=root
  4. dataSource.password=admin
  5. dataSource.maxActive=200
  6. dataSource.maxIdle=50
  7. dataSource.maxWait=10000

该文件位于/WEB-INF/目录下。
接下来,我们需要把它引入spring容器,修改applicationContext.xml:
applicationContext.xml

Xml代码 复制代码
  1. <context:property-placeholder
  2.     location=”/WEB-INF/database.properties” />
[xml] view plaincopy

  1. <context:property-placeholder
  2.     location=”/WEB-INF/database.properties” />

如果需要引入多个properties文件,可以用逗号分隔。
这时,我们已经引入了数据源配置,我们可以通过修改dao.xml构建基于DBCP的数据源:
dao.xml中dataSource配置

Xml代码 复制代码
  1. <bean
  2.         id=”dataSource”
  3.         class=”org.apache.commons.dbcp.BasicDataSource”
  4.         destroy-method=”close”
  5.         lazy-init=”false”
  6.         p:driverClassName=”${dataSource.driverClassName}”
  7.         p:url=”${dataSource.url}”
  8.         p:username=”${dataSource.username}”
  9.         p:password=”${dataSource.password}”
  10.         p:maxActive=”${dataSource.maxActive}”
  11.         p:maxIdle=”${dataSource.maxIdle}”
  12.         p:maxWait=”${dataSource.maxWait}” />
[xml] view plaincopy

  1. <bean
  2.         id=”dataSource”
  3.         class=”org.apache.commons.dbcp.BasicDataSource”
  4.         destroy-method=”close”
  5.         lazy-init=”false”
  6.         p:driverClassName=”${dataSource.driverClassName}”
  7.         p:url=”${dataSource.url}”
  8.         p:username=”${dataSource.username}”
  9.         p:password=”${dataSource.password}”
  10.         p:maxActive=”${dataSource.maxActive}”
  11.         p:maxIdle=”${dataSource.maxIdle}”
  12.         p:maxWait=”${dataSource.maxWait}” />


上述配置稀松平常,没有什么好阐述的内容,这与一般spring配置无异样。
需要注意的是这个jdbcTemplate配置!
dao.xml中jdbcTemplate配置

Xml代码 复制代码
  1. <bean
  2.     class=”org.springframework.jdbc.core.JdbcTemplate”
  3.     p:dataSource-ref=”dataSource” />
[xml] view plaincopy

  1. <bean
  2.     class=”org.springframework.jdbc.core.JdbcTemplate”
  3.     p:dataSource-ref=”dataSource” />

这个配置很关键,如果你要使用其他的ORM框架,同样需要配置这样的模板类,在Dao实现中无需继承JdbcDaoSupport类。
不需要明确JdbcTemplate的id(id=”jdbcTemplate”)吗?不再需要了!
AccountDao.java

Java代码 复制代码
  1. public interface AccountDao {
  2.     /**
  3.      * 读取账户信息
  4.      *
  5.      * @param username
  6.      * @return
  7.      */
  8.     Account read(String username);
  9.     /**
  10.      * 读取账户信息
  11.      *
  12.      * @param id
  13.      * @return
  14.      */
  15.     Account read(int id);
  16. }
[java] view plaincopy

  1. public interface AccountDao {
  2.     /**
  3.      * 读取账户信息
  4.      *
  5.      * @param username
  6.      * @return
  7.      */
  8.     Account read(String username);
  9.     /**
  10.      * 读取账户信息
  11.      *
  12.      * @param id
  13.      * @return
  14.      */
  15.     Account read(int id);
  16. }

AccountDaoImpl.java

Java代码 复制代码
  1. /**
  2.  * 2010-1-23
  3.  */
  4. package org.zlex.spring.dao.impl;
  5. import java.sql.ResultSet;
  6. import java.sql.SQLException;
  7. import org.springframework.beans.factory.annotation.Autowired;
  8. import org.springframework.jdbc.core.JdbcTemplate;
  9. import org.springframework.jdbc.core.RowMapper;
  10. import org.springframework.stereotype.Repository;
  11. import org.zlex.spring.dao.AccountDao;
  12. import org.zlex.spring.domain.Account;
  13. /**
  14.  * 账户数据库实现
  15.  *
  16.  * @author <a href=”mailto:zlex.dongliang@gmail.com”>梁栋</a>
  17.  * @version 1.0
  18.  * @since 1.0
  19.  */
  20. @Repository
  21. public class AccountDaoImpl implements AccountDao {
  22.     @Autowired
  23.     private JdbcTemplate jdbcTemplate;
  24.     @Override
  25.     public Account read(String username) {
  26.         String sql = ”SELECT * From account WHERE username = ?”;
  27.         return (Account) jdbcTemplate.queryForObject(sql,
  28.                 new Object[] { username }, accountRowMap);
  29.     }
  30.     @Override
  31.     public Account read(int id) {
  32.         String sql = ”SELECT * From account WHERE id = ?”;
  33.         return (Account) jdbcTemplate.queryForObject(sql, new Object[] { id },
  34.                 accountRowMap);
  35.     }
  36.     protected RowMapper accountRowMap = new RowMapper() {
  37.         @Override
  38.         public Object mapRow(ResultSet rs, int rowNum) throws SQLException {
  39.             Account account = new Account();
  40.             account.setId(rs.getInt(“id”));
  41.             account.setUsername(rs.getString(“username”));
  42.             account.setPassword(rs.getString(“password”));
  43.             account.setBirthday(rs.getDate(“birthday”));
  44.             account.setEmail(rs.getString(“email”));
  45.             return account;
  46.         }
  47.     };
  48. }
[java] view plaincopy

  1. /**
  2.  * 2010-1-23
  3.  */
  4. package org.zlex.spring.dao.impl;
  5. import java.sql.ResultSet;
  6. import java.sql.SQLException;
  7. import org.springframework.beans.factory.annotation.Autowired;
  8. import org.springframework.jdbc.core.JdbcTemplate;
  9. import org.springframework.jdbc.core.RowMapper;
  10. import org.springframework.stereotype.Repository;
  11. import org.zlex.spring.dao.AccountDao;
  12. import org.zlex.spring.domain.Account;
  13. /**
  14.  * 账户数据库实现
  15.  *
  16.  * @author <a href=”mailto:zlex.dongliang@gmail.com”>梁栋</a>
  17.  * @version 1.0
  18.  * @since 1.0
  19.  */
  20. @Repository
  21. public class AccountDaoImpl implements AccountDao {
  22.     @Autowired
  23.     private JdbcTemplate jdbcTemplate;
  24.     @Override
  25.     public Account read(String username) {
  26.         String sql = ”SELECT * From account WHERE username = ?”;
  27.         return (Account) jdbcTemplate.queryForObject(sql,
  28.                 new Object[] { username }, accountRowMap);
  29.     }
  30.     @Override
  31.     public Account read(int id) {
  32.         String sql = ”SELECT * From account WHERE id = ?”;
  33.         return (Account) jdbcTemplate.queryForObject(sql, new Object[] { id },
  34.                 accountRowMap);
  35.     }
  36.     protected RowMapper accountRowMap = new RowMapper() {
  37.         @Override
  38.         public Object mapRow(ResultSet rs, int rowNum) throws SQLException {
  39.             Account account = new Account();
  40.             account.setId(rs.getInt(“id”));
  41.             account.setUsername(rs.getString(“username”));
  42.             account.setPassword(rs.getString(“password”));
  43.             account.setBirthday(rs.getDate(“birthday”));
  44.             account.setEmail(rs.getString(“email”));
  45.             return account;
  46.         }
  47.     };
  48. }

分段详述:
注解@Repository明确这个类是用于持久层的实现类,注意这样的注解不能用于接口,仅适用于实现类!
同时,不再需要继承JdbcDaoSupport类,其而代之的是直接注入JdbcTemplate类!
再看声明JdbcTemplate类:

Java代码 复制代码
  1. @Autowired
  2. private JdbcTemplate jdbcTemplate;
[java] view plaincopy

  1. @Autowired
  2. private JdbcTemplate jdbcTemplate;

需要说明一下,这里的JdbcTemplate对象jdbcTemplate名称可以自定,没有任何限制!
这里使用 RowMapper 定义了一个用于绑定Account域对象的内部映射类:
RowMapper

Java代码 复制代码
  1. protected RowMapper accountRowMap = new RowMapper() {
  2.     @Override
  3.     public Object mapRow(ResultSet rs, int rowNum) throws SQLException {
  4.         Account account = new Account();
  5.         account.setId(rs.getInt(“id”));
  6.         account.setUsername(rs.getString(“username”));
  7.         account.setPassword(rs.getString(“password”));
  8.         account.setBirthday(rs.getDate(“birthday”));
  9.         account.setEmail(rs.getString(“email”));
  10.         return account;
  11.     }
  12. };
[java] view plaincopy

  1. protected RowMapper accountRowMap = new RowMapper() {
  2.     @Override
  3.     public Object mapRow(ResultSet rs, int rowNum) throws SQLException {
  4.         Account account = new Account();
  5.         account.setId(rs.getInt(“id”));
  6.         account.setUsername(rs.getString(“username”));
  7.         account.setPassword(rs.getString(“password”));
  8.         account.setBirthday(rs.getDate(“birthday”));
  9.         account.setEmail(rs.getString(“email”));
  10.         return account;
  11.     }
  12. };

语句级的内容,十分简单,如下所示:

Java代码 复制代码
  1. @Override
  2. public Account read(String username) {
  3.     String sql = ”SELECT * From account WHERE username = ?”;
  4.     return (Account) jdbcTemplate.queryForObject(sql,
  5.             new Object[] { username }, accountRowMap);
  6. }
  7. @Override
  8. public Account read(int id) {
  9.     String sql = ”SELECT * From account WHERE id = ?”;
  10.     return (Account) jdbcTemplate.queryForObject(sql, new Object[] { id },
  11.             accountRowMap);
  12. }
[java] view plaincopy

  1. @Override
  2. public Account read(String username) {
  3.     String sql = ”SELECT * From account WHERE username = ?”;
  4.     return (Account) jdbcTemplate.queryForObject(sql,
  5.             new Object[] { username }, accountRowMap);
  6. }
  7. @Override
  8. public Account read(int id) {
  9.     String sql = ”SELECT * From account WHERE id = ?”;
  10.     return (Account) jdbcTemplate.queryForObject(sql, new Object[] { id },
  11.             accountRowMap);
  12. }

写完这两段代码不由感慨,我曾经就这么噼里啪啦的敲了一年多这样的代码。不断的做绑定、映射、写SQL,直到可以有机会将持久层JDBC实现替换Hibernate、iBatis,我才得以解放!
接着,再调整一下Service实现类
AccountServiceImpl.java

Java代码 复制代码
  1. public class AccountServiceImpl implements AccountService {
  2.     @Autowired
  3.     private AccountDao accountDao;
  4.     @Override
  5.     public Account read(String username, String password) {
  6.         Account account = accountDao.read(username);
  7.         if (!password.equals(account.getPassword())) {
  8.             account = null;
  9.         }
  10.         return account;
  11.     }
  12.     @Override
  13.     public Account read(int id) {
  14.         return accountDao.read(id);
  15.     }
  16. }
[java] view plaincopy

  1. public class AccountServiceImpl implements AccountService {
  2.     @Autowired
  3.     private AccountDao accountDao;
  4.     @Override
  5.     public Account read(String username, String password) {
  6.         Account account = accountDao.read(username);
  7.         if (!password.equals(account.getPassword())) {
  8.             account = null;
  9.         }
  10.         return account;
  11.     }
  12.     @Override
  13.     public Account read(int id) {
  14.         return accountDao.read(id);
  15.     }
  16. }

使用AccountDao接口来完成响应的操作,逻辑部分不做详述,根据业务逻辑而定!
稍稍修改一下profile.jsp,将用户的生日、邮件地址都输出出来!

Jsp代码 复制代码
  1. <fieldset><legend>用户信息</legend>
  2. <ul>
  3.     <li><label>用户名:</label><c:out value=”${account.username}” /></li>
  4.     <li><label>生日:</label><fmt:formatDate value=”${account.birthday}”
  5.         pattern=”yyyy年MM月dd日” /></li>
  6.     <li><label>Email:</label><c:out value=”${account.email}” /></li>
  7. </ul>
  8. </fieldset>
  9. 标签<fmt:formatDate />用于格式化输出,大家可以了解一下,很简单很好用的标签! :D

启动应用,登录,查看用户信息:

  • http://blog.csdn.net/xrt95050/article/details/6226200