javaweb项目源码

package com.test.dao.impl; /** * ponit 表操作的实现类 */ 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 com.test.dao.PointDao; import com.test.model.Point; import com.test.model.Point; import com.test.util.DbConn; public class PointDaoImpl implements PointDao { private Connection conn = DbConn.getConn(); /** * 根据节点id获得节点对象 */ public Point findPointByid(int id) { Point p = null; String sql = "select * from Point where id=?"; try { PreparedStatement psmt = conn.prepareStatement(sql); psmt.setInt(1, id); ResultSet rs = psmt.executeQuery(); while (rs.next()) { int id2 = rs.getInt("id"); int point_id =rs.getInt("point_id"); int lun_ci =rs.getInt("lun_ci"); String status = rs.getString("status"); int status_id =rs.getInt("status_id"); String function = rs.getString("function"); String electric = rs.getString("electric"); String power = rs.getString("power" ); int X = rs.getInt("X"); int Y = rs.getInt("Y"); p = new Point(id2,point_id,lun_ci, status_id,status, function, electric, power, X, Y); } } catch (SQLException e) { // TODO Auto-generated catch block e.printStackTrace(); } return p; } /** * 添加节点 */ public boolean addPoint(Point p) { boolean flag = false; String sql = "insert into point(point_id,lun_ci,status,status_id ,electric,function,power,x,y) values (?,?,?,?,?,?,?,?,?)"; try { PreparedStatement psmt = conn.prepareStatement(sql); psmt.setInt(1, p.getPoint_id()); psmt.setInt(2, p.getLun_ci()); psmt.setInt(4, p.getStatus_id()); psmt.setString(3, p.getStatus()); psmt.setString(5, p.getElectric()); psmt.setString(6, p.getFunction()); psmt.setString(7, p.getPower()); psmt.setInt(8, p.getX()); psmt.setInt(9, p.getY()); int i = psmt.executeUpdate(); if (i == 1) { flag = true; } } catch (SQLException e) { // TODO Auto-generated catch block e.printStackTrace(); } return flag; } /** * 根据id删除节点 * * */ public boolean delPoint(int id) { boolean flag = false; String sql = "delete from Point where id=?"; try { PreparedStatement psmt = conn.prepareStatement(sql); psmt.setInt(1, id); if (psmt.executeUpdate() > 0) { flag = true; } } catch (SQLException e) { // TODO Auto-generated catch block e.printStackTrace(); } return flag; } /** * * * * 删除全部节点 * * * */ public boolean delAllPoint(){ boolean flag = false; String sql = "TRUNCATE TABLE Point"; try { PreparedStatement psmt = conn.prepareStatement(sql); if (psmt.executeUpdate() > 0) { flag = true; } } catch (SQLException e) { // TODO Auto-generated catch block e.printStackTrace(); } return flag; } /** * 更新节点对象 */ public boolean updatePoint(Point p) { boolean flag = false; String sql = "update Point set status=?,function=?,power=?,x=?,y=?,point_id=? where id=? "; try { PreparedStatement psmt = conn.prepareStatement(sql); psmt.setString(1, p.getStatus()); psmt.setString(2, p.getFunction()); psmt.setString(3, p.getPower()); psmt.setInt(4, p.getX()); psmt.setInt(5, p.getY()); psmt.setInt(6, p.getPoint_id()); psmt.setInt(7, p.getId()); int i = psmt.executeUpdate(); if (i == 1) { flag = true; } } catch (SQLException e) { // TODO Auto-generated catch block e.printStackTrace(); } return flag; } /** * 获得所有节点对象 */ public List StSelect() { List list = new ArrayList(); String sql = "select * from Point"; try { Statement smt = conn.createStatement(); ResultSet rs = smt.executeQuery(sql); while (rs.next()) { int id = rs.getInt("id"); int point_id =rs.getInt("point_id"); int lun_ci =rs.getInt("lun_ci"); String status = rs.getString("status"); int status_id =rs.getInt("status_id"); String function = rs.getString("function"); String electric = rs.getString("electric"); String power = rs.getString("power" ); int X = rs.getInt("X"); int Y = rs.getInt("Y"); Point p = new Point(id,point_id,lun_ci, status_id,status, function, electric, power, X, Y); list.add(p); } } catch (SQLException e) { // TODO Auto-generated catch block e.printStackTrace(); } return list; } public List StSelect2(int lunci) { List list = new ArrayList(); String sql = "select * from Point where lun_ci=?"; try { PreparedStatement psmt = conn.prepareStatement(sql); psmt.setInt(1, lunci); ResultSet rs = psmt.executeQuery(); while (rs.next()) { int id = rs.getInt("id"); int point_id =rs.getInt("point_id"); int lun_ci =rs.getInt("lun_ci"); String status = rs.getString("status"); int status_id =rs.getInt("status_id"); String function = rs.getString("function"); String electric = rs.getString("electric"); String power = rs.getString("power" ); int X = rs.getInt("X"); int Y = rs.getInt("Y"); Point p = new Point(id,point_id,lun_ci, status_id,status, function, electric, power, X, Y); list.add(p); } } catch (SQLException e) { // TODO Auto-generated catch block e.printStackTrace(); } return list; } public List SelectX(int lunci) { List list = new ArrayList(); String sql = "select distinct X ,Y from Point where lun_ci=?"; try { PreparedStatement psmt = conn.prepareStatement(sql); psmt.setInt(1, lunci); ResultSet rs = psmt.executeQuery(); while (rs.next()) { int X = rs.getInt("X"); list.add(X); } } catch (SQLException e) { // TODO Auto-generated catch block e.printStackTrace(); } return list; } public List SelectY(int lunci) { List list = new ArrayList(); String sql = "select distinct X, Y from Point where lun_ci=?"; try { PreparedStatement psmt = conn.prepareStatement(sql); psmt.setInt(1, lunci); ResultSet rs = psmt.executeQuery(); while (rs.next()) { int Y = rs.getInt("Y"); list.add(Y); } } catch (SQLException e) { // TODO Auto-generated catch block e.printStackTrace(); } return list; } public List Select_status_id(int lun_ci) { List list = new ArrayList(); String sql = "select status_id from Point where lun_ci=?"; try { PreparedStatement psmt = conn.prepareStatement(sql); psmt.setInt(1, lun_ci); ResultSet rs = psmt.executeQuery(); while (rs.next()) { String status_id =rs.getString("status_id"); list.add(status_id); } } catch (SQLException e) { // TODO Auto-generated catch block e.printStackTrace(); } return list; } }