• mvc三层架构的思想_使用连接池技术的综合案例

    * mvc:三层架构思想
     * 
     * view:视图层
     *         展示页面效果（SE阶段：测试类，EE阶段：jsp,html展示效果）
     * model:业务层的数据的数据处理
     *         web层以及service(业务接口层/业务实现层)
     * controller:控制层
     *         调用dao层来去连接数据库，操作数据库
     *         增删查改！返回给用户信息
     * 
     * 代码架构：
     *     xx.xx.entity
     *             实体类的属性---需要数据库表中字段对应（映射关系）
     *     xx.xx.service
     *             业务接口层
     *     xx.xx.service.impl
     *             业务接口实现层
     *     xx.xx.web
     *             后台处理，调用层
     * 
     * 需求:
     *           有一个用户:User类----- > 某个数据库中:user表
     *                  用户id:userId                    userId
     *                 用户姓名:username                username
     *               用户密码:password                passwoed
     *              用户名地址:address                address
     *              电话:phone                        phone
     *              
     *             对用户完成增删查改操作,使用JDBC
     *             按照上面的格式:
     *             
     *  分析：
     *      1）创建一个数据库，创建一张表：user
     *      2)对user类的属性产生一个映射关系（符合javaBean规范）
     *      3）业务接口层
     *      4）业务接口实现层
     *      5）数据库访问层
     *      6）数据库访问实现层 

    1. package com.lin.test;
    2.  
    3. import java.util.List;
    4.  
    5. import org.junit.Test;
    6.  
    7. import com.lin.entity.User;
    8. import com.lin.service.UserService;
    9. import com.lin.service.impl.UserServiceImpl;
    10.  
    11. public class UserTest {
    12. 	private UserService userService = new UserServiceImpl() ;
    13. 	
    14. 	@Test
    15. 	public void testAdd() {
    16. 		//创建User对象
    17. 		User user = new User() ;
    18. 		user.setUsername("张三");
    19. 		user.setPassword("2222");
    20. 		user.setAddress("甘肃");
    21. 		user.setPhone("13688889999");
    22. 		//需要调用service层
    23. 		//调用add功能
    24. 		int count = userService.add(user) ;
    25. 		System.out.println("影响了"+count+"行");
    26. 	}
    27. 	
    28. 	@Test
    29. 	public void testUpdate() {
    30. 		User user = new User() ;
    31. 		user.setUserId(4); 
    32. 		user.setUsername("李四");
    33. 		user.setPassword("123456");
    34. 		user.setAddress("北京");
    35. 		user.setPhone("13888888888");
    36. 		
    37. 		int count = userService.update(user) ;
    38. 		System.out.println(count);
    39. 	}
    40. 	
    41. 	@Test
    42. 	public void testDelete() {
    43. 		User user = new User() ;
    44. 		user.setUserId(6);
    45. 		int count = userService.delete(user.getUserId()) ;
    46. 		System.out.println(count);
    47. 		
    48. 		
    49. 		//请求转发.重定向到指定jsp/html页面中
    50. 	}
    51. 	
    52. 	@Test
    53. 	public void testFindAll() {
    54. 		List list = userService.selectAll() ;
    55. 		for(User user :list) {
    56. 			System.out.println(user);//执行实体类中toString()
    57. 		}
    58. 	}
    59. 	
    60. 	
    61. 	//测试:通过用户id查询用户信息
    62. 	@Test
    63. 	public void testFindById() {
    64. 		
    65. 		
    66. 		
    67. 		User user2 = userService.find(3) ;
    68. 		System.out.println(user2);
    69. 		if(user2 !=null) {
    70. 			System.out.println(user2.getUserId()+"---"+user2.getUsername()+"---"+user2.getPassword()
    71. 			+"---"+user2.getAddress()+"---"+user2.getPhone());
    72. 		}
    73. 	}
    74. }
    75.  
    1. package com.lin.dao.impl;
    2.  
    3. import java.sql.Connection;
    4. import java.sql.PreparedStatement;
    5. import java.sql.ResultSet;
    6. import java.sql.SQLException;
    7. import java.util.ArrayList;
    8. import java.util.List;
    9.  
    10. import com.lin.dao.UserDao;
    11. import com.lin.entity.User;
    12. import com.lin.utils.JdbcUtils;
    13.  
    14. public class UserDaoImpl implements UserDao {
    15.  
    16. 	private Connection conn;
    17. 	private PreparedStatement stmt;
    18. 	private ResultSet rs;
    19.  
    20. 	@Override
    21. 	public int add(User user) {
    22.  
    23. 		try {
    24. 			// 获取连接
    25. 			conn = JdbcUtils.getConnection();
    26. 			// 准备sql
    27. 			String sql = "insert into user(username,password,address,phone)values(?,?,?,?);";
    28. 			// 编译sql
    29. 			stmt = conn.prepareStatement(sql);
    30. //			给参数赋值
    31. 			stmt.setString(1,user.getUsername());
    32. 			stmt.setString(2,user.getPassword());
    33. 			stmt.setString(3,user.getAddress());
    34. 			stmt.setString(4,user.getPhone());
    35. //			PreparedStatement对象中执行sql
    36. 			return stmt.executeUpdate();
    37. 			
    38. 		} catch (SQLException e) {
    39. 			// TODO Auto-generated catch block
    40. 			e.printStackTrace();
    41. 		}
    42.  
    43. 		return 0;
    44. 	}
    45.  
    46. 	@Override
    47. 	public int updata(User user) {
    48. 		try {
    49. 			// 获取连接对象
    50. 			conn = JdbcUtils.getConnection();
    51. 			// 准备sql
    52. 			String sql = "updata user set username=?,set username=?,password=?,address=?,phone=? where userId=?;";
    53. 			// 预编译sql
    54. 			stmt = conn.prepareStatement(sql);
    55. 			//设置参数
    56. 			stmt.setString(1,user.getUsername());
    57. 			stmt.setString(2,user.getPassword());
    58. 			stmt.setString(3,user.getAddress());
    59. 			stmt.setString(4,user.getPhone());
    60. 			stmt.setInt(5,user.getUserId());
    61. //			执行sql
    62. 			return stmt.executeUpdate();
    63. 		} catch (SQLException e) {
    64. 			// TODO Auto-generated catch block
    65. 			e.printStackTrace();
    66. 		}
    67.  
    68. 		return 0;
    69. 	}
    70.  
    71. //	根据用户id删除用户信息
    72. 	@Override
    73. 	public int delete(int id) {
    74. 		try {
    75. 			conn=JdbcUtils.getConnection();
    76. 			String sql="delete from user where id=?;";
    77. 			stmt=conn.prepareStatement(sql);
    78. 			//设置参数
    79. 			stmt.setInt(1,id);
    80. 			//执行
    81. 			return stmt.executeUpdate();
    82. 		} catch (SQLException e) {
    83. 			// TODO Auto-generated catch block
    84. 			e.printStackTrace();
    85. 		}
    86. 		
    87. 		return 0;
    88. 	}
    89.  
    90. 	@Override
    91. 	public List selectAll() {
    92. 		//构造一个空的ArrayList
    93. 		ArrayList list;
    94. 		try {
    95. 			list=new ArrayList();
    96. 			conn=JdbcUtils.getConnection();
    97. 			String sql="select * from user;";
    98. 			stmt=conn.prepareStatement(sql);
    99. //			执行sql
    100. 			rs=stmt.executeQuery();
    101. 			User user=null;
    102. //			遍历集合结果，封装到User对象中
    103. 			while(rs.next()) {
    104. //				通过列的名称获取
    105. 				int userId=rs.getInt("userId");
    106. 				String username=rs.getString("username");
    107. 				String password=rs.getString("password");
    108. 				String address=rs.getString("address");
    109. 				String phone=rs.getString("phone");
    110. 				
    111. 				user=new User();
    112. 				user.setUserId(userId);
    113. 				user.setUsername(username);
    114. 				user.setPassword(password);
    115. 				user.setAddress(address);
    116. 				user.setPhone(phone);
    117. 				
    118. 				//添加到集合中
    119. 				list.add(user);
    120. 				return list;
    121. 				
    122. 			}
    123. 		} catch (SQLException e) {
    124. 			// TODO Auto-generated catch block
    125. 			e.printStackTrace();
    126. 		}finally {
    127. 			JdbcUtils.close(rs, stmt, conn);
    128. 		}
    129. 		return null;
    130. 	}
    131.  
    132. 	//通过id查询用户
    133. 	@Override
    134. 	public User findById(int id) {
    135. 		try {
    136. 			User user=new User();
    137. 			conn=JdbcUtils.getConnection();
    138. 			String sql="select * from user where useeId=?; ";
    139. //		编译sql
    140. 			stmt=conn.prepareStatement(sql);
    141. 			//设置参数
    142. 			stmt.setInt(1,id);
    143. //			执行查询
    144. 			rs=stmt.executeQuery();
    145. 			while(rs.next()) {
    146. 				int userId=rs.getInt("userId");
    147. 				String username=rs.getString("username");
    148. 				String password=rs.getString("password");
    149. 				String address=rs.getString("address");
    150. 				String phone=rs.getString("phone");
    151. 				
    152. //				封装User对象
    153. 				user.setUserId(userId);
    154. 				user.setUsername(username);
    155. 				user.setPassword(password);
    156. 				user.setAddress(address);
    157. 				user.setPhone(phone);
    158. 				
    159. 				return user;
    160. 			}
    161. 		} catch (SQLException e) {
    162. 			// TODO Auto-generated catch block
    163. 			e.printStackTrace();
    164. 		}finally {
    165. 			JdbcUtils.close(rs, stmt, conn);
    166. 		}
    167. 		
    168. 		return null;
    169. 	}
    170.  
    171. }
    1. package com.lin.dao;
    2.  
    3. import java.util.List;
    4.  
    5. import com.lin.entity.User;
    6.  
    7. /**
    8.  * 持久层（用户数据访问接口层）
    9.  * @author wl
    10.  * */
    11. public interface UserDao {
    12. //	添加用户信息
    13. 	public abstract int add(User user);
    14. 	
    15. //	更新操作
    16. 	public abstract int updata(User user);
    17. 	
    18. //	删除：通过编号删除用户
    19. 	public abstract int delete(int id);
    20. 	
    21. //	查询所有
    22. 	public abstract List selectAll();
    23. 	
    24. //	通过用户id查询用户
    25. 	public abstract User findById(int id);
    26. }
    1. package com.lin.service.impl;
    2.  
    3. import java.util.List;
    4. /**
    5.  * 用户的业务接口实现层
    6.  * 调用dao层完成增删查改业务
    7.  * @author wl
    8.  * */
    9.  
    10. import com.lin.dao.UserDao;
    11. import com.lin.dao.impl.UserDaoImpl;
    12. import com.lin.entity.User;
    13. import com.lin.service.UserService;
    14.  
    15. public class UserServiceImpl implements UserService {
    16. 	
    17. //	在创建一个实例：持久层对象dao层
    18. 	private UserDao ud=new UserDaoImpl();
    19.  
    20. 	@Override
    21. 	public int add(User user) {
    22. 		
    23. 		return ud.add(user);
    24. 	}
    25.  
    26. 	@Override
    27. 	public int update(User user) {
    28. 		return ud.updata(user);
    29. 	}
    30.  
    31. 	@Override
    32. 	public int delete(int id) {
    33. 		return ud.delete(id);
    34. 	}
    35.  
    36. 	@Override
    37. 	public List selectAll() {
    38. 		return ud.selectAll();
    39. 	}
    40.  
    41. 	@Override
    42. 	public User find(int id) {
    43. 		return ud.findById(id);
    44. 	}
    45.  
    46. 	@Override
    47. 	public long findCount() {
    48. 		return 0;
    49. 	}
    50.  
    51. }
    1. package com.lin.service;
    2.  
    3. import java.util.List;
    4.  
    5. import com.lin.entity.User;
    6.  
    7. /*
    8.  * 针对用户操作的业务接口层
    9.  * */
    10. public interface UserService {
    11. 	
    12. 	//添加用户信息
    13. 	public abstract int add(User user);
    14. 	
    15. 	//更新操作
    16. 	public abstract int update( User user);
    17. 	
    18. 	//删除：通过编号删除用户
    19. 	public abstract int delete(int id);
    20. 	
    21. 	//查询所有
    22. 	public abstract List selectAll();
    23. 	
    24. 	//通过用户id查询所有
    25. 	public abstract User find(int id);
    26. 	
    27. //	查询user表中记录
    28. 	public abstract long findCount();
    29. }
    1. package com.lin.entity;
    2.  
    3. public class User {
    4. 	//对应user表中的字段
    5. 	private int userId;
    6. 	private String username;
    7. 	private String password;
    8. 	private String address;
    9. 	private String phone;
    10. 	
    11. 	public User() {
    12. 		super();
    13. 		// TODO Auto-generated constructor stub
    14. 	}
    15.  
    16. 	public User(int userId, String username, String password, String address, String phone) {
    17. 		super();
    18. 		this.userId = userId;
    19. 		this.username = username;
    20. 		this.password = password;
    21. 		this.address = address;
    22. 		this.phone = phone;
    23. 	}
    24. 	
    25. 	public int getUserId() {
    26. 		return userId;
    27. 	}
    28.  
    29. 	public void setUserId(int userId) {
    30. 		this.userId = userId;
    31. 	}
    32.  
    33. 	public String getUsername() {
    34. 		return username;
    35. 	}
    36.  
    37. 	public void setUsername(String username) {
    38. 		this.username = username;
    39. 	}
    40.  
    41. 	public String getPassword() {
    42. 		return password;
    43. 	}
    44.  
    45. 	public void setPassword(String password) {
    46. 		this.password = password;
    47. 	}
    48.  
    49. 	public String getAddress() {
    50. 		return address;
    51. 	}
    52.  
    53. 	public void setAddress(String address) {
    54. 		this.address = address;
    55. 	}
    56.  
    57. 	public String getPhone() {
    58. 		return phone;
    59. 	}
    60.  
    61. 	public void setPhone(String phone) {
    62. 		this.phone = phone;
    63. 	}
    64.  
    65. 	@Override
    66. 	public String toString() {
    67. 		return "User [userId=" + userId + ", username=" + username + ", password=" + password + ", address=" + address
    68. 				+ ", phone=" + phone + ", getClass()=" + getClass() + ", hashCode()=" + hashCode() + ", toString()="
    69. 				+ super.toString() + "]";
    70. 	}
    71.  
    72. 	
    73. }
  • 相关阅读:
    【闲言碎语】学习 文本编辑器vim及其插件、ranger、C语言、WSL配置、X11等等
    基于stm32单片机的智能恒温自动加氧换水鱼缸
    100天精通Python（爬虫篇）——第47天：selenium自动化操作浏览器
    ABP Framework 5.3.0 版本新增功能和变更说明
    如何获取淘宝商品评论 API接口
    WordPress主题开发（ 八）之—— 模板循环详细用法
    Python：用tkinter制做一个音乐下载小软件
    前端面试题第六天
    项目管理构建工具——Maven（基础篇）
    Docker创建FTP服务器
  • 原文地址：https://blog.csdn.net/weixin_57219176/article/details/126370022