文档章节

Java Web--增删改查之二界面后台java代码

拯救世界的小安安
 拯救世界的小安安
发布于 2014/06/16 09:26
字数 1117
阅读 9287
收藏 6

上次我们已经搞完了jsp的操作。现在该是后台的配置了。

在dao包里面进行数据链接:DBConn.java

/**
 * 
 */
/**
 * @author Administrator
 *
 */
package dao;

import java.sql.*;
public class DBConn {
	/**
	 * 链接数据库
	 * @return
	 */
     public static Connection getConnection(){
    	 Connection conn=null;
    	 try {
		    Class.forName("com.microsoft.sqlserver.jdbc.SQLServerDriver");
		    conn=DriverManager.getConnection("jdbc:sqlserver://localhost:1433;DataBaseName=EstateDB","sa","123456");
		} catch (Exception e) {
			e.printStackTrace();
		}
		 return conn;
     }
}

BuildingDao.java

package dao;

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

import entity.Building;




public class BuildingDao {
  /**
   * 操作数据库命令链接
   * 数据访问类
   */
	private Connection conn;
	private Statement state;
	private ResultSet rs;
	private PreparedStatement pre;
	/**
	 * 查询全部
	 * @return
	 * @throws SQLException
	 */
	public List<Building> fill() throws SQLException {
		List<Building> list = new ArrayList<Building>();
		String sql = "select * from T_building";
		conn = DBConn.getConnection();
		state = conn.createStatement();
		rs = state.executeQuery(sql);
		Building p = null;
		while (rs.next()) {
			p = new Building();				
			p.setId(rs.getString("Id"));
			p.setCompany(rs.getString("Company"));
			p.setPhone(rs.getString("Phone"));
			p.setDescription(rs.getString("Description"));
			p.setStatus(rs.getString("Status"));
			list.add(p);
		}
		rs.close();
		state.close();
		conn.close();
		return list;
	}
	/**
	 * 根据Id查询
	 * @param Id
	 * @return
	 * @throws SQLException
	 */
public Building fill(String Id) throws SQLException{
		
		conn = DBConn.getConnection();
		String sql="select * from T_building where Id=?";
		pre = conn.prepareStatement(sql);
		pre.setString(1, Id);
		rs=pre.executeQuery();
		Building p = null;
		if(rs.next()){
			p = new Building();				
			p.setId(rs.getString("Id"));
			p.setCompany(rs.getString("Company"));
			p.setPhone(rs.getString("Phone"));
			p.setDescription(rs.getString("Description"));
			p.setStatus(rs.getString("Status"));
		}
		rs.close();
		pre.close();
		conn.close();
		return p;
	}
/**
 * 添加
 * @param building
 * @return
 * @throws SQLException
 */
	public int add(Building building) throws SQLException {

		String sql = "insert  T_building values ('" + building.getId() + "','"
				+ building.getCompany() + "','" + building.getPhone() + "','"
				+ building.getDescription() + "','" + building.getStatus()
				+ "')";
		System.out.println(sql);
		conn = DBConn.getConnection();
		state = conn.createStatement();		
		int result = state.executeUpdate(sql);
		state.close();
		conn.close();
		return result;

	}
	/**
	 * 修改
	 * @param building
	 * @return
	 * @throws SQLException
	 */
	public int  update(Building  building) throws SQLException {
		String sql="UPDATE T_building SET Company=?,Phone =?,"+"Description=?, Status=? WHERE Id=?";
		conn=DBConn.getConnection();
		pre = conn.prepareStatement(sql);
		pre.setString(1,  building.getCompany());
		pre.setString(2,  building.getPhone());
		pre.setString(3,  building.getDescription());
		pre.setString(4,  building.getStatus());
		pre.setString(5,  building.getId());
		int count=pre.executeUpdate();
		pre.close();
		conn.close();
		return count;		
		// TODO Auto-generated method stub
		
	}
/**
 * 根据ID删除一项
 * @param Id
 * @throws SQLException
 */
	public void  delete(String Id) throws SQLException {
		String sql="delete from  T_building where  Id=?";
		conn=DBConn.getConnection();
		pre = conn.prepareStatement(sql);
		pre.setString(1,Id);
		pre.executeUpdate();
		pre.close();
		conn.close();				
		// TODO Auto-generated method stub		
	}
	/**
	 * 多项选择Id删除
	 * @param Id
	 * @throws SQLException
	 */
	public void  delete(String[] Id) throws SQLException {
		conn = DBConn.getConnection();
		String ids="'"+Id[0]+"'";
		for(int i=1;i<Id.length;i++) {
			ids=ids+",'"+Id[i]+"'";
		}
		String sql="delete from  T_building where  Id  in ("+ids+")";
		pre = conn.prepareStatement(sql);		
		pre.executeUpdate();
		pre.close();
		conn.close();				
		// TODO Auto-generated method stub		
	}
}

