对数据库实现增删改查_"string sql = \"insert into airc_contorol (session-程序员宅基地

技术标签: Java  javaweb  servlet  JSP  MySQL  JDBC  

1.实体类

package com.oa.entity;
public class Users {
	private int id;
	private String uname;
	private String usex;
	private String upword;
	private int dept;
	private int role;
	private String date;
	public int getId() {
		return id;
	}
	public void setId(int id) {
		this.id = id;
	}
	public String getUname() {
		return uname;
	}
	public void setUname(String uname) {
		this.uname = uname;
	}
	public String getUsex() {
		return usex;
	}
	public void setUsex(String usex) {
		this.usex = usex;
	}
	public String getUpword() {
		return upword;
	}
	public void setUpword(String upword) {
		this.upword = upword;
	}
	public int getDept() {
		return dept;
	}
	public void setDept(int dept) {
		this.dept = dept;
	}
	public int getRole() {
		return role;
	}
	public void setRole(int role) {
		this.role = role;
	}
	public String getDate() {
		return date;
	}
	public void setDate(String date) {
		this.date = date;
	}
	
}

2.DAO层

package com.oa.dao;

import java.util.List;

import com.oa.entity.Users;
import com.oa.tool.PageUtil;

public interface UsersDao {

	public List<Users> gets(PageUtil page);
	public int getAllCounts();
	
	public boolean del(int id);
	
	public boolean delu(String ids);
	
	public Users sel(int id);
	
	public boolean add(Users u);
	
	public boolean update(Users u);
}

3.DAOImpl层

package com.oa.daoImpl;

import java.sql.Connection;
import java.sql.PreparedStatement;
import java.sql.ResultSet;
import java.util.ArrayList;
import java.util.List;

import com.oa.tool.*;
import com.oa.dao.UsersDao;
import com.oa.entity.Dept;
import com.oa.entity.Role;
import com.oa.entity.Users;
import com.oa.tool.C3p0Util;

public class UsersDaoImpl implements UsersDao{
    //查询所有用户信息
	@Override
	public List<Users> gets(PageUtil page) {
		List<Users> users = new ArrayList<>();
		Connection conn=null;
		PreparedStatement pstmt = null;
		ResultSet rs = null;
		String sql = "select * from t_user limit ?,?";
		try{
			conn = C3p0Util.getConnection();
			pstmt=conn.prepareStatement(sql);
			pstmt.setInt(1, page.getBeginRow());
			pstmt.setInt(2, page.getPageSize());
			rs=pstmt.executeQuery();
			while(rs.next()){
				Users user = new Users();
				user.setId(rs.getInt("id"));
				user.setUname(rs.getString("user_name"));
				user.setUsex(rs.getString("user_sex"));
				user.setUpword(rs.getString("user_password"));
				user.setDept(rs.getInt("user_department"));
				user.setRole(rs.getInt("user_role"));
				user.setDate(rs.getString("create_date"));
				
				
				users.add(user);
			}
		}catch(Exception e){
			e.printStackTrace();
		}finally{
			C3p0Util.close(conn, pstmt, rs);
		}
		return users;//集合
	}
	//查询数量,分页设计
	@Override
	public int getAllCounts() {
		Connection conn=null;
		PreparedStatement pst = null;
		ResultSet rs = null;
		int result=0;
		try{
			conn=C3p0Util.getConnection();
			System.out.print("---------------------成功"+conn);
			String sql="select count(*) from t_user";
			pst=conn.prepareStatement(sql);
			rs=pst.executeQuery();
			if(rs.next()){
				result=rs.getInt(1);//参数是列,返回这一列有多少条记录
			}
		}catch(Exception e){
			e.printStackTrace();
		}finally{
			C3p0Util.close(conn, pst, rs);
		}
		return result;
	}
	//查询单个用户信息
	@Override
	public Users sel(int id) {
		Users us=new Users();
		Connection conn=null;
		PreparedStatement pst = null;
		ResultSet rs = null;
		String sql = "select * from t_user where id=?";
		try{
			conn=C3p0Util.getConnection();
			pst=conn.prepareStatement(sql);
			pst.setInt(1, id);
			rs=pst.executeQuery();
			if(rs.next()){
				us.setId(rs.getInt("id"));
				us.setUname(rs.getString("user_name"));
				us.setUsex(rs.getString("user_sex"));
				us.setUpword(rs.getString("user_password"));
				us.setDept(rs.getInt("user_department"));
				us.setRole(rs.getInt("user_role"));
				us.setDate(rs.getString("create_date"));
			}
		}catch(Exception e){
			e.printStackTrace();
		}finally{
			C3p0Util.close(conn, pst, rs);
		}
		return us;
	}
//修改单条用户信息

