javajdbc标准模板.docx
《javajdbc标准模板.docx》由会员分享，可在线阅读，更多相关《javajdbc标准模板.docx（12页珍藏版）》请在冰点文库上搜索。
javajdbc标准模板
packagecn.edu.imut.ies.dao;
importjava.util.List;
publicinterfaceBaseDao{
intinsert（Tobj）;
intupdate（Tobj）;
intdelete（intid）;
TqueryObject（intid）;
ListqueryAll（）;
intqueryCount（）;
ListqueryPage（intoffset,intsize）;
intquerySearchCount（Stringsearch）;
ListquerySearch（Stringsearch,intoffset,intsize）;
}
packagecn.edu.imut.ies.dao;
importcn.edu.imut.ies.pojo.User;
publicinterfaceUserDaoextendsBaseDao{
}
packagecn.edu.imut.ies.dao.factory;
importcn.edu.imut.ies.dao.UserDao;
importcn.edu.imut.ies.dao.impl.UserDaoImpl;
publicclassDaoFactory{
publicstaticUserDaogeUserDao（）{
returnnewUserDaoImpl（）;
}
}
packagecn.edu.imut.ies.dao.impl;
importjava.sql.Connection;
importjava.sql.PreparedStatement;
importjava.sql.ResultSet;
importjava.sql.SQLException;
importjava.util.ArrayList;
importjava.util.List;
importcn.edu.imut.ies.dao.UserDao;
importcn.edu.imut.ies.db.DBUtils;
importcn.edu.imut.ies.pojo.User;
publicclassUserDaoImplimplementsUserDao{
@Override
publicintinsert（Userobj）{
//TODOAuto-generatedmethodstub
intflag=0;
Stringsql="insertintousers（id,username,password）values（users_seq.nextval,?
?
）";
//?
占位符
Connectionconnection=DBUtils.getConnection（）;
PreparedStatementpsmt=null;
try{
psmt=connection.prepareStatement（sql）;
psmt.setString（1,obj.getUserName（））;
psmt.setString（2,obj.getPassword（））;
flag=psmt.executeUpdate（）;
}catch（SQLExceptione1）{
//TODOAuto-generatedcatchblock
e1.printStackTrace（）;
}
try{
psmt.close（）;
connection.close（）;
}catch（SQLExceptione）{
//TODOAuto-generatedcatchblock
e.printStackTrace（）;
}
returnflag;
}
@Override
publicintupdate（Userobj）{
//TODOAuto-generatedmethodstub
intflag=0;
Stringsql="updateuserssetusername=?
password=?
whereid=?
";
//?
占位符
Connectionconnection=DBUtils.getConnection（）;
PreparedStatementpsmt=null;
try{
psmt=connection.prepareStatement（sql）;
psmt.setString（1,obj.getUserName（））;
psmt.setString（2,obj.getPassword（））;
psmt.setInt（3,obj.getId（））;
flag=psmt.executeUpdate（）;
}catch（SQLExceptione1）{
//TODOAuto-generatedcatchblock
e1.printStackTrace（）;
}
try{
psmt.close（）;
connection.close（）;
}catch（SQLExceptione）{
//TODOAuto-generatedcatchblock
e.printStackTrace（）;
}
returnflag;
}
@Override
publicintdelete（intid）{
//TODOAuto-generatedmethodstub
intflag=0;
Stringsql="deletefromuserswhereid=?
";
//?
占位符
Connectionconnection=DBUtils.getConnection（）;
PreparedStatementpsmt=null;
try{
psmt=connection.prepareStatement（sql）;
psmt.setInt（1,id）;
flag=psmt.executeUpdate（）;
}catch（SQLExceptione1）{
//TODOAuto-generatedcatchblock
e1.printStackTrace（）;
}
try{
psmt.close（）;
connection.close（）;
}catch（SQLExceptione）{
//TODOAuto-generatedcatchblock
e.printStackTrace（）;
}
returnflag;
}
@Override
publicUserqueryObject（intid）{
//TODOAuto-generatedmethodstub
Stringsql="select*fromuserswhereid=?
";
Listlist=newArrayList（）;
Connectionconnection=DBUtils.getConnection（）;
PreparedStatementps=null;
ResultSetrs=null;
Useruser=null;
try{
ps=connection.prepareStatement（sql）;
ps.setInt（1,id）;
rs=ps.executeQuery（）;
while（rs.next（））{
user=newUser（rs.getString（"username"）,rs.getString（"password"）,rs.getInt（"id"））;
}
}catch（SQLExceptione）{
//TODOAuto-generatedcatchblock
e.printStackTrace（）;
}
try{
rs.close（）;
connection.close（）;
ps.close（）;
}catch（Exceptione）{
//TODO:
handleexception
}
returnuser;
}
@Override
publicListqueryAll（）{
//TODOAuto-generatedmethodstub
Stringsql="select*fromusers";
Listlist=newArrayList（）;
Connectionconnection=DBUtils.getConnection（）;
PreparedStatementps=null;
ResultSetrs=null;
try{
ps=connection.prepareStatement（sql）;
rs=ps.executeQuery（）;
while（rs.next（））{
list.add（newUser（rs.getString（"username"）,rs.getString（"password"）,rs.getInt（"id"）））;
}
}catch（SQLExceptione）{
//TODOAuto-generatedcatchblock
e.printStackTrace（）;
}
try{
rs.close（）;
connection.close（）;
ps.close（）;
}catch（Exceptione）{
//TODO:
handleexception
}
returnlist;
}
@Override
publicintqueryCount（）{
//TODOAuto-generatedmethodstub
Stringsql="selectcount（*）asnumfromusers";
intcount=0;
Connectionconnection=DBUtils.getConnection（）;
PreparedStatementps=null;
ResultSetrs=null;
try{
ps=connection.prepareStatement（sql）;
rs=ps.executeQuery（）;
while（rs.next（））{
count=rs.getInt（"num"）;
}
}catch（SQLExceptione）{
//TODOAuto-generatedcatchblock
e.printStackTrace（）;
}
try{
rs.close（）;
connection.close（）;
ps.close（）;
}catch（Exceptione）{
//TODO:
handleexception
}
returncount;
}
@Override
publicListqueryPage（intoffset,intsize）{
//TODOAuto-generatedmethodstub
returnnull;
}
@Override
publicintquerySearchCount（Stringsearch）{
//TODOAuto-generatedmethodstub
return0;
}
@Override
publicListquerySearch（Stringsearch,intoffset,intsize）{
//TODOAuto-generatedmethodstub
returnnull;
}
}
packagecn.edu.imut.ies.db;
importjava.sql.Connection;
importjava.sql.DriverManager;
importjava.sql.SQLException;
publicclassDBUtils{
static{
try{
Class.forName（"oracle.jdbc.driver.OracleDriver"）;
/**
*查看DBUtils类有没有装载。
没有太多实际意义
*/
}catch（ClassNotFoundExceptione）{
e.printStackTrace（）;
}
}
publicstaticConnectiongetConnection（）{
try{
returnDriverManager.getConnection（"jdbc:
oracle:
thin:
@localhost:
1521:
orcl","cstd","cstd"）;
}catch（SQLExceptione）{
e.printStackTrace（）;
returnnull;
}
}
}
packagecn.edu.imut.ies.pojo;
importjava.io.Serializable;
publicclassUserimplementsSerializable{
privateStringuserName;
privateStringpassword;
privateintid;
publicStringgetUserName（）{
returnuserName;
}
publicvoidsetUserName（StringuserName）{
this.userName=userName;
}
publicStringgetPassword（）{
returnpassword;
}
publicvoidsetPassword（Stringpassword）{
this.password=password;
}
publicintgetId（）{
returnid;
}
publicvoidsetId（intid）{
this.id=id;
}
publicUser（）{
super（）;
//TODOAuto-generatedconstructorstub
}
@Override
publicStringtoString（）{
return"User[userName="+userName+",password="+password+",id="+id+"]";
}
publicUser（StringuserName,Stringpassword,intid）{
super（）;
this.userName=userName;
this.password=password;
this.id=id;
}
}
packagecn.edu.imut.ies.test;
importcn.edu.imut.ies.dao.factory.DaoFactory;
importcn.edu.imut.ies.pojo.User;
publicclasstest{
publicstaticvoidmain（String[]args）{
Userobj=newUser（）;
obj.setPassword（"password"）;
obj.setUserName（"userName"）;
intflag=DaoFactory.geUserDao（）.insert（obj）;
System.out.println（flag）;
System.out.println（"---------------------"）;
DaoFactory.geUserDao（）.queryAll（）.forEach（x->System.out.println（x））;
System.out.println（"---------------------"）;
DaoFactory.geUserDao（）.delete（3）;
DaoFactory.geUserDao（）.queryAll（）.forEach（x->System.out.println（x））;
System.out.println（"--------------------"）;
Userup=newUser（）;
up.setPassword（"password-6"）;
up.setUserName（"userName-6"）;
up.setId（6）;
inti=DaoFactory.geUserDao（）.update（up）;
System.out.println（i）;
DaoFactory.geUserDao（）.queryAll（）.forEach（x->System.out.println（x））;
System.out.println（"--------------------"）;
System.out.println（DaoFactory.geUserDao（）.queryObject（6））;
System.out.println（DaoFactory.geUserDao（）.queryCount（））;
}
}
升级会员 