daowork.java

通讯录 可以增 删 改 直接从数据库中读取信息 也可以手动添加

package roomserver;
import java.sql.Connection;
import java.sql.PreparedStatement;
import java.sql.ResultSet;
import java.sql.SQLException;
import java.util.ArrayList;
import java.util.Vector;
public class DAOWork {
	DBConnecton conn=new DBConnecton();
	private int infocount=0;
	private int pageinfo=3;
	private int maxpage=0;
	private int dangqpage=1;
	private int temp=1;
	ArrayList alist=new ArrayList();
	public ArrayList showAll(int userid,int currentpage){
		Connection conner=conn.getConn();
		String sql="select * from addresss where uid=?";
		try {
			PreparedStatement pse=conner.prepareStatement(sql, ResultSet.TYPE_SCROLL_INSENSITIVE,ResultSet.CONCUR_UPDATABLE);
			pse.setInt(1, userid);
			ResultSet rs=pse.executeQuery();
			rs.last();
			infocount=rs.getRow();
			if(infocount%pageinfo==0){
				this.maxpage=infocount/pageinfo;
			}else{
				this.maxpage=infocount/pageinfo+1;
				
			}
			rs.beforeFirst();
			for(int i=0;i<(currentpage-temp)*pageinfo;i++){
				rs.next();
			}
			this.dangqpage=currentpage;
			for(int j=0;j<pageinfo;j++){
				if(!rs.next()){
					break;
				}else{
					LianxirenInfo infobeann=new LianxirenInfo();
					infobeann.setAddresssid(rs.getInt(1));
					infobeann.setUid(rs.getInt(2));
					infobeann.setAddresssname(rs.getString(3));
					infobeann.setAddresssage(rs.getInt(4));
					infobeann.setAddresssdizhi(rs.getString(5));
					infobeann.setAddresssdianhua(rs.getString(6));
					alist.add(infobeann);
				}
			}
		} catch (Exception e) {
			e.printStackTrace();
		}
		return alist;
	}
	public int addlinkman(LianxirenInfo addinfobean){
		int backvalue=0;
		Connection conner=conn.getConn();
		String sql="insert into addresss (uid,addressname,addressage,addressdizhi,addresstelephone) values(?,?,?,?,?)";
		try {
			PreparedStatement pse=conner.prepareStatement(sql);
			pse.setInt(1, addinfobean.getUid());
			pse.setString(2, addinfobean.getAddresssname());
			pse.setInt(3, addinfobean.getAddresssage());
			pse.setString(4, addinfobean.getAddresssdizhi());
			pse.setString(5, addinfobean.getAddresssdianhua());
			backvalue=pse.executeUpdate();
			
		} catch (SQLException e) {
			e.printStackTrace();
		}
		return backvalue;
	}
	public int deleteLinkman(int linkmanid){
			String sql="delete from addresss where addressid=?";
			int bcak=0;
			Connection conner=conn.getConn();
			try {
				PreparedStatement pse=conner.prepareStatement(sql);
				pse.setInt(1, linkmanid);
				 bcak=pse.executeUpdate();
			} catch (SQLException e) {
				e.printStackTrace();
			}
		return bcak;
	}
	public Vector selectliknman(int selectaddressid,String addressdname,int uid){
		Connection conner=conn.getConn();
		Vector vet=new  Vector();
		String sql;
		if(selectaddressid==1){
			sql="select * from addresss where addressname=? and uid=?";
		}else{
			sql="select * from addresss where addressid=? and uid=?";
		}
			try {
				PreparedStatement pse=conner.prepareStatement(sql);
				if(selectaddressid==1){
					pse.setString(1, addressdname);
				}else{
					pse.setInt(1, selectaddressid);
				}
				pse.setInt(2, uid);
				ResultSet rs=pse.executeQuery();
				while(rs.next()){
					LianxirenInfo backinfo=new LianxirenInfo();
					backinfo.setAddresssid(rs.getInt(1));
					backinfo.setAddresssname(rs.getString(3));
					backinfo.setAddresssage(rs.getInt(4));
					backinfo.setAddresssdizhi(rs.getString(5));
					backinfo.setAddresssdianhua(rs.getString(6));
					vet.add(backinfo);
				}
			} catch (SQLException e) {
				e.printStackTrace();
			}
		return vet;
	}
	public LianxirenInfo Idselect(int Id){
		Connection conner=conn.getConn();
		LianxirenInfo info=new LianxirenInfo();
		String sql="select * from addresss where addressid=?";
		try {
			PreparedStatement pse=conner.prepareStatement(sql);
			pse.setInt(1, Id);
			ResultSet rs=pse.executeQuery();
			while(rs.next()){
				info.setAddresssid(rs.getInt(1));
				info.setAddresssname(rs.getString(3));
				info.setAddresssage(rs.getInt(4));
				info.setAddresssdizhi(rs.getString(5));
				info.setAddresssdianhua(rs.getString(6));
			}
		} catch (SQLException e) {
			e.printStackTrace();
		}
		return info;
	}
	public void upDate(LianxirenInfo infobean){
		Connection conner=conn.getConn();
		String sql="update addresss set uid=?,addressname=?,addressage=?,addressdizhi=?,addresstelephone=? where addressid=?";
		try {
			PreparedStatement pser=conner.prepareStatement(sql);
			pser.setInt(1, infobean.getUid());
			pser.setString(2, infobean.getAddresssname());
			pser.setInt(3, infobean.getAddresssage());
			pser.setString(4, infobean.getAddresssdizhi());
			pser.setString(5, infobean.getAddresssdianhua());
			pser.setInt(6, infobean.getAddresssid());
			pser.executeUpdate();
		} catch (SQLException e) {
			e.printStackTrace();
		}
	}
	public int getDangqpage() {
		return dangqpage;
	}
	public void setDangqpage(int dangqpage) {
		this.dangqpage = dangqpage;
	}
	public int getInfocount() {
		return infocount;
	}
	public void setInfocount(int infocount) {
		this.infocount = infocount;
	}
	public int getMaxpage() {
		return maxpage;
	}
	public void setMaxpage(int maxpage) {
		this.maxpage = maxpage;
	}
	public int getPageinfo() {
		return pageinfo;
	}
	public void setPageinfo(int pageinfo) {
		this.pageinfo = pageinfo;
	}
	public int getTemp() {
		return temp;
	}
	public void setTemp(int temp) {
		this.temp = temp;
	}
}