连接 MYSQL 数据库的简单增删改查
项目框架如图所示:
所需工具:
所需工具:
所需工具:
所需工具:
程序代码:package com.user.action;
import java.io.IOException;
import javax.servlet.ServletException;
import javax.servlet.http.HttpServlet;
import javax.servlet.http.HttpServletRequest;
import javax.servlet.http.HttpServletResponse;
import com.user.bean.UserBean;
import com.user.dao.UserDao;
public class InsertOrUpdateAction extends HttpServlet {
/**
*
*/
private static final long serialVersionUID = 1L;
private UserDao userDao ;
public void doGet(HttpServletRequest request, HttpServletResponse
response)
throws ServletException, IOException {
doPost(request, response);
}
response)
public void doPost(HttpServletRequest request, HttpServletResponse
throws ServletException, IOException {
request.setCharacterEncoding("utf-8");
response.setCharacterEncoding("utf-8");
userDao = new UserDao();
String str = request.getRequestURI();
str = str.substring(str.lastIndexOf("/")+1);
String yx = request.getParameter("yx");
String zy = request.getParameter("zy");
String age = request.getParameter("age");
String dh = request.getParameter("dh");
String qq = request.getParameter("qq");
String sex = request.getParameter("sex");
UserBean userBean = new UserBean();
userBean.setYx(yx);
userBean.setZy(zy);
if(!"".equals(age)&&age!=null)
{
userBean.setAge(Integer.valueOf(age));
}else{
userBean.setAge(0);
}
userBean.setDh(dh);
userBean.setQq(qq);
userBean.setSex(sex);
if("InsertUserAction".equals(str)){
if(userDao.insertUser(userBean)){
response.sendRedirect("SelectAllUser");
response.sendRedirect("SelectAllUser");
}else{
}
}else{
}else{
}else if("UpdateUserAction".equals(str)){
String strId = request.getParameter("id");
if(!"".equals(strId)&&strId!=null){
userBean.setId(Integer.valueOf(strId));
userBean.setId(-1);
}
if(userDao.updateUser(userBean)){
response.sendRedirect("SelectAllUser");
response.sendRedirect("SelectAllUser");
}
}
}
}
package com.user.action;
import java.io.IOException;
import javax.servlet.ServletException;
import javax.servlet.http.HttpServlet;
import javax.servlet.http.HttpServletRequest;
import javax.servlet.http.HttpServletResponse;
public class LoginAction extends HttpServlet {
/**
*
*/
private static final long serialVersionUID = 1L;
public void doGet(HttpServletRequest request, HttpServletResponse
throws ServletException, IOException {
doPost(request, response);
response)
}
response)
public void doPost(HttpServletRequest request, HttpServletResponse
throws ServletException, IOException {
String name= request.getParameter("name");
String password = request.getParameter("password");
if("".equals(name)||"".equals(password))
{
response.sendRedirect("/javaWebTest/index.jsp");
if("123".equals(name)&&"123".equals(password))
{
response.sendRedirect("SelectAllUser");
}else{
}else{
response.sendRedirect("/javaWebTest/index.jsp");
}
}
}
}
package com.user.action;
import java.io.IOException;
import java.util.List;
import javax.servlet.ServletException;
import javax.servlet.http.HttpServlet;
import javax.servlet.http.HttpServletRequest;
import javax.servlet.http.HttpServletResponse;
import com.user.bean.UserBean;
import com.user.dao.UserDao;
public class UserAction extends HttpServlet {
/**
*
*/
private static final long serialVersionUID = 1L;
private UserDao userDao ;
public void doGet(HttpServletRequest request, HttpServletResponse response)
throws ServletException, IOException {
doPost(request, response);
}
public void doPost(HttpServletRequest request, HttpServletResponse response)
throws ServletException, IOException {
request.setCharacterEncoding("utf-8");
response.setCharacterEncoding("utf-8");
userDao = new UserDao();
String str = request.getRequestURI();
str = str.substring(str.lastIndexOf("/")+1);
if("SelectAllUser".equals(str.trim()))
{
List list = userDao.getAllUser();
request.setAttribute("UserList", list);
request.getRequestDispatcher("/userList.jsp").forward(request,
response);
}else if("SelectOneUser".equals(str))
{
String strId = request.getParameter("id");
int id = Integer.valueOf(strId);
UserBean userBean = userDao.selectUserById(id);
request.setAttribute("userBean", userBean);
request.getRequestDispatcher("/updateUser.jsp").forward(request,
}else if("DeleteUserById".equals(str)){
String strId = request.getParameter("id");
int id = Integer.valueOf(strId);
if(userDao.deleteUser(id)){
response.sendRedirect("SelectAllUser");
}else{
response.sendRedirect("SelectAllUser");
response);
}
}
}
}
package com.user.dao;
import java.sql.ResultSet;
import java.sql.SQLException;
import java.util.ArrayList;
import java.util.List;
import com.user.bean.UserBean;
import com.util.DBUtils;
public class UserDao {
private DBUtils dbUtil;
/**
* 查询所有的 user
* @return
*/
public List getAllUser()
{
dbUtil = new DBUtils();
List list = new ArrayList();
String sql = "select * from user";
ResultSet rs = dbUtil.exceteSQl(sql);
try {
while(rs.next())
{
int i =1;
UserBean userBean = new UserBean();
userBean.setId(rs.getInt(i++));
userBean.setName(rs.getString(i++));
userBean.setYx(rs.getString(i++));
userBean.setZy(rs.getString(i++));
userBean.setAge(rs.getInt(i++));
userBean.setDh(rs.getString(i++));
userBean.setQq(rs.getString(i++));
userBean.setSex(rs.getString(i++));
list.add(userBean);
}
} catch (SQLException e) {
e.printStackTrace();
dbUtil.close();
}finally{
}
return list;
}
/**
* 根据 id 查询 user
* @param id
* @return
*/
public UserBean selectUserById(int id){
dbUtil = new DBUtils();
UserBean userBean = new UserBean();
String sql = "select * from user where id = '"+id+"'";
ResultSet rs = dbUtil.exceteSQl(sql);
try {
if(rs.next())
{
int i =1;
userBean.setId(rs.getInt(i++));
userBean.setYx(rs.getString(i++));
userBean.setZy(rs.getString(i++));
userBean.setAge(rs.getInt(i++));
userBean.setDh(rs.getString(i++));
userBean.setQq(rs.getString(i++));
userBean.setSex(rs.getString(i++));
}
}
} catch (SQLException e) {
e.printStackTrace();
return userBean;
}
/**
* 插入用户
* @param userBean
* @return
*/
public boolean insertUser(UserBean userBean){
if(row>0){
return true;
}
return false;
}
/**
* 删除用户
* @param id
* @return
*/
public boolean deleteUser(int id){
dbUtil = new DBUtils();
String sql = "insert into user (yx,zy,age,dh,qq,sex) values(?,?,?,?,?,?)";
int row = dbUtil.excete(sql, new
Object[]{userBean.getYx(),userBean.getZy(),userBean.getAge(),userBean.getDh(),use
rBean.getQq(),userBean.getSex()});
dbUtil = new DBUtils();
String sql = "delete from user where id = '"+id+ "'";
int row = dbUtil.excete(sql);
if(row>0)
{
return true;
}
return false;
}
/**
* 修改 user
* @param userBean