/*
    * Copyright 2004-2025 the original author or authors.
    *
    * Licensed under the Apache License, Version 2.0 (the "License");
    * you may not use this file except in compliance with the License.
    * You may obtain a copy of the License at
    *
    *    https://www.apache.org/licenses/LICENSE-2.0
    *
   * Unless required by applicable law or agreed to in writing, software
   * distributed under the License is distributed on an "AS IS" BASIS,
   * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
   * See the License for the specific language governing permissions and
   * limitations under the License.
   */
  package com.ibatis.common.jdbc.logging;
  
  import com.ibatis.common.beans.ClassInfo;
  import com.ibatis.common.logging.Log;
  import com.ibatis.common.logging.LogFactory;
  
  import java.lang.reflect.InvocationHandler;
  import java.lang.reflect.Method;
  import java.lang.reflect.Proxy;
  import java.sql.ResultSet;
  
  /**
   * ResultSet proxy to add logging.
   */
  public class ResultSetLogProxy extends BaseLogProxy implements InvocationHandler {
  
    /** The Constant log. */
    private static final Log log = LogFactory.getLog(ResultSet.class);
  
    /** The first. */
    boolean first = true;
  
    /** The rs. */
    private ResultSet rs;
  
    /**
     * Instantiates a new result set log proxy.
     *
     * @param rs
     *          the rs
     */
    private ResultSetLogProxy(ResultSet rs) {
      super();
      this.rs = rs;
      if (log.isDebugEnabled()) {
        log.debug("{rset-" + id + "} ResultSet");
      }
    }
  
    @Override
    public Object invoke(Object proxy, Method method, Object[] params) throws Throwable {
      try {
        Object o = method.invoke(rs, params);
        if (GET_METHODS.contains(method.getName())) {
          if (params[0] instanceof String) {
            if (rs.wasNull()) {
              setColumn(params[0], null);
            } else {
              setColumn(params[0], o);
            }
          }
        } else if ("next".equals(method.getName()) || "close".equals(method.getName())) {
          String s = getValueString();
          if (!"[]".equals(s)) {
            if (first) {
              first = false;
              if (log.isDebugEnabled()) {
                log.debug("{rset-" + id + "} Header: " + getColumnString());
              }
            }
            if (log.isDebugEnabled()) {
              log.debug("{rset-" + id + "} Result: " + s);
            }
          }
          clearColumnInfo();
        }
        return o;
      } catch (Throwable t) {
        throw ClassInfo.unwrapThrowable(t);
      }
    }
  
    /**
     * Creates a logging version of a ResultSet.
     *
     * @param rs
     *          - the ResultSet to proxy
     *
     * @return - the ResultSet with logging
     */
    public static ResultSet newInstance(ResultSet rs) {
      InvocationHandler handler = new ResultSetLogProxy(rs);
      ClassLoader cl = ResultSet.class.getClassLoader();
      return (ResultSet) Proxy.newProxyInstance(cl, new Class[] { ResultSet.class }, handler);
   }
 
   /**
    * Get the wrapped result set.
    *
    * @return the resultSet
    */
   public ResultSet getRs() {
     return rs;
   }
 
 }