	@Override
	public boolean update(Users u) {
		Connection conn=null;
		PreparedStatement pst = null;
		ResultSet rs = null;
		boolean result=false;
		String sql="UPDATE t_user SET user_name=?,user_sex=?,user_password=?, user_department=?, user_role=? WHERE id=?";
		try{
			conn=C3p0Util.getConnection();
			pst=conn.prepareStatement(sql);
			pst.setString(1, u.getUname());
			pst.setString(2, u.getUsex());
			pst.setString(3, u.getUpword());
			pst.setInt(4, u.getDept());
			pst.setInt(5, u.getRole());
			pst.setInt(6, u.getId());
			int in=pst.executeUpdate();
			if(in==1){
				result=true;
			}
			
		}catch(Exception e){
			e.printStackTrace();
		}finally{
			C3p0Util.close(conn, pst, rs);
		}
		return result;
	}

//添加用户
	@Override
	public boolean add(Users u) {
		Connection conn=null;
		PreparedStatement pst = null;
		ResultSet rs = null;
		boolean result=false;
		try{
			conn=C3p0Util.getConnection();
			String sql="INSERT into t_user(user_name,user_sex,user_password,user_department,user_role,create_date) VALUES(?,?,?,?,?,?)";
		pst=conn.prepareStatement(sql);
		pst.setString(1, u.getUname());
		pst.setString(2, u.getUsex());
		pst.setString(3, u.getUpword());
		pst.setInt(4, u.getDept());
		pst.setInt(5, u.getRole());
		pst.setString(6, u.getDate());
		int add=pst.executeUpdate();
		if(add==1){
			result = true;
		}
		}catch(Exception e){
			e.printStackTrace();
		}finally{
			C3p0Util.close(conn, pst, rs);
		}
		return result;
	}
	//删除单个用户
	@Override
	public boolean del(int id) {
		Connection conn=null;
		PreparedStatement pst = null;
		ResultSet rs = null;
		Users us =new Users();
		boolean result=false;
		try{
			conn=C3p0Util.getConnection();
			String sql="delete from t_user where id=?";
			pst=conn.prepareStatement(sql);
			pst.setInt(1, id);
			int res=pst.executeUpdate();
			if(res==1){
				result=true;
			}
		}catch(Exception e){
			e.printStackTrace();
		}finally{
			C3p0Util.close(conn, pst, rs);
		}
		return result;
	}
//删除多条记录
	@Override
	public boolean delu(String ids) {
		Connection conn=null;
		PreparedStatement pst = null;
		ResultSet rs = null;
		Users us =new Users();
		boolean result=false;
		try{
			conn=C3p0Util.getConnection();
			System.out.println(ids+" kkkkkkkkkkkkkkkkkkkkkkkkkkkkkkk"); 
			String sql="DELETE FROM t_user WHERE id in ("+ids+")";
			pst = conn.prepareStatement(sql);
			System.out.println(pst+"********");
			int in=pst.executeUpdate();
			if(in>=1){
				result = true;
			}
		}catch(Exception e){
			e.printStackTrace();
		}finally{
			C3p0Util.close(conn, pst, rs);
		}
		return result;
	}
}

4.service层

package com.oa.service;

import java.util.List;

import com.oa.entity.Users;
import com.oa.tool.PageUtil;

public interface UsersService {
  public List<Users> gets(PageUtil page);
  public int getAllCounts();
	
	public boolean del(int id);
	
	public boolean delu(String ids);
	
	public Users sel(int id);
	
	public boolean add(Users u);
	
	public boolean update(Users u);
}

5.ServiceImpl层

package com.oa.serviceImpl;

import java.util.List;
import com.oa.dao.*;
import com.oa.daoImpl.*;
import com.oa.entity.Users;
import com.oa.service.UsersService;
import com.oa.tool.PageUtil;

public class UsersServiceImpl implements UsersService {
	private UsersDao ud = new UsersDaoImpl();

