circuitbreaker/invocations/SQLUpdateInvocation.java

package dk.thoerup.circuitbreaker.invocations;

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

import dk.thoerup.circuitbreaker.CircuitInvocation;

public class SQLUpdateInvocation implements CircuitInvocation<Integer> {
        
        PreparedStatement pStatement = null;
        Statement statement = null;
        String sql = null;
                
        
        public SQLUpdateInvocation(Statement stmt, String sql) {
                this.statement = stmt;
                this.sql = sql;
        }
        
        public SQLUpdateInvocation(PreparedStatement pstmt) {
                pStatement = pstmt;
        }
        

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