使用JDBC实现数据访问对象层(DAO)代码示例
JAVA是面向对象的语言,开发者在操作数据的时候,通常更习惯面对一个特定类型的对象,如一个用户就是一个User类的对象。DAO层需要做的,就是为上层提供充分的对象支持,让上层再也看不到具体的数据,而是一个个活生生的对象。
增加,删除,查询和修改操作是DAO需要做的最基本的4项操作。查询一般需要提供遍历查询和id查询,对于遍历查询,DAO需要提供User泛型的list对象,对于id查询则提供已经装配好数据的User对象,至于增加和修改操作,上层一般会提供一个User对象,DAO把User对象中的数据使用Insert语句插入到表格中。删除操作则只需提供一个id即可
classUser{ privatelongid; privateStringname; privateStringgender; publicUser(){ super(); } publicUser(longid,Stringname,Stringgender){ super(); this.id=id; this.name=name; this.gender=gender; } //get,set方法 } //DAO类 publicclassjdbcDao{ static{ try{ Class.forName("com.mysql.jdbc.Driver"); }catch(Exceptione){ e.printStackTrace(); } } privateConnectiongetConn(){ try{ returnDriverManager.getConnection("jdbc:mysql://localhost:3306:xe","root","password"); }catch(Exceptione){ e.printStackTrace(); } } returnnull; } privatevoidrelease(ResultSetrs,Statementps,Connectionconn){ if(rs!=null){ try{ rs.close(); }catch(Exceptione){ e.printStackTrace(); } } if(ps!=null){ try{ ps.close(); }catch(Exceptione){ e.printStackTrace(); } } if(conn!=null){ try{ conn.close(); }catch(Exceptione){ e.printStackTrace(); } } } //用ID获取用户对象 publicUsergetUserById(longid){ ResultSetrs=null; PreparedStatementps=null; Connectionconn=null; Stringsql="select*fromuserwhereid=?"; try{ conn=this.getConnection(); ps=conn.prepareStatement(sql); ps.setLong(1,id); rs=ps.executeQuery(); if(rs.next()){ //如果存在,则直接构建并返回用户对象 Useruser=newUser(rs.getLong("id"),rs.getString("name"),rs.getString("gender")); returnuser; } }catch(Exceptione){ e.printStackTrace(); }finally{ this.release(rs,ps,conn); } returnnull; } //查询所有用户 publicListgetAllUsers(){ List list=newArrayList (); ResultSetrs=null; PreparedStatementps=null; Connectionconn=null; Stringsql="select*fromuser"; try{ conn=this.getConnection(); ps=conn.prepareStatement(sql); rs=ps.executeQuery(); //循环添加用户对象 while(rs.next()){ Useruser=newUser(rs.getLong("id"),rs.getString("name"),rs.getString("gender")); list.add(user); } }catch(Exceptione){ e.printStackTrace(); }finally{ this.release(rs,ps,conn); } returnlist; } //修改用户数据 publicUserupdateUser(Useruser){ PreparedStatementps=null; Connectionconn=null; Stringsql="updateusersetid=?,name=?,gender=?"; try{ conn=this.getConnection(); conn.setAutoCommit(false); ps=conn.prepareStatement(sql); ps.setLong(1,user.getId()); ps.setString(2,user.getName()); ps.setString(3,user.getGender()); intrst=ps.executeUpdate(); if(rst>0){ returnnewUser(user.getId(),user.getName(),user.getGender()); } conn.commit(); }catch(Exceptione){ e.printStackTrace(); try{ conn.rollback(); }catch(Exceptione1){ e1.printStackTrace(); } }finally{ this.release(null,ps,conn); } returnnull; } } //删除用户数据 publicbooleandeleteUser(longid){ PreparedStatementps=null; Connectionconn=null; Stringsql="deletefromuserwhereid=?; try{ conn=this.getConnection(); conn.setAutoCommit(false); ps=conn.prepareStatement(sql); ps.setLong(1,user.getId()); ps.setString(2,user.getName()); ps.setString(3,user.getGender()); intrst=ps.executeUpdate(); if(rst>0){ returnuser; } conn.commit(); }catch(Exceptione){ e.printStackTrace(); try{ conn.rollback(); }catch(Exceptione1){ e1.printStackTrace(); } }finally{ this.release(null,ps,conn); } returnnull; } } //插入用户数据 publicUserinsertUser(Useruser){ PreparedStatementps=null; Connectionconn=null; Stringsql="insertintouservalues(?,?,?)"; try{ conn=this.getConnection(); conn.setAutoCommit(false); ps=conn.prepareStatement(sql); ps.setLong(1,user.getId()); ps.setString(2,user.getName()); ps.setString(3,user.getGender()); intrst=ps.executeUpdate(); if(rst>0){ returnuser; } conn.commit(); }catch(Exceptione){ e.printStackTrace(); try{ conn.rollback(); }catch(Exceptione1){ e1.printStackTrace(); } }finally{ this.release(null,ps,conn); } returnnull; } } } }
总结
以上就是本文关于使用JDBC实现数据访问对象层(DAO)代码示例的全部内容,希望对大家有所帮助。感兴趣的朋友可以继续参阅:JDBC常用接口总结、BaseJDBC和CRUDDAO的写法实例代码、JDBC中resutset接口操作实例详解等,如有不足之处,欢迎留言指出,小编会及时回复大家并改正。感谢朋友们对毛票票的支持!