View Javadoc

1   /*
2    * Copyright (c) 2005, Henri Yandell
3    * All rights reserved.
4    * 
5    * Redistribution and use in source and binary forms, with or 
6    * without modification, are permitted provided that the 
7    * following conditions are met:
8    * 
9    * + Redistributions of source code must retain the above copyright notice, 
10   *   this list of conditions and the following disclaimer.
11   * 
12   * + Redistributions in binary form must reproduce the above copyright notice, 
13   *   this list of conditions and the following disclaimer in the documentation 
14   *   and/or other materials provided with the distribution.
15   * 
16   * + Neither the name of OSJava nor the names of its contributors 
17   *   may be used to endorse or promote products derived from this software 
18   *   without specific prior written permission.
19   * 
20   * THIS SOFTWARE IS PROVIDED BY THE COPYRIGHT HOLDERS AND CONTRIBUTORS "AS IS" 
21   * AND ANY EXPRESS OR IMPLIED WARRANTIES, INCLUDING, BUT NOT LIMITED TO, THE 
22   * IMPLIED WARRANTIES OF MERCHANTABILITY AND FITNESS FOR A PARTICULAR PURPOSE 
23   * ARE DISCLAIMED.  IN NO EVENT SHALL THE COPYRIGHT OWNER OR CONTRIBUTORS BE 
24   * LIABLE FOR ANY DIRECT, INDIRECT, INCIDENTAL, SPECIAL, EXEMPLARY, OR 
25   * CONSEQUENTIAL DAMAGES (INCLUDING, BUT NOT LIMITED TO, PROCUREMENT OF 
26   * SUBSTITUTE GOODS OR SERVICES; LOSS OF USE, DATA, OR PROFITS; OR BUSINESS 
27   * INTERRUPTION) HOWEVER CAUSED AND ON ANY THEORY OF LIABILITY, WHETHER IN 
28   * CONTRACT, STRICT LIABILITY, OR TORT (INCLUDING NEGLIGENCE OR OTHERWISE) 
29   * ARISING IN ANY WAY OUT OF THE USE OF THIS SOFTWARE, EVEN IF ADVISED OF THE 
30   * POSSIBILITY OF SUCH DAMAGE.
31   */
32  package org.osjava.oscube.service.store;
33  
34  import java.sql.*;
35  import org.apache.commons.dbutils.QueryRunner;
36  
37  import org.apache.log4j.Logger;
38  
39  public class CallableJdbcStore extends JdbcStore {
40  
41      private static Logger logger = Logger.getLogger(CallableJdbcStore.class);
42  
43      protected int executeSql(Connection conn, String sql, Object[] row, QueryRunner queryRunner ) throws SQLException {
44          CallableStatement cs = null;
45          try {
46              cs = conn.prepareCall(sql);
47              fillStatement(cs, row);
48              return cs.executeUpdate();
49          } finally {
50              cs.close();
51          }
52      }
53  
54      // COPIED FROM Commons DbUtils until it supports such a thing
55      protected void fillStatement(PreparedStatement stmt, Object[] params) throws SQLException {
56  
57          if (params == null) {
58              return;
59          }
60  
61          for (int i = 0; i < params.length; i++) {
62              if (params[i] != null) {
63                  stmt.setObject(i + 1, params[i]);
64              } else {
65                  // VARCHAR works with many drivers regardless
66                  // of the actual column type.  Oddly, NULL and 
67                  // OTHER don't work with Oracle's drivers.
68                  stmt.setNull(i + 1, Types.VARCHAR);
69              }
70          }
71      }
72      
73  }