对啦,忘记创建实体类了。在entity包里面建实体类

Building.java

/**
 * 
 */
/**
 * @author Administrator
 *
 */
package entity;
public class Building {
	/**
	 * 实体类
	 * 定义get ,set 属性
	 */
    private String Id;
    private String Company;
    private String Phone;
    private String Description;
    private String Status;
	public String getId() {
		return Id;
	}
	public void setId(String id) {
		Id = id;
	}
	public String getCompany() {
		return Company;
	}
	public void setCompany(String company) {
		Company = company;
	}
	public String getPhone() {
		return Phone;
	}
	public void setPhone(String phone) {
		Phone = phone;
	}
	public String getDescription() {
		return Description;
	}
	public void setDescription(String description) {
		Description = description;
	}
	public String getStatus() {
		return Status;
	}
	public void setStatus(String status) {
		Status = status;
	}
	
    
}

service服务

BuildingService.java

/**
 * 
 */
/**
 * @author Administrator
 *
 */
package service;

import java.sql.SQLException;
import java.util.List;

import dao.BuildingDao;
import entity.Building;


public class BuildingService{
	/**
	 * 添加
	 * @param building
	 * @return
	 * @throws SQLException
	 */
	public int add(Building building) throws SQLException {
		BuildingDao dao=new BuildingDao();
		return dao.add(building);			
	}
	/**
	 * 查询
	 * @return
	 * @throws SQLException
	 */
	public  List<Building>  fill() throws SQLException{
		BuildingDao dao=new BuildingDao();	
		return dao.fill();
	}
	public  Building  fill(String  Id) throws SQLException{
		BuildingDao dao=new BuildingDao();	
		return dao.fill(Id);
	}
	/**
	 * 修改
	 * @param building
	 * @return
	 * @throws SQLException
	 */
	public int update(Building building) throws SQLException{
		BuildingDao dao=new BuildingDao();
		return dao.update(building);		
	}
	/**
	 *  删除
	 * @param Id
	 * @throws SQLException
	 */
	public void delete(String Id) throws SQLException{
		BuildingDao dao=new BuildingDao();
		 dao.delete(Id);;	
	}
	
	public void delete(String[] Id) throws SQLException {
		BuildingDao dao=new BuildingDao();
		dao.delete(Id);
	}
}

在action包里建servlet

BuildingServlet.java

/**
 * 
 */
/**
 * @author Administrator
 *
 */
package action;

import java.io.IOException;
import java.io.PrintWriter;
import java.sql.SQLException;
import java.util.List;
import javax.servlet.ServletException;
import javax.servlet.http.HttpServletRequest;
import javax.servlet.http.HttpServletResponse;
import javax.swing.JApplet;
import service.BuildingService;
import entity.Building;


