001    package railo.runtime.db.driver.state;
002    
003    import java.sql.PreparedStatement;
004    import java.sql.ResultSet;
005    import java.sql.SQLException;
006    import java.sql.Statement;
007    
008    import railo.runtime.PageContext;
009    import railo.runtime.PageContextImpl;
010    import railo.runtime.db.driver.ConnectionProxy;
011    import railo.runtime.db.driver.PreparedStatementProxy;
012    import railo.runtime.debug.ActiveQuery;
013    import railo.runtime.engine.ThreadLocalPageContext;
014    
015    public class StatePreparedStatement extends PreparedStatementProxy {
016    
017            public StatePreparedStatement(ConnectionProxy conn, PreparedStatement stat, String sql) {
018                    super(conn, stat,sql);
019            }
020            
021    
022            @Override
023            public boolean execute(String sql) throws SQLException {
024                    return StateUtil.execute(ThreadLocalPageContext.get(),stat, sql);
025            }
026    
027            @Override
028            public boolean execute(PageContext pc, String sql) throws SQLException {
029                    return StateUtil.execute(pc,stat, sql);
030            }
031    
032            @Override
033            public boolean execute(String sql, int autoGeneratedKeys) throws SQLException {
034                    return StateUtil.execute(ThreadLocalPageContext.get(), stat, sql,autoGeneratedKeys);
035            }
036    
037            @Override
038            public boolean execute(PageContext pc, String sql, int autoGeneratedKeys) throws SQLException {
039                    return StateUtil.execute(pc, stat, sql,autoGeneratedKeys);
040            }
041    
042            @Override
043            public boolean execute(String sql, int[] columnIndexes) throws SQLException {
044                    return StateUtil.execute(ThreadLocalPageContext.get(), stat, sql,columnIndexes);
045            }
046    
047            @Override
048            public boolean execute(PageContext pc, String sql, int[] columnIndexes) throws SQLException {
049                    return StateUtil.execute(pc, stat, sql,columnIndexes);
050            }
051    
052            @Override
053            public boolean execute(String sql, String[] columnNames) throws SQLException {
054                    return StateUtil.execute(ThreadLocalPageContext.get(), stat, sql,columnNames);
055            }
056    
057            @Override
058            public boolean execute(PageContext pc, String sql, String[] columnNames) throws SQLException {
059                    return StateUtil.execute(pc, stat, sql,columnNames);
060            }
061            @Override
062            public ResultSet executeQuery(String sql) throws SQLException {
063                    return StateUtil.executeQuery(ThreadLocalPageContext.get(), stat,sql);
064            }
065            @Override
066            public ResultSet executeQuery(PageContext pc, String sql) throws SQLException {
067                    return StateUtil.executeQuery(pc, stat,sql);
068            }
069            
070            @Override
071            public int executeUpdate(String sql) throws SQLException {
072                    return StateUtil.executeUpdate(ThreadLocalPageContext.get(), stat, sql);
073            }
074    
075            @Override
076            public int executeUpdate(PageContext pc, String sql) throws SQLException {
077                    return StateUtil.executeUpdate(pc, stat, sql);
078            }
079    
080            @Override
081            public int executeUpdate(String sql, int autoGeneratedKeys) throws SQLException {
082                    return StateUtil.executeUpdate(ThreadLocalPageContext.get(), stat, sql,autoGeneratedKeys);
083            }
084    
085            @Override
086            public int executeUpdate(PageContext pc, String sql, int autoGeneratedKeys) throws SQLException {
087                    return StateUtil.executeUpdate(pc, stat, sql,autoGeneratedKeys);
088            }
089    
090            @Override
091            public int executeUpdate(String sql, int[] columnIndexes) throws SQLException {
092                    return StateUtil.executeUpdate(ThreadLocalPageContext.get(), stat, sql,columnIndexes);
093            }
094    
095            @Override
096            public int executeUpdate(PageContext pc, String sql, int[] columnIndexes) throws SQLException {
097                    return StateUtil.executeUpdate(pc, stat, sql,columnIndexes);
098            }
099    
100            @Override
101            public int executeUpdate(String sql, String[] columnNames) throws SQLException {
102                    return StateUtil.executeUpdate(ThreadLocalPageContext.get(), stat, sql,columnNames);
103            }
104    
105            @Override
106            public int executeUpdate(PageContext pc, String sql, String[] columnNames) throws SQLException {
107                    return StateUtil.executeUpdate(pc, stat, sql,columnNames);
108            }
109            
110            @Override
111            public boolean execute() throws SQLException {
112                    return StateUtil.execute(ThreadLocalPageContext.get(), stat, sql);
113            }
114            
115            @Override
116            public boolean execute(PageContext pc) throws SQLException {
117                    return StateUtil.execute(pc, stat, sql);
118            }
119    
120            @Override
121            public ResultSet executeQuery() throws SQLException {
122                    return StateUtil.executeQuery(ThreadLocalPageContext.get(), stat, sql);
123            }
124    
125            @Override
126            public ResultSet executeQuery(PageContext pc) throws SQLException {
127                    return StateUtil.executeQuery(pc, stat, sql);
128            }
129    
130            @Override
131            public int executeUpdate() throws SQLException {
132                    return StateUtil.executeUpdate(ThreadLocalPageContext.get(), stat, sql);
133            }
134    
135            @Override
136            public int executeUpdate(PageContext pc) throws SQLException {
137                    return StateUtil.executeUpdate(pc, stat, sql);
138            }
139    
140            protected void setActiveStatement(PageContextImpl pc,Statement stat, String sql) {
141                    pc.setActiveQuery(new ActiveQuery(sql,System.currentTimeMillis()));
142            }
143    }