ADD file via upload

RiderDaoImplmbz.java

@@ -0,0 +1,166 @@
+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;
+	}
+
+}