	@Override
	public List<Users> gets(PageUtil page) {
		// TODO Auto-generated method stub
		return ud.gets(page);
	}

	@Override
	public int getAllCounts() {
		// TODO Auto-generated method stub
		return ud.getAllCounts();
	}

	@Override
	public boolean del(int id) {
		// TODO Auto-generated method stub
		return ud.del(id);
	}

	@Override
	public boolean delu(String ids) {
		// TODO Auto-generated method stub
		return ud.delu(ids);
	}

	@Override
	public Users sel(int id) {
		// TODO Auto-generated method stub
		return ud.sel(id);
	}

	@Override
	public boolean add(Users u) {
		// TODO Auto-generated method stub
		return ud.add(u);
	}

	@Override
	public boolean update(Users u) {
		// TODO Auto-generated method stub
		return ud.update(u);
	}
	

}

6.Servlet层

package com.oa.servlet;

import java.io.IOException;
import java.sql.Timestamp;
import java.util.List;

import javax.servlet.ServletException;
import javax.servlet.annotation.WebServlet;
import javax.servlet.http.HttpServlet;
import javax.servlet.http.HttpServletRequest;
import javax.servlet.http.HttpServletResponse;

import com.oa.entity.Users;
import com.oa.service.UsersService;
import com.oa.serviceImpl.UsersServiceImpl;
import com.oa.tool.PageUtil;

/**
 * Servlet implementation class UsersServlet
 */
@WebServlet("/UsersServlet")
public class UsersServlet extends HttpServlet {
	private static final long serialVersionUID = 1L;
	private UsersService us = new UsersServiceImpl();
	protected void service(HttpServletRequest request, HttpServletResponse response) throws ServletException, IOException {
		String info = request.getParameter("users.info");
		//info=2 查询全部用户;info=3删除 ; info=4添加;  info=5查询单条信息; info=6 修改 ; info=7多条删除
		if("2".equals(info)){
			System.out.println("-----doGet--selsUserServlet--查询全部用户-users.info=2------");
			selsUserServlet(request, response); 
		}else if("3".equals(info)){
			System.out.println("-----doGet----删除-users.info=3------");
			delUserServlet(request, response); 
		}else if("4".equals(info)){
			System.out.println("-----doGet--addUserServlet--添加-users.info=4------");
			addUserServlet(request, response); 
		}else if("5".equals(info)){
			System.out.println("-----doGet--selUserServlet--查询单条信息-users.info=5------");
			selUserServlet(request, response); 
		}else if("6".equals(info)){
			System.out.println("-----doGet--updUserServlet--修改-users.info=6------");
			updUserServlet(request, response); 
		}else if("7".equals(info)){
			System.out.println("-----doGet--updsUserServlet--批量删除-users.info=7------");
			delsUserServlet(request, response); 
		}
	}
	//查询所有用户信息
		protected void selsUserServlet(HttpServletRequest request, HttpServletResponse response) throws ServletException, IOException {
		PageUtil page =new PageUtil();
		
		//获取当前页数
		String currentPage =request.getParameter("currentPage");
				int currentPageIndex=0;
				if(currentPage!=null){
					currentPageIndex=Integer.parseInt(currentPage);
				}else{
					currentPageIndex=1;
				}
				int totalCount=us.getAllCounts();
				page.setCurrentPage(currentPageIndex);//当前页
				page.setPageSize(5);//每页数目
				page.setTotalCount(totalCount);//总条数
				
				//查询所有用户信息
				List<Users> list = us.gets(page);
				
				//返回数据
				request.setAttribute("PageObj", page);
		
		         request.setAttribute("lists", list);
		       request.getRequestDispatcher("files/yonghuxinxi.jsp").forward(request, response);
		}
		//查询单个用户
		protected void selUserServlet(HttpServletRequest request, HttpServletResponse response) throws ServletException, IOException {
	      UsersService us =new UsersServiceImpl();
	      int id =Integer.parseInt(request.getParameter("id"));
	      Users uu =us.sel(id);
			request.setAttribute("edit", uu);
			request.getRequestDispatcher("files/yonghuedit.jsp").forward(request, response); 
		}
		//修改个用户
		protected void updUserServlet(HttpServletRequest request, HttpServletResponse response) throws ServletException, IOException {
			  UsersService us =new UsersServiceImpl();
			  Users user = new Users();
				user.setId(Integer.parseInt(request.getParameter("id")));
				user.setUname(request.getParameter("user_name"));
				user.setUpword(request.getParameter("user_password"));
				user.setUsex(request.getParameter("user_sex"));
				user.setDept(Integer.parseInt(request.getParameter("user_department")));
				user.setRole(Integer.parseInt(request.getParameter("user_role")));
				boolean bool = us.update(user);
				if(bool){
					System.out.println("用户修改成功");  
					response.sendRedirect("UsersServlet?users.info=2"); 
				}
		}
		//添加用户
		protected void addUserServlet(HttpServletRequest request, HttpServletResponse response) throws ServletException, IOException {
			UsersService us =new UsersServiceImpl();
			  Users user = new Users();
			  System.out.println(request.getParameter("user_department")+"9999999999999kkkkkkkkkkkkkk");
				Timestamp timestamp = new Timestamp(System.currentTimeMillis());
				user.setUname(request.getParameter("user_name"));
				user.setUpword(request.getParameter("user_password"));
				user.setUsex(request.getParameter("user_sex"));
				user.setDept(Integer.parseInt(request.getParameter("user_department")));
				user.setRole(Integer.parseInt(request.getParameter("user_role")));
				user.setDate(timestamp.toString());
				
				boolean bool = us.add(user);
				if(bool){
					System.out.println("用户添加成功");  
					response.sendRedirect("UsersServlet?users.info=2"); 
				}
		}
		//删除单条记录
		protected void delUserServlet(HttpServletRequest request, HttpServletResponse response) throws ServletException, IOException {
			int id = Integer.parseInt(request.getParameter("id"));
			UsersService us = new UsersServiceImpl();
			boolean bool = us.del(id);
			if(bool){
				System.out.println(id+"用户删除成功dddddddddddddddddddddddddddd");
				response.sendRedirect("UsersServlet?users.info=2"); 
			}
		}
		//删除多条记录
		protected void delsUserServlet(HttpServletRequest request, HttpServletResponse response) throws ServletException, IOException {
			String id = request.getParameter("ids");
			UsersService us = new UsersServiceImpl();
			boolean bool = us.delu(id);
			if(bool){
				System.out.println("用户删除成功");   
				response.sendRedirect("UsersServlet?users.info=2"); 
			}
		}
		}

 

