利用全注解实现ssh的一个完整例子

2017-04-23 21:25 阅读 645 次 评论 0 条

 

在一个稍大的项目中,通常会有上百个组件,如果这些组件采用xml的bean定义来配置,显然会增加配置文件的体积,查找以及维护起来也不太方便。个人也不喜欢配置那么多的xml文件。下面我们就利用java的注解实现ssh框架,注解相当于一种标记加了注解就等于打上了某种标记,没加,则等于没有某种标记,以后,javac编译器,开发工具包和其他程序可以用反射来了解你的类以及各种元素上有何种标记,看你有什么标记,就去干相应的事,标记可以加载包,类,字段,方法,方法的参数以及局部变量上。关于注解在这里不多说,网上大把资料。

先看看完整的工程目录吧

1.为了使用注解我们需要配置web.xml文件,在web-inf目录下内容如下

  1. <?xmlversion="1.0" encoding="UTF-8"?>
  2. <web-appversion="2.5"
  3. xmlns="http://java.sun.com/xml/ns/javaee"
  4. xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
  5. xsi:schemaLocation="http://java.sun.com/xml/ns/javaee
  6. http://java.sun.com/xml/ns/javaee/web-app_2_5.xsd">
  7. <!-- 加载spring配置文件 -->
  8. <context-param>
  9. <param-name>contextConfigLocation</param-name>
  10. <param-value>
  11. classpath*:applicationContext*.xml
  12. </param-value>
  13. </context-param>
  14. <listener>
  15. <listener-class>
  16. springframework.web.context.ContextLoaderListener
  17. </listener-class>
  18. </listener>
  19. <!-- struts2 的配置-->
  20. <filter>
  21. <filter-name>struts2</filter-name>
  22. <filter-class>
  23. apache.struts2.dispatcher.ng.filter.StrutsPrepareAndExecuteFilter
  24. </filter-class>
  25. <init-param>
  26. <!--  //固定格式-->
  27. <param-name>actionPackages</param-name>
  28. <param-value>ssh</param-value>
  29. </init-param>
  30. </filter>
  31. <filter-mapping>
  32. <filter-name>struts2</filter-name>
  33. <url-pattern>/*</url-pattern>
  34. </filter-mapping>
  35. <display-name></display-name>
  36. <welcome-file-list>
  37. <welcome-file>jsp</welcome-file>
  38. </welcome-file-list>
  39. </web-app>

2.接下来看看spring和hibernate的配置文件applicationContext.xml

  1. <?xmlversion="1.0" encoding="UTF-8"?>
  2. <beansxmlns="http://www.springframework.org/schema/beans"
  3. xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
  4. xmlns:context="http://www.springframework.org/schema/context"
  5. xmlns:aop="http://www.springframework.org/schema/aop"
  6. xmlns:tx="http://www.springframework.org/schema/tx"
  7. xsi:schemaLocation="
  8. http://www.springframework.org/schema/beans
  9. http://www.springframework.org/schema/beans/spring-beans.xsd
  10. http://www.springframework.org/schema/context
  11. http://www.springframework.org/schema/context/spring-context.xsd
  12. http://www.springframework.org/schema/aop
  13. http://www.springframework.org/schema/aop/spring-aop.xsd
  14. http://www.springframework.org/schema/tx
  15. http://www.springframework.org/schema/tx/spring-tx.xsd">
  16. <!-- 使用annotation -->
  17. <context:annotation-config/>
  18. <!-- 使用annotation 自动注册bean,并检查@Controller, @Service, @Repository注解已被注入 -->
  19. <context:component-scanbase-package="com.ssh" />
  20. <!-- 数据库配置-->
  21. <beanid="dataSource"
  22. class="org.apache.commons.dbcp.BasicDataSource">
  23. <propertyname="driverClassName"
  24. value="com.mysql.jdbc.Driver">
  25. </property>
  26. <propertyname="url"
  27. value="jdbc:mysql://localhost:3306/myssh">
  28. </property>
  29. <propertyname="username" value="anan"></property>
  30. <propertyname="password" value="123456"></property>
  31. </bean>
  32. <!-- sessionFactory -->
  33. <beanid="sessionFactory"
  34. class="org.springframework.orm.hibernate3.annotation.AnnotationSessionFactoryBean">
  35. <propertyname="dataSource">
  36. <refbean="dataSource" />
  37. </property>
  38. <propertyname="hibernateProperties">
  39. <props>
  40. <propkey="hibernate.dialect">
  41. hibernate.dialect.MySQLDialect
  42. </prop>
  43. <propkey="hibernate.show_sql">true</prop>
  44. <!-- 可以自动创建数据库表(create),不创建(none) -->
  45. <propkey="hibernate.hbm2ddl.auto">update</prop>
  46. </props>
  47. </property>
  48. <!-- 包扫描的方式加载注解类(推荐) -->
  49. <propertyname="packagesToScan">
  50. <list>
  51. <value>ssh.*</value>
  52. </list>
  53. </property>
  54. </bean>
  55. <!--JDBC事务管理器,根据你的情况使用不同的事务管理器,如果工程中有Hibernate,就用Hibernate的事务管理器-->
  56. <beanid="transactionManager"
  57. class="org.springframework.jdbc.datasource.DataSourceTransactionManager">
  58. <propertyname="dataSource">
  59. <reflocal="dataSource" />
  60. </property>
  61. </bean>
  62. <!-- 用注解来实现事务管理-->
  63. <tx:annotation-driventransaction-manager="transactionManager" />
  64. </beans>

基本都有注释了,这里不多说了,需要注意的是如果是自己搞回去用千万记得要改上面的数据库配置。

 

3.接下来我们再看看struts的配置文件struts.xml

  1. <?xmlversion="1.0" encoding="UTF-8" ?>
  2. <!DOCTYPE struts PUBLIC "-//Apache Software Foundation//DTD Struts Configuration 2.1//EN" "http://struts.apache.org/dtds/struts-2.1.dtd">
  3. <struts>
  4. <!-- 开启使用开发模式,详细错误提示 -->
  5. <constant name="struts.devMode" value="false" />
  6. <!-- 将对象交给spring管理 -->
  7. <constant name="struts.objectFactory" value="spring" />
  8. <!-- 指定资源编码类型 -->
  9. <constant name="struts.i18n.encoding" value="UTF-8" />
  10. <!-- 指定每次请求到达,重新加载资源文件-->
  11. <constantname="struts.i18n.reload" value="false" />
  12. <!-- 指定每次配置文件更改后,自动重新加载-->
  13. <constantname="struts.configuration.xml.reload" value="false" />
  14. <!-- 默认后缀名-->
  15. <!--     <constant name="struts.action.extension" value="do,action,jhtml,," /> -->
  16. <!-- Struts Annotation -->
  17. <!--     <constant name="actionPackages" value="com.test1"/> -->
  18. </struts>

基本上注释写的很详细了吧,我也不是很懂就那样配置着先....

接下来我们就可以安心的写java代码了,先创建如下图所示的包和类

 

先看看实体类User.java

  1. packagessh.user.model;
  2. importpersistence.Column;
  3. importpersistence.Entity;
  4. importpersistence.GeneratedValue;
  5. importpersistence.GenerationType;
  6. importpersistence.Id;
  7. importpersistence.Table;
  8. /**
  9. * 类名称:User
  10. * 类描述:用户信息实体
  11. * 创建人:anan
  12. * 创建时间:2012-12-21 下午10:55:19
  13. * 修改人:anan
  14. * 修改时间:2012-12-21 下午10:55:19
  15. * 修改备注:
  16. * @version
  17. * */
  18. @Entity
  19. @Table(name = "user")
  20. publicclassUser {
  21. /**
  22. * 用户id
  23. */
  24. @Id
  25. @Column(name = "userId")
  26. @GeneratedValue(strategy = GenerationType.IDENTITY)
  27. privateint userId;
  28. /**
  29. * 用户名
  30. */
  31. @Column(name = "userName", length = 50)
  32. privateString userName;
  33. /**
  34. * 用户登录密码
  35. */
  36. @Column(name = "passWord", length = 50)
  37. privateString passWord;
  38. publicint getUserId() {
  39. returnuserId;
  40. }
  41. publicvoid setUserId(int userId) {
  42. this.userId = userId;
  43. }
  44. publicString getUserName() {
  45. returnuserName;
  46. }
  47. publicvoid setUserName(String userName) {
  48. this.userName = userName;
  49. }
  50. publicString getPassWord() {
  51. returnpassWord;
  52. }
  53. publicvoid setPassWord(String passWord) {
  54. this.passWord = passWord;
  55. }
  56. publicUser(int userId, String userName, String passWord) {
  57. this.userId = userId;
  58. this.userName = userName;
  59. this.passWord = passWord;
  60. }
  61. publicUser(String userName, String passWord) {
  62. this.userName = userName;
  63. this.passWord = passWord;
  64. }
  65. publicUser(int userId) {
  66. this.userId = userId;
  67. }
  68. publicUser() {
  69. }
  70. }

