circuitbreaker/invocations/SQLQueryInvocation.java

package dk.thoerup.circuitbreaker.invocations;

import java.sql.PreparedStatement;
import java.sql.ResultSet;
import java.sql.Statement;

import dk.thoerup.circuitbreaker.CircuitInvocation;

public class SQLQueryInvocation implements CircuitInvocation<ResultSet> {

        PreparedStatement pStatement = null;
        Statement statement = null;
        String sql = null;
                
        
        public SQLQueryInvocation(Statement stmt, String sql) {
                this.statement = stmt;
                this.sql = sql;
        }
        
        public SQLQueryInvocation(PreparedStatement pstmt) {
                pStatement = pstmt;
        }
        

        public ResultSet proceed() throws Exception {
                ResultSet res;
                
                if (pStatement != null) {
                        res = pStatement.executeQuery();
                } else {
                        res = statement.executeQuery(sql);
                }
                
                return res;
        }
        
        
}
1	package dk.thoerup.circuitbreaker.invocations;
2
3	import java.sql.PreparedStatement;
4	import java.sql.ResultSet;
5	import java.sql.Statement;
6
7	import dk.thoerup.circuitbreaker.CircuitInvocation;
8
9	public class SQLQueryInvocation implements CircuitInvocation<ResultSet> {
10
11	PreparedStatement pStatement = null;
12	Statement statement = null;
13	String sql = null;
14
15
16	public SQLQueryInvocation(Statement stmt, String sql) {
17	this.statement = stmt;
18	this.sql = sql;
19	}
20
21	public SQLQueryInvocation(PreparedStatement pstmt) {
22	pStatement = pstmt;
23	}
24
25
26	public ResultSet proceed() throws Exception {
27	ResultSet res;
28
29	if (pStatement != null) {
30	res = pStatement.executeQuery();
31	} else {
32	res = statement.executeQuery(sql);
33	}
34
35	return res;
36	}
37
38
39	}