spring 一个controller中需要不同dao方法查询数据库,hibernate session怎么关闭合

spring 一个controller中需要不同dao方法查询数据库,hibernate session怎么关闭合,第1张

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等相关内容解答,如果想了解更多相关内容,可以关注我们,你们的支持是我们更新的动力!

欢迎分享,转载请注明来源:内存溢出

原文地址: http://www.outofmemory.cn/sjk/9331045.html

(0)
打赏 微信扫一扫 微信扫一扫 支付宝扫一扫 支付宝扫一扫
上一篇 2023-04-27
下一篇 2023-04-27

发表评论

登录后才能评论

评论列表(0条)

保存