package dao.impl;

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

import dao.RiderDAOmbz;

import domain.Ridermbz;

public class RiderDaoImplmbz implements RiderDAOmbz{

	@Override
	public ArrayList<Ridermbz> findAll() {
		String sql="select * from rider";
		ArrayList<Ridermbz> rider=new ArrayList<Ridermbz>();
		try {
			
			Connection conn=JDBCUtil.getConnection();
			PreparedStatement pstm = conn.prepareStatement(sql);
			ResultSet rs=pstm.executeQuery();
			while(rs.next()){
				Ridermbz ri=new Ridermbz();
				ri.setUserid(rs.getString("userid"));
				ri.setPassword(rs.getString("password"));
				ri.setName(rs.getString("name"));
				ri.setPhone(rs.getString("phone"));
				rider.add(ri);
			}			
		} catch (Exception e) {
			// TODO 自动生成的 catch 块
			e.printStackTrace();
		}
		
		// TODO 自动生成的方法存根
		return rider;
	}


	@Override
	public Ridermbz findById(String userid) {
		Connection conn =null;
		PreparedStatement pstm =null;
		ResultSet rs=null;
		Ridermbz ri=null;
		try {
			conn=JDBCUtil.getConnection();
			String sql="select * from rider where userid=?";
			pstm = conn.prepareStatement(sql);
			pstm.setString(1, userid);
			rs=pstm.executeQuery();
			
			if(rs.next()){
				ri=new Ridermbz();
				ri.setUserid(rs.getString("userid"));
				ri.setPassword(rs.getString("password"));
				ri.setName(rs.getString("name"));
				ri.setPhone(rs.getString("phone"));
				return ri;
			}
		} catch (Exception e) {
			// TODO 自动生成的 catch 块
			e.printStackTrace();
		}finally {
			if(rs!=null) {
				try {
					rs.close();
				} catch (SQLException e) {
				}
		}
		if(pstm!=null) {
			try {
				rs.close();
			} catch (SQLException e) {
			}
	}
		if(pstm!=null) {
			try {
				rs.close();
			} catch (SQLException e) {
			}
	}
}
		return null;
	}
	

	@Override
	public int modify(Ridermbz rider) {
		String sql="update rider set password = ? where userid=?";
		try {
			
			Connection conn=JDBCUtil.getConnection();
			
			PreparedStatement pstm = conn.prepareStatement(sql);
			
				pstm.setString(1, rider.getUserid());
				pstm.setString(2, rider.getPassword());
				pstm.setString(3, rider.getName());
				pstm.setString(4, rider.getPhone());
				
				
				int affectedRows = pstm.executeUpdate();
				System.out.printf("成功更新%d条数据。\n",affectedRows);
					
		} catch (Exception e) {
			e.printStackTrace();
		}
		return 0;
	}	

	@Override
	public int delete(Ridermbz rider) {
		String sql="delect from rider where?";
		try {
			
			Connection conn=JDBCUtil.getConnection();
			PreparedStatement pstm = conn.prepareStatement(sql);
			pstm.setString(1, rider.getUserid());
			pstm.setString(2, rider.getPassword());
			pstm.setString(3, rider.getName());
			pstm.setString(4, rider.getPhone());
			
			
			int affectedRows = pstm.executeUpdate();
			System.out.printf("成功删除%d条数据。\n",affectedRows);
				

		} catch (Exception e) {
			// TODO 自动生成的 catch 块
			e.printStackTrace();
		}
		// TODO 自动生成的方法存根
		return 0;
	}
	

	@Override
	public int insert(Ridermbz rider) {
try {
			
			Connection conn=JDBCUtil.getConnection();
			String sql="insert into rider values(?,?,?,?)";
			PreparedStatement pstm = conn.prepareStatement(sql);
			
			pstm.setString(1, rider.getUserid());
			pstm.setString(2, rider.getPassword());
	
			pstm.setString(3, rider.getName());
			
			pstm.setString(4, rider.getPhone());
			
			int affectedRows = pstm.executeUpdate();
			System.out.printf("成功插入%d条数据。\n",affectedRows);
				
		} catch (Exception e) {
			
			return -1;
		}
			// TODO 自动生成的方法存根
			return 0;
	}

}