目录
beanfactory实现service与dao层解耦合
在实际网站开发过程中,在service会new一个dao从而调用该dao中的方法,如下代码,但是一旦更换数据库需要改变dao的指向,此时就需要重新部署新的项目
userdao userdao=new userdaoimpl();
在本文中使用beanfactory的方式,在xml中配置dao的指向,一旦发生变化,无需重新部署,只需要改变xml中的配置即可,代码如下:
userdao userdao=(userdao)beanfactory.createobject("userdao");
全部实现代码如下,请重点关注解耦思想,即关注beanfactory中的实现
整体的实现思路是
userserviceimp调用beanfactory中的createobject("userdao")方法----》在beanfactory中解析xml文件,获取xml中id与userdao相同的节点,并获取该节点上的class文件----》利用反射机制创建对象并返回。
userserviceimp.java
package cn.itcast.store.service.serviceimp; import java.sql.sqlexception; import cn.itcast.store.dao.userdao; import cn.itcast.store.dao.daoimp.userdaoimp; import cn.itcast.store.domain.user; import cn.itcast.store.service.userservice; import cn.itcast.store.utils.beanfactory; public class userserviceimp implements userservice { userdao userdao=(userdao)beanfactory.createobject("userdao"); @override public void userregist(user user) throws sqlexception { //实现注册功能 userdao.userregist(user); } @override public boolean useractive(string code) throws sqlexception { //实现注册功能 ///对db发送select * from user where code=? user user=userdao.useractive(code); if(null!=user){ //可以根据激活码查询到一个用户 //修改用户的状态,清除激活码 user.setstate(1); user.setcode(null); //对数据库执行一次真实的更新操作 update user set state=1 , code=null where uid=? //update user set username=? , password=? ,name =? ,email=?, telephone =? ,birthday =? ,sex=? ,state=? ,code= ? where uid=? userdao.updateuser(user); return true; }else{ //不可以根据激活码查询到一个用户 return false; } } @override public user userlogin(user user) throws sqlexception { //此处:可以利用异常在模块之间传递数据 //select * from user where username=? and password=? user uu=userdao.userlogin(user); if(null==uu){ throw new runtimeexception("密码有误!"); }else if(uu.getstate()==0){ throw new runtimeexception("用户未激活!"); }else{ return uu; } } }
beanfactory.java
package cn.itcast.store.utils; import java.io.inputstream; import java.sql.sqlexception; import java.util.list; import org.dom4j.document; import org.dom4j.element; import org.dom4j.io.saxreader; import cn.itcast.store.dao.userdao; import cn.itcast.store.domain.user; public class beanfactory { //解析xml public static object createobject(string name) { try { //通过传递过来的name获取application.xml中name对应的class值 //获取到document对象 saxreader reader=new saxreader(); //如果获取application.xml文件的输入流 (application.xml必须位于src下) inputstream is=beanfactory.class.getclassloader().getresourceasstream("application.xml"); document doc=reader.read(is); //通过document对象获取根节点 beans element rootelement = doc.getrootelement(); //通过根节点获取到根节点下所有的子节点 bean,返回集合 list<element> list = rootelement.elements(); //遍历集合,判断每个元素上的id的值是否和当前的name一致 for (element ele : list) { //ele相当于beans节点下的每个bean //获取到当前节点的id属性值 //如果一致,获取到当前元素上class属性值 string id=ele.attributevalue("id"); if(id.equals(name)){ string str=ele.attributevalue("class"); //通过反射创建对象并且返回 class clazz=class.forname(str); //利用class值通过反射创建对象返回 return clazz.newinstance(); } } } catch (exception e) { e.printstacktrace(); } return null; } public static void main(string[] args) throws sqlexception { userdao ud=(userdao)beanfactory.createobject("userdao"); user user=new user(); user.setusername("aaa"); user.setpassword("aaa"); user uu = ud.userlogin(user); system.out.println(uu); } }
application.xml
<?xml version="1.0" encoding="utf-8"?> <beans> <bean id="categorydao" class="cn.itcast.store.dao.daoimp.categorydaoimp"/> <bean id="userdao" class="cn.itcast.store.dao.daoimp.userdaoimp"/> <bean id="productdao" class="cn.itcast.store.dao.daoimp.productdaoimp"/> </beans>
dao层实现类creatfactory.java
public class creatfactory { //单例模式 private static sqlsessionfactory factory=null; public static sqlsessionfactory creatfactory(){ if(factory==null){ //加载配置文件 string resource = "mybatis/config.xml";//配置文件地址 //读取文件resource,变成字符流 reader reader; try { reader = resources.getresourceasreader(resource); //将字符流,相当于connection factory= new sqlsessionfactorybuilder().build(reader); } catch (ioexception e) { e.printstacktrace(); } } return factory; } }
以上为个人经验,希望能给大家一个参考,也希望大家多多支持。