这是一个基本的pojo类,关键看看那几个注解@Entity表示当前类是一个实体,@Table(name = "user")指定这个类映射到数据库的哪一个表,@Column(name = "userId")表示这个属性映射数据库对应表中的那一列...
接下来看看UserDao.java

  1. packagessh.user.dao;
  2. importutil.List;
  3. importssh.user.model.User;
  4. /**
  5. * 类名称:UserDao
  6. * 类描述:用户控制dao实现数据库操作接口
  7. * 创建人:anan
  8. * 创建时间:2012-12-21 下午11:05:46
  9. * 修改人:anan
  10. * 修改时间:2012-12-21 下午11:05:46
  11. * 修改备注:
  12. * @version
  13. * */
  14. publicinterfaceUserDao {
  15. publicvoid addUser(User user);
  16. publicvoid delUser(int userId);
  17. publicvoid updateUser(User user);
  18. publicList<User> selectUser();
  19. publicUser getUserByUserId(int userId);
  20. publicboolean isExitByName(String userName);
  21. publicboolean isExitByNameAndPass(User user);
  22. }

这是一个接口指定用户操作,定义一些方法

接下来具体实现这些方法,看UserDaoImpl.java

  1. packagessh.user.dao.impl;
  2. importutil.ArrayList;
  3. importutil.Iterator;
  4. importutil.List;
  5. importhibernate.Session;
  6. importhibernate.Transaction;
  7. importspringframework.stereotype.Repository;
  8. importssh.user.dao.UserDao;
  9. importssh.user.model.User;
  10. importssh.util.MyHibernateDaoSupport;
  11. /**
  12. * 类名称:UserDaoImpl
  13. * 类描述:用户控制dao实现数据库操作接口实现
  14. * 创建人:anan
  15. * 创建时间:2012-12-21 下午11:07:43
  16. * 修改人:anan
  17. * 修改时间:2012-12-21 下午11:07:43
  18. * 修改备注:
  19. * @version
  20. * */
  21. @Repository("userDao")
  22. publicclassUserDaoImpl extends MyHibernateDaoSupport implements UserDao{
  23. publicvoid addUser(User user)  {
  24. Session session = this.getSession(true);
  25. Transaction tc = (Transaction) session.beginTransaction();
  26. save(user);
  27. try{
  28. commit();
  29. catch(Exception e) {
  30. printStackTrace();
  31. }
  32. close();
  33. }
  34. publicvoid delUser(int userId) {
  35. Session session = this.getSession(true);
  36. Transaction tc = (Transaction) session.beginTransaction();
  37. User u = newUser(userId);
  38. delete(u);
  39. try{
  40. commit();
  41. catch(Exception e) {
  42. printStackTrace();
  43. }
  44. close();
  45. }
  46. publicvoid updateUser(User user) {
  47. Session session = this.getSession(true);
  48. Transaction tc = (Transaction) session.beginTransaction();
  49. update(user);
  50. try{
  51. commit();
  52. catch(Exception e) {
  53. printStackTrace();
  54. }
  55. close();
  56. }
  57. publicList<User> selectUser()  {
  58. List<User> users = newArrayList<User>();
  59. Session session = this.getSession(true);
  60. Transaction tc = (Transaction) session.beginTransaction();
  61. List list = session.createQuery("From User").list();
  62. for(Iterator iterator = list.iterator(); iterator.hasNext();) {
  63. User u = (User) iterator.next();
  64. add(u);
  65. }
  66. try{
  67. commit();
  68. catch(Exception e) {
  69. printStackTrace();
  70. }
  71. close();
  72. returnusers;
  73. }
  74. publicUser getUserByUserId(int userId)  {
  75. Session session = this.getSession(true);
  76. Transaction tc = (Transaction) session.beginTransaction();
  77. //load 是说明数据库中一定存在这条记录,没有则报出:ObjectNotFoundException
  78. //get 如果查不到记录,返回的是一个null
  79. User user = (User)session.load(User.class, userId);
  80. try{
  81. commit();
  82. catch(Exception e) {
  83. printStackTrace();
  84. }
  85. close();
  86. returnuser;
  87. }
  88. publicboolean isExitByName(String userName)  {
  89. Session session = this.getSession(true);
  90. Transaction tc = (Transaction) session.beginTransaction();
  91. List user = (List)session.createQuery("From User u where u.userName=:userName").setString("userName", userName).list();
  92. if(user.size()>0){
  93. try{
  94. commit();
  95. catch(Exception e) {
  96. printStackTrace();
  97. }
  98. close();
  99. returntrue;
  100. }
  101. try{
  102. commit();
  103. catch(Exception e) {
  104. printStackTrace();
  105. }
  106. close();
  107. returnfalse;
  108. }
  109. publicboolean isExitByNameAndPass(User user)  {
  110. Session session = this.getSession(true);
  111. Transaction tc = (Transaction) session.beginTransaction();
  112. List users = (List)session.createQuery("From User u where u.userName=:userName and u.passWord=:passWord").setString("userName", user.getUserName()).setString("passWord", user.getPassWord()).list();
  113. if(users.size()>0){
  114. try{
  115. commit();
  116. catch(Exception e) {
  117. printStackTrace();
  118. }
  119. close();
  120. returntrue;
  121. }
  122. try{
  123. commit();
  124. catch(Exception e) {
  125. printStackTrace();
  126. }
  127. close();
  128. returnfalse;
  129. }
  130. }

到这里数据库操作基本搞完,接下来写业务逻辑代码,先看看UserService.java

  1. packagessh.user.service;
  2. importutil.List;
  3. importssh.user.model.User;
  4. /**
  5. * 类名称:UserService
  6. * 类描述:用户业务逻辑接口
  7. * 创建人:anan
  8. * 创建时间:2012-12-21 下午10:58:32
  9. * 修改人:anan
  10. * 修改时间:2012-12-21 下午10:58:32
  11. * 修改备注:
  12. * @version
  13. * */
  14. publicinterfaceUserService {
  15. /**
  16. * 判断用户是否存在
  17. * @param userName
  18. * @return user
  19. * @
  20. * */
  21. publicboolean isExitUser(String userName) ;
  22. /**
  23. * 判断用户是否存在
  24. * @param userName passWord
  25. * @return user
  26. * @
  27. * */
  28. publicboolean isExitByNameAndPass(User user) ;
  29. /**
  30. * 保存用户
  31. * @param user
  32. * @return boolean
  33. * @
  34. * */
  35. publicvoid save(User user) ;
  36. /**
  37. * 查询所有用户
  38. * @param
  39. * @return List<User>
  40. * @
  41. * */
  42. publicList<User> getUsers() ;
  43. /**
  44. * 删除用户
  45. * @param userId
  46. * @return
  47. * @
  48. * */
  49. publicvoid del(int userId) ;
  50. /**
  51. * 修改用户
  52. * @param user
  53. * @return
  54. * @
  55. * */
  56. publicvoid update(User user) ;
  57. /**
  58. * 根据id获得user
  59. * @param userId
  60. * @return user
  61. * @
  62. * */
  63. publicUser getUserById(int userId) ;
  64. }

这个只是一个接口,定义我们接下来需要的方法。下面是具体的实现类UserServiceImpl.java

  1. packagessh.user.service.Impl;
  2. importutil.List;
  3. importannotation.Resource;
  4. importspringframework.stereotype.Service;
  5. importspringframework.transaction.annotation.Propagation;
  6. importspringframework.transaction.annotation.Transactional;
  7. importssh.user.dao.UserDao;
  8. importssh.user.model.User;
  9. importssh.user.service.UserService;
  10. /**
  11. * 类名称:UserServiceImpl
  12. * 类描述:用户信息操作业务逻辑接口实现
  13. * 创建人:anan
  14. * 创建时间:2012-12-21 下午11:08:18
  15. * 修改人:anan
  16. * 修改时间:2012-12-21 下午11:08:18
  17. * 修改备注:
  18. * @version
  19. * */
  20. @Service
  21. publicclassUserServiceImpl implements UserService {
  22. @Resource
  23. privateUserDao userDao;
  24. publicboolean isExitUser(String userName) {
  25. returnisExitByName(userName);
  26. }
  27. publicvoid save(User user) {
  28. addUser(user);
  29. }
  30. publicList<User> getUsers() {
  31. List<User> users = userDao.selectUser();
  32. returnusers;
  33. }
  34. publicvoid del(int userId) {
  35. delUser(userId);
  36. }
  37. publicvoid update(User user) {
  38. updateUser(user);
  39. }
  40. publicUser getUserById(int userId) {
  41. returngetUserByUserId(userId);
  42. }
  43. publicboolean isExitByNameAndPass(User user) {
  44. returnisExitByNameAndPass(user);
  45. }
  46. }

业务逻辑在这里包括了判断用户是否存在,保存用户信息,获取用户信息,删除用户,更新用户信息等

通过上面两个类业务逻辑层也就完成了,接下来写视图控制器,这里只是写了一个简单的登录控制器LoginAction.java

  1. packagessh.user.action;
  2. importannotation.Resource;
  3. importapache.struts2.convention.annotation.Action;
  4. importapache.struts2.convention.annotation.Result;
  5. importopensymphony.xwork2.ActionSupport;
  6. importssh.user.dao.UserDao;
  7. importssh.user.model.User;
  8. /**
  9. * 类名称:LoginAction
  10. * 类描述:用户控制器的实现
  11. * 创建人:anan
  12. * 创建时间:2012-12-21 下午11:17:36
  13. * 修改人:anan
  14. * 修改时间:2012-12-21 下午11:17:36
  15. * 修改备注:
  16. * @version
  17. * */
  18. @Action(value = "loginAction", results = {
  19. @Result(name = "loginSuccess", location = "/loginSuss.jsp"),
  20. @Result(name = "loginFailer", location = "/loginFailer.jsp") })
  21. publicclassLoginAction extends ActionSupport {
  22. privatestatic final long serialVersionUID = -2266695172069461659L;
  23. @Resource
  24. privateUserDao userDao;
  25. privateUser user;
  26. publicUser getUser() {
  27. returnuser;
  28. }
  29. publicvoid setUser(User user) {
  30. this.user = user;
  31. }
  32. publicString login(){
  33. booleanflag = userDao.isExitByNameAndPass(user);
  34. if(flag){
  35. return"loginSuccess";
  36. }
  37. return"loginFailer";
  38. }
  39. }

这个就是控制层。

再写几个jsp文件来测试一下

 

内容如下:

index.jsp

  1. <%@ page language="java"import="java.util.*" pageEncoding="UTF-8"%>
  2. <%@taglib prefix="s"uri="/struts-tags"%>
  3. <%
  4. String path= request.getContextPath();
  5. String basePath= request.getScheme()+"://"+request.getServerName()+":"+request.getServerPort()+path+"/";
  6. %>
  7. <!DOCTYPE HTML PUBLIC "-//W3C//DTD HTML 4.01 Transitional//EN">
  8. <html>
  9. <head>
  10. <basehref="<%=basePath%>">
  11. <title>My JSP 'index.jsp' starting page</title>
  12. <metahttp-equiv="pragma" content="no-cache">
  13. <metahttp-equiv="cache-control" content="no-cache">
  14. <metahttp-equiv="expires" content="0">
  15. <metahttp-equiv="keywords" content="keyword1,keyword2,keyword3">
  16. <metahttp-equiv="description" content="This is my page">
  17. <!--
  18. <link rel="stylesheet" type="text/css" href="styles.css">
  19. -->
  20. </head>
  21. <body>
  22. <s:formaction="loginAction!login">
  23. <s:textfieldname="user.userName" label="userName"></s:textfield>
  24. <s:textfieldname="user.passWord" label="passWord"></s:textfield>
  25. <s:submitvalue="login"></s:submit>
  26. </s:form>
  27. </body>
  28. </html>

 

loginFailer.jsp

  1. <%@ page language="java"import="java.util.*" pageEncoding="UTF-8"%>
  2. <%
  3. String path= request.getContextPath();
  4. String basePath= request.getScheme()+"://"+request.getServerName()+":"+request.getServerPort()+path+"/";
  5. %>
  6. <!DOCTYPE HTML PUBLIC "-//W3C//DTD HTML 4.01 Transitional//EN">
  7. <html>
  8. <head>
  9. <basehref="<%=basePath%>">
  10. <title>My JSP 'loginFailer.jsp' starting page</title>
  11. <metahttp-equiv="pragma" content="no-cache">
  12. <metahttp-equiv="cache-control" content="no-cache">
  13. <metahttp-equiv="expires" content="0">
  14. <metahttp-equiv="keywords" content="keyword1,keyword2,keyword3">
  15. <metahttp-equiv="description" content="This is my page">
  16. <!--
  17. <link rel="stylesheet" type="text/css" href="styles.css">
  18. -->
  19. </head>
  20. <body>
  21. 登录失败</body>
  22. </html>

loginSuss.jsp

  1. <%@ page language="java"import="java.util.*" pageEncoding="utf-8"%>
  2. <%
  3. String path= request.getContextPath();
  4. String basePath= request.getScheme()+"://"+request.getServerName()+":"+request.getServerPort()+path+"/";
  5. %>
  6. <!DOCTYPE HTML PUBLIC "-//W3C//DTD HTML 4.01 Transitional//EN">
  7. <html>
  8. <head>
  9. <basehref="<%=basePath%>">
  10. <title>My JSP 'loginSuss.jsp' starting page</title>
  11. <metahttp-equiv="pragma" content="no-cache">
  12. <metahttp-equiv="cache-control" content="no-cache">
  13. <metahttp-equiv="expires" content="0">
  14. <metahttp-equiv="keywords" content="keyword1,keyword2,keyword3">
  15. <metahttp-equiv="description" content="This is my page">
  16. <!--
  17. <link rel="stylesheet" type="text/css" href="styles.css">
  18. -->
  19. </head>
  20. <body>
  21. 登录成功<br>
  22. </body>
  23. </html>

启动tomcat我们可以看到数据库自动生成一个user表。我们添加一条记录为下面测试

接下来打开浏览器,输入http://localhost:8080/ssh/

版权声明:本文著作权归原作者所有,欢迎分享本文,谢谢支持!
转载请注明:利用全注解实现ssh的一个完整例子 | 猿笔记
分类:JAVA, 程序笔记 标签:, ,

发表评论


表情