1.1 --- a/java/sql-dk/src/info/globalcode/sql/dk/SQLCommandNumbered.java Sun Dec 22 22:02:44 2013 +0100
1.2 +++ b/java/sql-dk/src/info/globalcode/sql/dk/SQLCommandNumbered.java Sun Dec 22 23:31:55 2013 +0100
1.3 @@ -17,8 +17,11 @@
1.4 */
1.5 package info.globalcode.sql.dk;
1.6
1.7 +import static info.globalcode.sql.dk.Functions.notNull;
1.8 import java.sql.Connection;
1.9 import java.sql.PreparedStatement;
1.10 +import java.sql.SQLException;
1.11 +import java.util.List;
1.12
1.13 /**
1.14 *
1.15 @@ -26,13 +29,28 @@
1.16 */
1.17 public class SQLCommandNumbered extends SQLCommand {
1.18
1.19 - @Override
1.20 - public PreparedStatement prepareStatement(Connection c) {
1.21 - throw new UnsupportedOperationException("Not supported yet."); //To change body of generated methods, choose Tools | Templates.
1.22 + private List<Parameter> parameters;
1.23 +
1.24 + public SQLCommandNumbered(COMMAND_TYPE commandType, String query, List<Parameter> parameters) {
1.25 + super(commandType, query);
1.26 + this.parameters = parameters;
1.27 }
1.28
1.29 @Override
1.30 - public void parametrize(PreparedStatement ps) {
1.31 - throw new UnsupportedOperationException("Not supported yet."); //To change body of generated methods, choose Tools | Templates.
1.32 + public PreparedStatement prepareStatement(Connection c) throws SQLException {
1.33 + return c.prepareStatement(getQuery());
1.34 + }
1.35 +
1.36 + @Override
1.37 + public void parametrize(PreparedStatement ps) throws SQLException {
1.38 + int i = 1;
1.39 + for (Parameter p : notNull(parameters)) {
1.40 + ps.setObject(i++, p.getValue(), p.getType());
1.41 + }
1.42 + }
1.43 +
1.44 + @Override
1.45 + public List<Parameter> getParameters() {
1.46 + return parameters;
1.47 }
1.48 }