public class BuildingServlet extends javax.servlet.http.HttpServlet implements
		javax.servlet.Servlet {

	static final long serialVersionUID = 1L;

	public BuildingServlet() {
		super();
	}

	@Override
	protected void doGet(HttpServletRequest request,
			HttpServletResponse response) throws ServletException, IOException {
		// TODO Auto-generated method stub

		response.setCharacterEncoding("utf-8");
		try {
			start(request, response);
		} catch (Exception e) {
			// TODO Auto-generated catch block
			e.printStackTrace();
		}

	}

	@Override
	protected void doPost(HttpServletRequest request,
			HttpServletResponse response) throws ServletException, IOException {
		// TODO Auto-generated method stub
		request.setCharacterEncoding("utf-8");
		try {
			start(request, response);
		} catch (Exception e) {
			// TODO Auto-generated catch block
			e.printStackTrace();
		}

	}

	private void start(HttpServletRequest request, HttpServletResponse response)
			throws Exception {

		response.setCharacterEncoding("GBK");
		response.setContentType("text/html;charset=utf-8");
		BuildingService service = new BuildingService();
		String action = request.getParameter("action");
		String id = request.getParameter("id");
		/**
		 * 添加
		 */
		if (action.equals("add")) {
			response.setContentType("text/html;charset=utf-8");
			String Id = request.getParameter("Id");
			String Company = request.getParameter("Company");
			String Phone = request.getParameter("Phone");
			String Description = request.getParameter("Description");
			String Status = request.getParameter("Status");
			Building b = new Building();
			b.setId(Id);
			b.setCompany(Company);
			b.setPhone(Phone);
			b.setDescription(Description);
			b.setStatus(Status);
			BuildingService buildingService = new BuildingService();
			try {
				buildingService.add(b);
				PrintWriter out = response.getWriter();
				out.print("添加成功");
			} catch (SQLException e) {
				PrintWriter out = response.getWriter();
				out.print("添加失败");
				e.printStackTrace();
			}
		}
		/**
		 * 查詢
		 */
		else if (action.equals("list")) {
					try {
							List<Building> buildingList = service.fill();
							request.setAttribute("buildingList", buildingList);
							request.getRequestDispatcher("buildingList.jsp").forward(
									request, response);
						} catch (Exception e) {
							// TODO Auto-generated catch block
							e.printStackTrace();
						}
				} else if (action.equals("list2")) {
					String id1 = request.getParameter("id");
					try {
							Building building = service.fill(id1);
							request.setAttribute("building", building);
							request.getRequestDispatcher("buildingList.jsp").forward(
									request, response);
						} catch (Exception e) {
							e.printStackTrace();
						}
				}
		/**
		 * 修改
		 */				
				else if (id != null&&action.equals("update")) {
							try {
									Building building = service.fill(id);
									request.setAttribute("building", building);
									request.getRequestDispatcher("buildingUpdate.jsp").forward(
											request, response);
								} catch (Exception e) {
									e.printStackTrace();
								}
						} else if(action.equals("update2")){
								String Id = request.getParameter("Id");
								String Company = request.getParameter("Company");
								String Phone = request.getParameter("Phone");
								String Description = request.getParameter("Description");
								String Status = request.getParameter("Status");
								Building b = new Building();
								b.setId(Id);
								b.setCompany(Company);
								b.setPhone(Phone);
								b.setDescription(Description);
								b.setStatus(Status);
								BuildingService buildingService = new BuildingService();
								try {
										buildingService.update(b);
										PrintWriter out = response.getWriter();
										out.print("修改成功");
										
									} catch (Exception e) {
										// TODO Auto-generated catch block
										e.printStackTrace();
									}				
						}
		/**
		 * 删除
		 */
					 if(action.equals("delete")) {
						 try {							
							List<Building> buildingDelete = service.fill();
							request.setAttribute("buildingDelete", buildingDelete);
							request.getRequestDispatcher("buildingDelete.jsp").forward(
									request, response);
						} catch (Exception e) {
							// TODO Auto-generated catch block
							e.printStackTrace();
						}
					  }
					  else if(action.equals("delete2")) {
						  String[] ids=request.getParameterValues("Id");
						 // String id1=request.getParameter("id");
						  try {
							//service.delete(id1);
							service.delete(ids);
							  response.sendRedirect("BuildingServlet?action=delete");
						} catch (Exception e) {
							// TODO Auto-generated catch block
							e.printStackTrace();
						}
					  }
					  else if(action.equals("delete3")) {						  
						  String id1=request.getParameter("id");
						  try {							
							service.delete(id1);
							  response.sendRedirect("BuildingServlet?action=delete");
						} catch (Exception e) {
							// TODO Auto-generated catch block
							e.printStackTrace();
						}
					  }
					
			}
}