版权声明:本文为博主原创文章,遵循 CC 4.0 BY-SA 版权协议,转载请附上原文出处链接和本声明。
本文链接:https://blog.csdn.net/weixin_44022886/article/details/98330766

智能推荐

php 5.4.23,PHP 5.5.7/5.4.23/5.3.28 紧急发布-程序员宅基地

文章浏览阅读68次。PHP 5.5.7/5.4.23/5.3.28紧急发布.2013-12-13.上个版本是2013-11-14的5.5.6/5.4.22。全部修正了一个 OpenSSL的安全漏洞(CVE-2013-6420)5.3本来已停止常规开发也更新了。 总共修正了10几个Bug(包括Opcache的几个Bug)及安全漏洞。完全改进:Version 5.5.712-Dec-2013Core:Fixed bu..._cve-2013-6420

华为Could API人工智能系列——文本合成MP3音频_api-huacloud.net-程序员宅基地

文章浏览阅读3.8k次,点赞61次,收藏41次。华为Could API人工智能系列——文本合成MP3音频_api-huacloud.net

python多进程(multiprocessing)(map)_multiprocessing map-程序员宅基地

文章浏览阅读9.9k次。map的基本使用:map函数一手包办了序列操作,参数传递和结果保存等一系列的操作。from multiprocessing.dummy import Poolpoop = Pool(4) # 4代表电脑是多少核的results = pool.map(爬取函数,网址列表)from multiprocessing.dummy import Pool as ThreadPool..._multiprocessing map

文字居中、水平居中、垂直居中_垂直居中 text-align-last:center-程序员宅基地

文章浏览阅读773次。1、效果2、应用场景:表单文字对齐、按钮内均匀分布…3、源码<div style="width:400px;background-color:#eee;text-align-last:justify"> 水平均匀分布 </div> <div style="width:400px;background-color:green;text-align:center"> 居中 </div> <div style="_垂直居中 text-align-last:center

SpringBoot-总结-程序员宅基地

