ストアドプロシージャなどのSQLのログ出力処理の呼び出し

Author: mygreen

sqlmapper-parent/sqlmapper-core/src/main/java/com/github/mygreen/sqlmapper/core/StoredName.java

@@ -1,12 +1,15 @@
 package com.github.mygreen.sqlmapper.core;
 
+import com.github.mygreen.sqlmapper.core.util.NameUtils;
+
 import lombok.Getter;
 import lombok.RequiredArgsConstructor;
 
 /**
  * ストアドプロシージャ／ストアドファンクションの名称を指定するためのクラス。
  * <p>スキーマ／カタログを指定する際に利用します。
  *
+ * @version 0.4
  * @since 0.3
  * @author T.TSUCHIE
  *
@@ -52,4 +55,13 @@ public StoredName withCatalog(String catalog) {
         return this;
     }
 
+    /**
+     * スキーマ名／カタログ名を考慮したフルネームを取得します。
+     * @since 0.4
+     * @return フルネームを取得します。
+     */
+    public String toFullName() {
+        return NameUtils.tableFullName(name, catalog, schema);
+    }
+
 }

sqlmapper-parent/sqlmapper-core/src/main/java/com/github/mygreen/sqlmapper/core/query/SqlLogger.java

@@ -17,6 +17,7 @@
 import org.springframework.util.CollectionUtils;
 
 import com.github.mygreen.sqlmapper.core.config.ShowSqlProperties;
+import com.github.mygreen.sqlmapper.core.util.QueryUtils;
 
 import lombok.Getter;
 import lombok.RequiredArgsConstructor;
@@ -55,7 +56,7 @@ public class SqlLogger {
      */
     public void out(final String sql, final Object[] params) {
         outSql(sql);
-        if(prop.getBindParam().isEnabled() && params != null) {
+        if(prop.getBindParam().isEnabled() && !QueryUtils.isEmpty(params)) {
             outParams(Arrays.asList(params));
         }
 
@@ -82,6 +83,16 @@ public void outBatch(final String sql, final List<Object[]> batchParams) {
 
     }
 
+    /**
+     * ストアドプロシージャ／ストアドファンクションのログを出力する。
+     * @param callName ストアドプロシージャ／ストアドファンクションのSQL
+     * @param callParams ストアドプロシージャ／ストアドファンクションのバインド変数
+     */
+    public void outCall(final String callName, final Object[] callParams) {
+        outCallName(callName, callParams);
+        outCallParams(callParams);
+    }
+
     /**
      * SQLをログ出力する。
      * @param sql 出力対象のSQL
@@ -139,6 +150,44 @@ private void outBatchParams(final Collection<Object[]> batchParams) {
         }
     }
 
+    /**
+     * ストアドプロシージャ/ストアドファンクションの名称をログ出力する。
+     * @param callName 名称
+     * @param callParams パラメータ
+     */
+    private void outCallName(final String callName, final Object[] callParams) {
+        if(!prop.isEnabled()) {
+            return;
+        }
+
+        int paramCount = (callParams == null) ? 0 : callParams.length;
+        String args = QueryUtils.repeat("?", ", ", paramCount);
+        invokeLog(prop.getBindParam().getLogLevel(), "sql call : {}({})", new Object[]{callName, args});
+    }
+
+    /**
+     * ストアドプロシージャ/ストアドファンクションのパラメータをログ出力する。
+     * @param callParams パラメータ
+     */
+    private void outCallParams(final Object[] callParams) {
+        if(!prop.isEnabled() || !prop.getBindParam().isEnabled() || QueryUtils.isEmpty(callParams)) {
+            return;
+        }
+
+        int paramCount = 1;
+        for(Object param : callParams) {
+            String paramType = resolveBindParamType(param);
+            String paramValue = resolveBindParamValue(param);
+
+            invokeLog(prop.getBindParam().getLogLevel(), "sql call binding parameter : [{}] as [{}] - [{}]",
+                    new Object[]{paramCount, paramType, paramValue });
+
+            paramCount++;
+        }
+    }
+
+
+
     /**
      * ログレベルを指定してログに出力する。
      * @param level ログレベル。

sqlmapper-parent/sqlmapper-core/src/main/java/com/github/mygreen/sqlmapper/core/query/auto/AutoFunctionCallImpl.java

@@ -74,7 +74,6 @@ public AutoFunctionCallImpl<T> queryTimeout(int seconds) {
 
     @Override
     public T execute() {
-
         final SimpleJdbcCall jdbcCall = new SimpleJdbcCall(getJdbcTemplate())
                 .withFunctionName(functionName.getName());
 
@@ -88,13 +87,16 @@ public T execute() {
 
 
         if(parameter.isEmpty()) {
+            context.getSqlLogger().outCall(functionName.toFullName(), null);
             return jdbcCall.executeFunction(resultClass);
 
         } else {
             SqlParameter[] parameterTypes = createSqlParameterTypes(paramMeta);
             Object[] parameterValues = parameter.map(p -> createParameterValues(paramMeta, p))
                     .orElseGet(() -> new Object[0]);
 
+            context.getSqlLogger().outCall(functionName.toFullName(), parameterValues);
+
             if(containsResultParam(paramMeta, parameter)) {
                 Map<String, Object> out = jdbcCall.declareParameters(parameterTypes)
                         .execute(parameterValues);

sqlmapper-parent/sqlmapper-core/src/main/java/com/github/mygreen/sqlmapper/core/query/auto/AutoProcedureCallImpl.java

@@ -72,7 +72,6 @@ public AutoProcedureCallImpl queryTimeout(int seconds) {
 
     @Override
     public void execute() {
-
         final SimpleJdbcCall jdbcCall = new SimpleJdbcCall(getJdbcTemplate())
                 .withProcedureName(procedureName.getName());
 
@@ -84,15 +83,17 @@ public void execute() {
             jdbcCall.withSchemaName(procedureName.getSchema());
         }
 
-
         if(parameter.isEmpty()) {
+            context.getSqlLogger().outCall(procedureName.toFullName(), null);
             jdbcCall.execute();
 
         } else {
             SqlParameter[] parameterTypes = createSqlParameterTypes(paramMeta);
             Object[] parameterValues = parameter.map(p -> createParameterValues(paramMeta, p))
                     .orElseGet(() -> new Object[0]);
 
+            context.getSqlLogger().outCall(procedureName.toFullName(), parameterValues);
+
             Map<String, Object> out = jdbcCall.declareParameters(parameterTypes)
                     .execute(parameterValues);
 

sqlmapper-parent/sqlmapper-core/src/main/java/com/github/mygreen/sqlmapper/core/util/QueryUtils.java

@@ -9,7 +9,7 @@
 /**
  * クエリ組み立て時のヘルパークラス
  *
- *
+ * @version 0.4
  * @author T.TSUCHIE
  *
  */
@@ -138,4 +138,19 @@ public static String escapeLike(final String str, final char escape) {
         return sb.toString();
     }
 
+    /**
+     * 配列が空かどうか判定します。
+     *
+     * @since 0.4
+     * @param array 判定対象の配列
+     * @return 配列が {@literal null} または要素数が {@literal 0}のときに {@literal true} を返します。
+     */
+    public static boolean isEmpty(final Object[] array) {
+        if(array == null || array.length == 0) {
+            return true;
+        }
+
+        return false;
+    }
+
 }