java JDBC-使用javabean来保存数据库记录

r囧r小猫 2021-07-24 21:56 284阅读 0赞

**javabean:**
    
    public class Emp { 
    	private Integer id;
    	private String empname;
    	private Integer age;
    	private double salary;
    	private Date birthday;
    	private Integer deptId;
    	
    	
    	public Integer getId() { 
    		return id;
    	}
    
    	public void setId(Integer id) { 
    		this.id = id;
    	}
    
    	public String getEmpname() { 
    		return empname;
    	}
    
    	public void setEmpname(String empname) { 
    		this.empname = empname;
    	}
    
    	public double getSalary() { 
    		return salary;
    	}
    
    	public void setSalary(double salary) { 
    		this.salary = salary;
    	}
    
    	public Date getBirthday() { 
    		return birthday;
    	}
    
    	public void setBirthday(Date birthday) { 
    		this.birthday = birthday;
    	}
    
    	public Integer getDeptId() { 
    		return deptId;
    	}
    
    	public void setDeptId(Integer deptId) { 
    		this.deptId = deptId;
    	}
    
    	public Integer getAge() { 
    		return age;
    	}
    
    	public void setAge(Integer age) { 
    		this.age = age;
    	}
    
    	
    	public Emp(String empname, Integer age, double salary, Date birthday, Integer deptId) { 
    		super();
    		this.empname = empname;
    		this.age = age;
    		this.salary = salary;
    		this.birthday = birthday;
    		this.deptId = deptId;
    	}
    
    	public Emp(Integer id, String empname, Integer age, double salary, Date birthday, Integer deptId) { 
    		super();
    		this.id = id;
    		this.empname = empname;
    		this.age = age;
    		this.salary = salary;
    		this.birthday = birthday;
    		this.deptId = deptId;
    	}
    
    	public Emp(String empname, Integer age, double salary) { 
    		super();
    		this.empname = empname;
    		this.age = age;
    		this.salary = salary;
    	}
    
    	public Emp()
    	{ 
    		
    	}
    	public static void main(String[] args) { 
    		
    	}
    }
    
    **客户端：**
    
    public class Demo14 { 
    
    	public static void main(String[] args) { 
    		Connection conn=jdbcutil.getMysqlConn();
    		PreparedStatement ps=null;
    		ResultSet rs=null;
    		List<Emp> list=new ArrayList<Emp>();
    		
    		try { 
    			ps = conn.prepareStatement("select empname,salary,age from emp where id=?");
    			ps.setInt(1, 1);
    			rs=ps.executeQuery();
    
    			while(rs.next())
    			{ 
    				Emp emp=new Emp(rs.getString(1),rs.getInt(3),rs.getDouble(2));
    				
    				list.add(emp);
    				
    			}
    			for(Emp e:list)
    			{ 
    				System.out.println(e.getEmpname()+"-"+e.getSalary()+"-"+e.getAge());
    			}
    			
    			
    		} catch (SQLException e) { 
    			e.printStackTrace();
    		}finally
    		{ 
    			jdbcutil.close(rs, ps, conn);
    		}
    	}
    }
    **工具类：**
    public class jdbcutil { 
    static Properties pros = null;   //可以帮助读取和处理资源文件中的信息
    	
    	static {    //加载JDBCUtil类的时候调用
    		pros = new Properties();
    		try { 
    			pros.load(Thread.currentThread().getContextClassLoader().getResourceAsStream("db.properties"));
    		} catch (IOException e) { 
    			e.printStackTrace();
    		}
    	}
    	
    	
    	public static Connection getMysqlConn(){ 
    		try { 
    			Class.forName(pros.getProperty("mysqlDriver"));
    			return DriverManager.getConnection(pros.getProperty("mysqlURL"),
    					pros.getProperty("mysqlUser"),pros.getProperty("mysqlPwd"));
    		} catch (Exception e) { 
    			e.printStackTrace();
    			return null;
    		}
    	}
    	
    	
    	public static void close(ResultSet rs,Statement ps,Connection conn){ 
    		try { 
    			if(rs!=null){ 
    				rs.close();
    			}
    		} catch (SQLException e) { 
    			e.printStackTrace();
    		}
    		try { 
    			if(ps!=null){ 
    				ps.close();
    			}
    		} catch (SQLException e) { 
    			e.printStackTrace();
    		}
    		try { 
    			if(conn!=null){ 
    				conn.close();
    			}
    		} catch (SQLException e) { 
    			e.printStackTrace();
    		}
    	}
    	
    	public static void close(Statement ps,Connection conn){ 
    		try { 
    			if(ps!=null){ 
    				ps.close();
    			}
    		} catch (SQLException e) { 
    			e.printStackTrace();
    		}
    		try { 
    			if(conn!=null){ 
    				conn.close();
    			}
    		} catch (SQLException e) { 
    			e.printStackTrace();
    		}
    	}
    	public static void close(Connection conn){ 
    		try { 
    			if(conn!=null){ 
    				conn.close();
    			}
    		} catch (SQLException e) { 
    			e.printStackTrace();
    		}
    	}
    }