Chinaunix首页 | 论坛 | 博客
  • 博客访问: 181640
  • 博文数量: 153
  • 博客积分: 0
  • 博客等级: 民兵
  • 技术积分: 1610
  • 用 户 组: 普通用户
  • 注册时间: 2019-06-17 10:57
文章分类

全部博文(153)

文章存档

2021年(152)

2019年(1)

我的朋友

分类: Java

2021-07-29 11:42:05

有很多的接口都只是执行个SQL查询之后就直接返回给前端,那么我们能不能把这些SQL保存在数据库中,调用一个固定的接口就能根据传参查询出想要的数据呢?或者当为了加减个字段就得修改代码重启服务的痛苦能不能减少点呢?下面就是方案。

调用直接传入SQL语句(可以选择存数据库)和参数,SQL语句写法和在XML内的写法保持一致即可,包括Mybatis标签等等,参数选择使用通用的Map,可以从接口接收任何参数,方法的返回值是List

点击(此处)折叠或打开

  1. <dependency>
  2.    <groupId>org.ow2.asm</groupId>
  3.    <artifactId>asm</artifactId>
  4.    <version>7.0</version>
  5. </dependency>

点击(此处)折叠或打开

  1. import lombok.extern.slf4j.Slf4j;
  2. import org.apache.ibatis.builder.xml.XMLMapperBuilder;
  3. import org.apache.ibatis.executor.ErrorContext;
  4. import org.apache.ibatis.session.Configuration;
  5. import org.apache.ibatis.session.SqlSession;
  6. import org.apache.ibatis.session.SqlSessionFactory;
  7. import org.apache.ibatis.session.defaults.DefaultSqlSessionFactory;
  8. import org.springframework.beans.factory.annotation.Autowired;
  9. import org.springframework.stereotype.Component;
  10.  
  11. import java.io.ByteArrayInputStream;
  12. import java.io.InputStream;
  13. import java.lang.reflect.Method;
  14. import java.util.Map;
  15.  
  16. //from fhadmin.cn
  17. @Component
  18. @Slf4j
  19. public class SqlExecutor {
  20.  
  21.     @Autowired
  22.     private SqlSessionFactory sqlSessionFactory;
  23.  
  24.     public void parserString(String originSql,Map<String,Object> param) {
  25.         StringBuilder builder = new StringBuilder();
  26.         builder.append("1.0\" encoding=\"UTF-8\"?>\r\n");
  27.         builder.append("-//mybatis.org//DTD Mapper 3.0//EN\" \"http://mybatis.org/dtd/mybatis-3-mapper.dtd\">\r\n");
  28.         builder.append("cn.video.asm.TestMapper\">\r\n");
  29.         builder.append("     \r\n");
  30.         builder.append("");
  31.         InputStream inputStream = new ByteArrayInputStream(builder.toString().getBytes());
  32.         Configuration baseConfig = sqlSessionFactory.getConfiguration();
  33.         // 不能使用原有的config对象加载,否则下次就不会重复加载导致传入的SQL语句不能切换
  34.         // 也可以在这里指定数据源,从对应的数据源做查询动作
  35.         Configuration configuration = new Configuration(baseConfig.getEnvironment());
  36.         String resource = "resource";
  37.         ErrorContext.instance().resource(resource);
  38.         XMLMapperBuilder mapperParser = new XMLMapperBuilder(inputStream, configuration,resource ,configuration.getSqlFragments());
  39.         mapperParser.parse();
  40.         SqlSession sqlSessionXML = new DefaultSqlSessionFactory(configuration).openSession();
  41.         Object result = null;
  42.         try {
  43.             // 使用自定义的ClassLoader
  44.             MyClassLoader loader = new MyClassLoader();
  45.             // 生成二进制字节码
  46.             byte[] bytes = MyClassLoader.dump();
  47.             // 加载我们生成的 Mapper类
  48.             Class<?> clazz = loader.defineClass("cn.video.asm.TestMapper", bytes);
  49.             // 将生成的类对象加载到configuration中
  50.             configuration.addMapper(clazz);
  51.             Method query = clazz.getMethod("queryById", Map.class);
  52.             // 这里就是通过类对象从configuration中获取对应的Mapper
  53.             Object testMapper = sqlSessionXML.getMapper(clazz);
  54.             result = query.invoke(testMapper, param);
  55.         } catch (Exception e) {
  56.             log.error("",e);
  57.         }
  58.         System.out.println("dyn : " + result);
  59.     }
  60. }

点击(此处)折叠或打开

  1. package cn.video.common;
  2.  
  3. import jdk.internal.org.objectweb.asm.ClassWriter;
  4. import jdk.internal.org.objectweb.asm.MethodVisitor;
  5.  
  6. import static jdk.internal.org.objectweb.asm.Opcodes.*;
  7.  
  8. //from fhadmin.cn
  9. public class MyClassLoader extends ClassLoader {
  10.  
  11.     public static byte[] dump() {
  12.         ClassWriter cw = new ClassWriter(0);
  13.         cw.visit(52, ACC_PUBLIC + ACC_ABSTRACT + ACC_INTERFACE, "cn/video/asm/TestMapper", null, "java/lang/Object", null);
  14.         cw.visitSource("TestMapper.java", null);
  15.         {
  16.             MethodVisitor mv = cw.visitMethod(ACC_PUBLIC + ACC_ABSTRACT, "queryById", "(Ljava/util/Map;)Ljava/util/List;", "(Ljava/util/Map;)Ljava/util/List;", null);
  17.             mv.visitEnd();
  18.         }
  19.         cw.visitEnd();
  20.         return cw.toByteArray();
  21.     }
  22.  
  23.     public Class<?> defineClass(String name, byte[] b) {
  24.         // ClassLoader是个抽象类,而ClassLoader.defineClass 方法是protected的
  25.         // 所以我们需要定义一个子类将这个方法暴露出来
  26.         Class<?> clazz = super.findLoadedClass(name);
  27.         if (clazz != null) {
  28.             return clazz;
  29.         }
  30.         return super.defineClass(name, b, 0, b.length);
  31.     }
  32. }



阅读(288) | 评论(0) | 转发(0) |
给主人留下些什么吧!~~