Java连接数据库,及增删改查的示例
自定义连接数据库的util类
packagecom.shuzf.jdbc; importjava.sql.Connection; importjava.sql.DriverManager; importjava.sql.ResultSet; importjava.sql.SQLException; importjava.sql.Statement; publicclassJDBCUtil{ //定义驱动器类的路径 privatestaticfinalStringDRIVER="oracle.jdbc.driver.OracleDriver"; //定义用于连接数据库的URL privatestaticfinalStringURL="jdbc:oracle:thin****l"; //定义用于访问数据库的用户名及密码 privatestaticfinalStringUSERNAME="s****t"; privatestaticfinalStringPASSWORD="t***r"; //加载驱动器类 static{ try{ Class.forName(DRIVER); }catch(ClassNotFoundExceptione){ e.printStackTrace(); } } //定义获得连接的方法 publicstaticConnectiongetConnection(){ Connectionconn=null; ; try{ conn=DriverManager.getConnection(URL,USERNAME,PASSWORD); }catch(SQLExceptione){ e.printStackTrace(); } returnconn; } //定义释放数据库资源的方法 publicstaticvoiddestory(Connectioncon,Statementstat,ResultSetrs){ if(rs!=null){ try{ rs.close(); }catch(SQLExceptione){ e.printStackTrace(); } } if(stat!=null){ try{ stat.close(); }catch(SQLExceptione){ e.printStackTrace(); } } if(con!=null){ try{ con.close(); }catch(SQLExceptione){ e.printStackTrace(); } } } }
基本类
packagecom.shuzf.jdbc; publicclassStudent{ privateIntegerId; privateStringName; privateStringSex; privateintAge; publicStudent(){ super(); } publicStudent(Stringname,Stringsex,intage){ Id=null; Name=name; Sex=sex; Age=age; } publicIntegergetId(){ returnId; } publicvoidsetId(Integerid){ Id=id; } publicStringgetName(){ returnName; } publicvoidsetName(Stringname){ Name=name; } publicStringgetSex(){ returnSex; } publicvoidsetSex(Stringsex){ Sex=sex; } publicintgetAge(){ returnAge; } publicvoidsetAge(intage){ Age=age; } }
增删改查
packagecom.shuzf.jdbc; importjava.sql.Connection; importjava.sql.Date; importjava.sql.PreparedStatement; importjava.sql.ResultSet; importjava.sql.SQLException; importjava.util.ArrayList; publicclassJdbcTest{ publicintinsert(Studentstudent){ Connectionconn=JDBCUtil.getConnection(); inti=0; PreparedStatementpst=null; Stringsql="insertintostudents(Name,Sex,Age,Addtime)values(?,?,?,?)"; try{ pst=conn.prepareStatement(sql); pst.setString(1,student.getName()); pst.setString(2,student.getSex()); pst.setInt(3,student.getAge()); pst.setDate(4,newDate(newjava.util.Date().getTime())); i=pst.executeUpdate(); }catch(SQLExceptione){ e.printStackTrace(); }finally{ JDBCUtil.destory(conn,pst,null); } returni; } publicintupdate(Studentstudent){ Connectionconn=JDBCUtil.getConnection(); inti=0; PreparedStatementpst=null; Stringsql="updatestudentssetAge='"+student.getAge()+"'whereName='"+student.getName()+"'"; try{ pst=conn.prepareStatement(sql); i=pst.executeUpdate(); }catch(SQLExceptione){ e.printStackTrace(); }finally{ JDBCUtil.destory(conn,pst,null); } returni; } publicintdelete(Studentstudent){ Connectionconn=JDBCUtil.getConnection(); inti=0; PreparedStatementpst=null; Stringsql="deletefromstudentswhereName='"+student.getName()+"'"; try{ pst=conn.prepareStatement(sql); i=pst.executeUpdate(); }catch(SQLExceptione){ e.printStackTrace(); }finally{ JDBCUtil.destory(conn,pst,null); } returni; } publicArrayListgetStudent(Stringname){ Connectionconn=JDBCUtil.getConnection(); PreparedStatementpst=null; ResultSetrs=null; ArrayList students=newArrayList (); Stringsql="select*fromstudentswhereName='"+name+"'"; try{ pst=conn.prepareStatement(sql); rs=pst.executeQuery(); //intcount=rs.getMetaData().getColumnCount();//指示列数目的int值 while(rs.next()){ Students=newStudent(); s.setId(rs.getInt("id")); s.setName(rs.getString("name")); s.setSex(rs.getString("sex")); s.setAge(rs.getInt("age")); students.add(s); } }catch(SQLExceptione){ e.printStackTrace(); }finally{ JDBCUtil.destory(conn,pst,rs); } returnstudents; } publicstaticvoidmain(String[]args){ //TODOAuto-generatedmethodstub } }
以上就是Java连接数据库,及增删改查的示例的详细内容,更多关于Java操作数据库的资料请关注毛票票其它相关文章!