KickJava   Java API By Example, From Geeks To Geeks.

Java > Open Source Codes > org > ofbiz > entity > jdbc > CursorConnection


1 /*
2  * $Id: CursorConnection.java 5462 2005-08-05 18:35:48Z jonesde $
3  *
4  * Copyright (c) 2001-2005 The Open For Business Project - www.ofbiz.org
5  *
6  * Permission is hereby granted, free of charge, to any person obtaining a
7  * copy of this software and associated documentation files (the "Software"),
8  * to deal in the Software without restriction, including without limitation
9  * the rights to use, copy, modify, merge, publish, distribute, sublicense,
10  * and/or sell copies of the Software, and to permit persons to whom the
11  * Software is furnished to do so, subject to the following conditions:
12  *
13  * The above copyright notice and this permission notice shall be included
14  * in all copies or substantial portions of the Software.
15  *
16  * THE SOFTWARE IS PROVIDED "AS IS", WITHOUT WARRANTY OF ANY KIND, EXPRESS
17  * OR IMPLIED, INCLUDING BUT NOT LIMITED TO THE WARRANTIES OF
18  * MERCHANTABILITY, FITNESS FOR A PARTICULAR PURPOSE AND NONINFRINGEMENT.
19  * IN NO EVENT SHALL THE AUTHORS OR COPYRIGHT HOLDERS BE LIABLE FOR ANY
20  * CLAIM, DAMAGES OR OTHER LIABILITY, WHETHER IN AN ACTION OF CONTRACT, TORT
21  * OR OTHERWISE, ARISING FROM, OUT OF OR IN CONNECTION WITH THE SOFTWARE OR
22  * THE USE OR OTHER DEALINGS IN THE SOFTWARE.
23  */
24 package org.ofbiz.entity.jdbc;
25
26 import java.lang.reflect.Method JavaDoc;
27 import java.sql.Connection JavaDoc;
28 import java.sql.PreparedStatement JavaDoc;
29 import java.sql.Statement JavaDoc;
30
31 /**
32  *
33  * @version $Rev: 5462 $
34  * @since 3.1
35  */
36 public class CursorConnection extends AbstractCursorHandler {
37
38     public static Connection JavaDoc newCursorConnection(Connection JavaDoc con, String JavaDoc cursorName, int pageSize) throws Exception JavaDoc {
39         return (Connection JavaDoc) newHandler(new CursorConnection(con, cursorName, pageSize), Connection JavaDoc.class);
40     }
41
42     protected Connection JavaDoc con;
43
44     protected CursorConnection(Connection JavaDoc con, String JavaDoc cursorName, int fetchSize) {
45         super(cursorName, fetchSize);
46         this.con = con;
47     }
48
49     public Object JavaDoc invoke(Object JavaDoc proxy, Method JavaDoc method, Object JavaDoc[] args) throws Throwable JavaDoc {
50         if (method.getName().equals("prepareStatement")) {
51             System.err.println("prepareStatement");
52             args[0] = "DECLARE " + cursorName + " CURSOR FOR " + args[0];
53             PreparedStatement JavaDoc pstmt = (PreparedStatement JavaDoc) method.invoke(con, args);
54             return CursorStatement.newCursorPreparedStatement(pstmt, cursorName, fetchSize);
55         } else if (method.getName().equals("createStatement")) {
56             System.err.println("createStatement");
57             Statement JavaDoc stmt = (Statement JavaDoc) method.invoke(con, args);
58             return CursorStatement.newCursorStatement(stmt, cursorName, fetchSize);
59         }
60         return super.invoke(con, proxy, method, args);
61     }
62 }
63
Popular Tags