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;
ArrayListstudents=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操作数据库的资料请关注毛票票其它相关文章！