使用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(){
Listlist=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接口操作实例详解等,如有不足之处,欢迎留言指出,小编会及时回复大家并改正。感谢朋友们对毛票票的支持!