MybatisはSQLクエリのインターセプションと変更の詳細を実装します

 パブリックインターフェースインターセプター{
 オブジェクト intercept(Invocation invocation) は Throwable をスローします。
 オブジェクトプラグイン(オブジェクトターゲット);
 void setProperties(プロパティプロパティ);
}

パブリッククラスPluginはInvocationHandlerを実装します{
 
 プライベートオブジェクトターゲット;
 プライベートインターセプターインターセプター;
 プライベート Map、Set> signatureMap;
 
 プライベートプラグイン(オブジェクトターゲット、インターセプターインターセプター、マップ、Set> signatureMap) {
  this.target = ターゲット;
  this.interceptor = インターセプター;
  this.signatureMap = 署名マップ;
 }
 
 パブリック静的オブジェクトラップ(オブジェクトターゲット、インターセプターインターセプター) {
  マップ、セット> signatureMap = getSignatureMap(インターセプター);
  クラスタイプ = target.getClass();
  クラス[]インターフェース = getAllInterfaces(type, signatureMap);
  インターフェースの長さが0より大きい場合
   Proxy.newProxyInstance() を返します。
     type.getClassLoader()、
     インターフェース、
     新しいプラグイン(ターゲット、インターセプター、シグネチャマップ));
  }
  ターゲットを返します。
 }
 
 パブリックオブジェクトinvoke(オブジェクトプロキシ、メソッドメソッド、オブジェクト[]引数)throwsThrowable{
  試す {
   メソッドを signatureMap.get(method.getDeclaringClass()); に設定します。
   メソッドが null の場合、methods.contains(method) は次のように記述されます。
    interceptor.intercept(new Invocation(target, method, args)) を返します。
   }
   メソッドを呼び出します(ターゲット、引数)。
  } キャッチ (例外 e) {
   ExceptionUtil.unwrapThrowable(e) をスローします。
  }
 }
 
 プライベート静的マップ、Set> getSignatureMap(インターセプターインターセプター) {
  インターセプト interceptsAnnotation = interceptor.getClass().getAnnotation(Intercepts.class);
  if (interceptsAnnotation == null) { // 問題 #251
   throw new PluginException("インターセプターに @Intercepts アノテーションが見つかりません " + interceptor.getClass().getName());   
  }
  署名[] sigs = interceptsAnnotation.value();
  Map、Set> signatureMap = new HashMap、Set>();
  (署名 sig : sigs) {
   メソッドを設定します = signatureMap.get(sig.type());
   if (メソッド == null) {
    メソッド = 新しい HashSet();
    signatureMap.put(sig.type(), メソッド);
   }
   試す {
    メソッド method = sig.type().getMethod(sig.method(), sig.args());
    メソッドを追加します。
   } キャッチ (NoSuchMethodException e) {
    throw new PluginException("" + sig.type() + " に " + sig.method() + " という名前のメソッドが見つかりませんでした。原因: " + e, e);
   }
  }
  署名マップを返します。
 }
 
 プライベート静的Class[] getAllInterfaces(クラス型、マップ、セット> signatureMap) {
  Set> インターフェース = new HashSet>();
  while (type != null) {
   (クラスcの場合: type.getInterfaces()) {
    署名マップにキーが含まれている場合(c)
     インターフェースを追加します。
    }
   }
   タイプ = type.getSuperclass();
  }
  戻り値:interfaces.toArray(新しいClass[interfaces.size()]);
 }
 
}

@Intercepts({@Signature(メソッド = "準備"、タイプ = StatementHandler.class、引数 = {Connection.class})、
    @Signature(メソッド = "query"、タイプ = StatementHandler.class、引数 = {java.sql.Statement.class、ResultHandler.class})})
パブリッククラス TenantInterceptor は Interceptor を実装します {
.....

  <!-- mybatis を設定する -->
  <bean id="sqlSessionFactory" クラス="org.mybatis.spring.SqlSessionFactoryBean">
    <プロパティ名="データソース" ref="データソース"/>
    <プロパティ名="configLocation" 値="classpath:mybatis/mybatis-config.xml"/>
    <!-- マッパースキャン -->
    <プロパティ名="mapperLocations" 値="classpath:mybatis/*/*.xml"/>
    <プロパティ名="プラグイン">
      <配列>
        <!-- 独自のインターセプターを登録する -->
        <bean id="paginationInterceptor" class="xxx.xxx.TenantInterceptor">
        </bean>
      </配列>
    </プロパティ>
  </bean>