review.fuel-infra Code Review - packages/trusty/mysql-wsrep-5.6.git/blob

   1 /*
   2  *  Copyright (c) 2011, Oracle and/or its affiliates. All rights reserved.
   3  *
   4  *  This program is free software; you can redistribute it and/or modify
   5  *  it under the terms of the GNU General Public License as published by
   6  *  the Free Software Foundation; version 2 of the License.
   7  *
   8  *  This program is distributed in the hope that it will be useful,
   9  *  but WITHOUT ANY WARRANTY; without even the implied warranty of
  10  *  MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the
  11  *  GNU General Public License for more details.
  12  *
  13  *  You should have received a copy of the GNU General Public License
  14  *  along with this program; if not, write to the Free Software
  15  *  Foundation, Inc., 51 Franklin St, Fifth Floor, Boston, MA 02110-1301  USA
  16  */
  17
  18 package com.mysql.clusterj.jdbc;
  19
  20 import java.sql.SQLException;
  21
  22 import com.mysql.clusterj.core.util.I18NHelper;
  23 import com.mysql.clusterj.core.util.Logger;
  24 import com.mysql.clusterj.core.util.LoggerFactoryService;
  25 import com.mysql.jdbc.ResultSetInternalMethods;
  26
  27 /** This class is part of the statement interceptor contract with the MySQL JDBC connection.
  28  * When a statement is intercepted and executed, an instance of this class is returned if there
  29  * is only an insert/delete/update count. A sibling class, ResultSetInternalMethodsImpl, is
  30  * returned if there is a real result to be iterated.
  31  * This class in turn delegates to the clusterj ResultData to retrieve data from the cluster.
  32  */
  33 public class ResultSetInternalMethodsUpdateCount extends
  34         AbstractResultSetInternalMethods {
  35
  36     /** My message translator */
  37     static final I18NHelper local = I18NHelper.getInstance(ResultSetInternalMethodsUpdateCount.class);
  38
  39     /** My logger */
  40     static final Logger logger = LoggerFactoryService.getFactory().getInstance(ResultSetInternalMethodsUpdateCount.class);
  41
  42     /** Counts for multi-statement result */
  43     private long[] counts;
  44
  45     /** The current result set for multi-statement results */
  46     private int current = 0;
  47
  48     /** Construct an instance with the count to be returned.
  49      *
  50      * @param count the number of "rows affected"
  51      */
  52     public ResultSetInternalMethodsUpdateCount(long count) {
  53         this.counts = new long[1];
  54         this.counts[0] = count;
  55     }
  56
  57     /** Construct an instance with the count to be returned.
  58      *
  59      * @param counts the number of "rows affected" for each row of a multi-statement result
  60      */
  61     public ResultSetInternalMethodsUpdateCount(long[] counts) {
  62         this.counts = counts;
  63     }
  64
  65     /**
  66      * Returns the next ResultSet in a multi-resultset "chain", if any,
  67      * null if none exists.
  68      * @return the next ResultSet
  69      */
  70     @Override
  71     public ResultSetInternalMethods getNextResultSet() {
  72         if (++current >= counts.length) {
  73             return null;
  74         } else {
  75             return this;
  76         }
  77     }
  78
  79     /**
  80      * Clears the reference to the next result set in a multi-result set
  81      * "chain".
  82      */
  83     @Override
  84     public void clearNextResult() {
  85         // nothing to do
  86     }
  87
  88     @Override
  89     public long getUpdateCount() {
  90         return counts[current];
  91     }
  92
  93     @Override
  94     public long getUpdateID() {
  95         return 0;
  96     }
  97
  98     @Override
  99     public boolean reallyResult() {
 100         return false;
 101     }
 102
 103     @Override
 104     public void realClose(boolean arg0) throws SQLException {
 105     }
 106
 107 }