mybatis 实现接口式编程

淩亂°似流年 2023-06-18 05:58 48阅读 0赞

通过动态代理实现接口式编程，避免手写命名空间和mapper中的 id出错

![watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzM1Mjc1MjMz_size_16_color_FFFFFF_t_70][]

相关的代码实现如下，简单的代码片段

public class DBAccess {
    	public SqlSession getSqlSession() throws IOException {
    		// 通过配置文件获取数据库连接信息
    		Reader reader = Resources.getResourceAsReader("com/imooc/config/Configuration.xml");
    		// 通过配置信息构建一个SqlSessionFactory
    		SqlSessionFactory sqlSessionFactory = new SqlSessionFactoryBuilder().build(reader);
    		// 通过sqlSessionFactory打开一个数据库会话
    		SqlSession sqlSession = sqlSessionFactory.openSession();
    		return sqlSession;
    	}
    }

IMessage

/**
     * 与Message配置文件相对应的接口
     */
    public interface IMessage {
    	/**
    	 * 根据查询条件查询消息列表
    	 */
    	public List<Message> queryMessageList(Message message);
    }

IMessageDao

/**
    	 * 和message表相关的数据库操作
    	 */
    	public class MessageDao {
    		
    		/**
    		 * 根据查询条件查询消息列表
    		 */
    		public List<Message> queryMessageList(Message message) {
    			DBAccess dbAccess = new DBAccess();
    			List<Message> messageList = new ArrayList<Message>();
    			SqlSession sqlSession = null;
    			try {
    				sqlSession = dbAccess.getSqlSession();
    				// 通过sqlSession执行SQL语句
    				IMessage imessage = sqlSession.getMapper(IMessage.class);
    				messageList = imessage.queryMessageList(message);
    			} catch (Exception e) {
    				// TODO Auto-generated catch block
    				e.printStackTrace();
    			} finally {
    				if(sqlSession != null) {
    					sqlSession.close();
    				}
    			}
    			return messageList;
    		}
       }

其中getMapper内部通过代理工厂生成动态代理返回到接口中

\-----------------------------------------------以下为手写动态代理代码，模拟mybatis动态代理-------------------------------------------

步骤：

1、重新定义一个接口代替案例中改的IMessage接口

2、创建一个类实现InvocationHandler接口，在invoke方法中打印（接口全名称与方法名）

3、创建SqlSession类代替Mybatis中的SqlSession接口，在getMapper方法中创建代理实例并做强转

4、在main方法调用跑通整个过程

IMessage接口

package com.smiletimli.test;
    
    import java.util.List;
    
    public interface MyInterface {
    	public List<Object> query(Object parameter);
    }

MapperProxy

package com.smiletimli.test;
    
    import java.lang.reflect.InvocationHandler;
    import java.lang.reflect.Method;
    import java.util.ArrayList;
    import java.util.List;
    
    public class MapperProxy implements InvocationHandler{
    
    	@Override
    	public Object invoke(Object proxy, Method method, Object[] args)
    			throws Throwable {
    		System.out.println("");
    		System.out.println("================MapperProxy===============");
    		System.out.println("通过接口与method获取对应的配置文件中的信息：");
    		System.out.println("接口名称.方法名==namespace.id");
    		System.out.println("通过配置文件中的信息获取SQL语句的类型");
    		System.out.println("根据SQL语句类型调用sqlSession对应的增删改查方法");
    		System.out.println("当SQL语句类型是查询时");
    		System.out.println("根据返回值的类型是List、Map、Object");
    		System.out.println("分别调用selectList、selectMap、selectOne方法");
    		// 返回查询出的结果
    		List<Object> list = new ArrayList<Object>();
    		list.add("1");
    		list.add("2");
    		list.add("3");
    		System.out.println("================MapperProxy===============");
    		return list;
    	}
    
    }

SqlSession

package com.imooc.test;
    
    import java.lang.reflect.Proxy;
    
    public class SqlSession {
    	@SuppressWarnings("unchecked")
    	public <T> T getMapper(Class<T> type) {
    		System.out.println("通过接口的Class从代理工厂Map取出对应的代理工厂");
    		System.out.println("通过代理工厂实例化一个代理类");
    		System.out.println("用这个代理类生成一个代理实例返回出去");
    		return (T) Proxy.newProxyInstance(type.getClassLoader(), new Class[]{type}, new MapperProxy());
    	}
    }

main方法：

package com.imooc.test;
    
    import java.util.List;
    
    public class MyMain {
    	public static void main(String[] args) {
    		System.out.println("加载配置信息……");
    		System.out.println("通过加载配置信息加载一个代理工厂Map：");
    		System.out.println("这个Map存放的是接口Class与对应的代理工厂");
    		SqlSession sqlSession = new SqlSession();
    		MyInterface myInterface = sqlSession.getMapper(MyInterface.class);
    		List<Object> list = myInterface.query(new Object());
    		System.out.println(list.size());
    	}
    }

[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzM1Mjc1MjMz_size_16_color_FFFFFF_t_70]: https://img-blog.csdnimg.cn/20191130174429393.png?x-oss-process=image/watermark,type_ZmFuZ3poZW5naGVpdGk,shadow_10,text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzM1Mjc1MjMz,size_16,color_FFFFFF,t_70