HibernateTemplate提供非常多的常用方法来完成基本的 *** 作,比如,添加删除、增加等spring20更增加对命名sql查询的支持,也增加对分页的支持。大部分情况下,使用Hibernate的常规用法,就可完成大多数DAO对象的CRUD *** 作。CRUD就是数据库基本 *** 作:CreateReadUpdateDeletehibernateTemplate的常用方法:Øvoiddelete(Objectentity):删除指定持久化实例ØdeleteAll(Collectionentities):删除集合内全部持久化类实例Øfind(StringqueryString):根据HQL查询字符串来返回实例集合ØfindByNamedQuery(StringqueryName):根据命名查询返回实例集合Øget(ClassentityClass,Serializableid):根据主键加载特定持久化类的实例Øsave(Objectentity):保存新的实例ØsaveOrUpdate(Objectentity):根据实例状态,选择保存或者更新Øupdate(Objectentity):更新实例的状态,要求entity是持久状态ØsetMaxResults(intmaxResults):设置分页的大小HibernateDaoSupport:Spring为Hibernate的DAO提供工具类:HibernateDaoASupport。该类主要提供如下两个方法,方便DAO的实现:1、publicfinalHibernateTemplategetHibernateTemplate()2、publicfinalvoidsetSessionFactory(SessionFactorysessionFactory)其中setSessionFactory方法用来接收Spring的ApplicationContext的依赖注入,可接收配置在Spring的SessionFactory实例,getHibernateTemplate方法则用来更具获得的SessionFactory产生Session,最后生成HibernateTeplate来完成数据库访问。看到这些的时候似乎好像明白了以些,HibernateDaoSupport此类其实并不做太多的事情,它只有两个方法一个是获得getHibernateTemplate()和setSessionFacotry()。就像我们在配置文件中配置的那个sessionFactory属性。而getHibernateTemplate()方法就是常用的save、delete等CRUD基本 *** 作。Spring的源码如下:publicabstractclassHibernateDaoSupportextendsDaoSupport{privateHibernateTemplatehibernateTemplate;publicfinalvoidsetSessionFactory(SessionFactorysessionFactory){thishibernateTemplate=createHibernateTemplate(sessionFactory);}protectedHibernateTemplatecreateHibernateTemplate(SessionFactorysessionFactory){returnnewHibernateTemplate(sessionFactory);}publicfinalSessionFactorygetSessionFactory(){return(thishibernateTemplate!=nullthishibernateTemplategetSessionFactory():null);}publicfinalvoidsetHibernateTemplate(HibernateTemplatehibernateTemplate){thishibernateTemplate=hibernateTemplate;}publicfinalHibernateTemplategetHibernateTemplate(){returnhibernateTemplate;}protectedfinalvoidcheckDaoConfig(){if(thishibernateTemplate==null){thrownewIllegalArgumentException("sessionFactoryorhibernateTemplateisrequired");}}protectedfinalSessiongetSession()throwsDataAccessResourceFailureException,IllegalStateException{returngetSession(thishibernateTemplateisAllowCreate());}protectedfinalSessiongetSession(booleanallowCreate)throwsDataAccessResourceFailureException,IllegalStateException{return(!allowCreateSessionFactoryUtilsgetSession(getSessionFactory(),false):SessionFactoryUtilsgetSession(getSessionFactory(),thishibernateTemplategetEntityInterceptor(),thishibernateTemplategetJdbcExceptionTranslator()));}protectedfinalDataAccessExceptionconvertHibernateAccessException(HibernateExceptionex){returnthishibernateTemplateconvertHibernateAccessException(ex);}protectedfinalvoidreleaseSession(Sessionsession){SessionFactoryUtilsreleaseSession(session,getSessionFactory());}Spring为Hibernate的DAO提供工具类:HibernateDaoASupport。该类主要提供如下两个方法,方便DAO的实现:1、publicfinalHibernateTemplategetHibernateTemplate()2、publicfinalvoidsetSessionFactory(SessionFactorysessionFactory)其中setSessionFactory方法用来接收Spring的ApplicationContext的依赖注入,可接收配置在Spring的SessionFactory实例,getHibernateTemplate方法则用来更具获得的SessionFactory产生Session,最后生成HibernateTeplate来完成数据库访问。HibernateTemplate用于持久层的访问,该模板无需打开session及关闭Session。它只要获得SessionFactory的引用,就可以打开Session,并在持久化访问结束后关闭Session,程序开发只需要完成持久曾逻辑,通用的CRUD *** 作由HibernateTemplate完成其实Spring+hibernate访问数据库有以下几种方法:1、注入SessionFactory在spring配置文件中,对Dao注入sessionFactory比较简单。如:这里的sessionFacotry注入不是给类的,而是给继承HibernateDaoSupport类的sessionFactory,在上面源码中可以看到。以前写SSH程序的时候就是用这个的,因为是不知道,这个好处就是我们不再需要关心关闭、是否连接成功等问题。主要是很方便。但是这个不好就是java只支持单继承,所以唯一的继承给了HibernateDaoSupport有点可惜。而且也没有必要这样做。2、注入HibernateTemplate这种方法本质上跟上面的sessionFacotry一样,只不过进行了一层包装,好处就是Dao中的类就不用再继承那个HibernateDaoSuport了,不过要先配置好HibernateTemplate:非常的方便,我现在就在用这个了。其实并没有改多少,就是曾经的sessionFactroy改成了hibernatemplate。3、注入jdbcTemplate这种方法适合那些不喜欢hibernate的save,delete等方法,喜欢自己写的N人吧。有时候jdbcTemplate查询的效率会很高。这可能是跟jdbc有关吧。配置如下:在类中set方法jdbctemplate方法就可以了,spring中的配置跟sessionFactory基本一样。总的感觉还是喜欢HibernateTemplate,原因就是好用,不需要写太多的sql语句,不需要类去继承,只要提供一个set方法,再注入一下很方便。应该还有很多的地方不同,欢迎大家讨论。
package comlvjjentity;
import javautilDate;
import javautilTimerTask;
public class WrongTimerTask extends TimerTask {
private Date start; //开始时间
public Date getStart() {
return start;
}
public void setStart(Date start) {
thisstart = start;
}
public void run() {
//调用Dao层
if (true) {//DAO层满足条件
thiscancel();
}
Date d = new Date();//当前时间
try {
long t = dgetTime()- startgetTime(); //当前时间减去开始时间
if(t==120000)//2分钟
thiscancel();//退出
} catch (Exception e) {
// TODO Auto-generated catch block
eprintStackTrace();
}
}
}
------------------------上面是定时器类
package comlvjjmain;
import javautilDate;
import javautilTimer;
import comlvjjentityWrongTimerTask;
public class Time {
/
@param args
/
public static void main(String[] args) {
try {
WrongTimerTask task = new WrongTimerTask();
Timer timer = new Timer("TestTimer");
tasksetStart(new Date());
timerscheduleAtFixedRate(task, 0, 1000);
} catch (Exception e) {
eprintStackTrace();
}
}
}
-----------------------上面是测试执行类
你只要把定时器类的调用DAO层方法和Dao层满足的条件改一下就可以了
dao包,database access object属于持久层db包,应该是database的缩写,估计是用来连数据库的factory包,就是字面意思,工厂包filter包,过滤器servlet包,这个就不用解释了吧vo包,value object的缩写,用于业务层之间数据传递的对象
package orgdao;
import javalangreflectInvocationTargetException;
import javalangreflectMethod;
import javasqlConnection;
import javasqlPreparedStatement;
import javasqlResultSet;
import javasqlResultSetMetaData;
import javasqlSQLException;
import javautilDate;
import orgdbcDBManageer;
import orgdbcDBUtil;
import orgvoCardInfo;
public class CardInfoDao {
public void testResultSetMetaData() {
String sql = "select from cardinfo";
Connection con = new DBUtil()getConnection();
PreparedStatement ps = null;
ResultSetMetaData rsmd = null;
ResultSet rs = null;
try {
ps = conprepareStatement(sql);
rs = psexecuteQuery();
rsmd = rsgetMetaData();
for (int i = 1; i < rsmdgetColumnCount(); i++) {
Systemoutprint(" 数据类型名:" + rsmdgetColumnClassName(i));
Systemoutprint(" 别名:" + rsmdgetColumnLabel(i));
Systemoutprint(" 列名:" + rsmdgetColumnName(i));
Systemoutprint(" 数据类型:" + rsmdgetColumnTypeName(i));
Systemoutprintln(" 数据类型:" + rsmdgetColumnType(i));
}
while (rsnext()) {
// 通过反射可以对VO对象(CardInfo)自动赋值
// for()
// CardInfo ci=new CardInfo();
// cisetId(rsgetInt(columnIndex))
/
CardInfo ca = new CardInfo(); Class cc = cagetClass();
/
/Class<> c = ClassforName("orgvoCardInfo");
CardInfo ca = (CardInfo) cnewInstance();
casetCardId(rsgetString("cardId"));
casetCustomerName(rsgetString("customerName"));
casetCurrentMoney(rsgetFloat("currentMoney"));
casetOpenDate(rsgetDate("openDate"));
Systemoutprintln(ca);//ok /
//加载一个CardInfo类
Class c = ClassforName("orgvoCardInfo");
Object o = cnewInstance(); //获得它的一个实例
//定义String类的对象数组
Class[] params = new Class[] { Stringclass};
//定义float类的对象数组
Class[] floatparams = new Class[] { floatclass};
//定义Date(util)类的对象数组
Class[] dateparams = new Class[] { Dateclass};
//获得setCardId方法
Method me = cgetMethod("setCardId", params);
//实例方法的参数
Object []ostr = new Object[]{rsgetString("cardId")};
//如果底层方法是静态的,那么可以忽略指定的 obj 参数。该参数可以为 null。
//如果底层方法所需的形参数为 0,则所提供的 args 数组长度可以为 0 或 null。
//o 调用方法的对象 ostr 方法调用的参数
meinvoke(o, ostr);
//获得setCustomerName方法
Method name = cgetMethod("setCustomerName", params);
Object []cusname = new Object[]{rsgetString("customerName")};
nameinvoke(o,cusname);
//获得setCurrentMoney方法
Method money = cgetMethod("setCurrentMoney", floatparams);
Object []cusmoney = new Object[]{rsgetFloat("currentMoney")};
moneyinvoke(o,cusmoney);
//获得setOpenDate方法
Method date = cgetMethod("setOpenDate",dateparams);
Object []openDate = new Object[]{rsgetDate("openDate")};
dateinvoke(o, openDate);
//打印
Systemoutprintln(o);
}
} catch (SQLException e) {
eprintStackTrace();
} catch (ClassNotFoundException e) {
eprintStackTrace();
} catch (InstantiationException e) {
eprintStackTrace();
} catch (IllegalAccessException e) {
eprintStackTrace();
} catch (SecurityException e) {
eprintStackTrace();
}catch (IllegalArgumentException e) {
eprintStackTrace();
} catch (NoSuchMethodException e) {
eprintStackTrace();
} catch (InvocationTargetException e) {
eprintStackTrace();
}
}
public void showResultSet() {
String sql = "select from cardinfo";
Connection con = new DBManageer()getConnection();
PreparedStatement ps = null;
try {
ps = conprepareStatement(sql, ResultSetTYPE_SCROLL_SENSITIVE,
ResultSetCONCUR_UPDATABLE);
ResultSet rs = psexecuteQuery();
Systemoutprintln("---依次读取------");
while (rsnext()) {
CardInfo ca = new CardInfo();
casetCardId(rsgetString("cardId"));
casetCustomerName(rsgetString("customerName"));
casetCurrentMoney(rsgetFloat("currentMoney"));
casetOpenDate(rsgetDate("openDate"));
Systemoutprintln(ca);
}
Systemoutprintln("---倒读------");
while (rsprevious()) {
CardInfo ca = new CardInfo();
casetCardId(rsgetString("cardId"));
casetCustomerName(rsgetString("customerName"));
casetCurrentMoney(rsgetFloat("currentMoney"));
casetOpenDate(rsgetDate("openDate"));
Systemoutprintln(ca);
}
rsabsolute(3);// 定位倒第几行
rsupdateString("customerName", "star");
// rsupdateRow();
rsbeforeFirst();
while (rsnext()) {
CardInfo ca = new CardInfo();
casetCardId(rsgetString("cardId"));
casetCustomerName(rsgetString("customerName"));
casetCurrentMoney(rsgetFloat("currentMoney"));
casetOpenDate(rsgetDate("openDate"));
Systemoutprintln(ca);
}
} catch (SQLException e) {
eprintStackTrace();
}
}
}
以上就是关于spring 一个controller中需要不同dao方法查询数据库,hibernate session怎么关闭合全部的内容,包括:spring 一个controller中需要不同dao方法查询数据库,hibernate session怎么关闭合、java Action里面每隔5秒去调用一个dao数据库查询类,当返回值满足条件或者时间到2分钟就停止调用、什么是DAO Database Access Object等相关内容解答,如果想了解更多相关内容,可以关注我们,你们的支持是我们更新的动力!
欢迎分享,转载请注明来源:内存溢出
评论列表(0条)