© 著作权归作者所有

共有 人打赏支持
拯救世界的小安安
粉丝 4
博文 31
码字总数 30593
作品 0
徐汇
程序员
基于 Java 的 CMS 解决方案 - tjpcms

官网:http://www.tjpcms.com tjpcms 是一套基于 Java 的 CMS 解决方案,开源免费。其独有的实时配置增删改查的功能,是其区别于同类 cms 的最大特点,也是最大优势,极大减少了重复劳动。懂...

金盆洗手
2017/01/12
0
6
SpringBoot实战(四)之使用JDBC和Spring访问数据库

这里演示的是h2databse示例,所以简单的介绍普及下h2database相关知识 H2数据库是一个开源的关系型数据库。 H2是一个嵌入式数据库引擎,采用java语言编写,不受平台的限制,同时H2提供了一个...

youcongtech
08/03
0
0
大数据开发培训:0基础学习Java编程语言有哪些知识点?

Java 技术通用、高效、具有平台移植性和安全性,广泛应用于PC、数据中心、游戏控制台、科学超级计算机、移动电话和互联网等,学习Java首先要知道学习知识点有哪些。在这就用加米谷大数据培训...

加米谷大数据
07/25
0
0
微服务 SpringBoot 2.0(七):使用JdbcTemplates访问Mysql

一切没有与数据库交互的网站都是假网站 —— Java面试必修 引言 在web开发服务中,开发人员要做的事情就是将数据库中的数据返回至前端页面,在第五章我们已经整合了页面,今天我们再结合数据...

阿郎_
09/28
0
0
MyBatis+Hibernate+JDBC对比分析

MyBatis目前作为持久层,用的最多,因为它符合互联网开发的变动性,实际开发中需求总会有这样的,那样的变动,MyBatis虽然没有Hibernate那么全自动化,而且对于开发人员的sql能力要求比较高,...

youcongtech
04/04
0
0

没有更多内容

加载失败,请刷新页面

加载更多

好用的vue组件

http://elickzhao.github.io/2017/08/vue%E4%B8%80%E4%BA%9B%E7%89%B9%E5%88%AB%E6%9C%89%E7%94%A8%E7%9A%84%E6%8F%92%E4%BB%B6/...

Littlebox
36分钟前
3
0
linux 源码安装mysql8

1.安装依赖 yum -y install wget cmake gcc gcc-c++ ncurses ncurses-devel libaio-devel openssl openssl-devel   2.下载源码包 wget https://cdn.mysql.com//Downloads/MySQL-8.0/mysql-......

苏牧影子
36分钟前
1
0
BeanFactory和FactoryBean

BeanFactory BeanFactory是ioc容器的顶层接口,里面定义了一些容器基本的功能 类似ConfigurableBeanFatory和ApplicationContext就是比较高级的容器,除了基本的方法之外,还实现了很多高级的...

sendo
38分钟前
2
0
Java并发(9)- 从同步容器到并发容器

引言 容器是Java基础类库中使用频率最高的一部分,Java集合包中提供了大量的容器类来帮组我们简化开发,我前面的文章中对Java集合包中的关键容器进行过一个系列的分析,但这些集合类都是非线...

Ala6
42分钟前
3
0
Java定时器Timer学习之一

种类: 接通延时型定时器:接通延时型定时器是各种PLC(可编程控制器)中最常见最基本的定时器,这种定时器在Siemens的PLC中,成为SD型定时器 断开延时型定时器:这种定时器是当输入条件00000为ON时...

王怀楼
44分钟前
2
0

没有更多内容

加载失败,请刷新页面

加载更多

返回顶部
顶部