文章浏览阅读305次。今日授课目标能够理解SpringBoot的设计初衷,开发环境要求能够搭建SpringBoot的开发工程能够理解SpringBoot的配置文件常见配置ApplactionContext.xml导包配置文件api(new对象)能够使用SpringBoot整合MyBatis,整合Redis进行缓存,整合RestTemplate发送Http请求能够使用SpringBoot进行简单代码测试能够打包部署SpringBoot项目学习今日内容,必备基础知识:Spring的对象ioc容器

IDEA翻译插件Translation的安装,百度翻译的应用ID和秘钥申请详细步骤_idea百度翻译密钥-程序员宅基地

文章浏览阅读3w次,点赞56次,收藏92次。IDEA翻译插件Translation的安装,百度翻译的应用ID和秘钥申请下载插件使用方法字体和接口切换开通百度翻译api注意事项大家平时肯定遇到过这种情况,不管从抖音还是快手或者其他地方获得的一碗毒鸡汤,下肚以后心潮澎湃,凌晨一点也要翻开电脑,奋发图强到势不可挡,立志要成为技术大神。可当打开了编程工具,点进代码底层,通篇的陌生单词还是给了自己一盆冷水。嗯,我其实可以看点搞笑的段子。IDEA实时翻译插件Translation,今天他来了,这款翻译插件支持谷歌、有道和百度api接口,使用的时候我们只需_idea百度翻译密钥

随便推点

SM2椭圆曲线公钥密码算法的JAVA实现-程序员宅基地

文章浏览阅读2.3k次,点赞2次,收藏16次。2019独角兽企业重金招聘Python工程师标准>>> ..._java 把sm2公钥的r s, 按照asn1的标准计算

转载UnicodeDecodeError: ‘utf-8‘ codec can‘t decode bytes in position 1022-1023: unexpected end of data_unicodedecodeerror: 'utf-8' codec can't decode byt-程序员宅基地

文章浏览阅读6.9k次。仅作为记录,大佬请跳过。运行python程序时,出现UnicodeDecodeError: 'utf-8' codec can't decode bytes in position 1022-1023: unexpected end of data解决方案(博主未使用,多次运行就又好了)转载:传送门在开头输入:#!/usr/bin/env Python# coding=utf-8..._unicodedecodeerror: 'utf-8' codec can't decode bytes in position 1022-1023:

华为服务器如何通过bmc装系统,华为BMC管理模块介绍及指南-程序员宅基地

文章浏览阅读5.5k次。【实例简介】华为服务器服务工程师的培训教材,其中针对华为服务器BMC管理模块的配置及使用做了详细的介绍。目录1.BMC介绍2.BMC远程管理功能介绍HUAWEI TECHNOLOGIES CO, TDHuawei ConfidentialHUAWEI目录1.BMC介绍1.1BMC简介1.2BMC功能模块1.3BMC运行环境2.BMC远程管理功能介绍HUAWEI TECHNOLOGIES CO, T..._华为服务器如果通过bmc网络安装操作系统

uiautomatorviewer 无法得到android.view.view控件的内容_android.view.view内容无法提取-程序员宅基地

文章浏览阅读2.4k次。如下面的图片所示,我们在自动化测试中,需要得到view控件的内容,但是因为某些原因,app不是让你轻易得到数据,这里提供一个思路来提取数据,当然不是最好的,大家有好的想法,欢迎指出。思路:长按内容。 在出现复制标签后,点击复制。 从剪切板读取内容。代码: UiObject res0 = new UiObject(new UiSelector().resourc..._android.view.view内容无法提取

使用VScode 调试的时候提示Unable to start debugging_unable to start debugging. launch options string p-程序员宅基地

文章浏览阅读4.8w次,点赞13次,收藏8次。使用VScode 调试的时候提示Unable to start debugging. Launch options string provided by the project system is invalid. Unable to determine path to debugger. Please specify the "MIDebuggerPath" option.提示这个错误。..._unable to start debugging. launch options string provided by the project sys

【核心概念】图像分类和目标检测中的正负样本划分以及架构理解_图像配准数据的正负样本-程序员宅基地

文章浏览阅读3.8k次,点赞9次,收藏22次。图像分类和目标检测中的正负样本划分以及架构理解_图像配准数据的正负样本

推荐文章

热门文章

相关标签