fwxxdao.java

北大青鸟的租房网练习文件

package com.newer.dao;

import java.sql.Connection;
import java.sql.PreparedStatement;
import java.sql.ResultSet;
import java.util.Vector;

import com.newer.common.DBUtil;
import com.newer.entity.FwxxVO;

public class FwxxDao {
	/*
	 * 添加租房信息
	 */
	public boolean addNewFwxx(FwxxVO vo){
		boolean res=false;
		String sql="insert into tbl_fwxx(uid,jdid,lxid,shi,ting,fwxx,zj,title,telephone,lxr,qxid) ";
		sql+=" values(?,?,?,?,?,?,?,?,?,?,?)";
		Connection conn=DBUtil.getConn();
		PreparedStatement pstmt=null;
		try {
			pstmt=conn.prepareStatement(sql);
			pstmt.setInt(1, vo.getUid());
			pstmt.setInt(2, vo.getJdid());
			pstmt.setInt(3, vo.getLxid());
			pstmt.setInt(4, vo.getShi());
			pstmt.setInt(5, vo.getTing());
			pstmt.setString(6, vo.getFwxx());
			pstmt.setFloat(7, vo.getZj());
			pstmt.setString(8, vo.getTitle());
			pstmt.setString(9, vo.getTelephone());
			pstmt.setString(10,vo.getLxr());
			pstmt.setInt(11, vo.getQxid());
			int count=pstmt.executeUpdate();
			
			if(count>0){
				res=true;
			}
			} catch (Exception e) {
			e.printStackTrace();
		}
		return res;
	}
	/*
	 * 根据用户编号查询出该用户所发布的租房信息
	 */
	public Vector getFwxxByUID(int uid){
		Vector vc=new Vector();
		String sql="select * from tbl_fwxx where uid=?";
		Connection conn=DBUtil.getConn();
		PreparedStatement pstmt=null;
		try {
			pstmt=conn.prepareStatement(sql);
			pstmt.setInt(1, uid);
			ResultSet rs=pstmt.executeQuery();
			while(rs.next()){
				FwxxVO fwxxvo=new FwxxVO();
				fwxxvo.setFwid(rs.getInt("fwid"));
				fwxxvo.setUid(rs.getInt("uid"));
				fwxxvo.setQxid(rs.getInt("qxid"));
				fwxxvo.setJdid(rs.getInt("jdid"));
				fwxxvo.setLxid(rs.getInt("lxid"));
				fwxxvo.setShi(rs.getInt("shi"));
				fwxxvo.setTing(rs.getInt("ting"));
				fwxxvo.setFwxx(rs.getString("fwxx"));
				fwxxvo.setZj(rs.getFloat("zj"));
				fwxxvo.setTitle(rs.getString("title"));
				fwxxvo.setDate(rs.getString("date"));
				fwxxvo.setTelephone(rs.getString("telephone"));
				fwxxvo.setLxr(rs.getString("lxr"));
				vc.add(fwxxvo);				
			}
			rs.close();
			pstmt.close();
			conn.close();
		} catch (Exception e) {
			// TODO: handle exception
		}
		return vc;
	}
	/*
	 * 通过房屋编号获取租房的详细信息
	 */
	public FwxxVO getFwxxByFwID(int fwid){
		FwxxVO fwxxvo=new FwxxVO();
		String sql="select * from tbl_fwxx where fwid=?";
		Connection conn=DBUtil.getConn();
		PreparedStatement pstmt=null;
		try {
			pstmt=conn.prepareStatement(sql);
			pstmt.setInt(1, fwid);
			ResultSet rs=pstmt.executeQuery();
			while(rs.next()){
				fwxxvo.setFwid(rs.getInt("fwid"));
				fwxxvo.setUid(rs.getInt("uid"));
				fwxxvo.setQxid(rs.getInt("qxid"));
				fwxxvo.setJdid(rs.getInt("jdid"));
				fwxxvo.setLxid(rs.getInt("lxid"));
				fwxxvo.setShi(rs.getInt("shi"));
				fwxxvo.setTing(rs.getInt("ting"));
				fwxxvo.setFwxx(rs.getString("fwxx"));
				fwxxvo.setZj(rs.getFloat("zj"));
				fwxxvo.setTitle(rs.getString("title"));
				fwxxvo.setDate(rs.getString("date"));
				fwxxvo.setTelephone(rs.getString("telephone"));
				fwxxvo.setLxr(rs.getString("lxr"));
			}
			rs.close();
			pstmt.close();
			conn.close();
		} catch (Exception e) {
			e.printStackTrace();
		}
		return fwxxvo;
	}
	public boolean delFwxxByFwID(int fwid){
		Boolean res=false;
		String sql="delete from tbl_fwxx where fwid=?";
		Connection conn=DBUtil.getConn();
		PreparedStatement pstmt=null;
		try {
			pstmt=conn.prepareStatement(sql);
			pstmt.setInt(1, fwid);
			int count=pstmt.executeUpdate();
			if(count>0){
				res=true;
			}
			pstmt.close();
			conn.close();
			
		} catch (Exception e) {
			e.printStackTrace();
		}
		return res;
	}
	/*
	 * 将修改后的房屋信息数据提交保存到数据库
	 */
	public boolean modifyFwxx(FwxxVO vo){
		boolean res=false;
		String sql="update  tbl_fwxx set qxid=?,jdid=?,lxid=?,shi=?,ting=?,fwxx=?,zj=?,title=?,telephone=?,lxr=? where fwid=? ";
		Connection conn=DBUtil.getConn();
		PreparedStatement pstmt=null;
		try {
			pstmt=conn.prepareStatement(sql);
			//pstmt.setInt(1, vo.getUid());
			pstmt.setInt(1, vo.getQxid());
			pstmt.setInt(2, vo.getJdid());
			pstmt.setInt(3, vo.getLxid());
			pstmt.setInt(4, vo.getShi());
			pstmt.setInt(5, vo.getTing());
			pstmt.setString(6, vo.getFwxx());
			pstmt.setFloat(7, vo.getZj());
			pstmt.setString(8, vo.getTitle());
			pstmt.setString(9,vo.getTelephone());
			pstmt.setString(10, vo.getLxr());
			pstmt.setInt(11, vo.getFwid());
			int count=pstmt.executeUpdate();
			System.out.println("count:"+count);
			if(count>0){
				
				res=true;
			}
			pstmt.close();
			conn.close();
			} catch (Exception e) {
			e.printStackTrace();
		}
		return res;
	}

}