Mybatis implementiert Details zum Abfangen und Ändern von SQL-Abfragen

 öffentliche Schnittstelle Interceptor {
 Objekt abfangen (Aufrufaufruf) wirft Throwable;
 Objekt-Plugin (Objektziel);
 void setProperties(Eigenschafteneigenschaften);
}

öffentliche Klasse Plugin implementiert InvocationHandler {
 
 privates Objektziel;
 privater Abfangjäger Abfangjäger;
 private Map, Set> Signaturmap;
 
 privates Plugin(Objektziel, Interceptor Interceptor, Map, Set> SignaturMap) {
  dies.ziel = Ziel;
  dieser.Abfangjäger = Abfangjäger;
  diese.signatureMap = SignaturMap;
 }
 
 öffentliches statisches Objekt Wrap(Objektziel, Interceptor Interceptor) {
  Map, Set> SignaturMap = getSignatureMap(Abfangjäger);
  Klassentyp = Ziel.getClass();
  Klasse[] Schnittstellen = getAllInterfaces(Typ, Signaturkarte);
  if (Schnittstellenlänge > 0) {
   Proxy.newProxyInstance zurückgeben(
     Typ.getClassLoader(),
     Schnittstellen,
     neues Plugin (Ziel, Interceptor, Signaturkarte));
  }
  Rücklaufziel;
 }
 
 öffentliches Objekt aufrufen(Objektproxy, Methode Methode, Objekt[] args) wirft Throwable {
  versuchen {
   Methoden festlegen = signatureMap.get(method.getDeclaringClass());
   if (Methoden != null und Methoden.enthält(Methode)) {
    returniere interceptor.intercept(neuer Aufruf(Ziel, Methode, Argumente));
   }
   Rückgabemethode.Aufrufen (Ziel, Argumente);
  } Fang (Ausnahme e) {
   wirf ExceptionUtil.unwrapThrowable(e);
  }
 }
 
 private statische Karte, Set> getSignatureMap(Interceptor interceptor) {
  Intercepts interceptsAnnotation = interceptor.getClass().getAnnotation(Intercepts.class);
  if (interceptsAnnotation == null) { // Problem Nr. 251
   throw new PluginException("Keine @Intercepts-Annotation im Interceptor gefunden " + interceptor.getClass().getName());   
  }
  Signatur[] sigs = interceptsAnnotation.value();
  Map, Set> SignaturMap = neue HashMap, Set>();
  für (Signatur sig : sigs) {
   Methoden festlegen = signatureMap.get(sig.type());
   wenn (Methoden == null) {
    Methoden = neues HashSet();
    signatureMap.put(sig.type(), Methoden);
   }
   versuchen {
    Methode Methode = sig.type().getMethod(sig.method(), sig.args());
    Methoden.add(Methode);
   } Fang (NoSuchMethodException e) {
    throw new PluginException("Methode auf " + sig.type() + " mit dem Namen " + sig.method() + " konnte nicht gefunden werden. Ursache: " + e, e);
   }
  }
  Signaturkarte zurückgeben;
 }
 
 private static Klasse[] getAllInterfaces(Klassentyp, Map, Set> signatureMap) {
  Set> Schnittstellen = neues HashSet>();
  während (Typ != null) {
   für (Klasse c: Typ.getInterfaces()) {
    wenn (signatureMap.containsKey(c)) {
     Schnittstellen.add(c);
    }
   }
   Typ = Typ.getSuperclass();
  }
  gibt Schnittstellen zurück.toArray(neue Klasse[Schnittstellen.Größe()]);
 }
 
}

@Intercepts({@Signature(Methode = "vorbereiten", Typ = StatementHandler.class, Argumente = {Connection.class}),
    @Signature(Methode = "Abfrage", Typ = StatementHandler.class, Argumente = {java.sql.Statement.class, ResultHandler.class})})
öffentliche Klasse TenantInterceptor implementiert Interceptor {
.....

  <!-- Mybatis konfigurieren -->
  <bean id="sqlSessionFactory" class="org.mybatis.spring.SqlSessionFactoryBean">
    <Eigenschaftsname="Datenquelle" ref="Datenquelle"/>
    <Eigenschaftsname="Konfigurationsstandort" Wert="Klassenpfad:mybatis/mybatis-config.xml"/>
    <!-- Mapper-Scan -->
    <Eigenschaftsname="mapperLocations" Wert="Klassenpfad:mybatis/*/*.xml"/>
    <Eigenschaftsname="Plugins">
      <Feld>
        <!-- Registrieren Sie Ihren eigenen Interceptor -->
        <bean id="paginationInterceptor" class="xxx.xxx.TenantInterceptor">
        </bean>
      </array>
    </Eigenschaft>
  </bean>