package dao.impl;

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

import dao.ZhuhuDao;
import entity.Zhuhu;

public class ZhuhuImpl implements ZhuhuDao{

	public Zhuhu findById(String id) {
		Zhuhu acyc=new Zhuhu();
		try {
			
		    Connection conn = JDBCUtil.getConnection();
		    String sql = "select*from zhuhu where id = ?";
		    PreparedStatement prestm=conn.prepareStatement(sql);
		    prestm.setInt(1, Integer.valueOf(id));
		    ResultSet rs=prestm.executeQuery();
		    
		    	while(rs.next()) {
		    		Zhuhu zhushu=new Zhuhu();
					zhushu.setId(rs.getInt("id"));
					zhushu.setDizhidxy(rs.getString("dizhidxy"));
					zhushu.setHuzhudxy(rs.getString("huzhudxy"));
					zhushu.setLianxidianhuadxy(rs.getString("lianxidianhuadxy"));
					acyc=zhushu;
		    	}
				rs.close();
				prestm.close();
				conn.close();
			}
			catch(Exception e) {
				e.printStackTrace();
			}
			return acyc;
	}


	@Override
	public List<Zhuhu> findAll() {
		ArrayList<Zhuhu> zhushus=new ArrayList<Zhuhu>();
		try {
			Connection conn = JDBCUtil.getConnection();
			
			String sqlyc ="select *from zhuhu";
			Statement stsyc =conn.createStatement();
			ResultSet rsyc=stsyc.executeQuery(sqlyc);
			
			while(rsyc.next()) {
				Zhuhu zhushu=new Zhuhu();
				zhushu.setId(rsyc.getInt("id"));
				zhushu.setDizhidxy(rsyc.getString("dizhidxy"));
				zhushu.setHuzhudxy(rsyc.getString("huzhudxy"));
				zhushu.setLianxidianhuadxy(rsyc.getString("lianxidianhuadxy"));
				zhushus.add(zhushu);
			}
			rsyc.close();
			stsyc.close();
			conn.close();
		}
		catch(Exception e) {
			e.printStackTrace();
		}
		return zhushus;
	}


	@Override
	public int modify(Zhuhu zhuhu) {
		try {
			Connection conn = JDBCUtil.getConnection();
			
			String sqlyc ="update zhuhu set huzhudxy=?,dizhidxy=?,lianxidianhuadxy=? where id=?";
			PreparedStatement prestmyc=conn.prepareStatement(sqlyc);
			prestmyc.setString(1,zhuhu.getHuzhudxy());
			prestmyc.setString(2,zhuhu.getDizhidxy());
			prestmyc.setString(3,zhuhu.getLianxidianhuadxy());
			prestmyc.setInt(4,zhuhu.getId());
			prestmyc.executeUpdate();
			prestmyc.close();
			conn.close();
		}
		catch(Exception e) {
			e.printStackTrace();
		}
		return 0;
	}


	@Override
	public int create(Zhuhu zhuhu) {
		try {
			Connection conn = JDBCUtil.getConnection();
			String sqlyc ="Insert into zhuhu (huzhudxy,dizhidxy,lianxidianhuadxy) values(?,?,?)";
			PreparedStatement prestmyc=conn.prepareStatement(sqlyc);
			prestmyc.setString(1,zhuhu.getHuzhudxy());
			prestmyc.setString(2,zhuhu.getDizhidxy());
			prestmyc.setString(3,zhuhu.getLianxidianhuadxy());
			prestmyc.executeUpdate();
			prestmyc.close();
			conn.close();
		}
		catch(Exception e) {
			e.printStackTrace();
		}
		return 0;
	}


	@Override
	public int remove(Zhuhu zhuhu) {
		int flagyc=0;
		try {
			Connection conn = JDBCUtil.getConnection();
			String sqlyc ="delete from zhuhu where id=?";
			PreparedStatement prestmyc=conn.prepareStatement(sqlyc);
			prestmyc.setInt(1, zhuhu.getId());
			flagyc = prestmyc.executeUpdate();
			prestmyc.close();
			conn.close();
		}
		catch(Exception e) {
			e.printStackTrace();
		}
		return flagyc;
	}


}